Context Navigation

← Previous Revision
Latest Revision
Next Revision →
Normal
Revision Log

adodb-db2.inc.php @ 8222

Revision 8222, 21.6 KB checked in by angelo, 11 years ago (diff)
Ticket #3491 - Compatibilizar Expresso com novas versoes do PHP
Property svn:eol-style set to `native` Property svn:executable set to ``*

Rev	Line
[2]	1	<?php
	2	/*
[8222]	3	V5.18 3 Sep 2012 (c) 2000-2012 (jlim#natsoft.com). All rights reserved.
[2]	4
[34]	5	This is a version of the ADODB driver for DB2. It uses the 'ibm_db2' PECL extension
	6	for PHP (http://pecl.php.net/package/ibm_db2), which in turn requires DB2 V8.2.2 or
	7	higher.
[2]	8
[34]	9	Originally tested with PHP 5.1.1 and Apache 2.0.55 on Windows XP SP2.
	10	More recently tested with PHP 5.1.2 and Apache 2.0.55 on Windows XP SP2.
[2]	11
[34]	12	This file was ported from "adodb-odbc.inc.php" by Larry Menard, "larry.menard#rogers.com".
	13	I ripped out what I believed to be a lot of redundant or obsolete code, but there are
	14	probably still some remnants of the ODBC support in this file; I'm relying on reviewers
	15	of this code to point out any other things that can be removed.
[2]	16	*/
	17
	18	// security - hide paths
	19	if (!defined('ADODB_DIR')) die();
	20
[34]	21	define("_ADODB_DB2_LAYER", 2 );
	22
	23	/*--------------------------------------------------------------------------------------
	24	--------------------------------------------------------------------------------------*/
[2]	25
[34]	26
[8222]	27
	28
	29
