pdo操作:连接、增删查改操作(手写)
连接:
<?php
//连接数据库 1
// $pdo = new PDO('mysql:host=127.0.0.1;dbname=phpcn','root','root');
// print_r( $pdo );
//连接数据库 2
$db = [
'type' => 'mysql',
'host' => '127.0.0.1',
'dbname' => 'phpcn',
'username' => 'root',
'password' => 'root',
];
$dsn = "$db[type]:host=$db[host];dbname=$db[dbname]";
// $pdo = new PDO($dsn,$db['username'],$db['password']);
// print_r( $pdo);
//报错信息
try{
$pdo = new PDO($dsn,$db['username'],$db['password']);
echo '连接成功!';
}catch (PDOException $s){
die('连接失败,错误信息:' . $s->getMessage());
}
增加:
<?php
//连接数据库
require __DIR__ .'/config.php';
//创建数据库语句模板
$sql = 'INSERT INTO `user` SET `name`=:name, `pass`=:pass, `time`=:time, `dltime`=:dltime, `ip`=:ip ';
//创建数据库语句对象
$sqlt = $pdo->prepare($sql);
//绑定变量值
$name = 'username';
$pass = '123456';
$time = '1574341957818';
$dltime = '1574341957818';
$ip = '127.0.0.1';
$sqlt->bindParam('name',$name,PDO::PARAM_STR);
$sqlt->bindParam('pass',$pass,PDO::PARAM_STR);
$sqlt->bindParam('time',$time,PDO::PARAM_INT);
$sqlt->bindParam('dltime',$dltime,PDO::PARAM_INT);
$sqlt->bindParam('ip',$ip,PDO::PARAM_STR);
// $sqlt->execute();
if ($sqlt->execute()){
echo '成功增加' . $sqlt->rowCount() . '条记录!' ;
}else{
echo '失败!';
}
更新:
<?php
//更新记录
//连接数据库
require __DIR__ . '/config.php';
//创建数据库语句模板
$sql = 'UPDATE `user` SET `name`=:name, `pass`=:pass, `time`=:time, `dltime`=:dltime, `ip`=:ip WHERE `id`=:id';
//创建数据库语句对象
$sqlt = $pdo->prepare($sql);
//绑定变量
$name = 'username';
$pass = '123456';
$time = '1574341957818';
$dltime = '1574341957818';
$ip = '127.0.0.1';
$id = 2;
$sqlt->bindParam('name',$name,PDO::PARAM_STR);
$sqlt->bindParam('pass',$pass,PDO::PARAM_STR);
$sqlt->bindParam('time',$time,PDO::PARAM_INT);
$sqlt->bindParam('dltime',$dltime,PDO::PARAM_INT);
$sqlt->bindParam('ip',$ip,PDO::PARAM_STR);
$sqlt->bindParam('id',$id,PDO::PARAM_INT);
//执行操作
$sqlt->execute();
//销毁
$pdo = null;
删除:
<?php
//删除记录
require __DIR__ . '/config.php';
//创建数据库语句模板
$sql = 'DELETE FROM `user` WHERE `id`=:id';
//创建数据库语句对象
$sqlt = $pdo->prepare($sql);
//绑定变量
$id = 28;
$sqlt->bindParam('id',$id,PDO::PARAM_INT);
//执行数据库操作
$sqlt->execute();
//销毁
$pdo = null;
查询:
<?php
//查询记录
require __DIR__ . '/config.php';
//创建数据库语句模板
$sql = 'SELECT * FROM `user` WHERE `id`=:id';
//创建数据库语句对象
$sqlt = $pdo->prepare($sql);
//绑定变量
$id = 4;
$sqlt->bindParam('id',$id,PDO::PARAM_INT);
//执行操作
$sqlt->execute();
//返回
// print_r($sqlt->fetchAll(PDO::FETCH_ASSOC));
$s = $sqlt->fetchAll(PDO::FETCH_ASSOC);
foreach ($s as $v){
// print_r($v);
echo "用户名:$v[name]密码:$v[pass]登陆时间:";
echo date('Y-m-d H:i:s', "$v[time]");
}