PDO 操作实例全解

<?php

$dsn  = "uri:pdo_dsn.ini";//"mysql:host=127.0.0.1;dbname=test;port=3306";

$user = "root";

$pass = "123456";

try

{

$pdo = new PDO($dsn,$user,$pass);

//$in = $pdo -> exec("insert into user values (NULL,'quan','26')");

//var_dump($in); $in = 1

$pdo->setAttribute(PDO::ATTR_ERRMODE , PDO::ERRMODE_WARNING);

}

catch(PDOException $e)

{

print $e->getMessage();

}

/*

echo '1: '. $pdo -> getAttribute(PDO::ATTR_AUTOCOMMIT )."<br>";

echo '2: '. $pdo -> getAttribute(PDO::ATTR_CASE )."<br>";

echo '3: '. $pdo -> getAttribute(PDO::ATTR_CLIENT_VERSION )."<br>";

echo '4: '. $pdo -> getAttribute(PDO::ATTR_CONNECTION_STATUS )."<br>";

echo '5: '. $pdo -> getAttribute(PDO::ATTR_DRIVER_NAME )."<br>";

echo '6: '. $pdo -> getAttribute(PDO::ATTR_ERRMODE)."<br>";

echo '7: '. $pdo -> getAttribute(PDO::ATTR_ORACLE_NULLS )."<br>";

echo '8: '. $pdo -> getAttribute(PDO::ATTR_PERSISTENT )."<br>"; 

echo '9: '. $pdo -> getAttribute(PDO::ATTR_SERVER_INFO )."<br>";

echo '10: '. $pdo -> getAttribute(PDO::ATTR_SERVER_VERSION )."<br>"; 

*/

// 执行SQL语句的方法 exec query prepare

///echo $pdo -> exec("select * from user"); // 错误

/*

exec 返回更新数据库影响的行数 SQL的 insert   update   delete

query 返回结果集  SQL的 select 语句

*/

/*

$pdo->exec("insert into user (name,age) values ('cc','55')");

echo "最后插入的一条ID: ".$pdo->lastInsertId();

*/

/*

$stmt = $pdo->query("select * from user");

foreach($stmt as $row){

print_r($row);

echo "<br>";

}

*/

/*

prepare() //可以执行所有SQL语句

PDO 占位符 

:

*/

/*

//step 1 : 准备执行

//$stmt = $pdo->prepare("insert into user (name,age) values (?,?)");

$stmt = $pdo->prepare("insert into user (name,age) values (:name,:age)");

//step 2 : 绑定参数 

$stmt->bindParam(":name",$name,PDO::PARAM_STR);

$stmt->bindParam(":age",$age,PDO::PARAM_INT);

$name="faevvv";

$age = 13;

//step 3 : 执行SQL

$stmt->execute();

//连续插入

$stmt->execute(array(

"name"=>"1vsq",

"age"=>212

  ));

//表单操作 $stmt->execute($_POST);

*/

/*

//查询

$stmt = $pdo->prepare("select * from user where id>:id");

$stmt->execute(array("id"=>5));

$stmt->setFetchMode(PDO::FETCH_ASSOC); 

*/

/*

while($row = $stmt->fetch()){

print_r($row);

echo "<br>";

}

*/

//fetchAll

/*

$data = $stmt->fetchAll();

echo "<pre>";

print_r($data);

echo "</pre>";

echo "<br>总行数：".$stmt->rowCount();

echo "<br>总列数：".$stmt->columnCount();

*/

/*

//获取单个字段的单个值 相当于 mysql_result()

function db_result($pdo,$sql,$args=NULL,$row=0){

$dbh = $pdo->prepare($sql);

$dbh->execute($args);

$result  = $dbh->fetchAll(PDO::FETCH_NUM);

$rowCount = $dbh->rowCount();

if($result && $row<$rowCount)

return $result[$row];

else

return false;

}

$sql = "select name from user where id>:id";

var_dump( db_result($pdo,$sql,array("id"=>10),2) );

*/