WB 2.08.x

<?php

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

 * the Free Software Foundation, either version 3 of the License, or

 * (at your option) any later version.

 * 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, see <http://www.gnu.org/licenses/>.

 * WbDatabase.php

 *

 * @category     Core

 * @package      Core_database

 * @author       Werner v.d.Decken <wkl@isteam.de>

 * @author       Dietmar W. <dietmar.woellbrink@websitebaker.org>

 * @copyright    Werner v.d.Decken <wkl@isteam.de>

 * @license      http://www.gnu.org/licenses/gpl.html   GPL License

 * @version      0.0.9

 * @revision     $Revision$

 * @lastmodified $Date$

 * @deprecated   from WB version number 2.9

 * @description  Mysql database wrapper for use with websitebaker up to version 2.8.4

 */

	private $_db_handle = null; // readonly from outside

	private $_db_name   = '';

	private $error      = '';

	private $error_type = '';

	private function __clone() {}

/**

 * @param string $sIdentifier selector for several different instances

 * @return object

 */

	public static function getInstance($sIdentifier = 'core') {

		if( !isset(self::$_oInstances[$sIdentifier])) {

            $c = __CLASS__;

            self::$_oInstances[$sIdentifier] = new $c;

		}

		return self::$_oInstances[$sIdentifier];

	}

/**

 * disconnect and kills an existing instance

 * @param string $sIdentifier

 */

	public static function killInstance($sIdentifier) {

		if($sIdentifier != 'core') {

			if( isset(self::$_oInstances[$sIdentifier])) {

				self::$_oInstances[$sIdentifier]->disconnect();

				unset(self::$_oInstances[$sIdentifier]);

			}

		}

	}

/**

 * @param string $url

 * @return bool

 *

 * Example for SQL-Url:  'mysql://user:password@demo.de[:3306]/datenbank'

 */

	public function doConnect($url = '') {

			$aIni = parse_url($url);

			$scheme   = isset($aIni['scheme']) ? $aIni['scheme'] : 'mysql';

			$hostname = isset($aIni['host']) ? $aIni['host'] : '';

			$username = isset($aIni['user']) ? $aIni['user'] : '';

			$password = isset($aIni['pass']) ? $aIni['pass'] : '';

			$hostport = isset($aIni['port']) ? $aIni['port'] : '3306';

			$hostport = $hostport == '3306' ? '' : ':'.$hostport;

			$db_name  = ltrim(isset($aIni['path']) ? $aIni['path'] : '', '/\\');

			$this->_db_name = $db_name;

		                                  $username,

		                                  $password);

			                           $hostname.$hostport.'\'');

				throw new RuntimeException('unable to select database \''.$db_name.

				                           '\' on \''.$scheme.'://'.

				                           $hostname.$hostport.'\'');

				$this->connected = true;

			}

		}

		return $this->connected;

	}

		} else {

			return false;

		}

	}

		$this->set_error($mysql->error($this->_db_handle));

		if($mysql->error($this->_db_handle)) {

		} else {

			return $mysql;

		}

	}

		if(mysql_error($this->_db_handle)) {

		} else {

			return $result;

		}

	}

		$this->error = $message;

		if(strpos($message, 'no such table')) {

			$this->error_type = $TABLE_DOES_NOT_EXIST;

		} else {

			$this->error_type = $TABLE_UNKNOWN;

		}

	}

	}

	}

 * @param string

 * @return string

 */

	public function escapeString($string) {

		return mysql_real_escape_string($string, $this->_db_handle);

	}

