Proyectos de Subversion Moodle

Rev

| Ultima modificación | Ver Log |

Rev Autor Línea Nro. Línea
1 efrain 1
<?php
2
/**
3
 * ADOdb PDO dblib driver.
4
 *
5
 * This file is part of ADOdb, a Database Abstraction Layer library for PHP.
6
 *
7
 * @package ADOdb
8
 * @link https://adodb.org Project's web site and documentation
9
 * @link https://github.com/ADOdb/ADOdb Source code and issue tracker
10
 *
11
 * The ADOdb Library is dual-licensed, released under both the BSD 3-Clause
12
 * and the GNU Lesser General Public Licence (LGPL) v2.1 or, at your option,
13
 * any later version. This means you can use it in proprietary products.
14
 * See the LICENSE.md file distributed with this source code for details.
15
 * @license BSD-3-Clause
16
 * @license LGPL-2.1-or-later
17
 *
18
 * @copyright 2000-2013 John Lim
19
 * @copyright 2019 Damien Regad, Mark Newnham and the ADOdb community
20
 */
21
 
22
class ADODB_pdo_dblib extends ADODB_pdo
23
{
24
	var $hasTop = 'top';
25
	var $sysDate = 'convert(datetime,convert(char,GetDate(),102),102)';
26
	var $sysTimeStamp = 'GetDate()';
27
	var $metaDatabasesSQL = "select name from sysdatabases where name <> 'master'";
28
	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'))";
29
 
30
	var $metaColumnsSQL = "SELECT c.NAME, OBJECT_NAME(c.id) as tbl_name, c.length, c.isnullable, c.status, ( CASE WHEN c.xusertype=61 THEN 0 ELSE c.xprec END), ( CASE WHEN c.xusertype=61 THEN 0 ELSE c.xscale END), ISNULL(i.is_primary_key, 0) as primary_key FROM   syscolumns c INNER JOIN systypes t ON t.xusertype=c.xusertype INNER JOIN sysobjects o ON o.id=c.id LEFT JOIN sys.index_columns ic ON ic.object_id = c.id AND c.colid = ic.column_id LEFT JOIN sys.indexes i ON i.object_id = ic.object_id AND i.index_id = ic.index_id WHERE c.id = OBJECT_ID('%s') ORDER by c.colid";
31
 
32
	function _init(ADODB_pdo $parentDriver)
33
	{
34
		$parentDriver->hasTransactions = true;
35
		$parentDriver->_bindInputArray = true;
36
		$parentDriver->hasInsertID = true;
37
		$parentDriver->fmtTimeStamp = "'Y-m-d H:i:s'";
38
		$parentDriver->fmtDate = "'Y-m-d'";
39
	}
40
 
41
	function BeginTrans()
42
	{
43
		$returnval = parent::BeginTrans();
44
		return $returnval;
45
	}
46
 
47
	function MetaColumns($table, $normalize=true)
48
	{
49
		$this->_findschema($table,$schema);
50
		if ($schema) {
51
			$dbName = $this->database;
52
			$this->SelectDB($schema);
53
		}
54
		global $ADODB_FETCH_MODE;
55
		$save = $ADODB_FETCH_MODE;
56
		$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
57
 
58
		if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
59
		$rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
60
 
61
		if ($schema) {
62
			$this->SelectDB($dbName);
63
		}
64
 
65
		if (isset($savem)) $this->SetFetchMode($savem);
66
		$ADODB_FETCH_MODE = $save;
67
		if (!is_object($rs)) {
68
			$false = false;
69
			return $false;
70
		}
71
 
72
		$retarr = array();
73
		while (!$rs->EOF) {
74
			$fld = new ADOFieldObject();
75
			$fld->name = $rs->fields[0];
76
			$fld->type = $rs->fields[1];
77
			$fld->primary_key = $rs->fields[7];
78
 
79
			$fld->not_null = (!$rs->fields[3]);
80
			$fld->auto_increment = ($rs->fields[4] == 128);		// sys.syscolumns status field. 0x80 = 128 ref: http://msdn.microsoft.com/en-us/library/ms186816.aspx
81
 
82
			if (isset($rs->fields[5]) && $rs->fields[5]) {
83
				if ($rs->fields[5]>0) $fld->max_length = $rs->fields[5];
84
				$fld->scale = $rs->fields[6];
85
				if ($fld->scale>0) $fld->max_length += 1;
86
			} else
87
				$fld->max_length = $rs->fields[2];
88
 
89
			if ($save == ADODB_FETCH_NUM) {
90
				$retarr[] = $fld;
91
			} else {
92
				$retarr[strtoupper($fld->name)] = $fld;
93
			}
94
			$rs->MoveNext();
95
		}
96
 
97
		$rs->Close();
98
		return $retarr;
99
	}
100
 
101
	function MetaTables($ttype=false,$showSchema=false,$mask=false)
102
	{
103
		if ($mask) {
104
			$save = $this->metaTablesSQL;
105
			$mask = $this->qstr(($mask));
106
			$this->metaTablesSQL .= " AND name like $mask";
107
		}
108
		$ret = ADOConnection::MetaTables($ttype,$showSchema);
109
 
110
		if ($mask) {
111
			$this->metaTablesSQL = $save;
112
		}
113
		return $ret;
114
	}
115
 
116
	function SelectLimit($sql,$nrows=-1,$offset=-1, $inputarr=false,$secs2cache=0)
117
	{
118
		if ($nrows > 0 && $offset <= 0) {
119
			$sql = preg_replace(
120
				'/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop." $nrows ",$sql);
121
 
122
			if ($secs2cache)
123
				$rs = $this->CacheExecute($secs2cache, $sql, $inputarr);
124
			else
125
				$rs = $this->Execute($sql,$inputarr);
126
		} else
127
			$rs = ADOConnection::SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
128
 
129
		return $rs;
130
	}
131
 
132
	function _query($sql,$inputarr=false)
133
	{
134
		$this->_connectionID->setAttribute(\PDO::ATTR_EMULATE_PREPARES , true);
135
		if (is_array($sql)) {
136
			$stmt = $sql[1];
137
		} else {
138
			$stmt = $this->_connectionID->prepare($sql);
139
		}
140
 
141
		if ($stmt) {
142
			$this->_driver->debug = $this->debug;
143
			if ($inputarr) {
144
				foreach ($inputarr as $key => $value) {
145
					if(gettype($key) == 'integer') {
146
						$key += 1;
147
					}
148
					$stmt->bindValue($key, $value, $this->GetPDODataType($value));
149
				}
150
			}
151
		}
152
 
153
		$ok = $stmt->execute();
154
 
155
		$this->_errormsg = false;
156
		$this->_errorno = false;
157
 
158
		if ($ok) {
159
			$this->_stmt = $stmt;
160
			return $stmt;
161
		}
162
 
163
		if ($stmt) {
164
 
165
			$arr = $stmt->errorinfo();
166
			if ((integer)$arr[1]) {
167
				$this->_errormsg = $arr[2];
168
				$this->_errorno = $arr[1];
169
			}
170
 
171
		} else {
172
			$this->_errormsg = false;
173
			$this->_errorno = false;
174
		}
175
		return false;
176
	}
177
 
178
	private function GetPDODataType($var)
179
	{
180
		if(gettype($var) == 'integer') {
181
			return PDO::PARAM_INT ;
182
		}
183
		return PDO::PARAM_STR;
184
	}
185
 
186
	function ServerInfo()
187
	{
188
		return ADOConnection::ServerInfo();
189
	}
190
}