adodb-odbc_mssql.inc.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365
  1. <?php
  2. /*
  3. @version v5.20.17 31-Mar-2020
  4. @copyright (c) 2000-2013 John Lim (jlim#natsoft.com). All rights reserved.
  5. @copyright (c) 2014 Damien Regad, Mark Newnham and the ADOdb community
  6. Released under both BSD license and Lesser GPL library license.
  7. Whenever there is any discrepancy between the two licenses,
  8. the BSD license will take precedence.
  9. Set tabs to 4 for best viewing.
  10. Latest version is available at http://adodb.org/
  11. MSSQL support via ODBC. Requires ODBC. Works on Windows and Unix.
  12. For Unix configuration, see http://phpbuilder.com/columns/alberto20000919.php3
  13. */
  14. // security - hide paths
  15. if (!defined('ADODB_DIR')) die();
  16. if (!defined('_ADODB_ODBC_LAYER')) {
  17. include(ADODB_DIR."/drivers/adodb-odbc.inc.php");
  18. }
  19. class ADODB_odbc_mssql extends ADODB_odbc {
  20. var $databaseType = 'odbc_mssql';
  21. var $fmtDate = "'Y-m-d'";
  22. var $fmtTimeStamp = "'Y-m-d\TH:i:s'";
  23. var $_bindInputArray = true;
  24. var $metaDatabasesSQL = "select name from sysdatabases where name <> 'master'";
  25. 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'))";
  26. var $metaColumnsSQL = # xtype==61 is datetime
  27. "select c.name,t.name,c.length,c.isnullable, c.status,
  28. (case when c.xusertype=61 then 0 else c.xprec end),
  29. (case when c.xusertype=61 then 0 else c.xscale end)
  30. from syscolumns c join systypes t on t.xusertype=c.xusertype join sysobjects o on o.id=c.id where o.name='%s'";
  31. var $hasTop = 'top'; // support mssql/interbase SELECT TOP 10 * FROM TABLE
  32. var $sysDate = 'GetDate()';
  33. var $sysTimeStamp = 'GetDate()';
  34. var $leftOuter = '*=';
  35. var $rightOuter = '=*';
  36. var $substr = 'substring';
  37. var $length = 'len';
  38. var $ansiOuter = true; // for mssql7 or later
  39. var $identitySQL = 'select SCOPE_IDENTITY()'; // 'select SCOPE_IDENTITY'; # for mssql 2000
  40. var $hasInsertID = true;
  41. var $connectStmt = 'SET CONCAT_NULL_YIELDS_NULL OFF'; # When SET CONCAT_NULL_YIELDS_NULL is ON,
  42. # concatenating a null value with a string yields a NULL result
  43. function __construct()
  44. {
  45. parent::__construct();
  46. //$this->curmode = SQL_CUR_USE_ODBC;
  47. }
  48. // crashes php...
  49. function ServerInfo()
  50. {
  51. global $ADODB_FETCH_MODE;
  52. $save = $ADODB_FETCH_MODE;
  53. $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
  54. $row = $this->GetRow("execute sp_server_info 2");
  55. $ADODB_FETCH_MODE = $save;
  56. if (!is_array($row)) return false;
  57. $arr['description'] = $row[2];
  58. $arr['version'] = ADOConnection::_findvers($arr['description']);
  59. return $arr;
  60. }
  61. function IfNull( $field, $ifNull )
  62. {
  63. return " ISNULL($field, $ifNull) "; // if MS SQL Server
  64. }
  65. function _insertid()
  66. {
  67. // SCOPE_IDENTITY()
  68. // Returns the last IDENTITY value inserted into an IDENTITY column in
  69. // the same scope. A scope is a module -- a stored procedure, trigger,
  70. // function, or batch. Thus, two statements are in the same scope if
  71. // they are in the same stored procedure, function, or batch.
  72. return $this->GetOne($this->identitySQL);
  73. }
  74. function MetaForeignKeys($table, $owner=false, $upper=false)
  75. {
  76. global $ADODB_FETCH_MODE;
  77. $save = $ADODB_FETCH_MODE;
  78. $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
  79. $table = $this->qstr(strtoupper($table));
  80. $sql =
  81. "select object_name(constid) as constraint_name,
  82. col_name(fkeyid, fkey) as column_name,
  83. object_name(rkeyid) as referenced_table_name,
  84. col_name(rkeyid, rkey) as referenced_column_name
  85. from sysforeignkeys
  86. where upper(object_name(fkeyid)) = $table
  87. order by constraint_name, referenced_table_name, keyno";
  88. $constraints = $this->GetArray($sql);
  89. $ADODB_FETCH_MODE = $save;
  90. $arr = false;
  91. foreach($constraints as $constr) {
  92. //print_r($constr);
  93. $arr[$constr[0]][$constr[2]][] = $constr[1].'='.$constr[3];
  94. }
  95. if (!$arr) return false;
  96. $arr2 = false;
  97. foreach($arr as $k => $v) {
  98. foreach($v as $a => $b) {
  99. if ($upper) $a = strtoupper($a);
  100. $arr2[$a] = $b;
  101. }
  102. }
  103. return $arr2;
  104. }
  105. function MetaTables($ttype=false,$showSchema=false,$mask=false)
  106. {
  107. if ($mask) {//$this->debug=1;
  108. $save = $this->metaTablesSQL;
  109. $mask = $this->qstr($mask);
  110. $this->metaTablesSQL .= " AND name like $mask";
  111. }
  112. $ret = ADOConnection::MetaTables($ttype,$showSchema);
  113. if ($mask) {
  114. $this->metaTablesSQL = $save;
  115. }
  116. return $ret;
  117. }
  118. function MetaColumns($table, $normalize=true)
  119. {
  120. $this->_findschema($table,$schema);
  121. if ($schema) {
  122. $dbName = $this->database;
  123. $this->SelectDB($schema);
  124. }
  125. global $ADODB_FETCH_MODE;
  126. $save = $ADODB_FETCH_MODE;
  127. $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
  128. if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
  129. $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
  130. if ($schema) {
  131. $this->SelectDB($dbName);
  132. }
  133. if (isset($savem)) $this->SetFetchMode($savem);
  134. $ADODB_FETCH_MODE = $save;
  135. if (!is_object($rs)) {
  136. $false = false;
  137. return $false;
  138. }
  139. $retarr = array();
  140. while (!$rs->EOF){
  141. $fld = new ADOFieldObject();
  142. $fld->name = $rs->fields[0];
  143. $fld->type = $rs->fields[1];
  144. $fld->not_null = (!$rs->fields[3]);
  145. $fld->auto_increment = ($rs->fields[4] == 128); // sys.syscolumns status field. 0x80 = 128 ref: http://msdn.microsoft.com/en-us/library/ms186816.aspx
  146. if (isset($rs->fields[5]) && $rs->fields[5]) {
  147. if ($rs->fields[5]>0) $fld->max_length = $rs->fields[5];
  148. $fld->scale = $rs->fields[6];
  149. if ($fld->scale>0) $fld->max_length += 1;
  150. } else
  151. $fld->max_length = $rs->fields[2];
  152. if ($save == ADODB_FETCH_NUM) {
  153. $retarr[] = $fld;
  154. } else {
  155. $retarr[strtoupper($fld->name)] = $fld;
  156. }
  157. $rs->MoveNext();
  158. }
  159. $rs->Close();
  160. return $retarr;
  161. }
  162. function MetaIndexes($table,$primary=false, $owner=false)
  163. {
  164. $table = $this->qstr($table);
  165. $sql = "SELECT i.name AS ind_name, C.name AS col_name, USER_NAME(O.uid) AS Owner, c.colid, k.Keyno,
  166. 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,
  167. CASE WHEN I.status & 2 = 2 THEN 1 ELSE 0 END AS IsUnique
  168. FROM dbo.sysobjects o INNER JOIN dbo.sysindexes I ON o.id = i.id
  169. INNER JOIN dbo.sysindexkeys K ON I.id = K.id AND I.Indid = K.Indid
  170. INNER JOIN dbo.syscolumns c ON K.id = C.id AND K.colid = C.Colid
  171. WHERE LEFT(i.name, 8) <> '_WA_Sys_' AND o.status >= 0 AND O.Name LIKE $table
  172. ORDER BY O.name, I.Name, K.keyno";
  173. global $ADODB_FETCH_MODE;
  174. $save = $ADODB_FETCH_MODE;
  175. $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
  176. if ($this->fetchMode !== FALSE) {
  177. $savem = $this->SetFetchMode(FALSE);
  178. }
  179. $rs = $this->Execute($sql);
  180. if (isset($savem)) {
  181. $this->SetFetchMode($savem);
  182. }
  183. $ADODB_FETCH_MODE = $save;
  184. if (!is_object($rs)) {
  185. return FALSE;
  186. }
  187. $indexes = array();
  188. while ($row = $rs->FetchRow()) {
  189. if (!$primary && $row[5]) continue;
  190. $indexes[$row[0]]['unique'] = $row[6];
  191. $indexes[$row[0]]['columns'][] = $row[1];
  192. }
  193. return $indexes;
  194. }
  195. function _query($sql,$inputarr=false)
  196. {
  197. if (is_string($sql)) $sql = str_replace('||','+',$sql);
  198. return ADODB_odbc::_query($sql,$inputarr);
  199. }
  200. function SetTransactionMode( $transaction_mode )
  201. {
  202. $this->_transmode = $transaction_mode;
  203. if (empty($transaction_mode)) {
  204. $this->Execute('SET TRANSACTION ISOLATION LEVEL READ COMMITTED');
  205. return;
  206. }
  207. if (!stristr($transaction_mode,'isolation')) $transaction_mode = 'ISOLATION LEVEL '.$transaction_mode;
  208. $this->Execute("SET TRANSACTION ".$transaction_mode);
  209. }
  210. // "Stein-Aksel Basma" <basma@accelero.no>
  211. // tested with MSSQL 2000
  212. function MetaPrimaryKeys($table, $owner = false)
  213. {
  214. global $ADODB_FETCH_MODE;
  215. $schema = '';
  216. $this->_findschema($table,$schema);
  217. //if (!$schema) $schema = $this->database;
  218. if ($schema) $schema = "and k.table_catalog like '$schema%'";
  219. $sql = "select distinct k.column_name,ordinal_position from information_schema.key_column_usage k,
  220. information_schema.table_constraints tc
  221. where tc.constraint_name = k.constraint_name and tc.constraint_type =
  222. 'PRIMARY KEY' and k.table_name = '$table' $schema order by ordinal_position ";
  223. $savem = $ADODB_FETCH_MODE;
  224. $ADODB_FETCH_MODE = ADODB_FETCH_ASSOC;
  225. $a = $this->GetCol($sql);
  226. $ADODB_FETCH_MODE = $savem;
  227. if ($a && sizeof($a)>0) return $a;
  228. $false = false;
  229. return $false;
  230. }
  231. function SelectLimit($sql,$nrows=-1,$offset=-1, $inputarr=false,$secs2cache=0)
  232. {
  233. $nrows = (int) $nrows;
  234. $offset = (int) $offset;
  235. if ($nrows > 0 && $offset <= 0) {
  236. $sql = preg_replace(
  237. '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop." $nrows ",$sql);
  238. $rs = $this->Execute($sql,$inputarr);
  239. } else
  240. $rs = ADOConnection::SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
  241. return $rs;
  242. }
  243. // Format date column in sql string given an input format that understands Y M D
  244. function SQLDate($fmt, $col=false)
  245. {
  246. if (!$col) $col = $this->sysTimeStamp;
  247. $s = '';
  248. $len = strlen($fmt);
  249. for ($i=0; $i < $len; $i++) {
  250. if ($s) $s .= '+';
  251. $ch = $fmt[$i];
  252. switch($ch) {
  253. case 'Y':
  254. case 'y':
  255. $s .= "datename(yyyy,$col)";
  256. break;
  257. case 'M':
  258. $s .= "convert(char(3),$col,0)";
  259. break;
  260. case 'm':
  261. $s .= "replace(str(month($col),2),' ','0')";
  262. break;
  263. case 'Q':
  264. case 'q':
  265. $s .= "datename(quarter,$col)";
  266. break;
  267. case 'D':
  268. case 'd':
  269. $s .= "replace(str(day($col),2),' ','0')";
  270. break;
  271. case 'h':
  272. $s .= "substring(convert(char(14),$col,0),13,2)";
  273. break;
  274. case 'H':
  275. $s .= "replace(str(datepart(hh,$col),2),' ','0')";
  276. break;
  277. case 'i':
  278. $s .= "replace(str(datepart(mi,$col),2),' ','0')";
  279. break;
  280. case 's':
  281. $s .= "replace(str(datepart(ss,$col),2),' ','0')";
  282. break;
  283. case 'a':
  284. case 'A':
  285. $s .= "substring(convert(char(19),$col,0),18,2)";
  286. break;
  287. default:
  288. if ($ch == '\\') {
  289. $i++;
  290. $ch = substr($fmt,$i,1);
  291. }
  292. $s .= $this->qstr($ch);
  293. break;
  294. }
  295. }
  296. return $s;
  297. }
  298. }
  299. class ADORecordSet_odbc_mssql extends ADORecordSet_odbc {
  300. var $databaseType = 'odbc_mssql';
  301. function __construct($id,$mode=false)
  302. {
  303. return parent::__construct($id,$mode);
  304. }
  305. }