1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
<?php
require_once dirname(__FILE__) . '/../../../ext/pdo/tests/pdo_test.inc';
require_once dirname(__FILE__) . '/config.inc';
if (!isset($db)) {
$db = new Pdo\Pgsql($config['ENV']['PDOTEST_DSN']);
}
if (!isset($rounds) || empty($rounds)) {
$rounds = [ null, 'Re' ];
}
attach($db, array_shift($rounds));
$db->beginTransaction();
$db->exec("set client_min_messages to notice");
$db->exec("create temporary table t (a varchar(3))");
$db->exec("create function hey() returns trigger as \$\$ begin new.a := 'oh'; raise notice 'I tampered your data, did you know?'; return new; end; \$\$ language plpgsql");
$db->exec("create trigger hop before insert on t for each row execute procedure hey()");
$db->exec("insert into t values ('ah')");
while (count($rounds)) {
try {
attach($db, array_shift($rounds));
} catch (Throwable $err) {
echo "Caught ".get_class($err).": ".$err->getMessage()."\n";
}
try {
$db->exec("delete from t");
$db->exec("insert into t values ('ah')");
} catch (Throwable $err) {
echo "Caught ".get_class($err)." ".$err->getMessage()."\n";
}
}
$db->setNoticeCallback(null);
$db->exec("delete from t");
$db->exec("insert into t values ('ah')");
var_dump($db->query("select * from t")->fetchAll(PDO::FETCH_ASSOC));
echo "Done\n";
$db->rollback();
?>
|