/**

			case 'db_handle':

			case 'DbHandle':

				$retval = mysql_insert_id($this->_db_handle);

				break;

			case 'DbName':

				$retval = $this->iQueryCount;

				break;

				$retval = null;

				break;

		endswitch;

		return $retval;

	} // __get()

/*

 * @param string name of the field to seek for

 * @return bool true if field exists

	public function field_exists($table_name, $field_name)

	{

		$sql = 'DESCRIBE `'.$table_name.'` `'.$field_name.'` ';

	}

/*

 * @param string name of the index to seek for

 * @return bool true if field exists

	public function index_exists($table_name, $index_name, $number_fields = 0)

	{

		$number_fields = intval($number_fields);

		$keys = 0;

		$sql = 'SHOW INDEX FROM `'.$table_name.'`';

			while(($rec_key = $res_keys->fetchRow()))

			{

				if( $rec_key['Key_name'] == $index_name )

				{

					$keys++;

				}

			}

		}

		if( $number_fields == 0 )

		{

			return ($keys != $number_fields);

		}else

		{

			return ($keys == $number_fields);

		}

	}

 * @param string name of the field to add

 * @param string describes the new field like ( INT NOT NULL DEFAULT '0')

 * @return bool true if successful, otherwise false and error will be set

	public function field_add($table_name, $field_name, $description)

	{

			$sql = 'ALTER TABLE `'.$table_name.'` ADD '.$field_name.' '.$description.' ';

			$this->set_error(mysql_error($this->_db_handle));

			{

		}else

		{

			$this->set_error('field \''.$field_name.'\' already exists');

		}

		return false;

	}

/*

 * @param string $table_name: full name of the table (incl. TABLE_PREFIX)

 * @param string $field_name: name of the field to add

 * @param string $description: describes the new field like ( INT NOT NULL DEFAULT '0')

 * @return bool: true if successful, otherwise false and error will be set

 */

	public function field_modify($table_name, $field_name, $description)

	{

		$retval = false;

/*

 * @param string $table_name: full name of the table (incl. TABLE_PREFIX)

 * @param string $field_name: name of the field to remove

 * @return bool: true if successful, otherwise false and error will be set

 */

	public function field_remove($table_name, $field_name)

	{

		$retval = false;

			$sql  = 'ALTER TABLE `'.$table_name.'` DROP `'.$field_name.'`';

		return $retval;

	}

/*

 * @param string $table_name: full name of the table (incl. TABLE_PREFIX)

 */

     {

        $retval = false;

        $field_list = str_replace(' ', '', $field_list);

        $field_list = explode(',', $field_list);

        $number_fields = sizeof($field_list);

        $field_list = '`'.implode('`,`', $field_list).'`';

        $index_name = $index_type == 'PRIMARY' ? $index_type : $index_name;

        if( $this->index_exists($table_name, $index_name, $number_fields) ||

            $this->index_exists($table_name, $index_name))

        {

            $sql  = 'ALTER TABLE `'.$table_name.'` ';

            $sql .= 'DROP INDEX `'.$index_name.'`';

            if( !$this->query($sql, $this->_db_handle)) { return false; }

        }

        $sql  = 'ALTER TABLE `'.$table_name.'` ';

        $sql .= 'ADD '.$index_type.' ';

        $sql .= $index_type == 'PRIMARY' ? 'KEY ' : '`'.$index_name.'` ';

        $sql .= '( '.$field_list.' ); ';

        if( $this->query($sql, $this->_db_handle)) { $retval = true; }

        return $retval;

    }

/*

 * @param string $table_name: full name of the table (incl. TABLE_PREFIX)

 * @param string $field_name: name of the field to remove

 * @return bool: true if successful, otherwise false and error will be set

 */

	public function index_remove($table_name, $index_name)

	{

		$retval = false;

		if( $this->index_exists($table_name, $index_name) )

		{ // modify a existing field in a table

			$sql  = 'ALTER TABLE `'.$table_name.'` DROP INDEX `'.$index_name.'`';

		return $retval;

	}

 * Import a standard *.sql dump file

 * @param string $sSqlDump link to the sql-dumpfile

 * @param string $sTablePrefix

 * @param string $sTblCollation

 * @return boolean true if import successful

 */

	public function SqlImport($sSqlDump,

	                          $sTablePrefix = '',

		$retval = true;

		$this->error = '';

		$aSearch  = array('{TABLE_PREFIX}','{TABLE_ENGINE}', '{TABLE_COLLATION}');

		$aReplace = array($sTablePrefix, $sTblEngine, $sTblCollation);

		$sql = '';

		$aSql = file($sSqlDump);

		while ( sizeof($aSql) > 0 ) {

			$sSqlLine = trim(array_shift($aSql));

					$sql = trim(str_replace( $aSearch, $aReplace, $sql));

					if (!($bPreserve && preg_match('/^\s*DROP TABLE IF EXISTS/siU', $sql))) {

							break;

						}

					}

					$sql = '';

				}

			}

		}

		return $retval;

	}

 * retuns the type of the engine used for requested table

 * @param string $table name of the table, including prefix

 * @return boolean/string false on error, or name of the engine (myIsam/InnoDb)

 */

	{

		$retVal = false;

				$retVal = $row[$engineValue];

			}

		}

		return $retVal;

	}

define('MYSQL_SEEK_LAST', -1);

	private $_db_handle = null;

		$this->_db_handle = $dbHandle;

		$this->result = mysql_query($statement, $this->_db_handle);

		$this->error = mysql_error($this->_db_handle);

	}

	function numRows() {

		return mysql_num_rows($this->result);

	}

	// Fetch row  $typ = MYSQL_ASSOC, MYSQL_NUM, MYSQL_BOTH

	function fetchRow($typ = MYSQL_BOTH) {

		return mysql_fetch_array($this->result, $typ);

	{

		return $this->seekRow();

	}

	function seekRow( $position = MYSQL_SEEK_FIRST )

	{

		$pmax = $this->numRows() - 1;

		$p = (($position < 0 || $position > $pmax) ? $pmax : $position);

		return mysql_data_seek($this->result, $p);

	}

	function error() {

		if(isset($this->error)) {

			return $this->error;

		} else {

			return null;

		}

	}

}

/*  function to update a var/value-pair(s) in table ****************************

 *  nonexisting keys are inserted

 *  @param string $table: name of table to use (without prefix)

 *  @param mixed $key:    a array of key->value pairs to update

 *                        or a string with name of the key to update

 *  @param string $value: a sting with needed value, if $key is a string too

 *  @return bool:  true if any keys are updated, otherwise false

 */

	function db_update_key_value($table, $key, $value = '')

	{

		global $database;

		if( !is_array($key))

		{

			if( trim($key) != '' )

			{

				$key = array( trim($key) => trim($value) );

			} else {

				$key = array();

			}

		}

		$retval = true;

		foreach( $key as $index=>$val)

		{

			$index = strtolower($index);

			     . 'FROM `'.TABLE_PREFIX.$table.'` '

			     . 'WHERE `name` = \''.$index.'\' ';

			{

				$sql = 'UPDATE ';

				$sql_where = 'WHERE `name` = \''.$index.'\'';

			}else {

				$sql = 'INSERT INTO ';

				$sql_where = '';

			}

			$sql .= '`'.TABLE_PREFIX.$table.'` ';

			$sql .= 'SET `name` = \''.$index.'\', ';

			$sql .= '`value` = \''.$val.'\' '.$sql_where;

			if( !$database->query($sql) )

			{

				$retval = false;

			}

		}

		return $retval;

	}