pay/sdk/alipay/lotusphp_runtime/DB/Adapter/ConnectionAdapter/DbConnectionAdapterSqlite.php

<?php
/**
 * Sqlite 预定义了类 SQLiteDatabase 本实现没有使用。 
 * 这里使用的全部是过程函数。 
 * 无论是函数还是类，本实现只支持sqlite的2.x系列版本。 
 * php5.3新增扩展sqlite3用来支持3.x版本。 
 * PDO则同时支持2.x和3.x版本。
 */
class LtDbConnectionAdapterSqlite implements LtDbConnectionAdapter
{
	public function connect($connConf)
	{
		if (isset($connConf['pconnect']) && true == $connConf['pconnect'])
		{
			$func = 'sqlite_popen';
		} 
		else
		{
			$func = 'sqlite_open';
		} 
		$connConf["host"] = rtrim($connConf["host"], '\\/') . DIRECTORY_SEPARATOR;
		if(!is_dir($connConf["host"]))
		{
			if(!@mkdir($connConf["host"], 0777, true))
			{
				trigger_error("Can not create {$connConf['host']}");
			}
		}
		$error = '';
		$connResource = $func($connConf["host"] . $connConf["dbname"], 0666, $error);
		if (!$connResource)
		{
			trigger_error($error, E_USER_ERROR);
		} 
		else
		{
			return $connResource;
		} 
	} 

	public function exec($sql, $connResource)
	{
		if(empty($sql))
		{
			return 0;
		}
		sqlite_exec($connResource, $sql); 
		// echo '<pre>';
		// print_r(debug_backtrace());
		// debug_print_backtrace();
		// echo '</pre>';
		// delete from table 结果为0，原因未知。
		// 使用 delete from table where 1 能返回正确结果
		return sqlite_changes($connResource);
	} 

	public function query($sql, $connResource)
	{
		$result = sqlite_query($connResource, $sql, SQLITE_ASSOC);
		return sqlite_fetch_all($result, SQLITE_ASSOC);
	} 

	public function lastInsertId($connResource)
	{
		return sqlite_last_insert_rowid($connResource);
	} 

	public function escape($sql, $connResource)
	{
		return sqlite_escape_string($sql);
	} 
}