<html>
<head><title>PHP TEST</title></head>
<body>

<?php

require_once 'DB.php';

$dsn = 'mysqli://testuser:testuser@localhost/uriage';

$db = DB::connect($dsn);
if (PEAR::isError($db)) {
    die($db->getMessage());
}

print('接続に成功しました<br>');

$db->query('SET NAMES sjis');
if (PEAR::isError($db)) {
    die($db->getMessage());
}

$sql = 'select * from shouhin';
$res =& $db->query($sql);
if (PEAR::isError($res)) {
    die($res->getMessage());
}

while ($row =& $res->fetchRow(DB_FETCHMODE_OBJECT)){
    print($row->id);
    print($row->name.'<br>');
}

print('<br>データを追加します。<br><br>');

$sql = "insert into shouhin (id, name) VALUES (?, ?)";
$stmt = $db->prepare($sql);
if (PEAR::isError($res)) {
    die($res->getMessage());
}

$data = array(6, 'エアコン');
$db->execute($stmt, $data);
if (PEAR::isError($res)) {
    die($res->getMessage());
}

$data = array(7, '扇風機');
$db->execute($stmt, $data);
if (PEAR::isError($res)) {
    die($res->getMessage());
}

$data = array(8, '空気清浄機');
$db->execute($stmt, $data);
if (PEAR::isError($res)) {
    die($res->getMessage());
}

print('<br>追加後のデータを取得します。<br><br>');

$sql = 'select * from shouhin';
$res =& $db->query($sql);
if (PEAR::isError($res)) {
    die($res->getMessage());
}

while ($row =& $res->fetchRow(DB_FETCHMODE_OBJECT)){
    print($row->id);
    print($row->name.'<br>');
}

$db->disconnect();

?>

</body>
</html>