* drop_columns: Removing/Dropping columns

* add_primary_keys: adding primary keys

* add_unique_index: adding an unique index

*

* The values are in this format:

* {TABLE NAME} => array(

{

$statements = array();

switch ($this->sql_layer)

{

case 'firebird':

break;

case 'mysql_40':

case 'mysql_41':

$statements[] = 'CREATE INDEX ' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';

break;

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

if ($this->service_handle !== false && function_exists('ibase_server_info'))

{

return @ibase_server_info($this->service_handle, IBASE_SVC_SERVER_VERSION);

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

global $cache;

{

$result_id = @mssql_query("SELECT SERVERPROPERTY('productversion'), SERVERPROPERTY('productlevel'), SERVERPROPERTY('edition')", $this->db_connect_id);

$this->sql_server_version = ($row) ? trim(implode(' ', $row)) : 0;

{

$cache->put('mssql_version', $this->sql_server_version);

}

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

global $cache;

{

$result_id = @odbc_exec($this->db_connect_id, "SELECT SERVERPROPERTY('productversion'), SERVERPROPERTY('productlevel'), SERVERPROPERTY('edition')");

$this->sql_server_version = ($row) ? trim(implode(' ', $row)) : 0;

{

$cache->put('mssqlodbc_version', $this->sql_server_version);

}

}

$this->m_row_count = count($this->m_rows);

}

private function array_to_obj($array, &$obj)

{

var $m_insert_id = NULL;

var $last_query_text = '';

/**

* Connect to server

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

global $cache;

{

$arr_server_info = sqlsrv_server_info($this->db_connect_id);

$this->sql_server_version = $arr_server_info['SQLServerVersion'];

{

$cache->put('mssql_version', $this->sql_server_version);

}

if ($this->query_result === false)

{

{

$this->sql_error($query);

}

if (defined('DEBUG_EXTRA'))

{

{

$this->query_result = false;

{

if (strpos($query, "SELECT") === false)

{

$query = preg_replace('/SELECT(\s*DISTINCT)?/Dsi', 'SELECT$1 TOP '.$total, $query);

}

}

{

$query = preg_replace('/SELECT(\s*DISTINCT)?/Dsi', 'SELECT$1 TOP(10000000) ', $query);

$query = 'SELECT *

FROM (SELECT sub2.*, ROW_NUMBER() OVER(ORDER BY sub2.line2) AS line3

}

$result = $this->sql_query($query, $cache_ttl);

$row = @sqlsrv_fetch_array($query_id, SQLSRV_FETCH_ASSOC);

if ($row)

{

foreach ($row as $key => $value)

{

$row[$key] = ($value === ' ' || $value === NULL) ? '' : $value;

}

}

return $row;

}

{

$errors = @sqlsrv_errors(SQLSRV_ERR_ERRORS);

$error_message = '';

if ($errors != null)

{

{

$error_message .= "SQLSTATE: ".$error[ 'SQLSTATE']."\n";

$error_message .= "code: ".$error[ 'code']."\n";

$error_message .= "message: ".$error[ 'message']."\n";

}

$this->last_error_result = $error_message;

{

$error = (isset($this->last_error_result) && $this->last_error_result) ? $this->last_error_result : array();

}

}

/**

* Utility method used to retrieve number of rows

* Emulates mysql_num_rows

* Used in acp_database.php -> write_data_mssqlnative()

*/

function mssqlnative_num_rows($res)

{

if ($res !== false)

{

}

else

{

return false;

}

}

}

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

global $cache;

{

$result = @mysql_query('SELECT VERSION() AS version', $this->db_connect_id);

$row = @mysql_fetch_assoc($result);

$this->sql_server_version = $row['version'];

{

$cache->put('mysql_version', $this->sql_server_version);

}

/**

* Version information about used database

* @return string sql server version

*/

{

global $cache;

{

$result = @mysqli_query($this->db_connect_id, 'SELECT VERSION() AS version');

$row = @mysqli_fetch_assoc($result);

$this->sql_server_version = $row['version'];

{

$cache->put('mysqli_version', $this->sql_server_version);

}

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

/*

global $cache;

{

$cols = explode(', ', $regs[2]);

preg_match_all('/\'(?:[^\']++|\'\')*+\'|[\d-.]+/', $regs[3], $vals, PREG_PATTERN_ORDER);

if (sizeof($cols) !== sizeof($vals))

$vals = array(0 => $vals);

}

$inserts = $vals[0];

unset($vals);

if ($sqlserver)

{

{

list($sqlserver, $port) = explode(':', $sqlserver);

}

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

global $cache;

{

$query_id = @pg_query($this->db_connect_id, 'SELECT VERSION() AS version');

$row = @pg_fetch_assoc($query_id, null);

$this->sql_server_version = (!empty($row['version'])) ? trim(substr($row['version'], 10)) : 0;

{

$cache->put('pgsql_version', $this->sql_server_version);

}

/**

* Version information about used database

* @param bool $raw if true, only return the fetched sql_server_version

* @return string sql server version

*/

{

global $cache;

{

$result = @sqlite_query('SELECT sqlite_version() AS version', $this->db_connect_id);

$row = @sqlite_fetch_array($result, SQLITE_ASSOC);

$this->sql_server_version = (!empty($row['version'])) ? $row['version'] : 0;

}

return ($raw) ? $this->sql_server_version : 'SQLite ' . $this->sql_server_version;