<?php
/*
*-------------------------------phpMyBitTorrent--------------------------------*
*--- The Ultimate BitTorrent Tracker and BMS (Bittorrent Management System) ---*
*--------------   Created By Antonio Anzivino (aka DJ Echelon)   --------------*
*-------------               http://www.p2pmania.it               -------------*
*------------ Based on the Bit Torrent Protocol made by Bram Cohen ------------*
*-------------              http://www.bittorrent.com             -------------*
*------------------------------------------------------------------------------*
*------------------------------------------------------------------------------*
*--   This program is free software; you can redistribute it and/or modify   --*
*--   it under the terms of the GNU General Public License as published by   --*
*--   the Free Software Foundation; either version 2 of the License, or      --*
*--   (at your option) any later version.                                    --*
*--                                                                          --*
*--   This program is distributed in the hope that it will be useful,        --*
*--   but WITHOUT ANY WARRANTY; without even the implied warranty of         --*
*--   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the          --*
*--   GNU General Public License for more details.                           --*
*--                                                                          --*
*--   You should have received a copy of the GNU General Public License      --*
*--   along with this program; if not, write to the Free Software            --*
*-- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA --*
*--                                                                          --*
*------------------------------------------------------------------------------*
*------              ©2005 phpMyBitTorrent Development Team              ------*
*-----------               http://phpmybittorrent.com               -----------*
*------------------------------------------------------------------------------*
*/

/***************************************************************************

 *                                 db2.php

 *                            -------------------

 *   begin                : Saturday, Feb 13, 2001

 *   copyright            : (C) 2001 The phpBB Group

 *   email                : support@phpbb.com

 *

 *   $Id: db2.php,v 1.3 2010/01/08 16:33:51 joerobe Exp $

 *

 ***************************************************************************/



/***************************************************************************

 *

 *   This program is free software; you can redistribute it and/or modify

 *   it under the terms of the GNU General Public License as published by

 *   the Free Software Foundation; either version 2 of the License, or

 *   (at your option) any later version.

 *

 ***************************************************************************/

if (!defined('IN_PMBT')) die ("You can't access this file directly");


if(!defined("SQL_LAYER"))