[34]	30	class ADODB_db2 extends ADOConnection {
[2]	31	var $databaseType = "db2";
[34]	32	var $fmtDate = "'Y-m-d'";
[2]	33	var $concat_operator = '\|\|';
[34]	34
	35	var $sysTime = 'CURRENT TIME';
	36	var $sysDate = 'CURRENT DATE';
[2]	37	var $sysTimeStamp = 'CURRENT TIMESTAMP';
	38
[8222]	39	var $fmtTimeStamp = "'Y-m-d H:i:s'";
[34]	40	var $replaceQuote = "''"; // string to use to replace quotes
	41	var $dataProvider = "db2";
	42	var $hasAffectedRows = true;
	43
	44	var $binmode = DB2_BINARY;
	45
	46	var $useFetchArray = false; // setting this to true will make array elements in FETCH_ASSOC mode case-sensitive
	47	// breaking backward-compat
	48	var $_bindInputArray = false;
	49	var $_genIDSQL = "VALUES NEXTVAL FOR %s";
[8222]	50	var $_genSeqSQL = "CREATE SEQUENCE %s START WITH %s NO MAXVALUE NO CYCLE";
[34]	51	var $_dropSeqSQL = "DROP SEQUENCE %s";
	52	var $_autocommit = true;
	53	var $_haserrorfunctions = true;
	54	var $_lastAffectedRows = 0;
	55	var $uCaseTables = true; // for meta* functions, uppercase table names
	56	var $hasInsertID = true;
[2]	57
[8222]	58
[34]	59	function _insertid()
	60	{
	61	return ADOConnection::GetOne('VALUES IDENTITY_VAL_LOCAL()');
	62	}
[2]	63
[34]	64	function ADODB_db2()
	65	{
	66	$this->_haserrorfunctions = ADODB_PHPVER >= 0x4050;
[2]	67	}
	68
[34]	69	// returns true or false
	70	function _connect($argDSN, $argUsername, $argPassword, $argDatabasename)
[2]	71	{
[34]	72	global $php_errormsg;
	73
	74	if (!function_exists('db2_connect')) {
[8222]	75	ADOConnection::outp("Warning: The old ODBC based DB2 driver has been renamed 'odbc_db2'. This ADOdb driver calls PHP's native db2 extension which is not installed.");
[34]	76	return null;
	77	}
	78	// This needs to be set before the connect().
	79	// Replaces the odbc_binmode() call that was in Execute()
	80	ini_set('ibm_db2.binmode', $this->binmode);
	81
[8222]	82	if ($argDatabasename && empty($argDSN)) {
	83
	84	if (stripos($argDatabasename,'UID=') && stripos($argDatabasename,'PWD=')) $this->_connectionID = db2_connect($argDatabasename,null,null);
	85	else $this->_connectionID = db2_connect($argDatabasename,$argUsername,$argPassword);
[34]	86	} else {
[8222]	87	if ($argDatabasename) $schema = $argDatabasename;
	88	if (stripos($argDSN,'UID=') && stripos($argDSN,'PWD=')) $this->_connectionID = db2_connect($argDSN,null,null);
	89	else $this->_connectionID = db2_connect($argDSN,$argUsername,$argPassword);
[34]	90	}
	91	if (isset($php_errormsg)) $php_errormsg = '';
	92
	93	// For db2_connect(), there is an optional 4th arg. If present, it must be
	94	// an array of valid options. So far, we don't use them.
	95
	96	$this->_errorMsg = @db2_conn_errormsg();
	97	if (isset($this->connectStmt)) $this->Execute($this->connectStmt);
	98
[8222]	99	if ($this->_connectionID && isset($schema)) $this->Execute("SET SCHEMA=$schema");
[34]	100	return $this->_connectionID != false;
[2]	101	}
	102
[34]	103	// returns true or false
	104	function _pconnect($argDSN, $argUsername, $argPassword, $argDatabasename)
[2]	105	{
[34]	106	global $php_errormsg;
[2]	107
[34]	108	if (!function_exists('db2_connect')) return null;
[2]	109
[34]	110	// This needs to be set before the connect().
	111	// Replaces the odbc_binmode() call that was in Execute()
	112	ini_set('ibm_db2.binmode', $this->binmode);
	113
	114	if (isset($php_errormsg)) $php_errormsg = '';
	115	$this->_errorMsg = isset($php_errormsg) ? $php_errormsg : '';
[2]	116
[8222]	117	if ($argDatabasename && empty($argDSN)) {
	118
	119	if (stripos($argDatabasename,'UID=') && stripos($argDatabasename,'PWD=')) $this->_connectionID = db2_pconnect($argDatabasename,null,null);
	120	else $this->_connectionID = db2_pconnect($argDatabasename,$argUsername,$argPassword);
[34]	121	} else {
[8222]	122	if ($argDatabasename) $schema = $argDatabasename;
	123	if (stripos($argDSN,'UID=') && stripos($argDSN,'PWD=')) $this->_connectionID = db2_pconnect($argDSN,null,null);
	124	else $this->_connectionID = db2_pconnect($argDSN,$argUsername,$argPassword);
[2]	125	}
[34]	126	if (isset($php_errormsg)) $php_errormsg = '';
	127
	128	$this->_errorMsg = @db2_conn_errormsg();
	129	if ($this->_connectionID && $this->autoRollback) @db2_rollback($this->_connectionID);
	130	if (isset($this->connectStmt)) $this->Execute($this->connectStmt);
[2]	131
[8222]	132	if ($this->_connectionID && isset($schema)) $this->Execute("SET SCHEMA=$schema");
[34]	133	return $this->_connectionID != false;
[2]	134	}
[34]	135
	136	// format and return date string in database timestamp format
	137	function DBTimeStamp($ts)
	138	{
	139	if (empty($ts) && $ts !== 0) return 'null';
	140	if (is_string($ts)) $ts = ADORecordSet::UnixTimeStamp($ts);
	141	return 'TO_DATE('.adodb_date($this->fmtTimeStamp,$ts).",'YYYY-MM-DD HH24:MI:SS')";
	142	}
[2]	143
	144	// Format date column in sql string given an input format that understands Y M D
	145	function SQLDate($fmt, $col=false)
	146	{
	147	// use right() and replace() ?
	148	if (!$col) $col = $this->sysDate;
[34]	149
	150	/* use TO_CHAR() if $fmt is TO_CHAR() allowed fmt */
	151	if ($fmt== 'Y-m-d H:i:s')
	152	return 'TO_CHAR('.$col.", 'YYYY-MM-DD HH24:MI:SS')";
	153
[2]	154	$s = '';
	155
	156	$len = strlen($fmt);
	157	for ($i=0; $i < $len; $i++) {
[34]	158	if ($s) $s .= $this->concat_operator;
[2]	159	$ch = $fmt[$i];
	160	switch($ch) {
	161	case 'Y':
	162	case 'y':
[34]	163	if ($len==1) return "year($col)";
[2]	164	$s .= "char(year($col))";
	165	break;
	166	case 'M':
[34]	167	if ($len==1) return "monthname($col)";
[2]	168	$s .= "substr(monthname($col),1,3)";
	169	break;
	170	case 'm':
[34]	171	if ($len==1) return "month($col)";
[2]	172	$s .= "right(digits(month($col)),2)";
	173	break;
	174	case 'D':
	175	case 'd':
[34]	176	if ($len==1) return "day($col)";
[2]	177	$s .= "right(digits(day($col)),2)";
	178	break;
	179	case 'H':
	180	case 'h':
[34]	181	if ($len==1) return "hour($col)";
[2]	182	if ($col != $this->sysDate) $s .= "right(digits(hour($col)),2)";
	183	else $s .= "''";
	184	break;
	185	case 'i':
	186	case 'I':
[34]	187	if ($len==1) return "minute($col)";
[2]	188	if ($col != $this->sysDate)
	189	$s .= "right(digits(minute($col)),2)";
	190	else $s .= "''";
	191	break;
	192	case 'S':
	193	case 's':
[34]	194	if ($len==1) return "second($col)";
[2]	195	if ($col != $this->sysDate)
	196	$s .= "right(digits(second($col)),2)";
	197	else $s .= "''";
	198	break;
	199	default:
	200	if ($ch == '\\') {
	201	$i++;
	202	$ch = substr($fmt,$i,1);
	203	}
	204	$s .= $this->qstr($ch);
	205	}
	206	}
	207	return $s;
	208	}
	209
	210
[34]	211	function ServerInfo()
[2]	212	{
[8222]	213	$row = $this->GetRow("SELECT service_level, fixpack_num FROM TABLE(sysproc.env_get_inst_info())
	214	as INSTANCEINFO");
	215
	216
	217	if ($row) {
	218	$info['version'] = $row[0].':'.$row[1];
	219	$info['fixpack'] = $row[1];
	220	$info['description'] = '';
[2]	221	} else {
[34]	222	return ADOConnection::ServerInfo();
[2]	223	}
[8222]	224
	225	return $info;
[34]	226	}
	227
	228	function CreateSequence($seqname='adodbseq',$start=1)
	229	{
	230	if (empty($this->_genSeqSQL)) return false;
[8222]	231	$ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname,$start));
[34]	232	if (!$ok) return false;
	233	return true;
	234	}
	235
	236	function DropSequence($seqname)
	237	{
	238	if (empty($this->_dropSeqSQL)) return false;
	239	return $this->Execute(sprintf($this->_dropSeqSQL,$seqname));
	240	}
	241
