pay/sdk/alipay/lotusphp_runtime/Session/Store/SessionStoreSqlite.php

<?php
class LtSessionSqlite implements LtSessionStore
{
	public $conf;

	private $lifeTime; //session.gc_maxlifetime
	private $dbHandle;
	private $dbName;
	private $tableName;

	public function __construct()
	{ 
		// --
	}
	public function init()
	{
		if (isset($this->conf['gc_maxlifetime']))
		{
			$this->lifeTime = $this->conf['gc_maxlifetime'];
		}
		else
		{
			$this->lifeTime = get_cfg_var("session.gc_maxlifetime");
		}
		if (isset($this->conf['table_name']))
		{
			$this->tableName = $this->conf['table_name'];
		}
		else
		{
			$this->tableName = 'lotus_session';
		}
		if (isset($this->conf['db_name']))
		{
			$this->dbName = $this->conf['db_name'];
		}
		else
		{
			$this->dbName = '/tmp/Lotus/session/session_sqlite2.db';
		}

		if (!$this->dbHandle = sqlite_open($this->dbName, 0666))
		{
			trigger_error('session sqlite db error');
			return false;
		}
		return true;
	}

	public function open($savePath, $sessName)
	{
		return true;
	}

	public function close()
	{
		$this->gc($this->lifeTime);
		return @sqlite_close($this->dbHandle);
	}

	public function read($sessID)
	{
		$res = sqlite_query("SELECT session_data AS d FROM $this->tableName
                           WHERE session_id = '$sessID'
                           AND session_expires > " . time(), $this->dbHandle);
		if ($row = sqlite_fetch_array($res, SQLITE_ASSOC))
		{
			return $row['d'];
		}
		else
		{
			return "";
		}
	}

	public function write($sessID, $sessData)
	{
		$newExp = time() + $this->lifeTime;
		$res = sqlite_query("SELECT * FROM $this->tableName
                           WHERE session_id = '$sessID'", $this->dbHandle);
		if (sqlite_num_rows($res))
		{
			sqlite_exec("UPDATE $this->tableName
                        SET session_expires = '$newExp',
                        session_data = '$sessData'
                        WHERE session_id = '$sessID'", $this->dbHandle);
			if (sqlite_changes($this->dbHandle))
			{
				return true;
			}
		}
		else
		{
			sqlite_exec("INSERT INTO $this->tableName (
                        session_id,
                        session_expires,
                        session_data)
                        VALUES(
                        '$sessID',
                        '$newExp',
                        '$sessData')", $this->dbHandle);
			if (sqlite_changes($this->dbHandle))
			{
				return true;
			}
		}
		return false;
	}

	public function destroy($sessID)
	{
		sqlite_exec("DELETE FROM $this->tableName WHERE session_id = '$sessID'", $this->dbHandle);
		if (sqlite_changes($this->dbHandle))
		{
			return true;
		}
		return false;
	}

	public function gc($sessMaxLifeTime)
	{
		sqlite_exec("DELETE FROM $this->tableName WHERE session_expires < " . time(), $this->dbHandle);
		return sqlite_changes($this->dbHandle);
	}

	public function runOnce()
	{
		$sql = "SELECT name FROM sqlite_master WHERE type='table' UNION ALL SELECT name FROM sqlite_temp_master WHERE type='table' AND name='" . $this->tableName . "'";
		$res = sqlite_query($sql, $this->dbHandle);
		$row = sqlite_fetch_array($res, SQLITE_ASSOC);
		if (empty($row))
		{
			$sql = "CREATE TABLE $this->tableName (
			[session_id] VARCHAR(255)  NOT NULL PRIMARY KEY,
			[session_expires] INTEGER DEFAULT '0' NOT NULL,
			[session_data] TEXT  NULL
		)";
			return sqlite_exec($sql, $this->dbHandle);
		}
		return false;
	}
}