Context Navigation

source: Dev/trunk/rdfapi/util/adodb/session/adodb-session.php @ 12

Last change on this file since 12 was 12, checked in by basvannuland, 14 years ago
Added RAP RDF API Added RDF reader writer for save and load survey
File size: 21.7 KB

Line
1	<?php
2
3
4	/*
5	V4.94 23 Jan 2007 (c) 2000-2007 John Lim (jlim#natsoft.com.my). All rights reserved.
6	Contributed by Ross Smith (adodb@netebb.com).
7	Released under both BSD license and Lesser GPL library license.
8	Whenever there is any discrepancy between the two licenses,
9	the BSD license will take precedence.
10	Set tabs to 4 for best viewing.
11	*/
12
13	/*
14	You may want to rename the 'data' field to 'session_data' as
15	'data' appears to be a reserved word for one or more of the following:
16	ANSI SQL
17	IBM DB2
18	MS SQL Server
19	Postgres
20	SAP
21
22	If you do, then execute:
23
24	ADODB_Session::dataFieldName('session_data');
25
26	*/
27
28	if (!defined('_ADODB_LAYER')) {
29	require realpath(dirname(__FILE__) . '/../adodb.inc.php');
30	}
31
32	if (defined('ADODB_SESSION')) return 1;
33
34	define('ADODB_SESSION', dirname(__FILE__));
35
36
37	/*
38	Unserialize session data manually. See http://phplens.com/lens/lensforum/msgs.php?id=9821
39
40	From Kerr Schere, to unserialize session data stored via ADOdb.
41	1. Pull the session data from the db and loop through it.
42	2. Inside the loop, you will need to urldecode the data column.
43	3. After urldecode, run the serialized string through this function:
44
45	*/
46	function adodb_unserialize( $serialized_string )
47	{
48	$variables = array( );
49	$a = preg_split( "/(\w+)\\|/", $serialized_string, -1, PREG_SPLIT_NO_EMPTY \| PREG_SPLIT_DELIM_CAPTURE );
50	for( $i = 0; $i < count( $a ); $i = $i+2 ) {
51	$variables[$a[$i]] = unserialize( $a[$i+1] );
52	}
53	return( $variables );
54	}
55
56	/*
57	Thanks Joe Li. See http://phplens.com/lens/lensforum/msgs.php?id=11487&x=1
58	Since adodb 4.61.
59	*/
60	function adodb_session_regenerate_id()
61	{
62	$conn =& ADODB_Session::_conn();
63	if (!$conn) return false;
64
65	$old_id = session_id();
66	if (function_exists('session_regenerate_id')) {
67	session_regenerate_id();
68	} else {
69	session_id(md5(uniqid(rand(), true)));
70	$ck = session_get_cookie_params();
71	setcookie(session_name(), session_id(), false, $ck['path'], $ck['domain'], $ck['secure']);
72	//@session_start();
73	}
74	$new_id = session_id();
75	$ok =& $conn->Execute('UPDATE '. ADODB_Session::table(). ' SET sesskey='. $conn->qstr($new_id). ' WHERE sesskey='.$conn->qstr($old_id));
76
77	/* it is possible that the update statement fails due to a collision */
78	if (!$ok) {
79	session_id($old_id);
80	if (empty($ck)) $ck = session_get_cookie_params();
81	setcookie(session_name(), session_id(), false, $ck['path'], $ck['domain'], $ck['secure']);
82	return false;
83	}
84
85	return true;
86	}
87
88	/*
89	Generate database table for session data
90	@see http://phplens.com/lens/lensforum/msgs.php?id=12280
91	@return 0 if failure, 1 if errors, 2 if successful.
92	@author Markus Staab http://www.public-4u.de
93	*/
94	function adodb_session_create_table($schemaFile=null,$conn = null)
95	{
96	// set default values
97	if ($schemaFile===null) $schemaFile = ADODB_SESSION . '/session_schema.xml';
98	if ($conn===null) $conn =& ADODB_Session::_conn();
99
100	if (!$conn) return 0;
101
102	$schema = new adoSchema($conn);
103	$schema->ParseSchema($schemaFile);
104	return $schema->ExecuteSchema();
105	}
106
107	/*!
108	\static
109	*/
110	class ADODB_Session {
111	/////////////////////
112	// getter/setter methods
113	/////////////////////
114
115	/*
116
117	function Lock($lock=null)
118	{
119	static $_lock = false;
120
121	if (!is_null($lock)) $_lock = $lock;
122	return $lock;
123	}
124	*/
125	/*!
126	*/
127	function driver($driver = null) {
128	static $_driver = 'mysql';
129	static $set = false;
130
131	if (!is_null($driver)) {
132	$_driver = trim($driver);
133	$set = true;
134	} elseif (!$set) {
135	// backwards compatibility
136	if (isset($GLOBALS['ADODB_SESSION_DRIVER'])) {
137	return $GLOBALS['ADODB_SESSION_DRIVER'];
138	}
139	}
140
141	return $_driver;
142	}
143
144	/*!
145	*/
146	function host($host = null) {
147	static $_host = 'localhost';
148	static $set = false;
149
150	if (!is_null($host)) {
151	$_host = trim($host);
152	$set = true;
153	} elseif (!$set) {
154	// backwards compatibility
155	if (isset($GLOBALS['ADODB_SESSION_CONNECT'])) {
156	return $GLOBALS['ADODB_SESSION_CONNECT'];
157	}
158	}
159
160	return $_host;
161	}
162
163	/*!
164	*/
165	function user($user = null) {
166	static $_user = 'root';
167	static $set = false;
168
169	if (!is_null($user)) {
170	$_user = trim($user);
171	$set = true;
172	} elseif (!$set) {
173	// backwards compatibility
174	if (isset($GLOBALS['ADODB_SESSION_USER'])) {
175	return $GLOBALS['ADODB_SESSION_USER'];
176	}
177	}
178
179	return $_user;
180	}
181
182	/*!
183	*/
184	function password($password = null) {
185	static $_password = '';
186	static $set = false;
187
188	if (!is_null($password)) {
189	$_password = $password;
190	$set = true;
191	} elseif (!$set) {
192	// backwards compatibility
193	if (isset($GLOBALS['ADODB_SESSION_PWD'])) {
194	return $GLOBALS['ADODB_SESSION_PWD'];
195	}
196	}
197
198	return $_password;
199	}
200
201	/*!
202	*/
203	function database($database = null) {
204	static $_database = 'xphplens_2';
205	static $set = false;
206
207	if (!is_null($database)) {
208	$_database = trim($database);
209	$set = true;
210	} elseif (!$set) {
211	// backwards compatibility
212	if (isset($GLOBALS['ADODB_SESSION_DB'])) {
213	return $GLOBALS['ADODB_SESSION_DB'];
214	}
215	}
216
217	return $_database;
218	}
219
220	/*!
221	*/
222	function persist($persist = null)
223	{
224	static $_persist = true;
225
226	if (!is_null($persist)) {
227	$_persist = trim($persist);
228	}
229
230	return $_persist;
231	}
232
233	/*!
234	*/
235	function lifetime($lifetime = null) {
236	static $_lifetime;
237	static $set = false;
238
239	if (!is_null($lifetime)) {
240	$_lifetime = (int) $lifetime;
241	$set = true;
242	} elseif (!$set) {
243	// backwards compatibility
244	if (isset($GLOBALS['ADODB_SESS_LIFE'])) {
245	return $GLOBALS['ADODB_SESS_LIFE'];
246	}
247	}
248	if (!$_lifetime) {
249	$_lifetime = ini_get('session.gc_maxlifetime');
250	if ($_lifetime <= 1) {
251	// bug in PHP 4.0.3 pl 1 -- how about other versions?
252	//print "<h3>Session Error: PHP.INI setting <i>session.gc_maxlifetime</i>not set: $lifetime</h3>";
253	$_lifetime = 1440;
254	}
255	}
256
257	return $_lifetime;
258	}
259
260	/*!
261	*/
262	function debug($debug = null) {
263	static $_debug = false;
264	static $set = false;
265
266	if (!is_null($debug)) {
267	$_debug = (bool) $debug;
268
269	$conn = ADODB_Session::_conn();
270	if ($conn) {
271	$conn->debug = $_debug;
272	}
273	$set = true;
274	} elseif (!$set) {
275	// backwards compatibility
276	if (isset($GLOBALS['ADODB_SESS_DEBUG'])) {
277	return $GLOBALS['ADODB_SESS_DEBUG'];
278	}
279	}
280
281	return $_debug;
282	}
283
284	/*!
285	*/
286	function expireNotify($expire_notify = null) {
287	static $_expire_notify;
288	static $set = false;
289
290	if (!is_null($expire_notify)) {
291	$_expire_notify = $expire_notify;
292	$set = true;
293	} elseif (!$set) {
294	// backwards compatibility
295	if (isset($GLOBALS['ADODB_SESSION_EXPIRE_NOTIFY'])) {
296	return $GLOBALS['ADODB_SESSION_EXPIRE_NOTIFY'];
297	}
298	}
299
300	return $_expire_notify;
301	}
302
303	/*!
304	*/
305	function table($table = null) {
306	static $_table = 'sessions';
307	static $set = false;
308
309	if (!is_null($table)) {
310	$_table = trim($table);
311	$set = true;
312	} elseif (!$set) {
313	// backwards compatibility
314	if (isset($GLOBALS['ADODB_SESSION_TBL'])) {
315	return $GLOBALS['ADODB_SESSION_TBL'];
316	}
317	}
318
319	return $_table;
320	}
321
322	/*!
323	*/
324	function optimize($optimize = null) {
325	static $_optimize = false;
326	static $set = false;
327
328	if (!is_null($optimize)) {
329	$_optimize = (bool) $optimize;
330	$set = true;
331	} elseif (!$set) {
332	// backwards compatibility
333	if (defined('ADODB_SESSION_OPTIMIZE')) {
334	return true;
335	}
336	}
337
338	return $_optimize;
339	}
340
341	/*!
342	*/
343	function syncSeconds($sync_seconds = null) {
344	static $_sync_seconds = 60;
345	static $set = false;
346
347	if (!is_null($sync_seconds)) {
348	$_sync_seconds = (int) $sync_seconds;
349	$set = true;
350	} elseif (!$set) {
351	// backwards compatibility
352	if (defined('ADODB_SESSION_SYNCH_SECS')) {
353	return ADODB_SESSION_SYNCH_SECS;
354	}
355	}
356
357	return $_sync_seconds;
358	}
359
360	/*!
361	*/
362	function clob($clob = null) {
363	static $_clob = false;
364	static $set = false;
365
366	if (!is_null($clob)) {
367	$_clob = strtolower(trim($clob));
368	$set = true;
369	} elseif (!$set) {
370	// backwards compatibility
371	if (isset($GLOBALS['ADODB_SESSION_USE_LOBS'])) {
372	return $GLOBALS['ADODB_SESSION_USE_LOBS'];
373	}
374	}
375
376	return $_clob;
377	}
378
379	/*!
380	*/
381	function dataFieldName($data_field_name = null) {
382	static $_data_field_name = 'data';
383
384	if (!is_null($data_field_name)) {
385	$_data_field_name = trim($data_field_name);
386	}
387
388	return $_data_field_name;
389	}
390
391	/*!
392	*/
393	function filter($filter = null) {
394	static $_filter = array();
395
396	if (!is_null($filter)) {
397	if (!is_array($filter)) {
398	$filter = array($filter);
399	}
400	$_filter = $filter;
401	}
402
403	return $_filter;
404	}
405
406	/*!
407	*/
408	function encryptionKey($encryption_key = null) {
409	static $_encryption_key = 'CRYPTED ADODB SESSIONS ROCK!';
410
411	if (!is_null($encryption_key)) {
412	$_encryption_key = $encryption_key;
413	}
414
415	return $_encryption_key;
416	}
417
418	/////////////////////
419	// private methods
420	/////////////////////
421
422	/*!
423	*/
424	function &_conn($conn=null) {
425	return $GLOBALS['ADODB_SESS_CONN'];
426	}
427
428	/*!
429	*/
430	function _crc($crc = null) {
431	static $_crc = false;
432
433	if (!is_null($crc)) {
434	$_crc = $crc;
435	}
436
437	return $_crc;
438	}
439
440	/*!
441	*/
442	function _init() {
443	session_module_name('user');
444	session_set_save_handler(
445	array('ADODB_Session', 'open'),
446	array('ADODB_Session', 'close'),
447	array('ADODB_Session', 'read'),
448	array('ADODB_Session', 'write'),
449	array('ADODB_Session', 'destroy'),
450	array('ADODB_Session', 'gc')
451	);
452	}
453
454
455	/*!
456	*/
457	function _sessionKey() {
458	// use this function to create the encryption key for crypted sessions
459	// crypt the used key, ADODB_Session::encryptionKey() as key and session_id() as salt
460	return crypt(ADODB_Session::encryptionKey(), session_id());
461	}
462
463	/*!
464	*/
465	function _dumprs($rs) {
466	$conn =& ADODB_Session::_conn();
467	$debug = ADODB_Session::debug();
468
469	if (!$conn) {
470	return;
471	}
472
473	if (!$debug) {
474	return;
475	}
476
477	if (!$rs) {
478	echo "<br />\$rs is null or false<br />\n";
479	return;
480	}
481
482	//echo "<br />\nAffected_Rows=",$conn->Affected_Rows(),"<br />\n";
483
484	if (!is_object($rs)) {
485	return;
486	}
487
488	require_once ADODB_SESSION.'/../tohtml.inc.php';
489	rs2html($rs);
490	}
491
492	/////////////////////
493	// public methods
494	/////////////////////
495
496	function config($driver, $host, $user, $password, $database=false,$options=false)
497	{
498	ADODB_Session::driver($driver);
499	ADODB_Session::host($host);
500	ADODB_Session::user($user);
501	ADODB_Session::password($password);
502	ADODB_Session::database($database);
503
504	if ($driver == 'oci8' \|\| $driver == 'oci8po') $options['lob'] = 'CLOB';
505
506	if (isset($options['table'])) ADODB_Session::table($options['table']);
507	if (isset($options['lob'])) ADODB_Session::clob($options['lob']);
508	if (isset($options['debug'])) ADODB_Session::debug($options['debug']);
509	}
510
511	/*!
512	Create the connection to the database.
513
514	If $conn already exists, reuse that connection
515	*/
516	function open($save_path, $session_name, $persist = null)
517	{
518	$conn =& ADODB_Session::_conn();
519
520	if ($conn) {
521	return true;
522	}
523
524	$database = ADODB_Session::database();
525	$debug = ADODB_Session::debug();
526	$driver = ADODB_Session::driver();
527	$host = ADODB_Session::host();
528	$password = ADODB_Session::password();
529	$user = ADODB_Session::user();
530
531	if (!is_null($persist)) {
532	ADODB_Session::persist($persist);
533	} else {
534	$persist = ADODB_Session::persist();
535	}
536
537	# these can all be defaulted to in php.ini
538	# assert('$database');
539	# assert('$driver');
540	# assert('$host');
541
542	$conn =& ADONewConnection($driver);
543
544	if ($debug) {
545	$conn->debug = true;
546	// ADOConnection::outp( " driver=$driver user=$user pwd=$password db=$database ");
547	}
548
549	if ($persist) {
550	switch($persist) {
551	default:
552	case 'P': $ok = $conn->PConnect($host, $user, $password, $database); break;
553	case 'C': $ok = $conn->Connect($host, $user, $password, $database); break;
554	case 'N': $ok = $conn->NConnect($host, $user, $password, $database); break;
555	}
556	} else {
557	$ok = $conn->Connect($host, $user, $password, $database);
558	}
559
560	if ($ok) $GLOBALS['ADODB_SESS_CONN'] =& $conn;
561	else
562	ADOConnection::outp('<p>Session: connection failed</p>', false);
563
564
565	return $ok;
566	}
567
568	/*!
569	Close the connection
570	*/
571	function close()
572	{
573	/*
574	$conn =& ADODB_Session::_conn();
575	if ($conn) $conn->Close();
576	*/
577	return true;
578	}
579
580	/*
581	Slurp in the session variables and return the serialized string
582	*/
583	function read($key)
584	{
585	$conn =& ADODB_Session::_conn();
586	$data = ADODB_Session::dataFieldName();
587	$filter = ADODB_Session::filter();
588	$table = ADODB_Session::table();
589
590	if (!$conn) {
591	return '';
592	}
593
594	//assert('$table');
595
596	$qkey = $conn->quote($key);
597	$binary = $conn->dataProvider === 'mysql' ? '/! BINARY /' : '';
598
599	$sql = "SELECT $data FROM $table WHERE sesskey = $binary $qkey AND expiry >= " . time();
600	/* Lock code does not work as it needs to hold transaction within whole page, and we don't know if
601	developer has commited elsewhere... :(
602	*/
603	#if (ADODB_Session::Lock())
604	# $rs =& $conn->RowLock($table, "$binary sesskey = $qkey AND expiry >= " . time(), $data);
605	#else
606
607	$rs =& $conn->Execute($sql);
608	//ADODB_Session::_dumprs($rs);
609	if ($rs) {
610	if ($rs->EOF) {
611	$v = '';
612	} else {
613	$v = reset($rs->fields);
614	$filter = array_reverse($filter);
615	foreach ($filter as $f) {
616	if (is_object($f)) {
617	$v = $f->read($v, ADODB_Session::_sessionKey());
618	}
619	}
620	$v = rawurldecode($v);
621	}
622
623	$rs->Close();
624
625	ADODB_Session::_crc(strlen($v) . crc32($v));
626	return $v;
627	}
628
629	return '';
630	}
631
632	/*!
633	Write the serialized data to a database.
634
635	If the data has not been modified since the last read(), we do not write.
636	*/
637	function write($key, $val)
638	{
639	global $ADODB_SESSION_READONLY;
640
641	if (!empty($ADODB_SESSION_READONLY)) return;
642
643	$clob = ADODB_Session::clob();
644	$conn =& ADODB_Session::_conn();
645	$crc = ADODB_Session::_crc();
646	$data = ADODB_Session::dataFieldName();
647	$debug = ADODB_Session::debug();
648	$driver = ADODB_Session::driver();
649	$expire_notify = ADODB_Session::expireNotify();
650	$filter = ADODB_Session::filter();
651	$lifetime = ADODB_Session::lifetime();
652	$table = ADODB_Session::table();
653
654	if (!$conn) {
655	return false;
656	}
657	$qkey = $conn->qstr($key);
658
659	//assert('$table');
660
661	$expiry = time() + $lifetime;
662
663	$binary = $conn->dataProvider === 'mysql' ? '/! BINARY /' : '';
664
665	// crc32 optimization since adodb 2.1
666	// now we only update expiry date, thx to sebastian thom in adodb 2.32
667	if ($crc !== false && $crc == (strlen($val) . crc32($val))) {
668	if ($debug) {
669	echo '<p>Session: Only updating date - crc32 not changed</p>';
670	}
671
672	$expirevar = '';
673	if ($expire_notify) {
674	$var = reset($expire_notify);
675	global $$var;
676	if (isset($$var)) {
677	$expirevar = $$var;
678	}
679	}
680
681
682	$sql = "UPDATE $table SET expiry = ".$conn->Param('0').",expireref=".$conn->Param('1')." WHERE $binary sesskey = ".$conn->Param('2')." AND expiry >= ".$conn->Param('3');
683	$rs =& $conn->Execute($sql,array($expiry,$expirevar,$key,time()));
684	return true;
685	}
686	$val = rawurlencode($val);
687	foreach ($filter as $f) {
688	if (is_object($f)) {
689	$val = $f->write($val, ADODB_Session::_sessionKey());
690	}
691	}
692
693	$arr = array('sesskey' => $key, 'expiry' => $expiry, $data => $val, 'expireref' => '');
694	if ($expire_notify) {
695	$var = reset($expire_notify);
696	global $$var;
697	if (isset($$var)) {
698	$arr['expireref'] = $$var;
699	}
700	}
701
702	if (!$clob) { // no lobs, simply use replace()
703	$arr[$data] = $conn->qstr($val);
704	$rs = $conn->Replace($table, $arr, 'sesskey', $autoQuote = true);
705
706	} else {
707	// what value shall we insert/update for lob row?
708	switch ($driver) {
709	// empty_clob or empty_lob for oracle dbs
710	case 'oracle':
711	case 'oci8':
712	case 'oci8po':
713	case 'oci805':
714	$lob_value = sprintf('empty_%s()', strtolower($clob));
715	break;
716
717	// null for all other
718	default:
719	$lob_value = 'null';
720	break;
721	}
722
723	$conn->StartTrans();
724	$expiryref = $conn->qstr($arr['expireref']);
725	// do we insert or update? => as for sesskey
726	$rs =& $conn->Execute("SELECT COUNT(*) AS cnt FROM $table WHERE $binary sesskey = $qkey");
727	if ($rs && reset($rs->fields) > 0) {
728	$sql = "UPDATE $table SET expiry = $expiry, $data = $lob_value, expireref=$expiryref WHERE sesskey = $qkey";
729	} else {
730	$sql = "INSERT INTO $table (expiry, $data, sesskey,expireref) VALUES ($expiry, $lob_value, $qkey,$expiryref)";
731	}
732	if ($rs)$rs->Close();
733
734
735	$err = '';
736	$rs1 =& $conn->Execute($sql);
737	if (!$rs1) $err = $conn->ErrorMsg()."\n";
738
739	$rs2 =& $conn->UpdateBlob($table, $data, $val, " sesskey=$qkey", strtoupper($clob));
740	if (!$rs2) $err .= $conn->ErrorMsg()."\n";
741
742	$rs = ($rs && $rs2) ? true : false;
743	$conn->CompleteTrans();
744	}
745
746	if (!$rs) {
747	ADOConnection::outp('<p>Session Replace: ' . $conn->ErrorMsg() . '</p>', false);
748	return false;
749	} else {
750	// bug in access driver (could be odbc?) means that info is not committed
751	// properly unless select statement executed in Win2000
752	if ($conn->databaseType == 'access') {
753	$sql = "SELECT sesskey FROM $table WHERE $binary sesskey = $qkey";
754	$rs =& $conn->Execute($sql);
755	ADODB_Session::_dumprs($rs);
756	if ($rs) {
757	$rs->Close();
758	}
759	}
760	}/*
761	if (ADODB_Session::Lock()) {
762	$conn->CommitTrans();
763	}*/
764	return $rs ? true : false;
765	}
766
767	/*!
768	*/
769	function destroy($key) {
770	$conn =& ADODB_Session::_conn();
771	$table = ADODB_Session::table();
772	$expire_notify = ADODB_Session::expireNotify();
773
774	if (!$conn) {
775	return false;
776	}
777
778	//assert('$table');
779
780	$qkey = $conn->quote($key);
781	$binary = $conn->dataProvider === 'mysql' ? '/! BINARY /' : '';
782
783	if ($expire_notify) {
784	reset($expire_notify);
785	$fn = next($expire_notify);
786	$savem = $conn->SetFetchMode(ADODB_FETCH_NUM);
787	$sql = "SELECT expireref, sesskey FROM $table WHERE $binary sesskey = $qkey";
788	$rs =& $conn->Execute($sql);
789	ADODB_Session::_dumprs($rs);
790	$conn->SetFetchMode($savem);
791	if (!$rs) {
792	return false;
793	}
794	if (!$rs->EOF) {
795	$ref = $rs->fields[0];
796	$key = $rs->fields[1];
797	//assert('$ref');
798	//assert('$key');
799	$fn($ref, $key);
800	}
801	$rs->Close();
802	}
803
804	$sql = "DELETE FROM $table WHERE $binary sesskey = $qkey";
805	$rs =& $conn->Execute($sql);
806	ADODB_Session::_dumprs($rs);
807
808	return $rs ? true : false;
809	}
810
811	/*!
812	*/
813	function gc($maxlifetime)
814	{
815	$conn =& ADODB_Session::_conn();
816	$debug = ADODB_Session::debug();
817	$expire_notify = ADODB_Session::expireNotify();
818	$optimize = ADODB_Session::optimize();
819	$sync_seconds = ADODB_Session::syncSeconds();
820	$table = ADODB_Session::table();
821
822	if (!$conn) {
823	return false;
824	}
825
826
827	$time = time();
828	$binary = $conn->dataProvider === 'mysql' ? '/! BINARY /' : '';
829
830	if ($expire_notify) {
831	reset($expire_notify);
832	$fn = next($expire_notify);
833	$savem = $conn->SetFetchMode(ADODB_FETCH_NUM);
834	$sql = "SELECT expireref, sesskey FROM $table WHERE expiry < $time";
835	$rs =& $conn->Execute($sql);
836	ADODB_Session::_dumprs($rs);
837	$conn->SetFetchMode($savem);
838	if ($rs) {
839	$conn->StartTrans();
840	$keys = array();
841	while (!$rs->EOF) {
842	$ref = $rs->fields[0];
843	$key = $rs->fields[1];
844	$fn($ref, $key);
845	$del = $conn->Execute("DELETE FROM $table WHERE sesskey=".$conn->Param('0'),array($key));
846	$rs->MoveNext();
847	}
848	$rs->Close();
849
850	$conn->CompleteTrans();
851	}
852	} else {
853
854	if (1) {
855	$sql = "SELECT sesskey FROM $table WHERE expiry < $time";
856	$arr =& $conn->GetAll($sql);
857	foreach ($arr as $row) {
858	$sql2 = "DELETE FROM $table WHERE sesskey=".$conn->Param('0');
859	$conn->Execute($sql2,array($row[0]));
860	}
861	} else {
862	$sql = "DELETE FROM $table WHERE expiry < $time";
863	$rs =& $conn->Execute($sql);
864	ADODB_Session::_dumprs($rs);
865	if ($rs) $rs->Close();
866	}
867	if ($debug) {
868	ADOConnection::outp("<p><b>Garbage Collection</b>: $sql</p>");
869	}
870	}
871
872	// suggested by Cameron, "GaM3R" <gamr@outworld.cx>
873	if ($optimize) {
874	$driver = ADODB_Session::driver();
875
876	if (preg_match('/mysql/i', $driver)) {
877	$sql = "OPTIMIZE TABLE $table";
878	}
879	if (preg_match('/postgres/i', $driver)) {
880	$sql = "VACUUM $table";
881	}
882	if (!empty($sql)) {
883	$conn->Execute($sql);
884	}
885	}
886
887	if ($sync_seconds) {
888	$sql = 'SELECT ';
889	if ($conn->dataProvider === 'oci8') {
890	$sql .= "TO_CHAR({$conn->sysTimeStamp}, 'RRRR-MM-DD HH24:MI:SS')";
891	} else {
892	$sql .= $conn->sysTimeStamp;
893	}
894	$sql .= " FROM $table";
895
896	$rs =& $conn->SelectLimit($sql, 1);
897	if ($rs && !$rs->EOF) {
898	$dbts = reset($rs->fields);
899	$rs->Close();
900	$dbt = $conn->UnixTimeStamp($dbts);
901	$t = time();
902
903	if (abs($dbt - $t) >= $sync_seconds) {
904	$msg = __FILE__ .
905	": Server time for webserver {$_SERVER['HTTP_HOST']} not in synch with database: " .
906	" database=$dbt ($dbts), webserver=$t (diff=". (abs($dbt - $t) / 60) . ' minutes)';
907	error_log($msg);
908	if ($debug) {
909	ADOConnection::outp("<p>$msg</p>");
910	}
911	}
912	}
913	}
914
915	return true;
916	}
917	}
918
919	ADODB_Session::_init();
920	if (empty($ADODB_SESSION_READONLY))
921	register_shutdown_function('session_write_close');
922
923	// for backwards compatability only
924	function adodb_sess_open($save_path, $session_name, $persist = true) {
925	return ADODB_Session::open($save_path, $session_name, $persist);
926	}
927
928	// for backwards compatability only
929	function adodb_sess_gc($t)
930	{
931	return ADODB_Session::gc($t);
932	}
933
934	?>

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

Download in other formats: