class DBQuery
{
　/**
　*保存一個實現了DB接口對象的引用。
　*/
　protected $db;

　/**
　*如果是一個存儲過程，設為true。
　*/
　protected $stored_procedure = false;

　/**
　*保存一個刪除了所有字符串的query。
　*/
　private $query;

　/**
　*用于在SQL中匹配引號。
　*/
　private static $QUOTE_MATCH = "/(".*(?db = $db;
}

public function prepare($query)
{
　$this->stored_procedure = true;
}

public function compile($args)
{}

public function execute($query)
{}
}

/**
* 把query準備為一個存儲過程。
* @param string $query Prepared query text
* @return void
*/
public function prepare($query)
{
　$this->stored_procedure = true;
　$this->quote_store = array(); //清除引號
　$this->query = preg_replace(self::$QUOTE_MATCH, '$this->sql_quote_replace("1"?"1":'2')', $query);
}

private function sql_quote_replace($match)
{
　$number = count($this->query_strings);
　$this->query_strings[] = $match;
　return "$||$$number";
}

/**
* 返回編譯的query，但并不執行它。
* @param mixed $args,... Query Parameters
* @return string Compiled Query
*/
public function compile($params)
{
　if (! $this->stored_procedure) {
　　throw new Exception("存儲過程未被初始化！");
　}

　/* 替代參數 */
　$params = func_get_args(); // 取得函數參數
　$query = preg_replace("/(?query);

　return $this->add_strings($query); //把字符串放回query中
}

/**
* 重新插入被prepare()函數移除的字符串。
*/
private function add_strings($string)
{
　$numbers = array_keys($this->query_strings);
　$count = count($numbers);
　$searches = array();
　for($x = 0; $x < $count; $x ) {
　　$searches[$x] = "$||${$numbers[$x]}";
　}

　return str_replace($searches, $this->query_strings, $string);
}

/**
* 每次執行，存儲過程中都有一個占位符被替換。
*/
protected function compile_callback($params, $index, $type)
{
　--$index;

　/* 拋出一個異常 */
　if (! isset($params[$index])) {
　　throw new Exception("存儲過程未收到所需的參數數目！");
　}

　/* 可以在此添加別的類型，如日期和時間。 */
　switch ($type) {
　　case 'S':
　　　return '"' . $this->db->escape_string($params[$index]) . '"';
　　　break;
　　case 'I':
　　　return (int) $params[$index];
　　　break;
　　case 'N':
　　　return (float) $params[$index];
　　default:
　　　throw new Exception("存儲過程中指定的數據類型 '$type' 無法識別。");
　}
}

/**
*
* 執行當前query，并把占位符替換為所提供的參數。
*
* @param mixed $queryParams,... Query parameter
* @return resource A reference to the resource representing the executed query.
*/
public function execute($queryParams = '')
{
　//例如：SELECT * FROM table WHERE name=:1S AND type=:2I AND level=:3N
　$args = func_get_args();

　if ($this->stored_procedure) {
　　/* 調用函數compile以取得query */
　　$query = call_user_func_array(array($this, 'compile'), $args);
　} else {
　　/* 如果存儲過程未被初始化，就把它作為標準query執行。*/
　　$query = $queryParams;
　}

　$this->result = $this->db->query($query);

　return $this->result;
}

require 'MySQL_db.PHP5';
require_once 'query2.PHP5';

$db = new MySQLDb;
$db->connect('host', 'username', 'pass');
$db->query('use content_management_system');

$query = new DBQuery($db);

$query->prepare('SELECT fname,sname FROM users WHERE username=:1S AND pword=:2S AND expire_time<:3I');

if ($result = $query->execute("visualad", "apron", time())) {
　if ($db->num_rows($result) == 1) {
　　echo('憑證正確。');
　} else {
　　echo('憑證不正確，會話已過期。');
　}
} else {
　echo('執行query時發生錯誤：' . $db->error());
}