欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页  >  后端开发

一个用mysql内存表来代替php session的类

程序员文章站 2022-05-30 13:55:21
...
  2. /**
  3. * session mysql内存表
  4. @Usage: use some other storage method(mysql or memcache) instead of php sessoin
  5. @author:lein
  6. @Version:1.2
  7. */
  8. session_start();
  9. if(!isset($_SESSION['test'])){
  10. $_SESSION['test']="123_lein_".date("Y-m-d H:i:s");
  11. }
  13. class session{
  14. //session data
  15. private $data;
  16. //engine,mysql or memcache
  17. private $engine;
  18. //php session expire time
  19. private $sessionexpiredTime;
  20. //current user's session cookie value
  21. private $sessionID;
  22. //session coolie name
  23. private $sessionCookieName;
  24. public function session($engineBase=NULL,$engineName='mysql',$storage_name='php_session'){
  25. try{
  26. $this->sessionexpiredTime = intval(ini_get("session.cache_expire"))*10;//默认是180分钟，太长了，改为了30分钟
  27. }catch(Exception $Exception){
  28. $this->sessionexpiredTime = 1200;
  29. }
  30. try{
  31. $this->sessionCookieName = ini_get("session.name");
  32. }catch(Exception $Exception){
  33. $this->sessionCookieName = 'PHPSESSID';
  34. }
  36. if(!isset($_COOKIE[$this->sessionCookieName])){
  37. @session_start();
  38. $this->sessionID=session_id();
  39. }else{
  40. $this->sessionID=$_COOKIE[$this->sessionCookieName];
  41. }
  42. $className = $engineName."SessionEngine";
  43. $this->engine = new $className(
  44. array(
  45. 'storage_name'=>$storage_name,//mysql table name or memcahce key which stores data;
  46. 'expire_time'=>$this->sessionexpiredTime,
  47. 'data_too_long_instead_value' => '{__DATA IS *$* TO LONG__}'
  48. ),
  49. $this->sessionID,
  50. &$engineBase
  51. );
  52. $this->init();
  53. $this->loadFromSession();
  54. $this->engine->refresh();
  55. $this->engine->cleanup();
  56. }
  57. private function init()
  58. {
  59. $this->data = $this->engine->get();
  60. if(empty($this->data)){
  61. @session_start();
  62. if(!empty($_SESSION)){
  63. $this->data = $_SESSION;
  64. $this->engine->create(false, $this->data);
  65. }
  66. else
  67. {
  68. $this->engine->create(false, "");
  69. }
  70. }
  71. }
  72. public function loadFromSession($flagStartSession = false){
  73. $flag=false;
  74. if($flagStartSession){
  75. @session_start();
  76. }
  77. if($_SESSION&&is_array($_SESSION)){
  78. foreach($_SESSION as $k=>$v){
  79. if(!isset($this->data[$k])){
  80. $this->data[$k] = $v;
  81. $flag=true;
  82. }
  83. }
  84. }
  85. if($flag){
  86. $this->engine->set(false, $this->data);
  87. }
  88. }
  89. private function __get($nm)
  90. {
  91. if (isset($this->data[$nm])) {
  92. $r = $this->data[$nm];
  93. return $r;
  94. }
  95. else
  96. {
  97. return NULL;
  98. }
  99. }
  100. private function __set($nm, $val)
  101. {
  102. $this->data[$nm] = $val;
  103. $this->engine->set(false, $this->data);
  104. }
  106. private function __isset($nm)
  107. {
  108. return isset($this->data[$nm]);
  109. }
  111. private function __unset($nm)
  112. {
  113. unset($this->data[$nm]);
  114. $this->engine->set(false, $this->data);
  115. }
  117. function __destruct(){
  118. $this->data = NULL;
  119. $this->engine->close();
  120. $this->engine = NULL;
  121. }
  122. }
  124. interface SessionEngine
  125. {
  126. /*
  127. * set varibles
  128. * @param $arr array,array(varible name=>varible value,...)
  129. */
  130. public function setVariable($arr);
  131. /*
  132. * get session value
  133. * @param $key string
  134. */
  135. public function get($key="");
  136. /*
  137. * set session value
  138. * @param $key string
  139. * @param $value string
  140. */
  141. public function set($key="",$value="");
  142. /*
  143. * set session value
  144. * @param $key string
  145. * @param $value string
  146. */
  147. public function create($key="",$value="");
  148. /*
  149. * update the session's invalid time
  150. * @param $key string
  151. */
  152. public function refresh($key="");
  153. /*
  154. * close mysql or memcache connection
  155. */
  156. public function close();
  157. /*
  158. * delete expired sessions
  159. */
  160. public function cleanup();
  161. }
  163. final class mysqlSessionEngine implements SessionEngine{
  164. private $id="";
  165. private $storage_name='php_session';
  166. private $storage_name_slow='php_session_slow';
  167. private $data_too_long_instead_value = '{__DATA IS ~ TO LONG__}';//if data is longer than $max_session_data_length and you are using mysql 4 or below,insert this value into memery table instead.
  168. private $expire_time=1200;
  169. private $max_session_data_length = 2048;
  170. private $conn;
  171. private $mysql_version;
  172. public function mysqlSessionEngine($arr=array(),$key="",&$_conn){
  173. $this->setVariable($arr);
  174. $this->id = $key;
  175. if(empty($this->id)||strlen($this->id)!=32){
  176. throw new Exception(__FILE__."->".__LINE__.": Session's cookie name can't be empty and it must have just 32 charactors!");
  177. }
  178. $this->conn = $_conn;
  179. if(!$this->conn||!is_resource($this->conn)){
  180. throw new Exception(__FILE__."->".__LINE__.": Need a mysql connection!");
  181. }
  182. $this->mysql_version = $this->getOne("select floor(version())");
  183. if($this->mysql_version $this->max_session_data_length = 255;
  184. }
  185. }
  186. public function setVariable($arr){
  187. if(!empty($arr)&&is_array($arr)){
  188. foreach($arr as $k=>$v){
  189. $this->$k = $v;
  190. if($k=='storage_name'){
  191. $this->storage_name_slow = $v.'_slow';
  192. }
  193. }
  194. }
  195. }
  196. public function get($key=""){
  197. if($key=="") $key = $this->id;
  198. $return = $this->getOne('select value from '.$this->storage_name.' where id="'.$key.'"');
  199. if($return==$this->data_too_long_instead_value)
  200. {
  201. $return = $this->getOne('select value from '.$this->storage_name_slow.' where id="'.$key.'"');
  202. }
  203. if(!$return)
  204. {
  205. $mysqlError = mysql_error($this->conn);
  206. if(strpos($mysqlError,"doesn't exist")!==false)
  207. {
  208. $this->initTable();
  209. }
  210. $return = array();
  211. }
  212. else
  213. {
  214. $return = unserialize($return);
  215. }
  216. return $return;
  217. }
  218. public function close(){
  219. @mysql_close($this->conn);
  220. }
  221. public function cleanup(){
  222. if($this->mysql_version>4){
  223. $sql = 'delete from '.$this->storage_name.' where date_add(`time`,INTERVAL '.$this->expire_time.' SECOND) }else{
  224. $sql = 'delete from '.$this->storage_name_slow.' where `time`+'.$this->expire_time.' if($_SESSION['username']=="leinchu"){
  225. echo $sql;
  226. }
  227. $this->execute($sql);
  228. $sql = 'delete from '.$this->storage_name.' where `time`+'.$this->expire_time.' if($_SESSION['username']=="leinchu"){
  229. echo $sql;
  230. }
  231. }
  232. $this->execute($sql);
  233. }
  234. public function refresh($key=""){
  235. if($this->mysql_version>4){
  236. $sql = 'update '.$this->storage_name.' set `time`=CURRENT_TIMESTAMP() where id="'.$key.'"';
  237. }else{
  238. $sql = 'update '.$this->storage_name.' set `time`=unix_timestamp() where id="'.$key.'"';
  239. }
  240. $return = $this->execute($sql);
  241. if(!$return){
  242. $this->initTable();
  243. $return = $this->execute($sql,true);
  244. }
  245. return $return;
  246. }
  247. public function create($key="",$value=""){
  248. if($key=="") $key = $this->id;
  249. if($value != "") $value = mysql_real_escape_string(serialize($value),$this->conn);
  250. if(strlen($value)>$this->max_session_data_length)
  251. {
  252. if($this->mysql_version>4){
  253. throw new Exception(__FILE__."->".__LINE__.": Session data is long than max allow length(".$this->max_session_data_length.")!");
  254. }
  255. }
  256. if($this->mysql_version>4){
  257. $sql = 'replace into '.$this->storage_name.' set value=/''.$value.'/',id="'.$key.'",`time`=CURRENT_TIMESTAMP()';
  258. }else{
  259. $sql = 'replace into '.$this->storage_name.' set value=/''.$value.'/',id="'.$key.'",`time`=unix_timestamp()';
  260. }
  261. $return = $this->execute($sql);
  262. if(!$return){
  263. $this->initTable();
  264. $return = $this->execute($sql,true);
  265. }
  266. return $return;
  267. }
  268. public function set($key="",$value=""){
  269. if($key=="") $key = $this->id;
  270. if($value != "") $value = mysql_real_escape_string(serialize($value),$this->conn);
  271. $sql = 'update '.$this->storage_name.' set value=/''.$value.'/' where id="'.$key.'"';
  272. if(strlen($value)>$this->max_session_data_length)
  273. {
  274. if($this->mysql_version>4){
  275. throw new Exception(__FILE__."->".__LINE__.": Session data is long than max allow length(".$this->max_session_data_length.")!");
  276. }
  277. $sql = 'replace into '.$this->storage_name_slow.' set value=/''.$value.'/',id="'.$key.'",`time`=unix_timestamp()';
  278. $this->execute($sql,true);
  279. $sql = 'update '.$this->storage_name.' set value=/''.$this->data_too_long_instead_value.'/' where id="'.$key.'"';
  280. }
  281. $return = $this->execute($sql);
  282. if(!$return){
  283. $this->initTable();
  284. $return = $this->execute($sql,true);
  285. }
  286. return $return;
  287. }
  288. private function initTable(){
  289. if($this->mysql_version>4){
  290. $sql = "
  291. CREATE TABLE if not exists `".$this->storage_name."` (
  292. `id` char(32) NOT NULL default 'ERR',
  293. `value` VARBINARY(".$this->max_session_data_length.") NULL,
  294. `time` timestamp NOT NULL default CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP,
  295. PRIMARY KEY (`id`),
  296. KEY `time` (`time`)
  297. ) ENGINE=MEMORY;
  298. ";
  299. }else{
  300. $sqlSlow = "
  301. CREATE TABLE if not exists `".$this->storage_name."_slow` (
  302. `id` char(32) NOT NULL default 'ERR',
  303. `value` text NULL,
  304. `time` int(10) not null default '0',
  305. PRIMARY KEY (`id`),
  306. KEY `time` (`time`)
  307. ) ENGINE=MyISAM;
  308. ";
  309. $this->execute($sqlSlow,true);
  311. $sql = "
  312. CREATE TABLE if not exists `".$this->storage_name."` (
  313. `id` char(32) NOT NULL default 'ERR',
  314. `value` VARCHAR(255) NULL,
  315. `time` int(10) not null default '0',
  316. PRIMARY KEY (`id`),
  317. KEY `time` (`time`)
  318. ) ENGINE=MEMORY;
  319. ";
  320. }
  321. return $this->execute($sql,true);
  322. }
  323. private function execute($sql,$die=false)
  324. {
  325. if($die)
  326. {
  327. mysql_query($sql,$this->conn) or die("exe Sql error:
    ".mysql_error()."
    ".$sql."
    ");
  328. }
  329. else
  330. {
  331. mysql_query($sql,$this->conn);
  332. if(mysql_error()){
  333. return false;
  334. }else{
  335. return true;
  336. }
  337. }
  338. }
  339. private function getOne($sql,$die=false){
  340. $rs = $this->query($sql,$die);
  341. if($rs && ($one = mysql_fetch_row($rs)) ){
  342. return $one[0];
  343. }else{
  344. return false;
  345. }
  346. }
  347. private function query($sql,$die=false){
  348. if($die)
  349. $rs = mysql_query($sql,$this->conn) or die("query Sql error:
    ".mysql_error()."
    ".$sql."
    ");
  350. else
  351. $rs = mysql_query($sql,$this->conn);
  352. return $rs;
  353. }
  354. }
  355. $lnk = mysql_connect('localhost', 'root', '123456')
  356. or die ('Not connected : ' . mysql_error());
  358. // make foo the current db
  359. mysql_select_db('test', $lnk) or die ('Can/'t use foo : ' . mysql_error());
  360. $S = new session($lnk);
  361. if(!$S->last){
  362. $S->last = time();
  363. }
  364. echo "First visit at ".$S->last."
    ";
  365. if(!$S->lastv){
  366. $S->lastv = 0;
  367. }
  368. $S->lastv++;
  369. echo "lastv=".$S->lastv."
    ";
  370. echo "test=".$S->test."
    ";
  371. if(isset($_GET['max'])){
  372. $S->boom = str_repeat("OK",255);
  373. }
  374. if(isset($_GET['boom'])){
  375. $S->boom = $_GET['boom'];
  376. }
  377. echo "boom=".$S->boom."
    ";
  378. ?>
复制代码
相关标签： 一个用mysql内存表来代替php session的类

上一篇： PHP中操作MySQL需要注意的问题

下一篇： MYSQL-font怎么连接远程服务器

推荐阅读