php mysqli 预处理 怎么绑定参数

Question

/**
 * php中预处理执行sql
 * $sql[String] sql语句
 * $args[array] 参数
 */
public function exeSql($sql,$args){
$mysqli_stmt=$mysqli->prepare($sql);
//由于$sql由调用者传入,所以sql语句和参数个数都不确定
//疑问1：怎么获取参数类型呢？php中有没有相应的函数呢？
//如果没有我用如下方法：getParamTypeStr($arr)是否可行呢？有什么好的建议吗？
//疑问2：怎么绑定参数呢？如下为参数个数确定时的绑定方法。
//$mysqli_stmt->bind_param("ssi","xx","xx",20);
$mysqli_stmt->execute();
$mysqli->close();
}   private function getParamTypeStr($arr){
$count = count($arr);
$typestr = "";
for($i = 0; $i<$count; $i++){
$type = gettype($arr[$i]);
switch($type){
case "integer":
$typestr.= "i";
break;
case "float":
case "double":
$typestr.= "d";
break;
case "string":
$typestr.= "s";
break;
}
}
return $typestr;
}
我知道java中是通过如下方式实现的：    //java中预处理执行sql
public void exeSql(String sql,Object[] args){
PreparedStatement preparedStatement = connection.prepareStatement(sql);
        for(int i =0;i<args.length;i++){
         preparedStatement.setObject(i+1, args[i]);
        }
        preparedStatement.executeUpdate();
        connection.close();
}哪位朋友帮忙解答下上面2点疑问，本人刚转php，看了文档，中有提及反射，不是很懂，也有朋友说通过替换sql中的'?',还望朋友详细指点，最好能提供点核心代码。非常感谢！

Answer 1

2. 
$callback = array($mysqli_stmt, 'bind_param');
// 将参数类型描述加入数组
array_unshift($args, getParamTypeStr($args)); 
call_user_func_array($callback, $args);
// 它的调用类似:
$mysqli_stmt->bind_param(getParamTypeStr($args), $args[0], $args[1], $args[2] ...);
推荐你用PDO，mysqli的这个功能挺不好用的，PDO的bindParam()方法要直观的多
http://www.php.net/manual/en/pdostatement.bindparam.php

Answer 2

我这里有一个我自己写的PHP的PDO类，你可以直接用：
<?php/* 连接数据库类 MysqlConnect */class MysqlConnect{
private $dbhost=null;
private $dbuser=null;
private $dbpwd=null;
private $dbname=null;
private $dbport=null;
private $ifpdo=null;
private $dburi=null;
private $handler=null;
function __construct($dbhost,$dbuser,$dbpwd,$dbname,$dbport,$ifpdo,$dburi){
$this->dbhost=$dbhost;
$this->dbuser=$dbuser;
$this->dbpwd=$dbpwd;
$this->dbname=$dbname;
$this->dbport=$dbport;
$this->ifpdo=$ifpdo;
$this->dburi=$dburi;//PDO的URI参数，可以查手册
if($this->ifpdo==1){//表示调用PDO来操作数据库
$this->handler=$this->CreatePdo();
}elseif($this->ifpdo==0){//这里可以写MYSQLI的方法
$this->handler=null;
}
}
/* ----------------这里是入口--------------------- */
//@param sql:外部调用时传递的完整SQL语句
//@param bindArray:绑定的参数数组，与sql语句有关，如果没有PDO占位符此处为空
//@param action:传递操作参数，"select"/"update"/"delete"/"insert"
public function exeSql($sql,$bindArray=array(),$action=""){
$stmt=$this->handler->prepare($sql);
$stmt->execute($bindArray);
switch($action){
case "select":
return $stmt->fetch(PDO::FETCH_ASSOC);
break;
case "selectAll":
return $stmt->fetchAll(PDO::FETCH_ASSOC);
break;
case "update":
case "delete":
return $stmt->rowCount();
break;
case "insert":
return $this->handler->lastInsertId();
break;
case "count":
return $stmt->rowCount();
default:
return "";
}
}
public function query($sql){
return $this->handler->query($sql);
}
private function CreatePdo(){
try{
$handler=new PDO($this->dburi,$this->dbuser,$this->dbpwd);
$handler->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
return $handler;
}catch(PDOException $e){
$e->getMessage();
$this->handler=null;
}
}
private function __get($args){
if($args=='handler'){
return $this->handler;
}
}
}
require(NEO_A_P.'\data\sqlconfig.php');//这里是sql的连接文件,下面创建对象的时候需要的变量就是这个文件里要有的
$handler=new MysqlConnect($dbhost,$dbuser,$dbpwd,$dbname,$dbport,$ifpdo,$dburi);
?>

Answer 3

调用的时候,直接require包含这个类,然后$handler就是操作对象