[8222]	242	function SelectLimit($sql,$nrows=-1,$offset=-1,$inputArr=false)
	243	{
	244	$nrows = (integer) $nrows;
	245	if ($offset <= 0) {
	246	// could also use " OPTIMIZE FOR $nrows ROWS "
	247	if ($nrows >= 0) $sql .= " FETCH FIRST $nrows ROWS ONLY ";
	248	$rs = $this->Execute($sql,$inputArr);
	249	} else {
	250	if ($offset > 0 && $nrows < 0);
	251	else {
	252	$nrows += $offset;
	253	$sql .= " FETCH FIRST $nrows ROWS ONLY ";
	254	}
	255	$rs = ADOConnection::SelectLimit($sql,-1,$offset,$inputArr);
	256	}
	257
	258	return $rs;
	259	}
	260
[34]	261	/*
	262	This algorithm is not very efficient, but works even if table locking
	263	is not available.
[2]	264
[34]	265	Will return false if unable to generate an ID after $MAXLOOPS attempts.
	266	*/
	267	function GenID($seq='adodbseq',$start=1)
	268	{
	269	// if you have to modify the parameter below, your database is overloaded,
	270	// or you need to implement generation of id's yourself!
[8222]	271	$num = $this->GetOne("VALUES NEXTVAL FOR $seq");
[34]	272	return $num;
[8222]	273	}
[34]	274
	275
	276	function ErrorMsg()
	277	{
	278	if ($this->_haserrorfunctions) {
	279	if ($this->_errorMsg !== false) return $this->_errorMsg;
	280	if (empty($this->_connectionID)) return @db2_conn_errormsg();
	281	return @db2_conn_errormsg($this->_connectionID);
	282	} else return ADOConnection::ErrorMsg();
[2]	283	}
	284
