以pikachu数据库为例，数据库名： pikachu
1.连接数据库
<?php
$dsn = 'mysql:host=localhost; port=3306; dbname=pikachu'; // 这里的空格比较敏感
$username = 'root';
$password = 'root';
try {
$pdo = new PDO($dsn, $username, $password);
var_dump($pdo);
}catch(PDOException $e){
// echo $e->getMessage();
die('Connection error:'. $e->getMessage());
}
?>
连接成功。
2. pdo查询
<?php
$dsn = 'mysql:host=127.0.0.1; dbname=pikachu';
$username = 'root';
$pwd = 'root';
$pdo = new PDO($dsn, $username,$pwd); // 连接数据库
$sql = 'select * from users where id=:id';
$stmt = $pdo->prepare($sql);
$stmt->bindValue(':id',1);
$stmt->execute();
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
echo '<pre>';
print_r($rows);
$pdo = null;
?>
:id 占位符
3.pdo更新
<?php
$dsn = 'mysql:host=127.0.0.1; dbname=pikachu';
$username = 'root';
$pwd = 'root';
$pdo = new PDO($dsn, $username,$pwd);
$sql = 'update users set level="4" where id=:id';
$stmt = $pdo->prepare($sql);
$stmt->bindValue(':id',1);
stmt->execute();
$pdo = null;
?>
4.pdo插入
<?php
$dsn = 'mysql:host=127.0.0.1; dbname=pikachu';
$username = 'root';
$pwd = 'root';
$pdo = new PDO($dsn, $username,$pwd);
$sql = 'insert into users(`id`,`username`,`password`,`level`) values(:id,:username,:password,:level)';
$stmt = $pdo->prepare($sql);
$stmt->bindValue(':id',4);
$stmt->bindValue(':username','Bob');
$stmt->bindValue(':password','e99a18c428cb38d5f260853678922e04');
$stmt->bindValue(':level','5');
$stmt->execute();
$id = $pdo->lastInsertId();
echo '<pre>';
var_dump($id);
$pdo = null;
?>
5. pdo删除
<?php
$dsn = 'mysql:host=127.0.0.1; dbname=pikachu';
$username = 'root';
$pwd = 'root';
$pdo = new PDO($dsn, $username,$pwd);
$sql = 'delete from pikachu where id = :id';
$stmt = $pdo->prepare($sql);
$stmt->bindValue(':id',1);
$stmt->execute();
// 返回受影响的行数，删除了多少行。
$rowCount = $stmt->rowCount();
echo '<pre>';
var_dump($rowCount);
$pdo = null;
?>
