データの追加(INSERT)
テーブル内に新たに1つのレコードを追加する場合は、以下のように記述します。
require_once('config.php');
try{
//データベースに接続
$db = new PDO('mysql:host='.$host.';dbname='.$dbname.';charset=utf8mb4', $username, $password);
//実行したいSQL
$sql = 'INSERT INTO blog(usr, tweet) VALUES(:user,:tweet)';
//SQL準備
$sth = $db->prepare($sql);
//挿入したいデータ
$user = '鈴木次郎';
$tweet = 'はじめまして!';
//ユーザからの入力情報をSQL文に代入
$sth->bindValue(':user', $user, PDO::PARAM_STR);
$sth->bindValue(':tweet', $tweet, PDO::PARAM_STR);
//実行
$sth->execute();
echo "情報を追加しました。";
}catch(PDOException $e){
die('エラーメッセージ:'.$e->getMessage());
}finally{
//データベース接続切断
$db = null;
}
追加後のデータを一覧表示したい場合は、以下のように新たにSQLを発行します。
require_once('config.php');
try{
//データベースに接続
$db = new PDO('mysql:host='.$host.';dbname='.$dbname.';charset=utf8mb4', $username, $password);
//実行したいSQL
$sql = 'INSERT INTO blog(usr, tweet) VALUES(:user,:tweet)';
//SQL準備
$sth = $db->prepare($sql);
//挿入したいデータ
$user = '鈴木次郎';
$tweet = 'はじめまして!';
//ユーザからの入力情報をSQL文に代入
$sth->bindValue(':user', $user, PDO::PARAM_STR);
$sth->bindValue(':tweet', $tweet, PDO::PARAM_STR);
//実行
$sth->execute();
print "データを追加しました。";
//追加後のデータを呼び出す
$sql = 'SELECT * FROM blog';
$sth = $db->prepare($sql);
$sth->execute();
}catch(PDOException $e){
die('エラーメッセージ:'.$e->getMessage());
}finally{
//データベース接続切断
$db = null;
}
print "<br>データ追加後の一覧<br>";
while ($row = $sth->fetch()){
print($row['id'])."<br>";
print($row['usr'])."<br>";
print($row['tweet'])."<br>";
print($row['time'])."<br>";
print "<br>";
}
コピーできました!