[34]	285	function ErrorNo()
	286	{
	287
	288	if ($this->_haserrorfunctions) {
	289	if ($this->_errorCode !== false) {
	290	// bug in 4.0.6, error number can be corrupted string (should be 6 digits)
	291	return (strlen($this->_errorCode)<=2) ? 0 : $this->_errorCode;
	292	}
[2]	293
[34]	294	if (empty($this->_connectionID)) $e = @db2_conn_error();
	295	else $e = @db2_conn_error($this->_connectionID);
	296
	297	// bug in 4.0.6, error number can be corrupted string (should be 6 digits)
	298	// so we check and patch
	299	if (strlen($e)<=2) return 0;
	300	return $e;
	301	} else return ADOConnection::ErrorNo();
	302	}
[2]	303
	304
[34]	305
	306	function BeginTrans()
	307	{
	308	if (!$this->hasTransactions) return false;
	309	if ($this->transOff) return true;
	310	$this->transCnt += 1;
	311	$this->_autocommit = false;
	312	return db2_autocommit($this->_connectionID,false);
	313	}
	314
	315	function CommitTrans($ok=true)
	316	{
	317	if ($this->transOff) return true;
	318	if (!$ok) return $this->RollbackTrans();
	319	if ($this->transCnt) $this->transCnt -= 1;
	320	$this->_autocommit = true;
	321	$ret = db2_commit($this->_connectionID);
	322	db2_autocommit($this->_connectionID,true);
	323	return $ret;
	324	}
	325
	326	function RollbackTrans()
[2]	327	{
[34]	328	if ($this->transOff) return true;
	329	if ($this->transCnt) $this->transCnt -= 1;
	330	$this->_autocommit = true;
	331	$ret = db2_rollback($this->_connectionID);
	332	db2_autocommit($this->_connectionID,true);
	333	return $ret;
[2]	334	}
[34]	335
	336	function MetaPrimaryKeys($table)
	337	{
	338	global $ADODB_FETCH_MODE;
	339
	340	if ($this->uCaseTables) $table = strtoupper($table);
	341	$schema = '';
	342	$this->_findschema($table,$schema);
[2]	343
[34]	344	$savem = $ADODB_FETCH_MODE;
	345	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
	346	$qid = @db2_primarykeys($this->_connectionID,'',$schema,$table);
	347
	348	if (!$qid) {
	349	$ADODB_FETCH_MODE = $savem;
	350	return false;
	351	}
	352	$rs = new ADORecordSet_db2($qid);
	353	$ADODB_FETCH_MODE = $savem;
	354
	355	if (!$rs) return false;
	356
[8222]	357	$arr = $rs->GetArray();
[34]	358	$rs->Close();
	359	$arr2 = array();
	360	for ($i=0; $i < sizeof($arr); $i++) {
	361	if ($arr[$i][3]) $arr2[] = $arr[$i][3];
	362	}
	363	return $arr2;
	364	}
	365
	366	function MetaForeignKeys($table, $owner = FALSE, $upper = FALSE, $asociative = FALSE )
