标签:
1. 何为PDO?
1 <?php 2 $cat = isset ($_GET[‘cat‘]) ? $_GET[‘cat‘] : "1"; 3 $pg = isset ($_GET[‘pg‘]) ? $_GET[‘pg‘] : "1"; 4 5 $limit = 10; 6 $dbname = ‘shelf.sqlite‘; 7 try { 8 $db = new PDO("sqlite:" . $dbname); 9 $sth = $db->prepare(‘select * from book where cat_id=:id limit :offset, :limit‘, array ( 10 PDO :: ATTR_CURSOR => PDO :: CURSOR_FWDONLY 11 )); 12 13 $result = $sth->execute(array ( 14 ‘:id‘ => $cat, 15 ‘:offset‘ => ($pg -1) * $limit, 16 ‘:limit‘ => $limit 17 )); 18 $list = array (); 19 $query = $db->query(‘select count(*) from book where cat_id=‘ . $cat)->fetch(); //Only 1 row 20 $list["count"] = $query[0]; 21 if ($result) { 22 while ($row = $sth->fetch(PDO :: FETCH_ASSOC)) { 23 $list["books"][] = $row; 24 } 25 } else { 26 print_r($db->errorInfo()); 27 } 28 29 $db = NULL; 30 31 echo str_replace(‘\\/‘, ‘/‘, json_encode($list)); 32 33 } catch (PDOException $ex) { 34 print_r($ex); 35 } 36 ?>
3. PDO中的常量
1 <?php 2 $db = new PDO(‘mysql:host=localhost;dbname=test‘, $user, $pass); 3 //使用新建立的数据库连接。 4 //... ... 5 //连接在PDO实例的生命周期里是活动的。使用完毕后应当关闭此连接,若不这样做PHP在代码结束时才关闭此连接,将占用一部分内存。 6 $db = null; 7 ?>
当然,事情并不都是这样,有时我们可能会需要一个永久的连接。具体做法是在PDO的构造函数里再加一个参数:
1 <?php 2 $db = new PDO(‘mysql:host=localhost;dbname=test‘, $user, $pass, array( 3 PDO::ATTR_PERSISTENT => true 4 )); 5 ?>
永久的连接能够跨越代码,在一个代码执行完毕时并未被关闭,而是被缓存起来,以供另一段拥有同样权限的代码重复使用。这样便不必每次都新建一个连接,省了不少事不说,还能够加快网站速度。
(2)PDO::query()用于执行一次SELECT语句,执行后应当随即使用PDOStatement::fetch()语句将结果取出,否则立即进行下一次的PDO::query()将会报错。在2.PDO实例部分,为了得到查询数据的总量,就用了PDO::query()语句。
1 $sth = $db->prepare(‘select * from book where cat_id=:id limit :offset, :limit‘, array ( 2 PDO :: ATTR_CURSOR => PDO :: CURSOR_FWDONLY 3 )); 4 //用$limit1得到一个结果 5 $result1 = $sth->execute(array ( 6 ‘:id‘ => $cat, 7 ‘:offset‘ => ($pg -1) * $limit1, 8 ‘:limit‘ => $limit1 9 )); 10 11 //用$limit2得到另一个结果 12 $result2 = $sth->execute(array ( 13 ‘:id‘ => $cat, 14 ‘:offset‘ => ($pg -1) * $limit2, 15 ‘:limit‘ => $limit2 16 ));
使用prepared statement还有一个好处就是,语句里不再使用引号,PDO driver已自动完成这一操作,可以防止SQL注入攻击的危险。查询语句里可以使用包含名字的(:name)和问号(?)的参数占位符,分别将用associated array 和indexed array传入数值。
1 //用位置参入参数 2 $stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (?, ?)"); 3 $stmt->bindParam(1, $name); 4 $stmt->bindParam(2, $value); 5 6 //用名称传入参数 7 $stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)"); 8 $stmt->bindParam(‘:name‘, $name); 9 $stmt->bindParam(‘:value‘, $value); 10 11 $name = ‘one‘; 12 $value = 1; 13 $stmt->execute(); 14 15 ///////////////////////////////////////////// 16 //也可以这样实现 17 //用位置参入参数,indexed array 18 $stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (?, ?)"); 19 $name = ‘one‘; 20 $value = 1; 21 $stmt->execute(array($name,$value)); 22 23 //用名称传入参数, associated array 24 $stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)"); 25 $name = ‘one‘; 26 $value = 1; 27 $stmt->execute(array(‘:name‘=>$name,‘:value‘=>$value));
特别注意:查询语句中的占位符应当是占据整个值的位置,如果有模糊查询的符号,应当这样做:
1 // placeholder must be used in the place of the whole value 2 $stmt = $dbh->prepare("SELECT * FROM REGISTRY where name LIKE ?"); 3 $stmt->execute(array("%$_GET[name]%")); 4 5 //下面这样就有问题了 6 $stmt = $dbh->prepare("SELECT * FROM REGISTRY where name LIKE ‘%?%‘"); 7 $stmt->execute(array($_GET[‘name‘]));
本文来自pinocchioatbeijing(专注前端技术 追求至美生活 以文会友)在博客园的博客,文章URL:http://www.cnblogs.com/pinocchioatbeijing/archive/2012/03/20/2407869.html ,转载请注明,并欢迎大家不吝赐教。
标签:
原文地址:http://www.cnblogs.com/yuxiuyan/p/5757569.html