php・mysqlの接続方法・pdoの使い方を詳しく解説

$dbh = 新しい PDO('mysql:host=localhost;dbname=access_control', 'root', '');
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$dbh->exec('set names utf8');
/*追加*/
//$sql = "INSERT INTO `user` SET `login`=:login AND `password`=:password";
$sql = "INSERT INTO `user` (`login` ,`password`)VALUES (:login, :password)";  $stmt = $dbh->prepare($sql);  $stmt->execute(array(':login'=>'kevin2',':password'=>''));
echo $dbh->lastinsertid();
/*修正*/
$sql = "UPDATE `user` SET `password`=:password WHERE `user_id`=:userId";
$stmt = $dbh->prepare($sql);
$stmt->execute(array(':userId'=>'7', ':password'=>'4607e782c4d86fd5364d7e4508bb10d9'));
echo $stmt->rowCount();
/*删除*/
$sql = "DELETE FROM `user` WHERE `login` LIKE 'kevin_'"; //kevin%
$stmt = $dbh->prepare($sql);
$stmt->execute();
echo $stmt->rowCount();
/*查询*/
$login = 'kevin%';
$sql = "SELECT * FROM `user` WHERE `login` LIKE :login";
$stmt = $dbh->prepare($sql);
$stmt->execute(array(':login'=>$login));
while($row = $stmt->fetch(PDO::FETCH_ASSOC)){
 print_r($row);
}
print_r( $stmt->fetchAll(PDO::FETCH_ASSOC));
?>

1、建立连接

 $dbh=newPDO('mysql:host=localhost;port=3306; dbname=test',$user,$pass,array(
 PDO::ATTR_PERSISTENT=>true
 ));
 ?>

持久性链接PDO::ATTR_PERSISTENT=>true

2、捕捉错误

 try{
 $dbh=newPDO('mysql:host=localhost;dbname=test',$user,$pass);
 $dbh->setAttribute(PDO::ATTR_ERRMODE) ,PDO::ERRMODE_EXCEPTION);
 $dbh->exec("SET CHARACTER SET utf8");
 $dbh=null; //断开连接
 }catch(PDOException$e){
 print"Error!:".$e->getMessage()."";
 die();
 }
?> ;

3、pdo事务

try{
$dbh->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$dbh->beginTransaction();//开启事务
$dbh- >exec("insertintostaff(id,first,last)values(23,'Joe','Bloggs')");
$dbh->exec("insertintosalarychange(id,amount,changedate)
values(23, 50000,NOW())");
$dbh->commit();//提交事务
}catch(Exception$e){
$dbh->rollBack();//错误回滚
echo"失敗:".$e->getMessage();
}
?>

4. 错误処理 ａ． 静默モード(默认モード)

 try{
 $dbh = 新しい PDO($dsn, $user, $password);
 $sql = ' CountryCode =:country の都市から * を選択';
 $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 $stmt = $dbh->prepare($sql);
 $stmt->bindParam(':country', $country, PDO::PARAM_STR);
 $stmt->execute();
 while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
 print $row['Name'] . "/t";
 }
 } // 問題がある場合は、ここで処理できます
 catch (PDOException $e) {
 echo 'PDO 例外をキャッチしました。  ';
 echo 'データベースのエラー: ';
 echo 'SQL クエリ: ', $sql;
 echo 'エラー: ' 。 $e->getMessage();
 }
 ?>

1、query()を使用します

$dbh->query($sql); 現在 $sql 中量は $dbh->quote($params); を使用できます。 //转义文字列の数据
$sql = 'Select * from city where CountryCode ='.$dbh->quote($country);
foreach ($dbh->query($sql) as $row) {
 print $row['Name'] . "/t";
 $row[' CountryCode'] を印刷します。 "/t";
 $row['Population'] を出力します。 "/n";
}
?>

2、prepare、bindParam を使用して実行します [推奨。追加、変更、削除もできます]

$dbh->prepare($sql); は PDOStatement オブジェクトを生成します
PDOStatement->bindParam()
PDOStatement->execute();//ここに置くことができます対応するバインド変数
?>

3.

 try {
 $dbh = new PDO('mysql:host=localhost;dbname=test', 'root', '');
 $dbh->query('set) names utf8;');
 $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 $dbh->beginTransaction(); `test` に挿入します。 `table` (`name` ,`age`)VALUES ('mick', 22);");
 $dbh->exec("Insert INTO `test`.`table` (`name` ,`age` )VALUES ('lily', 29);");
 $dbh->exec("Insert INTO `test`.`table` (`name` ,`age`)VALUES ('susan', 21);" );
 $dbh->commit();
 } catch (Exception $e) {
 $e->getMessage();
 ?>


コードをコピー