[2]	367	{
[34]	368	global $ADODB_FETCH_MODE;
	369
	370	if ($this->uCaseTables) $table = strtoupper($table);
	371	$schema = '';
	372	$this->_findschema($table,$schema);
	373
	374	$savem = $ADODB_FETCH_MODE;
	375	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
	376	$qid = @db2_foreign_keys($this->_connectionID,'',$schema,$table);
	377	if (!$qid) {
	378	$ADODB_FETCH_MODE = $savem;
	379	return false;
[2]	380	}
[34]	381	$rs = new ADORecordSet_db2($qid);
	382
	383	$ADODB_FETCH_MODE = $savem;
	384	/*
	385	$rs->fields indices
	386	0 PKTABLE_CAT
	387	1 PKTABLE_SCHEM
	388	2 PKTABLE_NAME
	389	3 PKCOLUMN_NAME
	390	4 FKTABLE_CAT
	391	5 FKTABLE_SCHEM
	392	6 FKTABLE_NAME
	393	7 FKCOLUMN_NAME
	394	*/
	395	if (!$rs) return false;
	396
	397	$foreign_keys = array();
	398	while (!$rs->EOF) {
	399	if (strtoupper(trim($rs->fields[2])) == $table && (!$schema \|\| strtoupper($rs->fields[1]) == $schema)) {
	400	if (!is_array($foreign_keys[$rs->fields[5].'.'.$rs->fields[6]]))
	401	$foreign_keys[$rs->fields[5].'.'.$rs->fields[6]] = array();
	402	$foreign_keys[$rs->fields[5].'.'.$rs->fields[6]][$rs->fields[7]] = $rs->fields[3];
	403	}
	404	$rs->MoveNext();
	405	}
	406
	407	$rs->Close();
	408	return $foreign_key;
	409	}
	410
	411
[8222]	412	function MetaTables($ttype=false,$schema=false)
[34]	413	{
	414	global $ADODB_FETCH_MODE;
	415
	416	$savem = $ADODB_FETCH_MODE;
	417	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
	418	$qid = db2_tables($this->_connectionID);
[2]	419
[34]	420	$rs = new ADORecordSet_db2($qid);
[2]	421
[34]	422	$ADODB_FETCH_MODE = $savem;
	423	if (!$rs) {
	424	$false = false;
	425	return $false;
	426	}
	427
[8222]	428	$arr = $rs->GetArray();
[34]	429	$rs->Close();
	430	$arr2 = array();
	431
	432	if ($ttype) {
	433	$isview = strncmp($ttype,'V',1) === 0;
	434	}
	435	for ($i=0; $i < sizeof($arr); $i++) {
	436	if (!$arr[$i][2]) continue;
	437	$type = $arr[$i][3];
[8222]	438	$owner = $arr[$i][1];
[34]	439	$schemaval = ($schema) ? $arr[$i][1].'.' : '';
	440	if ($ttype) {
	441	if ($isview) {
	442	if (strncmp($type,'V',1) === 0) $arr2[] = $schemaval.$arr[$i][2];
[8222]	443	} else if (strncmp($owner,'SYS',3) !== 0) $arr2[] = $schemaval.$arr[$i][2];
	444	} else if (strncmp($owner,'SYS',3) !== 0) $arr2[] = $schemaval.$arr[$i][2];
[34]	445	}
	446	return $arr2;
	447	}
	448
	449	/*
	450	See http://msdn.microsoft.com/library/default.asp?url=/library/en-us/db2/htm/db2datetime_data_type_changes.asp
	451	/ SQL data type codes /
	452	#define SQL_UNKNOWN_TYPE 0
	453	#define SQL_CHAR 1
	454	#define SQL_NUMERIC 2
	455	#define SQL_DECIMAL 3
	456	#define SQL_INTEGER 4
	457	#define SQL_SMALLINT 5
	458	#define SQL_FLOAT 6
	459	#define SQL_REAL 7
	460	#define SQL_DOUBLE 8
	461	#if (DB2VER >= 0x0300)
	462	#define SQL_DATETIME 9
	463	#endif
	464	#define SQL_VARCHAR 12
	465
	466
	467	/ One-parameter shortcuts for date/time data types /
	468	#if (DB2VER >= 0x0300)
	469	#define SQL_TYPE_DATE 91
	470	#define SQL_TYPE_TIME 92
	471	#define SQL_TYPE_TIMESTAMP 93
	472
	473	#define SQL_UNICODE (-95)
	474	#define SQL_UNICODE_VARCHAR (-96)
	475	#define SQL_UNICODE_LONGVARCHAR (-97)
	476	*/
	477	function DB2Types($t)
	478	{
	479	switch ((integer)$t) {
	480	case 1:
	481	case 12:
	482	case 0:
	483	case -95:
	484	case -96:
	485	return 'C';
	486	case -97:
	487	case -1: //text
[2]	488	return 'X';
[34]	489	case -4: //image
[2]	490	return 'B';
[34]	491
	492	case 9:
	493	case 91:
[2]	494	return 'D';
	495
[34]	496	case 10:
	497	case 11:
	498	case 92:
	499	case 93:
[2]	500	return 'T';
[34]	501
	502	case 4:
	503	case 5:
	504	case -6:
	505	return 'I';
	506
	507	case -11: // uniqidentifier
	508	return 'R';
	509	case -7: //bit
	510	return 'L';
[2]	511
[34]	512	default:
	513	return 'N';
	514	}
	515	}
	516
