setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
// get columns by name
$con->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
// return connection (note: no globals)
return $con;
}
function t1_get_one($f2) {
// connect to server and select database
$con = get_connection();
// prepare SQL statement
$stmt = $con->prepare('SELECT F1 FROM T1 WHERE F2=:F2');
// execute with parameters
$stmt->execute(array(':F2' => $f2));
// get first row and field F1
if($row = $stmt->fetch()) {
$f1 = $row['F1'];
} else {
die("$f2 not found");
}
// return value
return $f1;
}
function t1_get_all() {
// connect to server and select database
$con = get_connection();
// prepare SQL statement
$stmt = $con->prepare('SELECT F1,F2 FROM T1');
// execute with no parameters
$stmt->execute(array());
// create array to contain rows
$res = array();
// get all rows
while($row = $stmt->fetch()) {
$res[] = $row;
}
// return array with rows
return $res;
}
function t1_put($f1, $f2) {
// connect to server and select database
$con = get_connection();
// prepare SQL statement
$stmt = $con->prepare('INSERT INTO T1(F1,F2) VALUES(:F1,:F2)');
// execute with parameters
$stmt->execute(array(':F1' => $f1, ':F2' => $f2));
}
function t1_remove($f1) {
// connect to server and select database
$con = get_connection();
// prepare SQL statement
$stmt = $con->prepare('DELETE FROM T1 WHERE F1=:F1');
// execute with parameters
$stmt->execute(array(':F1' => $f1));
}
function t1_display($data) {
$rows = "";
foreach($data as $row) {
$f1 = $row['F1'];
$f2 = $row['F2'];
$rows .= sprintf("\r\n| $f1 | \r\n$f2 | \r\n
\r\n");
}
return "\r\n\r\n| F1 | \r\nF2 | \r\n
\r\n$rows
\r\n";
}
function test() {
$f1 = t1_get_one('BB');
echo "$f1
\r\n";
$data = t1_get_all();
echo t1_display($data);
t1_put(999, 'XXX');
$data = t1_get_all();
echo t1_display($data);
t1_remove(999);
$data = t1_get_all();
echo t1_display($data);
}
test();
?>