Search moodle.org's
Developer Documentation

See Release Notes
Long Term Support Release

  • Bug fixes for general core bugs in 3.9.x will end* 10 May 2021 (12 months).
  • Bug fixes for security issues in 3.9.x will end* 8 May 2023 (36 months).
  • PHP version: minimum PHP 7.2.0 Note: minimum PHP version has increased since Moodle 3.8. PHP 7.3.x and 7.4.x are supported too.
<?php
< /* < @version v5.20.16 12-Jan-2020 < @copyright (c) 2000-2013 John Lim (jlim#natsoft.com). All rights reserved. < @copyright (c) 2014 Damien Regad, Mark Newnham and the ADOdb community < Released under both BSD license and Lesser GPL library license. < Whenever there is any discrepancy between the two licenses, < the BSD license will take precedence. < Set tabs to 4 for best viewing. < < Latest version is available at http://adodb.org/ < < Native mssql driver. Requires mssql client. Works on Windows. < http://www.microsoft.com/sql/technologies/php/default.mspx < To configure for Unix, see < http://phpbuilder.com/columns/alberto20000919.php3 < < $stream = sqlsrv_get_field($stmt, $index, SQLSRV_SQLTYPE_STREAM(SQLSRV_ENC_BINARY)); < stream_filter_append($stream, "convert.iconv.ucs-2/utf-8"); // Voila, UTF-8 can be read directly from $stream <
> /** > * Native MSSQL driver. > * > * Requires mssql client. Works on Windows. > * https://docs.microsoft.com/sql/connect/php > * > * This file is part of ADOdb, a Database Abstraction Layer library for PHP. > * > * @package ADOdb > * @link https://adodb.org Project's web site and documentation > * @link https://github.com/ADOdb/ADOdb Source code and issue tracker > * > * The ADOdb Library is dual-licensed, released under both the BSD 3-Clause > * and the GNU Lesser General Public Licence (LGPL) v2.1 or, at your option, > * any later version. This means you can use it in proprietary products. > * See the LICENSE.md file distributed with this source code for details. > * @license BSD-3-Clause > * @license LGPL-2.1-or-later > * > * @copyright 2000-2013 John Lim > * @copyright 2014 Damien Regad, Mark Newnham and the ADOdb community
*/ // security - hide paths if (!defined('ADODB_DIR')) die(); if (!function_exists('sqlsrv_configure')) { die("mssqlnative extension not installed"); } if (!function_exists('sqlsrv_set_error_handling')) { function sqlsrv_set_error_handling($constant) { sqlsrv_configure("WarningsReturnAsErrors", $constant); } } if (!function_exists('sqlsrv_log_set_severity')) { function sqlsrv_log_set_severity($constant) { sqlsrv_configure("LogSeverity", $constant); } } if (!function_exists('sqlsrv_log_set_subsystems')) { function sqlsrv_log_set_subsystems($constant) { sqlsrv_configure("LogSubsystems", $constant); } }
< < //---------------------------------------------------------------- < // MSSQL returns dates with the format Oct 13 2002 or 13 Oct 2002 < // and this causes tons of problems because localized versions of < // MSSQL will return the dates in dmy or mdy order; and also the < // month strings depends on what language has been configured. The < // following two variables allow you to control the localization < // settings - Ugh. < // < // MORE LOCALIZATION INFO < // ---------------------- < // To configure datetime, look for and modify sqlcommn.loc, < // typically found in c:\mssql\install < // Also read : < // http://support.microsoft.com/default.aspx?scid=kb;EN-US;q220918 < // Alternatively use: < // CONVERT(char(12),datecol,120) < // < // Also if your month is showing as month-1, < // e.g. Jan 13, 2002 is showing as 13/0/2002, then see < // http://phplens.com/lens/lensforum/msgs.php?id=7048&x=1 < // it's a localisation problem. < //---------------------------------------------------------------- < < < // has datetime converstion to YYYY-MM-DD format, and also mssql_fetch_assoc < if (ADODB_PHPVER >= 0x4300) { < // docs say 4.2.0, but testing shows only since 4.3.0 does it work! < ini_set('mssql.datetimeconvert',0); < } else { < global $ADODB_mssql_mths; // array, months must be upper-case < $ADODB_mssql_date_order = 'mdy'; < $ADODB_mssql_mths = array( < 'JAN'=>1,'FEB'=>2,'MAR'=>3,'APR'=>4,'MAY'=>5,'JUN'=>6, < 'JUL'=>7,'AUG'=>8,'SEP'=>9,'OCT'=>10,'NOV'=>11,'DEC'=>12); < } <
class ADODB_mssqlnative extends ADOConnection { var $databaseType = "mssqlnative"; var $dataProvider = "mssqlnative"; var $replaceQuote = "''"; // string to use to replace quotes var $fmtDate = "'Y-m-d'"; var $fmtTimeStamp = "'Y-m-d\TH:i:s'";
> /** var $hasInsertID = true; > * Enabling InsertID capability will cause execution of an extra query var $substr = "substring"; > * {@see $identitySQL} after each INSERT statement. To improve performance var $length = 'len'; > * when inserting a large number of records, you should switch this off by var $hasAffectedRows = true; > * calling {@see enableLastInsertID enableLastInsertID(false)}. var $poorAffectedRows = false; > * @var bool $hasInsertID var $metaDatabasesSQL = "select name from sys.sysdatabases where name <> 'master'"; > */
var $metaTablesSQL="select name,case when type='U' then 'T' else 'V' end from sysobjects where (type='U' or type='V') and (name not in ('sysallocations','syscolumns','syscomments','sysdepends','sysfilegroups','sysfiles','sysfiles1','sysforeignkeys','sysfulltextcatalogs','sysindexes','sysindexkeys','sysmembers','sysobjects','syspermissions','sysprotects','sysreferences','systypes','sysusers','sysalternates','sysconstraints','syssegments','REFERENTIAL_CONSTRAINTS','CHECK_CONSTRAINTS','CONSTRAINT_TABLE_USAGE','CONSTRAINT_COLUMN_USAGE','VIEWS','VIEW_TABLE_USAGE','VIEW_COLUMN_USAGE','SCHEMATA','TABLES','TABLE_CONSTRAINTS','TABLE_PRIVILEGES','COLUMNS','COLUMN_DOMAIN_USAGE','COLUMN_PRIVILEGES','DOMAINS','DOMAIN_CONSTRAINTS','KEY_COLUMN_USAGE','dtproperties'))"; var $metaColumnsSQL = "select c.name, t.name as type, c.length, c.xprec as precision, c.xscale as scale, c.isnullable as nullable, c.cdefault as default_value, c.xtype, t.length as type_length, sc.is_identity from syscolumns c join systypes t on t.xusertype=c.xusertype join sysobjects o on o.id=c.id join sys.tables st on st.name=o.name join sys.columns sc on sc.object_id = st.object_id and sc.name=c.name where o.name='%s'"; var $hasTop = 'top'; // support mssql SELECT TOP 10 * FROM TABLE var $hasGenID = true; var $sysDate = 'convert(datetime,convert(char,GetDate(),102),102)'; var $sysTimeStamp = 'GetDate()'; var $maxParameterLen = 4000; var $arrayClass = 'ADORecordSet_array_mssqlnative'; var $uniqueSort = true; var $leftOuter = '*='; var $rightOuter = '=*'; var $ansiOuter = true; // for mssql7 or later var $identitySQL = 'select SCOPE_IDENTITY()'; // 'select SCOPE_IDENTITY'; # for mssql 2000 var $uniqueOrderBy = true; var $_bindInputArray = true; var $_dropSeqSQL = "drop table %s";
< var $connectionInfo = array();
> > var $connectionInfo = array('ReturnDatesAsStrings'=>true);
var $cachedSchemaFlush = false;
>
var $sequences = false; var $mssql_version = ''; function __construct() { if ($this->debug) { ADOConnection::outp("<pre>"); sqlsrv_set_error_handling( SQLSRV_ERRORS_LOG_ALL ); sqlsrv_log_set_severity( SQLSRV_LOG_SEVERITY_ALL ); sqlsrv_log_set_subsystems(SQLSRV_LOG_SYSTEM_ALL); sqlsrv_configure('WarningsReturnAsErrors', 0); } else { sqlsrv_set_error_handling(0); sqlsrv_log_set_severity(0); sqlsrv_log_set_subsystems(SQLSRV_LOG_SYSTEM_ALL); sqlsrv_configure('WarningsReturnAsErrors', 0); } } /** * Initializes the SQL Server version. * Dies if connected to a non-supported version (2000 and older) */ function ServerVersion() { $data = $this->ServerInfo(); preg_match('/^\d{2}/', $data['version'], $matches); $version = (int)reset($matches); // We only support SQL Server 2005 and up if($version < 9) { die("SQL SERVER VERSION {$data['version']} NOT SUPPORTED IN mssqlnative DRIVER"); } $this->mssql_version = $version; } function ServerInfo() { global $ADODB_FETCH_MODE; static $arr = false; if (is_array($arr)) return $arr; if ($this->fetchMode === false) { $savem = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; } elseif ($this->fetchMode >=0 && $this->fetchMode <=2) { $savem = $this->fetchMode; } else $savem = $this->SetFetchMode(ADODB_FETCH_NUM); $arrServerInfo = sqlsrv_server_info($this->_connectionID); $ADODB_FETCH_MODE = $savem;
> $arr['description'] = $arrServerInfo['SQLServerName'].' connected to '.$arrServerInfo['CurrentDatabase']; > $arr = array();
$arr['version'] = $arrServerInfo['SQLServerVersion'];//ADOConnection::_findvers($arr['description']); return $arr; } function IfNull( $field, $ifNull ) { return " ISNULL($field, $ifNull) "; // if MS SQL Server }
< function _insertid()
> public function enableLastInsertID($enable = true) { > $this->hasInsertID = $enable; > $this->lastInsID = false; > } > > /** > * Get the last value inserted into an IDENTITY column. > * > * The value will actually be set in {@see _query()} when executing an > * INSERT statement, but only if the connection's $hasInsertId property > * is true; this can be set with {@see enableLastInsertId()}. > * > * @inheritDoc > */ > protected function _insertID($table = '', $column = '')
{
< // SCOPE_IDENTITY() < // Returns the last IDENTITY value inserted into an IDENTITY column in < // the same scope. A scope is a module -- a stored procedure, trigger, < // function, or batch. Thus, two statements are in the same scope if < // they are in the same stored procedure, function, or batch. < return $this->lastInsertID;
> return $this->lastInsID;
} function _affectedrows() {
< if ($this->_queryID)
> if ($this->_queryID && is_resource($this->_queryID)) {
return sqlsrv_rows_affected($this->_queryID); }
> return false; > }
function GenID($seq='adodbseq',$start=1) {
< if (!$this->mssql_version) < $this->ServerVersion();
switch($this->mssql_version){ case 9: case 10: return $this->GenID2008($seq, $start); break; default: return $this->GenID2012($seq, $start); break; } } function CreateSequence($seq='adodbseq',$start=1) {
< if (!$this->mssql_version) < $this->ServerVersion(); <
switch($this->mssql_version){ case 9: case 10: return $this->CreateSequence2008($seq, $start); break; default: return $this->CreateSequence2012($seq, $start); break; }
<
} /** * For Server 2005,2008, duplicate a sequence with an identity table */ function CreateSequence2008($seq='adodbseq',$start=1) { if($this->debug) ADOConnection::outp("<hr>CreateSequence($seq,$start)"); sqlsrv_begin_transaction($this->_connectionID); $start -= 1; $this->Execute("create table $seq (id int)");//was float(53) $ok = $this->Execute("insert into $seq with (tablock,holdlock) values($start)"); if (!$ok) { if($this->debug) ADOConnection::outp("<hr>Error: ROLLBACK"); sqlsrv_rollback($this->_connectionID); return false; } sqlsrv_commit($this->_connectionID); return true; } /** * Proper Sequences Only available to Server 2012 and up */ function CreateSequence2012($seq='adodbseq',$start=1){ if (!$this->sequences){ $sql = "SELECT name FROM sys.sequences"; $this->sequences = $this->GetCol($sql); } $ok = $this->Execute("CREATE SEQUENCE $seq START WITH $start INCREMENT BY 1"); if (!$ok) die("CANNOT CREATE SEQUENCE" . print_r(sqlsrv_errors(),true)); $this->sequences[] = $seq; } /** * For Server 2005,2008, duplicate a sequence with an identity table */ function GenID2008($seq='adodbseq',$start=1) { if($this->debug) ADOConnection::outp("<hr>CreateSequence($seq,$start)"); sqlsrv_begin_transaction($this->_connectionID); $ok = $this->Execute("update $seq with (tablock,holdlock) set id = id + 1"); if (!$ok) { $start -= 1; $this->Execute("create table $seq (id int)");//was float(53) $ok = $this->Execute("insert into $seq with (tablock,holdlock) values($start)"); if (!$ok) { if($this->debug) ADOConnection::outp("<hr>Error: ROLLBACK"); sqlsrv_rollback($this->_connectionID); return false; } } $num = $this->GetOne("select id from $seq"); sqlsrv_commit($this->_connectionID); return $num; } /** * Only available to Server 2012 and up * Cannot do this the normal adodb way by trapping an error if the * sequence does not exist because sql server will auto create a * sequence with the starting number of -9223372036854775808 */ function GenID2012($seq='adodbseq',$start=1) { /* * First time in create an array of sequence names that we * can use in later requests to see if the sequence exists * the overhead is creating a list of sequences every time * we need access to at least 1. If we really care about * performance, we could maybe flag a 'nocheck' class variable */ if (!$this->sequences){ $sql = "SELECT name FROM sys.sequences"; $this->sequences = $this->GetCol($sql); } if (!is_array($this->sequences) || is_array($this->sequences) && !in_array($seq,$this->sequences)){ $this->CreateSequence2012($seq, $start); } $num = $this->GetOne("SELECT NEXT VALUE FOR $seq"); return $num; } // Format date column in sql string given an input format that understands Y M D function SQLDate($fmt, $col=false) {
< if (!$col) $col = $this->sysTimeStamp;
> if (!$col) { > $col = $this->sysTimeStamp; > }
$s = '';
> $ConvertableFmt=array( $len = strlen($fmt); > "m/d/Y"=>101, "m/d/y"=>101 // US for ($i=0; $i < $len; $i++) { > ,"Y.m.d"=>102, "y.m.d"=>102 // ANSI if ($s) $s .= '+'; > ,"d/m/Y"=>103, "d/m/y"=>103 // French /english $ch = $fmt[$i]; > ,"d.m.Y"=>104, "d.m.y"=>104 // German switch($ch) { > ,"d-m-Y"=>105, "d-m-y"=>105 // Italian case 'Y': > ,"m-d-Y"=>110, "m-d-y"=>110 // US Dash case 'y': > ,"Y/m/d"=>111, "y/m/d"=>111 // Japan $s .= "datename(yyyy,$col)"; > ,"Ymd"=>112, "ymd"=>112 // ISO break; > ,"H:i:s"=>108 // Time case 'M': > ); $s .= "convert(char(3),$col,0)"; > if (key_exists($fmt,$ConvertableFmt)) { break; > return "convert (varchar ,$col," . $ConvertableFmt[$fmt] . ")"; case 'm': > } $s .= "replace(str(month($col),2),' ','0')"; >
break; case 'Q': case 'q': $s .= "datename(quarter,$col)"; break; case 'D': case 'd': $s .= "replace(str(day($col),2),' ','0')"; break; case 'h': $s .= "substring(convert(char(14),$col,0),13,2)"; break; case 'H': $s .= "replace(str(datepart(hh,$col),2),' ','0')"; break; case 'i': $s .= "replace(str(datepart(mi,$col),2),' ','0')"; break; case 's': $s .= "replace(str(datepart(ss,$col),2),' ','0')"; break; case 'a': case 'A': $s .= "substring(convert(char(19),$col,0),18,2)"; break;
<
> case 'l': > $s .= "datename(dw,$col)"; > break;
default: if ($ch == '\\') { $i++; $ch = substr($fmt,$i,1); } $s .= $this->qstr($ch); break; } } return $s; } function BeginTrans() { if ($this->transOff) return true; $this->transCnt += 1; if ($this->debug) ADOConnection::outp('<hr>begin transaction'); sqlsrv_begin_transaction($this->_connectionID); return true; } function CommitTrans($ok=true) { if ($this->transOff) return true; if ($this->debug) ADOConnection::outp('<hr>commit transaction'); if (!$ok) return $this->RollbackTrans(); if ($this->transCnt) $this->transCnt -= 1; sqlsrv_commit($this->_connectionID); return true; }
>
function RollbackTrans() { if ($this->transOff) return true; if ($this->debug) ADOConnection::outp('<hr>rollback transaction'); if ($this->transCnt) $this->transCnt -= 1; sqlsrv_rollback($this->_connectionID); return true; } function SetTransactionMode( $transaction_mode ) { $this->_transmode = $transaction_mode; if (empty($transaction_mode)) { $this->Execute('SET TRANSACTION ISOLATION LEVEL READ COMMITTED'); return; } if (!stristr($transaction_mode,'isolation')) $transaction_mode = 'ISOLATION LEVEL '.$transaction_mode; $this->Execute("SET TRANSACTION ".$transaction_mode); } /* Usage: $this->BeginTrans(); $this->RowLock('table1,table2','table1.id=33 and table2.id=table1.id'); # lock row 33 for both tables # some operation on both tables table1 and table2 $this->CommitTrans(); See http://www.swynk.com/friends/achigrik/SQL70Locks.asp */ function RowLock($tables,$where,$col='1 as adodbignore') { if ($col == '1 as adodbignore') $col = 'top 1 null as ignore'; if (!$this->transCnt) $this->BeginTrans(); return $this->GetOne("select $col from $tables with (ROWLOCK,HOLDLOCK) where $where"); } function SelectDB($dbName) { $this->database = $dbName;
< $this->databaseName = $dbName; # obsolete, retained for compat with older adodb versions
if ($this->_connectionID) { $rs = $this->Execute('USE '.$dbName); if($rs) { return true; } else return false; } else return false; } function ErrorMsg() { $retErrors = sqlsrv_errors(SQLSRV_ERR_ALL); if($retErrors != null) { foreach($retErrors as $arrError) { $this->_errorMsg .= "SQLState: ".$arrError[ 'SQLSTATE']."\n"; $this->_errorMsg .= "Error Code: ".$arrError[ 'code']."\n"; $this->_errorMsg .= "Message: ".$arrError[ 'message']."\n"; } } return $this->_errorMsg; } function ErrorNo() { $err = sqlsrv_errors(SQLSRV_ERR_ALL);
< if($err[0]) return $err[0]['code']; < else return 0;
> if ($err && $err[0]) > return $err[0]['code']; > else > return 0;
} // returns true or false function _connect($argHostname, $argUsername, $argPassword, $argDatabasename) {
< if (!function_exists('sqlsrv_connect')) return null;
> if (!function_exists('sqlsrv_connect')) > { > if ($this->debug) > ADOConnection::outp('Microsoft SQL Server native driver (mssqlnative) not installed'); > return null; > } > > if (!empty($this->port)) > /* > * Port uses a comma > */ > $argHostname .= ",".$this->port; >
$connectionInfo = $this->connectionInfo; $connectionInfo["Database"]=$argDatabasename;
> if ((string)$argUsername != '' || (string)$argPassword != '') $connectionInfo["UID"]=$argUsername; > { $connectionInfo["PWD"]=$argPassword; > /* > * If they pass either a userid or password, we assume foreach ($this->connectionParameters as $parameter=>$value) > * SQL Server authentication $connectionInfo[$parameter] = $value; > */
< foreach ($this->connectionParameters as $parameter=>$value)
> if ($this->debug) > ADOConnection::outp('userid or password supplied, attempting connection with SQL Server Authentication'); > > } > else > { > /* > * If they don't pass either value, we won't add them to the > * connection parameters. This will then force an attempt > * to use windows authentication > */ > if ($this->debug) > > ADOConnection::outp('No userid or password supplied, attempting connection with Windows Authentication'); > } > > > /* > * Now merge in the passed connection parameters setting > */ > foreach ($this->connectionParameters as $options) > { > foreach($options as $parameter=>$value)
if ($this->debug) ADOConnection::outp("<hr>connecting... hostname: $argHostname params: ".var_export($connectionInfo,true));
> }
< if ($this->debug) ADOConnection::outp("<hr>connecting... hostname: $argHostname params: ".var_export($connectionInfo,true)); < //if ($this->debug) ADOConnection::outp("<hr>_connectionID before: ".serialize($this->_connectionID)); < if(!($this->_connectionID = sqlsrv_connect($argHostname,$connectionInfo))) { < if ($this->debug) ADOConnection::outp( "<hr><b>errors</b>: ".print_r( sqlsrv_errors(), true));
> if ($this->debug) ADOConnection::outp("connecting to host: $argHostname params: ".var_export($connectionInfo,true)); > if(!($this->_connectionID = @sqlsrv_connect($argHostname,$connectionInfo))) > { > if ($this->debug) > ADOConnection::outp( 'Connection Failed: '.print_r( sqlsrv_errors(), true));
}
< //if ($this->debug) ADOConnection::outp(" _connectionID after: ".serialize($this->_connectionID)); < //if ($this->debug) ADOConnection::outp("<hr>defined functions: <pre>".var_export(get_defined_functions(),true)."</pre>");
> > $this->ServerVersion(); >
return true; } // returns true or false function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename) { //return null;//not implemented. NOTE: Persistent connections have no effect if PHP is used as a CGI program. (FastCGI!) return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename); }
>
function Prepare($sql) { return $sql; // prepare does not work properly with bind parameters as bind parameters are managed by sqlsrv_prepare!
< < $stmt = sqlsrv_prepare( $this->_connectionID, $sql); < if (!$stmt) return $sql; < return array($sql,$stmt);
} // returns concatenated string // MSSQL requires integers to be cast as strings // automatically cast every datatype to VARCHAR(255) // @author David Rogers (introspectshun) function Concat() { $s = ""; $arr = func_get_args(); // Split single record on commas, if possible if (sizeof($arr) == 1) { foreach ($arr as $arg) { $args = explode(',', $arg); } $arr = $args; } array_walk( $arr, function(&$value, $key) { $value = "CAST(" . $value . " AS VARCHAR(255))"; } ); $s = implode('+',$arr); if (sizeof($arr) > 0) return "$s"; return ''; } /* Unfortunately, it appears that mssql cannot handle varbinary > 255 chars So all your blobs must be of type "image". Remember to set in php.ini the following... ; Valid range 0 - 2147483647. Default = 4096. mssql.textlimit = 0 ; zero to pass through ; Valid range 0 - 2147483647. Default = 4096. mssql.textsize = 0 ; zero to pass through */ function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB') { if (strtoupper($blobtype) == 'CLOB') { $sql = "UPDATE $table SET $column='" . $val . "' WHERE $where"; return $this->Execute($sql) != false; } $sql = "UPDATE $table SET $column=0x".bin2hex($val)." WHERE $where"; return $this->Execute($sql) != false; }
< // returns query ID if successful, otherwise false
> /** > * Execute a query. > * > * If executing an INSERT statement and $hasInsertId is true, will set > * $lastInsId. > * > * @param string $sql > * @param array $inputarr > * @return resource|false Query Id if successful, otherwise false > */
function _query($sql,$inputarr=false) { $this->_errorMsg = false;
< if (is_array($sql)) $sql = $sql[1];
> if (is_array($sql)) { > $sql = $sql[1]; > }
< $insert = false; < // handle native driver flaw for retrieving the last insert ID < if(preg_match('/^\W*insert[\s\w()[\]",.]+values\s*\((?:[^;\']|\'\'|(?:(?:\'\')*\'[^\']+\'(?:\'\')*))*;?$/i', $sql)) { < $insert = true; < $sql .= '; '.$this->identitySQL; // select scope_identity()
> // Handle native driver flaw for retrieving the last insert ID > if ($this->hasInsertID) { > // Check if it's an INSERT statement > $retrieveLastInsertID = preg_match( > '/^\W*insert[\s\w()[\]",.]+values\s*\((?:[^;\']|\'\'|(?:(?:\'\')*\'[^\']+\'(?:\'\')*))*;?$/i', > $sql > ); > if ($retrieveLastInsertID) { > // Append the identity SQL, so it is executed in the same > // scope as the insert query. > $sql .= '; ' . $this->identitySQL; > } > } else { > $retrieveLastInsertID = false;
}
>
if($inputarr) {
> // Ensure that the input array is indexed numerically, as required $rez = sqlsrv_query($this->_connectionID, $sql, $inputarr); > // by sqlsrv_query(). If param() was used to create portable binds } else { > // then the array might be associative. $rez = sqlsrv_query($this->_connectionID,$sql); > $inputarr = array_values($inputarr);
}
< if ($this->debug) ADOConnection::outp("<hr>running query: ".var_export($sql,true)."<hr>input array: ".var_export($inputarr,true)."<hr>result: ".var_export($rez,true)); <
> $this->lastInsID = false;
if(!$rez) { $rez = false;
< } else if ($insert) { < // retrieve the last insert ID (where applicable)
> } elseif ($retrieveLastInsertID) { > // Get the inserted id from the last result > // Note: loop is required as server may return more than one row, > // e.g. if triggers are involved (see #41)
while ( sqlsrv_next_result($rez) ) { sqlsrv_fetch($rez);
< $this->lastInsertID = sqlsrv_get_field($rez, 0);
> $this->lastInsID = sqlsrv_get_field($rez, 0);
} } return $rez; }
< // returns true or false
> /** > * Rolls back pending transactions and closes the connection. > * > * @return bool True, unless the connection id is invalid > */
function _close() {
< if ($this->transCnt) $this->RollbackTrans(); < $rez = @sqlsrv_close($this->_connectionID); < $this->_connectionID = false; < return $rez;
> if ($this->transCnt) { > $this->RollbackTrans();
}
< < // mssql uses a default date like Dec 30 2000 12:00AM < static function UnixDate($v) < { < return ADORecordSet_array_mssqlnative::UnixDate($v);
> if ($this->_connectionID) { > return sqlsrv_close($this->_connectionID);
}
< < static function UnixTimeStamp($v) < { < return ADORecordSet_array_mssqlnative::UnixTimeStamp($v);
> $this->_connectionID = false; > return true;
}
>
function MetaIndexes($table,$primary=false, $owner = false) { $table = $this->qstr($table); $sql = "SELECT i.name AS ind_name, C.name AS col_name, USER_NAME(O.uid) AS Owner, c.colid, k.Keyno, CASE WHEN I.indid BETWEEN 1 AND 254 AND (I.status & 2048 = 2048 OR I.Status = 16402 AND O.XType = 'V') THEN 1 ELSE 0 END AS IsPK, CASE WHEN I.status & 2 = 2 THEN 1 ELSE 0 END AS IsUnique FROM dbo.sysobjects o INNER JOIN dbo.sysindexes I ON o.id = i.id INNER JOIN dbo.sysindexkeys K ON I.id = K.id AND I.Indid = K.Indid INNER JOIN dbo.syscolumns c ON K.id = C.id AND K.colid = C.Colid WHERE LEFT(i.name, 8) <> '_WA_Sys_' AND o.status >= 0 AND O.Name LIKE $table ORDER BY O.name, I.Name, K.keyno"; global $ADODB_FETCH_MODE; $save = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; if ($this->fetchMode !== FALSE) { $savem = $this->SetFetchMode(FALSE); } $rs = $this->Execute($sql); if (isset($savem)) { $this->SetFetchMode($savem); } $ADODB_FETCH_MODE = $save; if (!is_object($rs)) { return FALSE; } $indexes = array(); while ($row = $rs->FetchRow()) { if (!$primary && $row[5]) continue; $indexes[$row[0]]['unique'] = $row[6]; $indexes[$row[0]]['columns'][] = $row[1]; } return $indexes; }
< function MetaForeignKeys($table, $owner=false, $upper=false)
> public function metaForeignKeys($table, $owner = '', $upper = false, $associative = false)
{ global $ADODB_FETCH_MODE; $save = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; $table = $this->qstr(strtoupper($table)); $sql = "select object_name(constid) as constraint_name, col_name(fkeyid, fkey) as column_name, object_name(rkeyid) as referenced_table_name, col_name(rkeyid, rkey) as referenced_column_name from sysforeignkeys where upper(object_name(fkeyid)) = $table order by constraint_name, referenced_table_name, keyno";
< $constraints =& $this->GetArray($sql);
> $constraints = $this->GetArray($sql);
$ADODB_FETCH_MODE = $save; $arr = false; foreach($constraints as $constr) { //print_r($constr); $arr[$constr[0]][$constr[2]][] = $constr[1].'='.$constr[3]; } if (!$arr) return false; $arr2 = false; foreach($arr as $k => $v) { foreach($v as $a => $b) { if ($upper) $a = strtoupper($a);
> if (is_array($arr2[$a])) { // a previous foreign key was define for this reference table, we merge the new one $arr2[$a] = $b; > $arr2[$a] = array_merge($arr2[$a], $b); } > } else {
}
> }
return $arr2; } //From: Fernando Moreira <FMoreira@imediata.pt> function MetaDatabases() { $this->SelectDB("master");
< $rs =& $this->Execute($this->metaDatabasesSQL);
> $rs = $this->Execute($this->metaDatabasesSQL);
$rows = $rs->GetRows(); $ret = array(); for($i=0;$i<count($rows);$i++) { $ret[] = $rows[$i][0]; } $this->SelectDB($this->database); if($ret) return $ret; else return false; } // "Stein-Aksel Basma" <basma@accelero.no> // tested with MSSQL 2000 function MetaPrimaryKeys($table, $owner=false) { global $ADODB_FETCH_MODE; $schema = ''; $this->_findschema($table,$schema); if (!$schema) $schema = $this->database; if ($schema) $schema = "and k.table_catalog like '$schema%'"; $sql = "select distinct k.column_name,ordinal_position from information_schema.key_column_usage k, information_schema.table_constraints tc where tc.constraint_name = k.constraint_name and tc.constraint_type = 'PRIMARY KEY' and k.table_name = '$table' $schema order by ordinal_position "; $savem = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; $a = $this->GetCol($sql); $ADODB_FETCH_MODE = $savem; if ($a && sizeof($a)>0) return $a; $false = false; return $false; } function MetaTables($ttype=false,$showSchema=false,$mask=false) { if ($mask) { $save = $this->metaTablesSQL; $mask = $this->qstr(($mask)); $this->metaTablesSQL .= " AND name like $mask"; } $ret = ADOConnection::MetaTables($ttype,$showSchema); if ($mask) { $this->metaTablesSQL = $save; } return $ret; } function MetaColumns($table, $upper=true, $schema=false){
< # start adg
> /* > * A simple caching mechanism, to be replaced in ADOdb V6 > */
static $cached_columns = array(); if ($this->cachedSchemaFlush) $cached_columns = array(); if (array_key_exists($table,$cached_columns)){ return $cached_columns[$table]; }
< # end adg
< if (!$this->mssql_version) < $this->ServerVersion();
$this->_findschema($table,$schema); if ($schema) { $dbName = $this->database; $this->SelectDB($schema); } global $ADODB_FETCH_MODE; $save = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false); $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table)); if ($schema) { $this->SelectDB($dbName); } if (isset($savem)) $this->SetFetchMode($savem); $ADODB_FETCH_MODE = $save; if (!is_object($rs)) { $false = false; return $false; } $retarr = array(); while (!$rs->EOF){ $fld = new ADOFieldObject(); if (array_key_exists(0,$rs->fields)) { $fld->name = $rs->fields[0]; $fld->type = $rs->fields[1]; $fld->max_length = $rs->fields[2]; $fld->precision = $rs->fields[3]; $fld->scale = $rs->fields[4]; $fld->not_null =!$rs->fields[5]; $fld->has_default = $rs->fields[6]; $fld->xtype = $rs->fields[7]; $fld->type_length = $rs->fields[8]; $fld->auto_increment= $rs->fields[9]; } else { $fld->name = $rs->fields['name']; $fld->type = $rs->fields['type']; $fld->max_length = $rs->fields['length']; $fld->precision = $rs->fields['precision']; $fld->scale = $rs->fields['scale']; $fld->not_null =!$rs->fields['nullable']; $fld->has_default = $rs->fields['default_value']; $fld->xtype = $rs->fields['xtype']; $fld->type_length = $rs->fields['type_length']; $fld->auto_increment= $rs->fields['is_identity']; } if ($save == ADODB_FETCH_NUM) $retarr[] = $fld; else $retarr[strtoupper($fld->name)] = $fld; $rs->MoveNext(); } $rs->Close();
< # start adg
$cached_columns[$table] = $retarr;
< # end adg
>
return $retarr; }
> /** } > * Returns a substring of a varchar type field > * /*-------------------------------------------------------------------------------------- > * The SQL server version varies because the length is mandatory, so Class Name: Recordset > * we append a reasonable string length --------------------------------------------------------------------------------------*/ > * > * @param string $fld The field to sub-string class ADORecordset_mssqlnative extends ADORecordSet { > * @param int $start The start point > * @param int $length An optional length var $databaseType = "mssqlnative"; > * var $canSeek = false; > * @return The SQL text var $fieldOffset = 0; > */ // _mths works only in non-localised system > function substr($fld,$start,$length=0) > { function __construct($id,$mode=false) > if ($length == 0) { > /* if ($mode === false) { > * The length available to varchar is 2GB, but that makes no global $ADODB_FETCH_MODE; > * sense in a substring, so I'm going to arbitrarily limit $mode = $ADODB_FETCH_MODE; > * the length to 1K, but you could change it if you want > */ } > $length = 1024; $this->fetchMode = $mode; > return parent::__construct($id,$mode); > $text = "SUBSTRING($fld,$start,$length)"; } > return $text; > } > function _initrs() > /** { > * Returns the maximum size of a MetaType C field. Because of the global $ADODB_COUNTRECS; > * database design, SQL Server places no limits on the size of data inserted # KMN # if ($this->connection->debug) ADOConnection::outp("(before) ADODB_COUNTRECS: {$ADODB_COUNTRECS} _numOfRows: {$this->_numOfRows} _numOfFields: {$this->_numOfFields}"); > * Although the actual limit is 2^31-1 bytes. /*$retRowsAff = sqlsrv_rows_affected($this->_queryID);//"If you need to determine the number of rows a query will return before retrieving the actual results, appending a SELECT COUNT ... query would let you get that information, and then a call to next_result would move you to the "real" results." > * ADOConnection::outp("rowsaff: ".serialize($retRowsAff)); > * @return int $this->_numOfRows = ($ADODB_COUNTRECS)? $retRowsAff:-1;*/ > */ $this->_numOfRows = -1;//not supported > function charMax() $fieldmeta = sqlsrv_field_metadata($this->_queryID); > { $this->_numOfFields = ($fieldmeta)? count($fieldmeta):-1; > return ADODB_STRINGMAX_NOLIMIT; # KMN # if ($this->connection->debug) ADOConnection::outp("(after) _numOfRows: {$this->_numOfRows} _numOfFields: {$this->_numOfFields}"); > } /* > * Copy the oracle method and cache the metadata at init time > /** */ > * Returns the maximum size of a MetaType X field. Because of the if ($this->_numOfFields>0) { > * database design, SQL Server places no limits on the size of data inserted $this->_fieldobjs = array(); > * Although the actual limit is 2^31-1 bytes. $max = $this->_numOfFields; > * for ($i=0;$i<$max; $i++) $this->_fieldobjs[] = $this->_FetchField($i); > * @return int } > */ > function textMax() } > { > return ADODB_STRINGMAX_NOLIMIT; > } //Contributed by "Sven Axelsson" <sven.axelsson@bokochwebb.se> > /** // get next resultset - requires PHP 4.0.5 or later > * Lists procedures, functions and methods in an array. function NextRecordSet() > * { > * @param string $procedureNamePattern (optional) if (!sqlsrv_next_result($this->_queryID)) return false; > * @param string $catalog (optional) $this->_inited = false; > * @param string $schemaPattern (optional) $this->bind = false; > $this->_currentRow = -1; > * @return array of stored objects in current database. $this->Init(); > * return true; > */ } > public function metaProcedures($procedureNamePattern = null, $catalog = null, $schemaPattern = null) > { /* Use associative array to get fields array */ > $metaProcedures = array(); function Fields($colname) > $procedureSQL = ''; { > $catalogSQL = ''; if ($this->fetchMode != ADODB_FETCH_NUM) return $this->fields[$colname]; > $schemaSQL = ''; if (!$this->bind) { > $this->bind = array(); > if ($procedureNamePattern) for ($i=0; $i < $this->_numOfFields; $i++) { > $procedureSQL = "AND ROUTINE_NAME LIKE " . strtoupper($this->qstr($procedureNamePattern)); $o = $this->FetchField($i); > $this->bind[strtoupper($o->name)] = $i; > if ($catalog) } > $catalogSQL = "AND SPECIFIC_SCHEMA=" . strtoupper($this->qstr($catalog)); } > > if ($schemaPattern) return $this->fields[$this->bind[strtoupper($colname)]]; > $schemaSQL = "AND ROUTINE_SCHEMA LIKE {$this->qstr($schemaPattern)}"; } > > $fields = " ROUTINE_NAME,ROUTINE_TYPE,ROUTINE_SCHEMA,ROUTINE_CATALOG"; /* Returns: an object containing field information. > Get column information in the Recordset object. fetchField() can be used in order to obtain information about > $SQL = "SELECT $fields fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by > FROM {$this->database}.information_schema.routines fetchField() is retrieved. > WHERE 1=1 Designed By jcortinap#jc.com.mx > $procedureSQL */ > $catalogSQL function _FetchField($fieldOffset = -1) > $schemaSQL { > ORDER BY ROUTINE_NAME $_typeConversion = array( > "; -155 => 'datetimeoffset', > -154 => 'char', > $result = $this->execute($SQL); -152 => 'xml', > -151 => 'udt', > if (!$result) -11 => 'uniqueidentifier', > return false; -10 => 'ntext', > while ($r = $result->fetchRow()){ -9 => 'nvarchar', > if (!isset($r[0])) -8 => 'nchar', > /* -7 => 'bit', > * Convert to numeric -6 => 'tinyint', > */ -5 => 'bigint', > $r = array_values($r); -4 => 'image', > -3 => 'varbinary', > $procedureName = $r[0]; -2 => 'timestamp', > $schemaName = $r[2]; -1 => 'text', > $routineCatalog= $r[3]; 1 => 'char', > $metaProcedures[$procedureName] = array('type'=> $r[1], 2 => 'numeric', > 'catalog' => $routineCatalog, 3 => 'decimal', > 'schema' => $schemaName, 4 => 'int', > 'remarks' => '', 5 => 'smallint', > ); 6 => 'float', > } 7 => 'real', > 12 => 'varchar', > return $metaProcedures; 91 => 'date', > } 93 => 'datetime' > ); > /** > * An SQL Statement that adds a specific number of $fa = @sqlsrv_field_metadata($this->_queryID); > * days or part to local datetime if ($fieldOffset != -1) { > * $fa = $fa[$fieldOffset]; > * @param float $dayFraction } > * @param string $date $false = false; > * if (empty($fa)) { > * @return string $f = false;//PHP Notice: Only variable references should be returned by reference > */ } > public function offsetDate($dayFraction, $date = false) else > { { > if (!$date) // Convert to an object > /* $fa = array_change_key_case($fa, CASE_LOWER); > * Use GETDATE() via systTimestamp; $fb = array(); > */ if ($fieldOffset != -1) > $date = $this->sysTimeStamp; { > $fb = array( > /* 'name' => $fa['name'], > * seconds, number of seconds, date base 'max_length' => $fa['size'], > */ 'column_source' => $fa['name'], > $dateFormat = "DATEADD(s, %s, %s)"; 'type' => $_typeConversion[$fa['type']] > ); > /* } > * Adjust the offset back to seconds else > */ { > $fraction = $dayFraction * 24 * 3600; foreach ($fa as $key => $value) > { > return sprintf($dateFormat,$fraction,$date); $fb[] = array( > 'name' => $value['name'], > } 'max_length' => $value['size'], >
'column_source' => $value['name'],
> /** 'type' => $_typeConversion[$value['type']] > * @var bool True if we have retrieved the fields metadata ); > */ } > private $fieldObjectsRetrieved = false; } > $f = (object) $fb; > /* } > * Cross-reference the objects by name for easy access return $f; > */ } > private $fieldObjectsIndex = array(); > /* > /* * Fetchfield copies the oracle method, it loads the field information > * Cross references the dateTime objects for faster decoding * into the _fieldobjs array once, to save multiple calls to the > */ * sqlsrv_field_metadata function > private $dateTimeObjects = array(); * > * @author KM Newnham > /* * @date 02/20/2013 > * flags that we have dateTimeObjects to handle */ > */ function FetchField($fieldOffset = -1) > private $hasDateTimeObjects = false; { > return $this->_fieldobjs[$fieldOffset]; > /* } > * This is cross reference between how the types are stored > * in SQL Server and their english-language description function _seek($row) > * -154 is a time field, see #432 { > */ return false;//There is no support for cursors in the driver at this time. All data is returned via forward-only streams. > private $_typeConversion = array( } > -155 => 'datetimeoffset', > -154 => 'char', // speedup > -152 => 'xml', function MoveNext() > -151 => 'udt', { > -11 => 'uniqueidentifier', //# KMN # if ($this->connection->debug) ADOConnection::outp("movenext()"); > -10 => 'ntext', //# KMN # if ($this->connection->debug) ADOConnection::outp("eof (beginning): ".$this->EOF); > -9 => 'nvarchar', if ($this->EOF) return false; > -8 => 'nchar', > -7 => 'bit', $this->_currentRow++; > -6 => 'tinyint', // # KMN # if ($this->connection->debug) ADOConnection::outp("_currentRow: ".$this->_currentRow); > -5 => 'bigint', > -4 => 'image', if ($this->_fetch()) return true; > -3 => 'varbinary', $this->EOF = true; > -2 => 'timestamp', //# KMN # if ($this->connection->debug) ADOConnection::outp("eof (end): ".$this->EOF); > -1 => 'text', > 1 => 'char', return false; > 2 => 'numeric', } > 3 => 'decimal', > 4 => 'int', > 5 => 'smallint', // INSERT UPDATE DELETE returns false even if no error occurs in 4.0.4 > 6 => 'float', // also the date format has been changed from YYYY-mm-dd to dd MMM YYYY in 4.0.4. Idiot! > 7 => 'real', function _fetch($ignore_fields=false) > 12 => 'varchar', { > 91 => 'date', # KMN # if ($this->connection->debug) ADOConnection::outp("_fetch()"); > 93 => 'datetime' if ($this->fetchMode & ADODB_FETCH_ASSOC) { > ); if ($this->fetchMode & ADODB_FETCH_NUM) { > //# KMN # if ($this->connection->debug) ADOConnection::outp("fetch mode: both"); > $this->fields = @sqlsrv_fetch_array($this->_queryID,SQLSRV_FETCH_BOTH); > } else { >
< return parent::__construct($id,$mode);
> parent::__construct($id);
< global $ADODB_COUNTRECS; < # KMN # if ($this->connection->debug) ADOConnection::outp("(before) ADODB_COUNTRECS: {$ADODB_COUNTRECS} _numOfRows: {$this->_numOfRows} _numOfFields: {$this->_numOfFields}"); < /*$retRowsAff = sqlsrv_rows_affected($this->_queryID);//"If you need to determine the number of rows a query will return before retrieving the actual results, appending a SELECT COUNT ... query would let you get that information, and then a call to next_result would move you to the "real" results." < ADOConnection::outp("rowsaff: ".serialize($retRowsAff)); < $this->_numOfRows = ($ADODB_COUNTRECS)? $retRowsAff:-1;*/
< $fieldmeta = sqlsrv_field_metadata($this->_queryID); < $this->_numOfFields = ($fieldmeta)? count($fieldmeta):-1; < # KMN # if ($this->connection->debug) ADOConnection::outp("(after) _numOfRows: {$this->_numOfRows} _numOfFields: {$this->_numOfFields}"); < /* < * Copy the oracle method and cache the metadata at init time < */ < if ($this->_numOfFields>0) { < $this->_fieldobjs = array(); < $max = $this->_numOfFields; < for ($i=0;$i<$max; $i++) $this->_fieldobjs[] = $this->_FetchField($i); < }
> // Cache the metadata right now > $this->_fetchField();
< if ($this->fetchMode != ADODB_FETCH_NUM) return $this->fields[$colname];
> if (!is_array($this->fields)) > /* > * Too early > */ > return; > if ($this->fetchMode != ADODB_FETCH_NUM) > return $this->fields[$colname]; >
< /* Returns: an object containing field information. < Get column information in the Recordset object. fetchField() can be used in order to obtain information about < fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by < fetchField() is retrieved. < Designed By jcortinap#jc.com.mx
> /** > * Returns: an object containing field information. > * > * Get column information in the Recordset object. fetchField() > * can be used in order to obtain information about fields in a > * certain query result. If the field offset isn't specified, > * the next field that wasn't yet retrieved by fetchField() > * is retrieved. > * > * @param int $fieldOffset (optional default=-1 for all > * @return mixed an ADOFieldObject, or array of objects
< function _FetchField($fieldOffset = -1)
> private function _fetchField($fieldOffset = -1)
< $_typeConversion = array( < -155 => 'datetimeoffset', < -154 => 'char', < -152 => 'xml', < -151 => 'udt', < -11 => 'uniqueidentifier', < -10 => 'ntext', < -9 => 'nvarchar', < -8 => 'nchar', < -7 => 'bit', < -6 => 'tinyint', < -5 => 'bigint', < -4 => 'image', < -3 => 'varbinary', < -2 => 'timestamp', < -1 => 'text', < 1 => 'char', < 2 => 'numeric', < 3 => 'decimal', < 4 => 'int', < 5 => 'smallint', < 6 => 'float', < 7 => 'real', < 12 => 'varchar', < 91 => 'date', < 93 => 'datetime' < ); < < $fa = @sqlsrv_field_metadata($this->_queryID); < if ($fieldOffset != -1) { < $fa = $fa[$fieldOffset];
> if ($this->fieldObjectsRetrieved) { > if ($this->fieldObjectsCache) { > // Already got the information > if ($fieldOffset == -1) { > return $this->fieldObjectsCache; > } else { > return $this->fieldObjectsCache[$fieldOffset];
< $false = false; < if (empty($fa)) { < $f = false;//PHP Notice: Only variable references should be returned by reference
> } else { > // No metadata available > return false;
< else < { < // Convert to an object < $fa = array_change_key_case($fa, CASE_LOWER); < $fb = array(); < if ($fieldOffset != -1) < { < $fb = array( < 'name' => $fa['name'], < 'max_length' => $fa['size'], < 'column_source' => $fa['name'], < 'type' => $_typeConversion[$fa['type']] < );
< else < { < foreach ($fa as $key => $value) < { < $fb[] = array( < 'name' => $value['name'], < 'max_length' => $value['size'], < 'column_source' => $value['name'], < 'type' => $_typeConversion[$value['type']] < );
> > $this->fieldObjectsRetrieved = true; > /* > * Retrieve all metadata in one go. This is always returned as a > * numeric array. > */ > $fieldMetaData = sqlsrv_field_metadata($this->_queryID); > > if (!$fieldMetaData) { > // Not a statement that gives us metaData > return false;
> //Dec 30 2000 12:00AM > $this->_numOfFields = count($fieldMetaData); if ($ADODB_mssql_date_order == 'dmy') { > foreach ($fieldMetaData as $key=>$value) { if (!preg_match( "|^([0-9]{1,2})[-/\. ]+([A-Za-z]{3})[-/\. ]+([0-9]{4})|" ,$v, $rr)) { > $fld = new ADOFieldObject; return parent::UnixDate($v); > // Caution - keys are case-sensitive, must respect casing of values } > $fld->name = $value['Name']; if ($rr[3] <= TIMESTAMP_FIRST_YEAR) return 0; > $fld->max_length = $value['Size']; > $fld->column_source = $value['Name']; $theday = $rr[1]; > $fld->type = $this->_typeConversion[$value['Type']]; $themth = substr(strtoupper($rr[2]),0,3); > } else { > $this->fieldObjectsCache[$key] = $fld; if (!preg_match( "|^([A-Za-z]{3})[-/\. ]+([0-9]{1,2})[-/\. ]+([0-9]{4})|" ,$v, $rr)) { > $this->fieldObjectsIndex[$fld->name] = $key;
< $f = (object) $fb;
> if ($fieldOffset == -1) { > return $this->fieldObjectsCache;
< return $f;
> > return $this->fieldObjectsCache[$fieldOffset];
if ($rr[3] <= TIMESTAMP_FIRST_YEAR) return 0;
> * @param int $fieldOffset (optional) > * $theday = $rr[2]; > * @return adoFieldObject $themth = substr(strtoupper($rr[1]),0,3); > *
< function FetchField($fieldOffset = -1)
> function fetchField($fieldOffset = -1)
< return $this->_fieldobjs[$fieldOffset];
> return $this->fieldObjectsCache[$fieldOffset];
< //# KMN # if ($this->connection->debug) ADOConnection::outp("movenext()"); < //# KMN # if ($this->connection->debug) ADOConnection::outp("eof (beginning): ".$this->EOF); < if ($this->EOF) return false;
> if ($this->EOF) > return false;
< // # KMN # if ($this->connection->debug) ADOConnection::outp("_currentRow: ".$this->_currentRow);
< if ($this->_fetch()) return true;
> if ($this->_fetch()) > return true;
< //# KMN # if ($this->connection->debug) ADOConnection::outp("eof (end): ".$this->EOF);
< < // INSERT UPDATE DELETE returns false even if no error occurs in 4.0.4 < // also the date format has been changed from YYYY-mm-dd to dd MMM YYYY in 4.0.4. Idiot!
< # KMN # if ($this->connection->debug) ADOConnection::outp("_fetch()");
< if ($this->fetchMode & ADODB_FETCH_NUM) { < //# KMN # if ($this->connection->debug) ADOConnection::outp("fetch mode: both");
> if ($this->fetchMode & ADODB_FETCH_NUM)
< } else { < //# KMN # if ($this->connection->debug) ADOConnection::outp("fetch mode: assoc");
> else
< }
< if (is_array($this->fields)) { < if (ADODB_ASSOC_CASE == 0) { < foreach($this->fields as $k=>$v) { < $this->fields[strtolower($k)] = $v; < } < } else if (ADODB_ASSOC_CASE == 1) { < foreach($this->fields as $k=>$v) { < $this->fields[strtoupper($k)] = $v; < }
> if (is_array($this->fields)) > { > > if (ADODB_ASSOC_CASE == ADODB_ASSOC_CASE_LOWER) > $this->fields = array_change_key_case($this->fields,CASE_LOWER); > else if (ADODB_ASSOC_CASE == ADODB_ASSOC_CASE_UPPER) > $this->fields = array_change_key_case($this->fields,CASE_UPPER); >
< } else { < //# KMN # if ($this->connection->debug) ADOConnection::outp("fetch mode: num");
> else
< } < if(is_array($this->fields) && array_key_exists(1,$this->fields) && !array_key_exists(0,$this->fields)) {//fix fetch numeric keys since they're not 0 based < $arrFixed = array(); < foreach($this->fields as $key=>$value) { < if(is_numeric($key)) { < $arrFixed[$key-1] = $value; < } else { < $arrFixed[$key] = $value; < } < } < //if($this->connection->debug) ADOConnection::outp("<hr>fixing non 0 based return array, old: ".print_r($this->fields,true)." new: ".print_r($arrFixed,true)); < $this->fields = $arrFixed; < } < if(is_array($this->fields)) { < foreach($this->fields as $key=>$value) { < if (is_object($value) && method_exists($value, 'format')) {//is DateTime object < $this->fields[$key] = $value->format("Y-m-d\TH:i:s\Z"); < } < } < } < if($this->fields === null) $this->fields = false; < # KMN # if ($this->connection->debug) ADOConnection::outp("<hr>after _fetch, fields: <pre>".print_r($this->fields,true)." backtrace: ".adodb_backtrace(false));
> > if (!$this->fields) > return false; >
< /* close() only needs to be called if you are worried about using too much memory while your script < is running. All associated result memory for the specified result identifier will automatically be freed. */
> /** > * close() only needs to be called if you are worried about using too much > * memory while your script is running. All associated result memory for > * the specified result identifier will automatically be freed. > * > * @return bool tru if we succeeded in closing down > */
select object_name(constid) as constraint_name,
> /* object_name(fkeyid) as table_name, > * If we are closing down a failed query, collect any col_name(fkeyid, fkey) as column_name, > * error messages. This is a hack fix to the "close too early" object_name(rkeyid) as referenced_table_name, > * problem so this might go away later col_name(rkeyid, rkey) as referenced_column_name > */ from sysforeignkeys > $this->connection->errorMsg();
< return true; < } < < // mssql uses a default date like Dec 30 2000 12:00AM < static function UnixDate($v) < { < return ADORecordSet_array_mssqlnative::UnixDate($v); < } < < static function UnixTimeStamp($v) < { < return ADORecordSet_array_mssqlnative::UnixTimeStamp($v); < } < } < < < class ADORecordSet_array_mssqlnative extends ADORecordSet_array { < function __construct($id=-1,$mode=false) < { < parent::__construct($id,$mode); < } < < // mssql uses a default date like Dec 30 2000 12:00AM < static function UnixDate($v) < { < < if (is_numeric(substr($v,0,1)) && ADODB_PHPVER >= 0x4200) return parent::UnixDate($v); < < global $ADODB_mssql_mths,$ADODB_mssql_date_order; < < //Dec 30 2000 12:00AM < if ($ADODB_mssql_date_order == 'dmy') { < if (!preg_match( "|^([0-9]{1,2})[-/\. ]+([A-Za-z]{3})[-/\. ]+([0-9]{4})|" ,$v, $rr)) { < return parent::UnixDate($v); < } < if ($rr[3] <= TIMESTAMP_FIRST_YEAR) return 0;
< $theday = $rr[1]; < $themth = substr(strtoupper($rr[2]),0,3); < } else { < if (!preg_match( "|^([A-Za-z]{3})[-/\. ]+([0-9]{1,2})[-/\. ]+([0-9]{4})|" ,$v, $rr)) { < return parent::UnixDate($v); < } < if ($rr[3] <= TIMESTAMP_FIRST_YEAR) return 0; < < $theday = $rr[2]; < $themth = substr(strtoupper($rr[1]),0,3); < } < $themth = $ADODB_mssql_mths[$themth]; < if ($themth <= 0) return false; < // h-m-s-MM-DD-YY < return adodb_mktime(0,0,0,$themth,$theday,$rr[3]);
> return true;
< static function UnixTimeStamp($v) < { < < if (is_numeric(substr($v,0,1)) && ADODB_PHPVER >= 0x4200) return parent::UnixTimeStamp($v); < < global $ADODB_mssql_mths,$ADODB_mssql_date_order; < < //Dec 30 2000 12:00AM < if ($ADODB_mssql_date_order == 'dmy') { < if (!preg_match( "|^([0-9]{1,2})[-/\. ]+([A-Za-z]{3})[-/\. ]+([0-9]{4}) +([0-9]{1,2}):([0-9]{1,2}) *([apAP]{0,1})|" < ,$v, $rr)) return parent::UnixTimeStamp($v); < if ($rr[3] <= TIMESTAMP_FIRST_YEAR) return 0; < < $theday = $rr[1]; < $themth = substr(strtoupper($rr[2]),0,3); < } else { < if (!preg_match( "|^([A-Za-z]{3})[-/\. ]+([0-9]{1,2})[-/\. ]+([0-9]{4}) +([0-9]{1,2}):([0-9]{1,2}) *([apAP]{0,1})|" < ,$v, $rr)) return parent::UnixTimeStamp($v); < if ($rr[3] <= TIMESTAMP_FIRST_YEAR) return 0; < < $theday = $rr[2]; < $themth = substr(strtoupper($rr[1]),0,3);
< $themth = $ADODB_mssql_mths[$themth]; < if ($themth <= 0) return false;
< switch (strtoupper($rr[6])) { < case 'P': < if ($rr[4]<12) $rr[4] += 12; < break; < case 'A': < if ($rr[4]==12) $rr[4] = 0; < break; < default: < break; < } < // h-m-s-MM-DD-YY < return adodb_mktime($rr[4],$rr[5],0,$themth,$theday,$rr[3]); < } < }
> class ADORecordSet_array_mssqlnative extends ADORecordSet_array {}