php7 pdo编码,php7 pdo抽象类操作数据库

查询

try {

$dbconnect = new PDO('mysql:host=localhost;dbname=pdodatabase','root','753951');

} catch (PDOException $exception) {

echo "Connection error message: " . $exception->getMessage();

}

$sqlquery = "SELECT * FROM user";

$result = $dbconnect->query($sqlquery);

$rownum = $result->rowCount();

echo "There are total ".$rownum." users:
";

while ($row = $result->fetch(PDO::FETCH_ASSOC)){

$name = $row['name'];

$gender = $row['gender'];

$age = $row['age'];

echo "user $name , is $gender ,and is $age years old.
";

}

?>

try {

$dbconnect = new PDO('mysql:host=localhost;dbname=pdodatabase','root','753951');

} catch (PDOException $exception) {

echo "Connection error message: " . $exception->getMessage();

}

$sqlquery = "SELECT * FROM user";

$result = $dbconnect->query($sqlquery);

$rownum = $result->rowCount();

echo "There are total ".$rownum." users:
";

$rowall = $result->fetchAll();

foreach ($rowall as $row){

$id = $row[0];

$name = $row[1];

$gender = $row[3];

$age = $row[2];

$info = $row['info'];

echo "ID: $id . User $name , is $gender ,and is $age years old. and info: $info
";

}

?>

try {

$dbconnect = new PDO('mysql:host=localhost;dbname=pdodatabase','root','753951');

} catch (PDOException $exception) {

echo "Connection error message: " . $exception->getMessage();

}

$sqlquery = "SELECT * FROM user";

$result = $dbconnect->query($sqlquery);

foreach ($result as $row){

$name = $row['name'];

$gender = $row['gender'];

$age = $row['age'];

echo "user $name , is $gender ,and is $age years old.
";

}

?>

插入修改

try {

$dbconnect = new PDO('mysql:host=localhost;dbname=pdodatabase','root','753951');

} catch (PDOException $exception) {

echo "Connection error message: " . $exception->getMessage();

}

$sqlquery = "INSERT INTO user (id,name,age,gender,info )VALUES (NULL,'zhangdaguang', '39', 'male', 'he is a middle-age male.')";

if($dbconnect->exec($sqlquery)){

echo "A new record has been inserted.
";

}

$sqlquery2 = "UPDATE user SET age='45' WHERE name='zhangdaguang'";

if($dbconnect->exec($sqlquery2)){

echo "The record has been updated.";

}

?>

删除

try {

$dbconnect = new PDO('mysql:host=localhost;dbname=pdodatabase','root','753951');

} catch (PDOException $exception) {

echo "Connection error message: " . $exception->getMessage();

}

$sqlquery = "DELETE FROM user WHERE name = 'zhangdaguang'";

if($dbconnect->exec($sqlquery)){

echo "A new record has been deleted.";

}

?>

这里有一点需要注意，就是select语句的执行必须用query方法，不能用exec方法执行，其他的操作可以用exec。