<?php
$type = 'mysql';
$host = '127.0.0.1';
$dbname = 'testdb';
$charset = 'utf8';
$port = 3306;
$user = 'root';
$pass = 'root';
$dsn = $type.':host='.$host.';dbname='.$dbname.';$charset='.$charset;
try{
$pdo = new PDO($dsn,$user,$pass); //连接
echo '链接成功','<br/>';
//创建一个用户 user001
$sql = "INSERT INTO xh_client_user (username,phone,pwd) VALUES (:username,:phone,:pwd)";
$stmt = $pdo -> prepare($sql);
$username = 'user001';
$phone = '13800138008';
$pwd = md5('1234567');
$stmt->bindParam(':username',$username,PDO::PARAM_STR,18);
$stmt->bindParam(':phone',$phone,PDO::PARAM_STR,11);
$stmt->bindParam(':pwd',$pwd,PDO::PARAM_STR,32);
if ($stmt->execute()) {
echo($stmt->rowcount()>0) ? '成功添加了'.$stmt->rowcount().'条记录' : '没有添加记录', '<br/>';
} else {
echo print_r($stmt->errorinfo(),true), '<br/>';
}
//修改用户 user001 的手机
$sql = "UPDATE xh_client_user SET phone = :phone WHERE username = :username";
$stmt = $pdo -> prepare($sql);
$username = 'user001';
$phone = '13800138019';
$stmt->bindParam(':phone',$phone,PDO::PARAM_STR,11);
$stmt->bindParam(':username',$username,PDO::PARAM_STR,18);
if ($stmt->execute()) {
echo($stmt->rowcount()>0) ? '成功更新了'.$stmt->rowcount().'条记录' : '没有更新记录' , '<br/>';
} else {
echo print_r($stmt->errorinfo(),true);
}
//查询用户 user001
$sql = "SELECT * FROM xh_client_user WHERE username = :username";
$stmt = $pdo -> prepare($sql);
$username = 'user001';
$stmt->bindParam(':username',$username,PDO::PARAM_STR,18);
if ($stmt->execute()) {
echo($stmt->rowcount()>0) ? '成功查询了'.$stmt->rowcount().'条记录,信息如下:' : '没有查询到记录' , '<br/>';
$row = $stmt->fetch(PDO::FETCH_ASSOC);
print_r($row);
echo '<br/>';
} else {
echo print_r($stmt->errorinfo(),true);
}
//删除用户 user001
$sql = "DELETE FROM xh_client_user WHERE username = :username";
$stmt = $pdo -> prepare($sql);
$username = 'user001';
$stmt->bindParam(':username',$username,PDO::PARAM_STR,18);
if ($stmt->execute()) {
echo($stmt->rowcount()>0) ? '成功删除了'.$stmt->rowcount().'条记录' : '没有删除记录' , '<br/>';
} else {
echo print_r($stmt->errorinfo(),true);
}
$pdo = null; //断开
echo '断开mysql:',var_dump($pdo);
}catch(PDOException $e){
echo '链接失败,原因:'. $e->getMessage();
}