[8222]	517	function MetaColumns($table, $normalize=true)
[34]	518	{
	519	global $ADODB_FETCH_MODE;
	520
	521	$false = false;
	522	if ($this->uCaseTables) $table = strtoupper($table);
	523	$schema = '';
	524	$this->_findschema($table,$schema);
	525
	526	$savem = $ADODB_FETCH_MODE;
	527	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
	528
	529	$colname = "%";
	530	$qid = db2_columns($this->_connectionID, "", $schema, $table, $colname);
	531	if (empty($qid)) return $false;
	532
[8222]	533	$rs = new ADORecordSet_db2($qid);
[34]	534	$ADODB_FETCH_MODE = $savem;
	535
	536	if (!$rs) return $false;
	537	$rs->_fetch();
	538
	539	$retarr = array();
	540
	541	/*
	542	$rs->fields indices
	543	0 TABLE_QUALIFIER
	544	1 TABLE_SCHEM
	545	2 TABLE_NAME
	546	3 COLUMN_NAME
	547	4 DATA_TYPE
	548	5 TYPE_NAME
	549	6 PRECISION
	550	7 LENGTH
	551	8 SCALE
	552	9 RADIX
	553	10 NULLABLE
	554	11 REMARKS
	555	*/
	556	while (!$rs->EOF) {
	557	if (strtoupper(trim($rs->fields[2])) == $table && (!$schema \|\| strtoupper($rs->fields[1]) == $schema)) {
	558	$fld = new ADOFieldObject();
	559	$fld->name = $rs->fields[3];
	560	$fld->type = $this->DB2Types($rs->fields[4]);
	561
	562	// ref: http://msdn.microsoft.com/library/default.asp?url=/archive/en-us/dnaraccgen/html/msdn_odk.asp
	563	// access uses precision to store length for char/varchar
	564	if ($fld->type == 'C' or $fld->type == 'X') {
	565	if ($rs->fields[4] <= -95) // UNICODE
	566	$fld->max_length = $rs->fields[7]/2;
	567	else
	568	$fld->max_length = $rs->fields[7];
	569	} else
	570	$fld->max_length = $rs->fields[7];
	571	$fld->not_null = !empty($rs->fields[10]);
	572	$fld->scale = $rs->fields[8];
	573	$fld->primary_key = false;
	574	$retarr[strtoupper($fld->name)] = $fld;
	575	} else if (sizeof($retarr)>0)
	576	break;
	577	$rs->MoveNext();
	578	}
	579	$rs->Close();
	580	if (empty($retarr)) $retarr = false;
	581
	582	$qid = db2_primary_keys($this->_connectionID, "", $schema, $table);
	583	if (empty($qid)) return $false;
	584
[8222]	585	$rs = new ADORecordSet_db2($qid);
[34]	586	$ADODB_FETCH_MODE = $savem;
	587
	588	if (!$rs) return $retarr;
	589	$rs->_fetch();
	590
	591	/*
	592	$rs->fields indices
	593	0 TABLE_CAT
	594	1 TABLE_SCHEM
	595	2 TABLE_NAME
	596	3 COLUMN_NAME
	597	4 KEY_SEQ
	598	5 PK_NAME
	599	*/
	600	while (!$rs->EOF) {
	601	if (strtoupper(trim($rs->fields[2])) == $table && (!$schema \|\| strtoupper($rs->fields[1]) == $schema)) {
	602	$retarr[strtoupper($rs->fields[3])]->primary_key = true;
	603	} else if (sizeof($retarr)>0)
	604	break;
	605	$rs->MoveNext();
	606	}
	607	$rs->Close();
	608
	609	if (empty($retarr)) $retarr = false;
	610	return $retarr;
	611	}
	612
