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

 * @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

 */

	if (!defined('MYSQL_ASSOC'))

	{

		define('MYSQL_SEEK_LAST',            -1);

		define('MYSQL_SEEK_FIRST',            0);

		define('MYSQL_ASSOC',                 1);

		define('MYSQL_NUM',                   2);

		define('MYSQL_BOTH',                  3);

		define('MYSQL_CLIENT_COMPRESS',      32);

		define('MYSQL_CLIENT_IGNORE_SPACE', 256);

		define('MYSQL_CLIENT_INTERACTIVE', 1024);

		define('MYSQL_CLIENT_SSL',         2048);

	}

	protected $sDbName      = '';

	protected $sInstanceIdentifier = '';

	protected $error        = '';

	protected $error_type   = '';

	protected $iQueryCount  = 0;

 * __constructor

 *  prevent from public instancing

 */

 * prevent from cloning

 */

 * @param string $sIdentifier selector for several different instances

            $c = __CLASS__;

		return self::$_oInstances[$sIdentifier];

	}

/**

 * disconnect and kills an existing instance

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

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

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

			}

		}

	}

/**

 * @return bool

 * @description opens a connection using connect URL<br />

 *              Example for SQL-Url:  'mysql://user:password@example.com[:3306]/database?charset=utf8&tableprefix=xx_'

	{

		if ($this->connected) { return $this->connected; } // prevent from reconnecting

		// parse URL and extract connection data

			$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';

			$aQuery = explode('&', $sTmp);

						$this->sCharset = strtolower(preg_replace('/[^a-z0-9]/i', '', $aArg[1]));

						break;

					case 'tableprefix':

						$this->sTablePrefix = $aArg[1];

						break;

					default:

						break;

				}

			}

		} else {

                @mysqli_query($this->oDbHandle, 'SET NAMES \''.$this->sCharset.'\'');

            }

            $this->connected = true;

		return $this->connected;

	}

 * disconnect database

 * @return bool

 * @description Disconnect current object from the database<br />

 *              the 'core' connection can NOT be disconnected!

 */

	public function disconnect()

	{

		if ($this->connected == true && $oInstance->sInstanceIdentifier != 'core') {

		}

 * Alias for doQuery()

	public function query($statement)

	{

		return $this->doQuery($statement);

	}

/**

 * execute query

 * @param string $statement the SQL-statement to execute

 * @return null|\mysql

 */

	public function doQuery($statement) {

		$mysql->query($statement);

		} else {

			return $mysql;

		}

	}

 * Alias for getOne()

	}

	// Gets the first column of the first row

/**

 * Gets the first column of the first row

 * @param string $statement  SQL-statement

 * @return null|mixed

 */

	public function getOne( $statement )

	{

		if (mysqli_error($this->oDbHandle)) {

    		$this->set_error(mysqli_error($this->oDbHandle));

		} else {

			return $result;

		}

	}

 * Alias for setError()

	public function set_error($message = null)

	{

		$this->setError($message = null);

	}

 * setError

 * @param string $message

 */

	public function setError($message = null)

	{

	}

 * Alias for isError

	public function is_error()

	{

		return $this->isError();

	}

/**

 * isError

 * @return bool

 */

	public function isError()

	{

	}

 * Alias for getError

	public function get_error()

	{

		return $this->getError();

	}

