[ Index ] |
|
Code source de Mantis 1.1.0rc3 |
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 ADOConnection::outp( '<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 ?>
titre
Description
Corps
titre
Description
Corps
titre
Description
Corps
titre
Corps
Généré le : Thu Nov 29 09:42:17 2007 | par Balluche grâce à PHPXref 0.7 |
![]() |