{



define("SQL_LAYER","db2");



class sql_db

{



        var $db_connect_id;

        var $query_result;

        var $query_resultset;

        var $query_numrows;

        var $next_id;

        var $row = array();

        var $rowset = array();

        var $row_index;

        var $num_queries = 0;


        //

        // Constructor

        //

        function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true)

        {

                $this->persistency = $persistency;

                $this->user = $sqluser;

                $this->password = $sqlpassword;

                $this->dbname = $database;

                $this->server = $sqlserver;



                if($this->persistency)

                {

                        $this->db_connect_id = odbc_pconnect($this->server, "", "");

                }

                else

                {

                        $this->db_connect_id = odbc_connect($this->server, "", "");

                }



                if($this->db_connect_id)

                {

                        @odbc_autocommit($this->db_connect_id, off);



                        return $this->db_connect_id;

                }

                else

                {

                        return false;

                }

        }

        //

        // Other base methods

        //

        function sql_close()

        {

                if($this->db_connect_id)

                {

                        if($this->query_result)

                        {

                                @odbc_free_result($this->query_result);

                        }

                        $result = @odbc_close($this->db_connect_id);

                        return $result;

                }

                else

                {

                        return false;

                }

        }





        //

        // Query method

        //

        function sql_query($query = "", $transaction = FALSE)

        {

                //

                // Remove any pre-existing queries

                //

                unset($this->query_result);

                unset($this->row);

                if($query != "")

                {

                        $this->num_queries++;



                        if(!eregi("^INSERT ",$query))

                        {

                                if(eregi("LIMIT", $query))

                                {

                                        preg_match("/^(.*)LIMIT ([0-9]+)[, ]*([0-9]+)*/s", $query, $limits);



                                        $query = $limits[1];

                                        if($limits[3])

                                        {

                                                $row_offset = $limits[2];

                                                $num_rows = $limits[3];

                                        }

                                        else

                                        {

                                                $row_offset = 0;

                                                $num_rows = $limits[2];

                                        }



                                        $query .= " FETCH FIRST ".($row_offset+$num_rows)." ROWS ONLY OPTIMIZE FOR ".($row_offset+$num_rows)." ROWS";



                                        $this->query_result = odbc_exec($this->db_connect_id, $query);



                                        $query_limit_offset = $row_offset;

                                        $this->result_numrows[$this->query_result] = $num_rows;

                                }

                                else

                                {

                                        $this->query_result = odbc_exec($this->db_connect_id, $query);



                                        $row_offset = 0;

                                        $this->result_numrows[$this->query_result] = 5E6;

                                }



                                $result_id = $this->query_result;

                                if($this->query_result && eregi("^SELECT", $query))

                                {



                                        for($i = 1; $i < odbc_num_fields($result_id)+1; $i++)

                                        {

                                                $this->result_field_names[$result_id][] = odbc_field_name($result_id, $i);

                                        }



                                        $i =  $row_offset + 1;

                                        $k = 0;

                                        while(odbc_fetch_row($result_id, $i) && $k < $this->result_numrows[$result_id])

                                        {



                                                for($j = 1; $j < count($this->result_field_names[$result_id])+1; $j++)

                                                {

                                                        $this->result_rowset[$result_id][$k][$this->result_field_names[$result_id][$j-1]] = odbc_result($result_id, $j);

                                                }

                                                $i++;

                                                $k++;

                                        }



                                        $this->result_numrows[$result_id] = $k;

                                        $this->row_index[$result_id] = 0;

                                }

                                else

                                {

                                        $this->result_numrows[$result_id] = @odbc_num_rows($result_id);

                                        $this->row_index[$result_id] = 0;

                                }

                        }

                        else

                        {

                                if(eregi("^(INSERT|UPDATE) ", $query))

                                {

                                        $query = preg_replace("/\\\'/s", "''", $query);

                                }



                                $this->query_result = odbc_exec($this->db_connect_id, $query);



                                if($this->query_result)

                                {

                                        $sql_id = "VALUES(IDENTITY_VAL_LOCAL())";



                                        $id_result = odbc_exec($this->db_connect_id, $sql_id);

                                        if($id_result)

                                        {

                                                $row_result = odbc_fetch_row($id_result);

                                                if($row_result)

                                                {

                                                        $this->next_id[$this->query_result] = odbc_result($id_result, 1);

                                                }

                                        }

                                }



                                odbc_commit($this->db_connect_id);



                                $this->query_limit_offset[$this->query_result] = 0;

                                $this->result_numrows[$this->query_result] = 0;

                        }



                        return $this->query_result;

                }

                else

                {

                        return false;

                }

        }

	function sql_escape($msg)
	{
		return db2_escape_string($msg);
	}


        //

        // Other query methods

        //

        function sql_numrows($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        return $this->result_numrows[$query_id];

                }

                else

                {

                        return false;

                }

        }

        function sql_affectedrows($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        return $this->result_numrows[$query_id];

                }

                else

                {

                        return false;

                }

        }

        function sql_numfields($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        $result = count($this->result_field_names[$query_id]);

                        return $result;

                }

                else

                {

                        return false;

                }

        }

        function sql_fieldname($offset, $query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        $result = $this->result_field_names[$query_id][$offset];

                        return $result;

                }

                else

                {

                        return false;

                }

        }

        function sql_fieldtype($offset, $query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        $result = @odbc_field_type($query_id, $offset);

                        return $result;

                }

                else

                {

                        return false;

                }

        }

        function sql_fetchrow($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        if($this->row_index[$query_id] < $this->result_numrows[$query_id])

                        {

                                $result = $this->result_rowset[$query_id][$this->row_index[$query_id]];

                                $this->row_index[$query_id]++;

                                return $result;

                        }

                        else

                        {

                                return false;

                        }

                }

                else

                {

                        return false;

                }

        }

        function sql_fetchrowset($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        $this->row_index[$query_id] = $this->result_numrows[$query_id];

                        return $this->result_rowset[$query_id];

                }

                else

                {

                        return false;

                }

        }

        function sql_fetchfield($field, $row = -1, $query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        if($row < $this->result_numrows[$query_id])

                        {

                                if($row == -1)

                                {

                                        $getrow = $this->row_index[$query_id]-1;

                                }

                                else

                                {

                                        $getrow = $row;

                                }



                                return $this->result_rowset[$query_id][$getrow][$this->result_field_names[$query_id][$field]];



                        }

                        else

                        {

                                return false;

                        }

                }

                else

                {

                        return false;

                }

        }

        function sql_rowseek($offset, $query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        $this->row_index[$query_id] = 0;

                        return true;

                }

                else

                {

                        return false;

                }

        }

        function sql_nextid($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        return $this->next_id[$query_id];

                }

                else

                {

                        return false;

                }

        }

        function sql_freeresult($query_id = 0)

        {

                if(!$query_id)

                {

                        $query_id = $this->query_result;

                }

                if($query_id)

                {

                        $result = @odbc_free_result($query_id);

                        return $result;

                }

                else

                {

                        return false;

                }

        }

        function sql_error($query_id = 0)

        {

//                $result['code'] = @odbc_error($this->db_connect_id);

//                $result['message'] = @odbc_errormsg($this->db_connect_id);



                return "";

        }



} // class sql_db



} // if ... define



?>