/**

 * get last Error

 * @return string

 */

	public function getError()

	{

	}

 * @param string name of property

 * @param mixed value

 * @throws WbDatabaseException

	{

/**

			case 'db_handle': // << set deprecated

				$retval = $this->oDbHandle;

			case 'db_name': // << set deprecated

				$retval = $this->sDbName;

				break;

				break;

				$retval = null;

				break;

	} // __get()

 * Escapes special characters in a string for use in an SQL statement

 * @param string $unescaped_string

 * @return string

 */

	public function escapeString($unescaped_string)

	{

/**

 * Last inserted Id

 * @return bool|int false on error, 0 if no record inserted

 */

	public function getLastInsertId()

	{

 * Alias for isField()

	public function field_exists($table_name, $field_name)

	{

		return $this->isField($table_name, $field_name);

	}

 * @param string name of the field to seek for

 * @return bool true if field exists

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

	}

 * Alias for isIndex()

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

	{

		return $this->isIndex($table_name, $index_name, $number_fields = 0);

	}

 * @param string name of the index to seek for

 * @return bool true if field exists

		$number_fields = intval($number_fields);

		$keys = 0;

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

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

				}

			}

		}

		}

	}

 * Alias for addField()

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

	{

		return $this->addField($table_name, $field_name, $description);

	}

 * @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

		// add new field into a table

			$this->set_error(mysqli_error($this->oDbHandle));

				return ( $this->isField($table_name, $field_name) ) ? true : false;

		}

		return false;

	}

 * Alias for modifyField()

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

	{

		return $this->modifyField($table_name, $field_name, $description);

	}

 * @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

 */

		$retval = false;

		// modify a existing field in a table

			$this->setError(mysqli_error($this->oDbHandle));

 * Alias for removeField()

	public function field_remove($table_name, $field_name)

	{

		return $this->removeField($table_name, $field_name);

	}

 * @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

 */

		$retval = false;

		// modify a existing field in a table

		return $retval;

	}

 * Alias for addIndex()

    public function index_add($table_name, $index_name, $field_list, $index_type = 'KEY')

	{

		return $this->addIndex($table_name, $index_name, $field_list, $index_type);

	}

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

 */

        $retval = false;

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

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

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

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

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

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

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

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

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

    }

 * Alias for removeIndex()

	public function index_remove($table_name, $index_name)

	{

		return $this->removeIndex($table_name, $index_name);

	}

 * @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

 */

		$retval = false;

		// modify a existing field in a table

		return $retval;

	}

	public function SqlImport($sSqlDump,

	                          $sTablePrefix = '',

	                          $sCollation   = 'utf8_unicode_ci')

	{

		return $this->importSql($sSqlDump, $sTablePrefix, $bPreserve, $sEngine, $sCollation);

	}

/**

 * @param mixed  $mSqlDump      can be string with filename or array with additional vars

 * @param string $sTablePrefix  can be used to override settings from WbDatabase object

 * @param string $sAction       'install', 'uninstall', 'upgrade', 'repair

 * @param string $sEngine       kind of table engine: MyIsam(default)

 * @param string $sCollation    utf8_unicode_ci(default)

 * @return bool  false on error

        $mSqlDump,

        $sTablePrefix = '',               // can override settings from WbDatabase object

        $sAction      = 'install',        // skip 'DROP TABLE' statements

        $sEngine      = 'MyISAM',         // the default table engine

        $sCollation   = 'utf8_unicode_ci' // the default collation to use

    )

    {

		$this->error = '';

        if (! is_string($sAction)) {

            $sAction = $sAction ? 'repair' : 'install';

        }

        $aAllowedActions = array('install', 'uninstall', 'upgrade', 'repair');

        $sAction = strtolower(preg_replace('/^.*?('.implode('|', $aAllowedActions).')(\.php)?$/iU', '$1', $sAction));

        $sAction = (in_array($sAction, $aAllowedActions) ? $sAction : 'install');

        $sTablePrefix = trim($sTablePrefix);

        $aEngineTypes = array(

            'csv'        => 'CSV',

            'blackhole'  => 'BLACKHOLE',

            'memory'     => 'MEMORY',

            'myisam'     => 'MyISAM',

            'innodb'     => 'InnoDB',

            'archive'    => 'ARCHIVE',

            'mrg_myisam' => 'MRG_MYISAM'

        );

        if (isset($aEngineTypes[strtolower($sEngine)])) {

            $sEngine = $aEngineTypes[strtolower($sEngine)];

        } else {

            $sEngine = 'MyISAM';

        }

        // test if selected collation is available. Otherwise select 'utf8_unicode_ci'

        $sql = 'SELECT COUNT(*) FROM `COLLATIONS` '

             . 'WHERE `COLLATION_NAME`=\''.$sCollation.'\'';

        $sCollation = ($this->get_one($sql) ? $sCollation : 'utf8_unicode_ci');

        $aTmp = preg_split('/_/', $sCollation, null, PREG_SPLIT_NO_EMPTY);

        $sCharset = $aTmp[0];

        // define array of searches

        $aSearch  = array(

            '/\{TABLE_PREFIX\}/',

            '/\{TABLE_COLLATION\}/', // deprecated from 2.8.4

            '/\{FIELD_COLLATION\}/', // deprecated from 2.8.4

            '/\{TABLE_ENGINE\}/',

            '/\{TABLE_ENGINE=([a-zA-Z_0-9]*)\}/',

            '/\{CHARSET\}/',

            '/\{COLLATION\}/'

        );

        // define array of replacements

        $aReplace = array(

            $sTablePrefix,

            ' COLLATE {COLLATION}', // deprecated from 2.8.4

            ' COLLATE {COLLATION}', // deprecated from 2.8.4

            ' {ENGINE='.$sEngine.'}',

            ' ENGINE=$1 DEFAULT CHARSET={CHARSET} COLLATION={COLLATION}',

            $sCharset,

            $sCollation

        );

        if (is_array($mSqlDump)) {

            // try to get dumpfile name

            if (!isset($mSqlDump['sSqlDump'])) {

                $this->error = 'missing index \'sSqlDump\' in $mSqlDump';

                return false;

            } else {

            // get dumpfile name from array and then remove entry

                $sDumpFile = (string)$mSqlDump['sSqlDump'];

                unset($mSqlDump['sSqlDump']);

                // import all vars and it's values from array

                foreach ($mSqlDump as $sIndex => $sValue) {

                    // transform varname into placeholder name ('sPageTitle' => 'PAGE_TITLE')

                    $sIndex = strtoupper(preg_replace('/([a-z0-9])([A-Z])/', '\1_\2', ltrim($sIndex, 'a..z')));

                    // fill search/replace arrays

                    $aSearch[]  = '/\{'.$sIndex.'\}/';

                    $aReplace[] = $sValue ;

                }

            }

        } elseif (is_string($mSqlDump)) {

            $sDumpFile = (string)$mSqlDump;

        } else {

            $this->error = 'invalid argument $mSqlDump';

            return false;

        }

        if (!is_readable($sDumpFile)) {

            $this->Error = 'unable to open \''.$sDumpFile.'\'';

            return false;

        }

        //	remove possible ByteOrderMark

                    $sAvailSqlObjects = 'TABLE|VIEW|INDEX|PROCEDURE|FUNCTION|TRIGGER|EVENT';

                    switch ($sAction) {

                        case 'uninstall': // skip CREATE; execute DROP

                            if (preg_match('/^\s*CREATE ('.$sAvailSqlObjects.') /siU', $sql)) {

                                $sql = '';

                                continue; // read next statement

                            }

                            break;

                        case 'upgrade': // skip DROP; execute CREATE

                        case 'repair':  // skip DROP; execute CREATE

                            if (preg_match('/^\s*DROP ('.$sAvailSqlObjects.') /siU', $sql)) {

                                $sql = '';

                                continue; // read next statement

                            }

                            break;

                        default: // install:  execute DROP; execute CREATE

                            break;

                    }

                    if (!$this->doQuery($sql)) {

                        $retval = false;

                        $this->error = $this->getError();

                        unset($aSql);

                        break;

                    }

				}

			}

		}

		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;

			}

		}

		return $retVal;

	}

/**

 * WbDatabaseException

 *

 * @category     Core

 * @package      Core_database

 * @copyright    Manuela v.d.Decken <manuela@isteam.de>

 * @version      2.9.0

 * @revision     $Revision$

 * @lastmodified $Date$

 * @description  Exceptionhandler for the WbDatabase and depending classes