利用PHP的OOP特性实现数据保护(1)(2)

**
* 返回编译的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());
}