介绍
介绍
今天开始我们来学习各种语言操作数据库的技巧，根据福哥学习编程的顺序，我们先来将PHP语言操作数据库的技巧。
因为相对强大又免费的数据库只有MySQL了，所以我们这里只讲解各种语言操作MySQL数据库的方法，其他数据库福哥会在后面给逐步给大家讲解。
PHP有很多版本，在PHP4的时代大家一般是通过php_mysql库来操作MySQL的；后来到了PHP5时代OOP成为了编程主流，而php_mysql库也被php_mysqli库取而代之了；再后来PHP团队发现巨婴的Asp.net有ADODB，太阳的Java有JdbcTemplate，都是一种多数据库集中解决方案，通过一套库可以操作各种各样的数据库，真是太帅了！PHP团队就搞出了一个PDO库，这个库类似ADODB和JdbcTemplate也是多数据库集中解决方案，同时它也是面向对象的。
所以，福哥今天就要给大家讲讲如何通过PHP的PDO库来操作MySQL数据库的了~~
安装
一般情况下，安装PDO库都在编译PHP的时候完成了，在编译PHP源码的时候增加如下参数即可。
--with-pdo-mysql
连接
连接MySQL需要知道服务器的地址、用户名、密码，在初始化PDO的时候福哥设置了超时时间，默认的连接超时时间比较长。福哥设置了PDO的错误模式为异常错误，也就是说当PDO处理出现错误的时候会抛出异常，这种模式方便我们调试程序。
try{
$myPDO = new \PDO("mysql:host=127.0.0.1",
"root",
"abcdef",
array(
\PDO::ATTR_TIMEOUT => $this->timeout,
));
$myPDO->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
}
catch (\PDOException $e){
echo $e->getMessage();
throw $e;
}数据库列表
PDO没有单独的方法用来获取数据库列表，福哥是通过执行“show databases”语句获取数据库列表信息的。这是一个最简单的查询语句的示例，大家看好了。
try{
$rs = $myPDO->prepare("show databases");
$rs->execute();
$databases = [];
while($database = $rs->fetch(\PDO::FETCH_ASSOC)){
$databases[] = $database;
}
echo "<h3>数据库列表</h3>";
foreach($databases as $database){
echo $database['Database']. "<br />";
}
}
catch (\PDOException $e){
echo $e->getMessage();
throw $e;
}
数据表列表
同样的PDO也没有用来获取数据表列表的方法，福哥是通过执行“show tables”语句获取当前数据库的数据表列表的。当前数据库也没有方法可以用，但是我们可以通过exec方法执行终端命令来达到目的。
try{
$myPDO->exec("use tfums");
$myPDO->exec("set names utf8");
$rs = $myPDO->prepare("show tables");
$rs->execute();
$tables = [];
while($table = $rs->fetch(\PDO::FETCH_ASSOC)){
$tables[] = $table;
}
echo "<h3>数据表列表</h3>";
foreach($tables as $table){
echo $table['Tables_in_tfums']. "<br />";
}
}
catch (\PDOException $e){
echo $e->getMessage();
throw $e;
}
插入数据
插入数据
插入数据也是通过prepare组织一个SQL语句，然后通过execute方法执行SQL语句完成的。不过，通过向prepare传递参数可以达到动态组织SQL语句的目的，最重要的是：这种方式还可以防止SQL注入。
插入数据是否成功就看有没有异常抛出就可以了，没插入成功一定会有原因的嘛~~
try{
$sql = "insert into user (passwd, createDT, userFlag, userState, userName)
values (:f1, now(), :f2, :f3, :f4)";
$params = array(
array(":f1", md5("123456")),
array(":f2", 6, \PDO::PARAM_INT),
array(":f3", 1, \PDO::PARAM_INT),
array(":f4", "福哥教PDO")
);
echo "<h3>插入数据</h3>";
$rs = $myPDO->prepare($sql, $params);
foreach($params as $param){
if(!isset($param[2])){
$param[2] = \PDO::PARAM_STR;
}
$rs->bindValue($param[0], $param[1], $param[2]);
}
$rs->execute();
}
catch (\PDOException $e){
echo $e->getMessage();
}第一次执行的时候不会报错，多次执行就会有下面的错误信息了！
获取自增列数值
刚刚福哥向用户表user插入了一条数据，用户表user的主键是自增列，要获取新数据的自增列的数值需要自己通过SQL获得。
try{
$sql = "insert into user (passwd, createDT, userFlag, userState, userName)
values (:f1, now(), :f2, :f3, :f4)";
$params = array(
array(":f1", md5("123456")),
array(":f2", 6, \PDO::PARAM_INT),
array(":f3", 1, \PDO::PARAM_INT),
array(":f4", "福哥教PDO")
);
echo "<h3>插入数据</h3>";
$rs = $myPDO->prepare($sql, $params);
foreach($params as $param){
if(!isset($param[2])){
$param[2] = \PDO::PARAM_STR;
}
$rs->bindValue($param[0], $param[1], $param[2]);
}
$rs->execute();
echo "<h3>获取自增列数值</h3>";
$rs = $myPDO->prepare("select LAST_INSERT_ID() as newId");
$rs->execute();
$row = $rs->fetch(\PDO::FETCH_ASSOC);
var_dump($row);
}
catch (\PDOException $e){
echo $e->getMessage();
}
更新数据
更新数据就是执行UPDATE语句了，更新语句的条件自然就是通过刚刚获取到的自增列的数值了。
更新是否成功也是看是否有异常抛出，如果没有抛出就是执行成功了！
我们还可以通过rowCount方法获得本次更新语句影响了多少行的数据！
try{
$sql = "update user set lastLoginDT = now() where userID = :f1";
$params = array(
array(":f1", 16, \PDO::PARAM_INT)
);
echo "<h3>更新数据</h3>";
$rs = $myPDO->prepare($sql, $params);
foreach($params as $param){
if(!isset($param[2])){
$param[2] = \PDO::PARAM_STR;
}
$rs->bindValue($param[0], $param[1], $param[2]);
}
$rs->execute();
$effectedRows = $rs->rowCount();
var_dump($effectedRows);
}
catch (\PDOException $e){
echo $e->getMessage();
}
删除数据
删除数据是通过DELETE语句完成的，删除语句的条件自然也是根据自增列的数值了。
删除是否成功也是通过是否有异常抛出判断的，如果没有异常抛出就表示执行成功了！
删除行数也可以通过rowCount方法得到！
try{
$sql = "delete from user where userID = :f1";
$params = array(
array(":f1", 16, \PDO::PARAM_INT)
);
echo "<h3>删除数据</h3>";
$rs = $myPDO->prepare($sql, $params);
foreach($params as $param){
if(!isset($param[2])){
$param[2] = \PDO::PARAM_STR;
}
$rs->bindValue($param[0], $param[1], $param[2]);
}
$rs->execute();
$effectedRows = $rs->rowCount();
var_dump($effectedRows);
}
catch (\PDOException $e){
echo $e->getMessage();
}
查询数据
查询语句就是SELECT语句，这是数据库操作里面最最常用的SQL语句了，单表查询、多表连接查询、子查询、分组查询、汇总查询、结果排序等等一系列的SQL查询技巧福哥今天不想在这里讲解，我们只用一个最简单的单表查询演示PDO是如何实现数据查询的就可以了~~
try{
$rs = $myPDO->prepare("select * from user order by userID desc");
$rs->execute();
$rows = [];
while($row = $rs->fetch(\PDO::FETCH_ASSOC)){
$rows[] = $row;
}
echo "<h3>数据表user的数据列表</h3>";
foreach($rows as $row){
echo $row['userID']. "@". $row['userName']. "<br />";
}
}
catch (\PDOException $e){
echo $e->getMessage();
throw $e;
}
注意事项
使用PDO库操作MySQL数据库有一些注意事项，大家一定要认真看哦~~
连接MySQL和选择数据库可以放到包含文件里面，这样可以实现代码的复用。
无论自己的数据库是不是utf-8编码的都设置一下连接编码，毕竟你不能保证运行你的程序的环境一定是utf-8的。
尽量不要阻止PDO抛出异常，有bug我们就解决bug，这样系统才健康！
执行“set names utf8”语句时候，编码不要用“`”这个字符括起来，会被PDO当成编码的一部分解析！
总结
今天福哥给童鞋们演示了使用PDO库连接MySQL数据库进行各种常规操作的技巧，这里面都是一些简单的基础操作。不过，即使是复制的SQL语句也和今天福哥将的内容大同小异，举一反三就可以实现了。
后面福哥会找时间专门给童鞋们讲解SQL语句的使用技巧，包括各种复杂的使用场景，各种复杂的查询语句，大家可以先行自己研究研究。