PHP数据库操作：PDO
使用PDO
不管是使用原生的MySQL API，还是MySQLi，都还是有缺陷的。1、不支持事务机制；
2、仅支持MySQL，不能使用其它数据库。
3、不安全，可能有注入风险
4、不支持异常处理
PHP的PDO扩展巧妙的解决了这些问题。
PDO使用dsn连接，支持众多类型的数据库，如mysql,postgresql,oracle,mssql等。
PDO(php data object)扩展类库为php访问数据库定义了轻量级的、一致性的接口,它提供了一个数据库访问抽象层。这样,无论你使用什么数据库,都可以通过一致的函数执行查询和获取数据。
PDO大大简化了数据库的操作并能够屏蔽不同数据库之间的差异，使用pdo可以很方便地进行跨数据库程序的开发,以及不同数据库间的移植,是将来php在数据库处理方面的主要发展方向。
<?php
$db = array(
'dsn' => 'mysql:host=localhost;dbname=test;port=3306;charset=utf8',
'host' => 'localhost',
'port' => '3306',
'dbname' => 'test',
'username' => 'root',
'password' => '123456',
'charset' => 'utf8',
);
//连接
$options = array(
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, //默认是PDO::ERRMODE_SILENT, 0, (忽略错误模式)
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认是PDO::FETCH_BOTH, 4
);
try{
$pdo = new PDO($db['dsn'], $db['username'], $db['password'], $options);
}catch(PDOException $e){
die('数据库连接失败:' . $e->getMessage());
}
//或者更通用的设置属性方式:
//$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置异常处理方式
//$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); //设置默认关联索引遍历
echo '<pre/>';
//1 查询
//1)使用query
$stmt = $pdo->query('select * from user limit 2'); //返回一个PDOStatement对象
//$row = $stmt->fetch(); //从结果集中获取下一行，用于while循环
$rows = $stmt->fetchAll(); //获取所有
$row_count = $stmt->rowCount(); //记录数，2
//print_r($rows);
echo '<br>';
//2)使用prepare 推荐!
$stmt = $pdo->prepare("select * from user where name = :name and age = :age ");
$stmt->execute(array(
":name" => "test",
":age" => 22
)); //执行一条预处理语句 .成功时返回 TRUE, 失败时返回 FALSE
$rows = $stmt->fetchAll();
print_r($rows);
//2 新增、更新、删除
//1)普通操作
//$count = $pdo->exec("insert into user(name,gender,age)values('test',2,23)"); //返回受影响的行数
//echo $pdo->lastInsertId();
//$count = $pdo->exec("update user set name='test2' where id = 15"); //返回受影响的行数
//$count = $pdo->exec("delete from user where id = 15"); //返回受影响的行数
//2)使用prepare 推荐!
/*
$stmt = $pdo->prepare("insert into user(name,gender,age)values(:name,:gender,:age)");
$stmt->execute(array(
":name" => "test",
":gender" => 1,
":age" => 22
));
*/
pdo::query()方法
当执行返回结果集的select查询时,或者所影响的行数无关紧要时,应当使用pdo对象中的query()方法.
如果该方法成功执行指定的查询,则返回一个PDOStatement对象.
如果使用了query()方法,并想了解获取数据行总数,可以使用PDOStatement对象中的rowCount()方法获取.
PDO事务：pdo::exec()方法
当执行insert,update,delete没有结果集的查询时,使用pdo对象中的exec()方法去执行.
该方法成功执行时,将返回受影响的行数.注意,该方法不能用于select查询.
$pdo->beginTransaction();//开启事务处理
try{
//PDO预处理以及执行语句...
$pdo->commit();//提交事务
}catch(PDOException $e){
$pdo->rollBack();//事务回滚
//相关错误处理
throw $e;
}
了解PDO更多内容：http://www.cnblogs.com/52fhy/p/3969340.html
评论