[8222]	613
[34]	614	function Prepare($sql)
	615	{
	616	if (! $this->_bindInputArray) return $sql; // no binding
	617	$stmt = db2_prepare($this->_connectionID,$sql);
	618	if (!$stmt) {
	619	// we don't know whether db2 driver is parsing prepared stmts, so just return sql
	620	return $sql;
	621	}
	622	return array($sql,$stmt,false);
	623	}
	624
	625	/* returns queryID or false */
	626	function _query($sql,$inputarr=false)
	627	{
	628	GLOBAL $php_errormsg;
	629	if (isset($php_errormsg)) $php_errormsg = '';
	630	$this->_error = '';
	631
	632	if ($inputarr) {
	633	if (is_array($sql)) {
	634	$stmtid = $sql[1];
	635	} else {
	636	$stmtid = db2_prepare($this->_connectionID,$sql);
	637
	638	if ($stmtid == false) {
	639	$this->_errorMsg = isset($php_errormsg) ? $php_errormsg : '';
	640	return false;
	641	}
	642	}
[2]	643
[34]	644	if (! db2_execute($stmtid,$inputarr)) {
	645	if ($this->_haserrorfunctions) {
	646	$this->_errorMsg = db2_stmt_errormsg();
	647	$this->_errorCode = db2_stmt_error();
	648	}
	649	return false;
	650	}
	651
	652	} else if (is_array($sql)) {
	653	$stmtid = $sql[1];
	654	if (!db2_execute($stmtid)) {
	655	if ($this->_haserrorfunctions) {
	656	$this->_errorMsg = db2_stmt_errormsg();
	657	$this->_errorCode = db2_stmt_error();
	658	}
	659	return false;
	660	}
	661	} else
	662	$stmtid = @db2_exec($this->_connectionID,$sql);
	663
	664	$this->_lastAffectedRows = 0;
	665	if ($stmtid) {
	666	if (@db2_num_fields($stmtid) == 0) {
	667	$this->_lastAffectedRows = db2_num_rows($stmtid);
	668	$stmtid = true;
	669	} else {
	670	$this->_lastAffectedRows = 0;
	671	}
[2]	672
[34]	673	if ($this->_haserrorfunctions) {
	674	$this->_errorMsg = '';
	675	$this->_errorCode = 0;
	676	} else
	677	$this->_errorMsg = isset($php_errormsg) ? $php_errormsg : '';
	678	} else {
	679	if ($this->_haserrorfunctions) {
	680	$this->_errorMsg = db2_stmt_errormsg();
	681	$this->_errorCode = db2_stmt_error();
	682	} else
	683	$this->_errorMsg = isset($php_errormsg) ? $php_errormsg : '';
	684
	685	}
	686	return $stmtid;
	687	}
	688
	689	/*
	690	Insert a null into the blob field of the table first.
	691	Then use UpdateBlob to store the blob.
	692
	693	Usage:
	694
	695	$conn->Execute('INSERT INTO blobtable (id, blobcol) VALUES (1, null)');
	696	$conn->UpdateBlob('blobtable','blobcol',$blob,'id=1');
	697	*/
	698	function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB')
	699	{
	700	return $this->Execute("UPDATE $table SET $column=? WHERE $where",array($val)) != false;
	701	}
	702
	703	// returns true or false
	704	function _close()
	705	{
	706	$ret = @db2_close($this->_connectionID);
	707	$this->_connectionID = false;
	708	return $ret;
	709	}
	710
	711	function _affectedrows()
	712	{
	713	return $this->_lastAffectedRows;
	714	}
	715
	716	}
	717
	718	/*--------------------------------------------------------------------------------------
	719	Class Name: Recordset
	720	--------------------------------------------------------------------------------------*/
	721
	722	class ADORecordSet_db2 extends ADORecordSet {
	723
	724	var $bind = false;
	725	var $databaseType = "db2";
	726	var $dataProvider = "db2";
	727	var $useFetchArray;
	728
	729	function ADORecordSet_db2($id,$mode=false)
	730	{
	731	if ($mode === false) {
	732	global $ADODB_FETCH_MODE;
	733	$mode = $ADODB_FETCH_MODE;
	734	}
	735	$this->fetchMode = $mode;
	736
	737	$this->_queryID = $id;
	738	}
	739
	740
	741	// returns the field object
[8222]	742	function FetchField($offset = -1)
[34]	743	{
	744	$o= new ADOFieldObject();
	745	$o->name = @db2_field_name($this->_queryID,$offset);
	746	$o->type = @db2_field_type($this->_queryID,$offset);
	747	$o->max_length = db2_field_width($this->_queryID,$offset);
	748	if (ADODB_ASSOC_CASE == 0) $o->name = strtolower($o->name);
	749	else if (ADODB_ASSOC_CASE == 1) $o->name = strtoupper($o->name);
	750	return $o;
	751	}
	752
	753	/* Use associative array to get fields array */
	754	function Fields($colname)
	755	{
	756	if ($this->fetchMode & ADODB_FETCH_ASSOC) return $this->fields[$colname];
	757	if (!$this->bind) {
	758	$this->bind = array();
	759	for ($i=0; $i < $this->_numOfFields; $i++) {
	760	$o = $this->FetchField($i);
	761	$this->bind[strtoupper($o->name)] = $i;
	762	}
	763	}
	764
	765	return $this->fields[$this->bind[strtoupper($colname)]];
	766	}
	767
	768
	769	function _initrs()
	770	{
	771	global $ADODB_COUNTRECS;
	772	$this->_numOfRows = ($ADODB_COUNTRECS) ? @db2_num_rows($this->_queryID) : -1;
	773	$this->_numOfFields = @db2_num_fields($this->_queryID);
	774	// some silly drivers such as db2 as/400 and intersystems cache return _numOfRows = 0
	775	if ($this->_numOfRows == 0) $this->_numOfRows = -1;
	776	}
	777
	778	function _seek($row)
	779	{
	780	return false;
	781	}
	782
	783	// speed up SelectLimit() by switching to ADODB_FETCH_NUM as ADODB_FETCH_ASSOC is emulated
[8222]	784	function GetArrayLimit($nrows,$offset=-1)
[34]	785	{
	786	if ($offset <= 0) {
[8222]	787	$rs = $this->GetArray($nrows);
[34]	788	return $rs;
	789	}
	790	$savem = $this->fetchMode;
	791	$this->fetchMode = ADODB_FETCH_NUM;
	792	$this->Move($offset);
	793	$this->fetchMode = $savem;
	794
	795	if ($this->fetchMode & ADODB_FETCH_ASSOC) {
[8222]	796	$this->fields = $this->GetRowAssoc(ADODB_ASSOC_CASE);
[34]	797	}
	798
	799	$results = array();
	800	$cnt = 0;
	801	while (!$this->EOF && $nrows != $cnt) {
	802	$results[$cnt++] = $this->fields;
	803	$this->MoveNext();
	804	}
	805
	806	return $results;
	807	}
	808
	809
	810	function MoveNext()
	811	{
	812	if ($this->_numOfRows != 0 && !$this->EOF) {
	813	$this->_currentRow++;
[2]	814
[34]	815	$this->fields = @db2_fetch_array($this->_queryID);
	816	if ($this->fields) {
	817	if ($this->fetchMode & ADODB_FETCH_ASSOC) {
[8222]	818	$this->fields = $this->GetRowAssoc(ADODB_ASSOC_CASE);
[34]	819	}
	820	return true;
	821	}
[2]	822	}
[34]	823	$this->fields = false;
	824	$this->EOF = true;
	825	return false;
	826	}
	827
	828	function _fetch()
	829	{
	830
	831	$this->fields = db2_fetch_array($this->_queryID);
	832	if ($this->fields) {
	833	if ($this->fetchMode & ADODB_FETCH_ASSOC) {
[8222]	834	$this->fields = $this->GetRowAssoc(ADODB_ASSOC_CASE);
[34]	835	}
	836	return true;
	837	}
	838	$this->fields = false;
	839	return false;
[2]	840	}
[34]	841
	842	function _close()
	843	{
	844	return @db2_free_result($this->_queryID);
	845	}
	846
[2]	847	}
	848	?>

Note: See TracBrowser for help on using the repository browser.

Context Navigation

source: sandbox/2.5.1-evolucao/phpgwapi/inc/adodb/drivers/adodb-db2.inc.php @ 8222

Download in other formats: