查询
<?php
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:<br />"; 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. <br />";
}
?>
<?php
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:<br />"; $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<br />";
}
?>
<?php
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. <br />";
}
?>
插入修改
<?php
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.<br />";
}
$sqlquery2 = "UPDATE user SET age='45' WHERE name='zhangdaguang'";
if($dbconnect->exec($sqlquery2)){
echo "The record has been updated.";
}
?>
删除
<?php
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。