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

<?php
class LtDbConnectionAdapterPdo implements LtDbConnectionAdapter
{
	public function connect($connConf)
	{
		// $option = array(PDO::ATTR_PERSISTENT => true);
		if (isset($connConf['pconnect']) && true == $connConf['pconnect'])
		{
			$option[PDO::ATTR_PERSISTENT] = true;
		}
		else
		{
			$option[PDO::ATTR_PERSISTENT] = false;
		}
		switch ($connConf['adapter'])
		{
			case "pdo_mysql":
				$dsn = "mysql:host={$connConf['host']};dbname={$connConf['dbname']}";
				break;
			case "pdo_sqlite":
				$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']}");
					}
				}
				$dsn = "{$connConf['sqlite_version']}:{$connConf['host']}{$connConf['dbname']}";
				break;
			case "pdo_pgsql":
				$dsn = "pgsql:host={$connConf['host']} port={$connConf['port']} dbname={$connConf['dbname']} user={$connConf['username']} password={$connConf['password']}";
				break;
			case "odbc":
				$dsn = "odbc:" . $connConf["host"];
				break;
		}
		return new PDO($dsn, $connConf['username'], $connConf['password'], $option);
	}

	public function exec($sql, $connResource)
	{
		return $connResource->exec($sql);
	}

	public function query($sql, $connResource)
	{
		return $connResource->query($sql)->fetchAll(PDO::FETCH_ASSOC);
	}

	/**
	 * 
	 * @todo pgsql support
	 */
	public function lastInsertId($connResource)
	{
		return $connResource->lastInsertId();
	}

	public function escape($sql, $connResource)
	{ 
		// quote返回值带最前面和最后面的单引号, 这里去掉, DbHandler中加
		return trim($connResource->quote($sql), "'");
	}
}