PDO
2015-05-26 本文已影响156人
snoweek
个人理解：数据库有很多种，如mysql,oracle等，不同的数据库有各自不同的函数，因此即使是实现同一个功能如插入数据，我们也需要记住多个函数，这无疑是一个巨大的工作。所以，我们希望有一个工具能够一个统一的方法来操作不同的数据库，这样，我们就可以只了解这一个工具就可以操作多种不同的数据库。Pdo就是这样一种工具。
有了pdo，我们不需要再为不同的数据库封装数据库操作类，只需要使用pdo接口中的方法就可以对数据库进行操作。在选择不同的数据库时，只需要修改pdo中的dsn即可。在使用pdo之前，我们首先要对配置文件进行更改。
- 打开php。Ini文件
- 加载”extension=php_pdo.dll”
-
若想支持某个具体的数据库还要加载相应的数据库选项。如，要支持mysql数据库，则需要加载”extension=php_pdo_mysql.dll”选项.
如图：
4.php。ini更改完后，保存并重启MySQL即可。
那么如何连接数据库呢。
原本，用MySQL数据库中的函数是这样的
$dbc=@mysqli_connect('127.0.0.1', 'root','123456','todolist') or die('could not connect to mysql');
mysqli_set_charset($dbc,'utf8');
现在，用pdo数据库抽象层进行操作是这样的
$dbName='todolist';
$user='root';
$pass='123456';
$host='localhost';
$dsn="$dbms:host=$host;dbname=$dbName";
try{
$pdo=new PDO($dsn,$user,$pass);
$pdo->query("set names utf8");
}catch(PDOException $e){
die("Error!:".$e->getMessage()."<br />");
}
$dbms='mysql'; 定义数据库的类型
$user='root';定义使用数据库的用户名
$pass='123456';定义密码
$host='localhost';定义使用的主机名称
$dsn="$dbms:host=$host;dbname=$dbName"DSN部分，有三部分组成：pdo的链接的数据库名称，主机名称和数据库名称;
$pdo=new PDO($dsn,$user,$pass);实例化对象
$pdo->query("set names utf8");设置编码格式，否则会导致读取数据库的中文内容是会出现乱码。
下面，我们以todolist中的register.php为例进行讲解。
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" lang="zh-CN">
<head>
<title>注册页面</title>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
</head>
<body>
<?php
session_start();
$dbc=@mysqli_connect('127.0.0.1', 'root','123456','todolist')
or die('could not connect to mysql');
mysqli_set_charset($dbc,'utf8');
require('D:\Dev Apps\xampp\htdocs\sunyan2015\mysqli_connecttodolist.php');
$error=array();
if($_SERVER['REQUEST_METHOD']=='POST'){
if(!empty($_POST['username'])){
$username=$_POST['username'];
}else{
$error[]="请输入用户名";
}
if(!empty($_POST['password'])){
$password=$_POST['password'];
}else{
$error[]="请输入密码";
}
if(empty($error)){
$q1="select user_id from usermessage where name='$username' ";
$r1=mysqli_query($dbc,$q1);
if(mysqli_num_rows($r1)==0){
$q="insert into usermessage(name,password)values(\"$username\",\"$password\")";
$r=mysqli_query($dbc,$q);
if($r){
echo'恭喜你，已注册成功。请点击<a href="login.php">登录</a>';
}else{//$r
echo'You could not be registered due to a system error.';
}
}else{
echo'对不起，此用户名已经注册';
}
mysqli_close($dbc);
exit();
}else{//empty
echo'<h2> Error!</h2>';
echo'The following error(s) occurred:</br>';
foreach($error as $msg){
echo"$msg";
echo"<br />";
}
echo'<p>Please try again.</p>';
}
}
?>
<form action="register.php" method="POST">
用户名：<br />
<input type="text" name="username" />
<br />
密码：<br />
<input type="password" name="password" />
请由字母数字或下划线组成，长度为5-21
<br />
<input type="submit" value="注册" />
</form>
<a href="login.php">登录</a>
<br />
<a href="changepassword.php">更改密码</a>
<br />
<a href="index.php">返回首页</a>
</body>
</html>
应用pdo
<?php
session_start();
include("../config.php");
$smarty->assign('title','注册页面');
echo'<form action="register.php" method="POST">
用户名：<br />
<input type="text" name="username" />
<br />
密码：<br />
<input type="password" name="password" />
<br />
<input type="submit" value="注册" />
</form>';
$error=array();
if($_SERVER['REQUEST_METHOD']=='POST'){
if(!empty($_POST['username'])){
$username=$_POST['username'];
}else{
$error[]="请输入用户名";
}
if(!empty($_POST['password'])){
$password=$_POST['password'];
}else{
$error[]="请输入密码";
}
if(empty($error)){
$dbms='mysql';
$dbName='todolist';
$user='root';
$pass='123456';
$host='localhost';
$dsn="$dbms:host=$host;dbname=$dbName";
try{
$pdo=new PDO($dsn,$user,$pass);
$pdo->query("set names utf8");
$q1="select user_id from usermessage where name='$username'";
$q="insert into usermessage(name,password)values(\"$username\",\"$password\")";
$r1=$pdo->query($q1);
if(!empty($r1)){
$r=$pdo->exec($q);
if($r){
echo'恭喜你，已注册成功。请点击<a href="login.php">登录</a>';
}else{
echo'You could not be registered due to a system error.';
}
}else{
echo'对不起，此用户名已经注册';
}
}catch(PDOException $e){
die("Error!:".$e->getMessage()."<br />");
}
}else{
echo'<h2> Error!</h2>';
echo'The following error(s) occurred:</br>';
foreach($error as $msg){
echo"$msg";
echo"<br />";
}
echo'<p>Please try again.</p>';
}
}
$smarty->assign('name1','login');
$smarty->assign('content1','登录');
$smarty->assign('name2','changepassword');
$smarty->assign('content2','更改密码');
$smarty->display('todo.html');
?>
从以上两段代码，我们可以开出
总体思路是不变的。变的只是数据库的链接部分和各种验证条件的位置。
通过上述代码，我们再来了解一下dpo是如何执行sql语句的。
- 对于insert,delete,update,用exec方法
$q="insert into usermessage(name,password)values(\"$username\",\"$password\")";
$r=$pdo->exec($q);
Exec方法返回执行后受影响的行数。
- 对于insert，用query方法
$q1="select user_id from usermessage where name='$username' ";
$r1=$pdo->query($q1);
Query方法返回一个结果集。
