MySQL接続クラス
PHPでMySQL接続のためのクラスを書きました。PDO（PHP Data Object）で書かれているので、PHP5.1以上が必要です（PHP4では動きません）。
host = $host;
$this->user = $user;
$this->pass = $pass;
$this->db = $db;
$this->dsn = "mysql:dbname=$db;$host=$host";
}
function fetch($sql)
{
try{
$pdo = new PDO ($this->dsn, $this->user, $this->pass, array(
PDO::MYSQL_ATTR_INIT_COMMAND => "SET CHARACTER SET 'utf8'"));
$stmt = $pdo->prepare($sql);
$stmt->execute();
$data = $stmt->fetchAll(PDO::FETCH_ASSOC);
return $data;
} catch(PDOException $ei) {
echo 'Connection failed:'.$e->getMessage();
exit();}
}
function execute ($sql)
{
try{
$pdo = new PDO ($this->dsn, $this->user, $this->pass, array(
PDO::MYSQL_ATTR_INIT_COMMAND => "SET CHARACTER SET 'utf8'"));
$stmt = $pdo->prepare($sql);
$stmt->execute();
$data = $pdo->lastInsertId();
return $data;
} catch(PDOException $ei) {
echo 'Connection failed:'.$e->getMessage();
exit();}
}
}
?>
クラスの使い方
このクラスファイルをrequireして、以下のような感じで使えます。
$conn = new DB($host,$user,$pass,$db);
$sql = "SELECT * FROM hoge where hogehoge";
$result = $conn->fetch($sql);
executeも同様です。
$update = $conn->execute($sql);
