3 const PQ_TEST_DSN = "";
5 const PQ_TEST_TABLE_CREATE = <<<SQL
6 drop table if exists test cascade;
16 const PQ_TEST_TABLE_DROP = <<<SQL
17 drop table if exists test cascade;
20 const PQ_TEST_REFTABLE_CREATE = <<<SQL
21 drop table if exists reftest cascade;
22 create table reftest (
23 test_id integer not null references test on delete cascade,
24 another_test_id integer not null references test on delete cascade
28 const PQ_TEST_REFTABLE_DROP = <<<SQL
29 drop table if exists reftest cascade;
32 const PQ_TEST_DATA = <<<SQL
33 insert into test values (default, 'yesterday', -1, -1.1, 'yesterday');
34 insert into test values (default, 'today', 0, 0, 'today');
35 insert into test values (default, 'tomorrow', 1, 1.1, 'tomorrow');
37 insert into reftest values (1,3);
38 insert into reftest values (2,2);
39 insert into reftest values (3,1);
42 spl_autoload_register(function($c) {
43 if (substr($c,0,3) == "pq\\") return require_once sprintf("%s/../lib/%s.php", __DIR__, strtr($c, "\\", "/"));
46 function executeInConcurrentTransaction(\pq\Query\ExecutorInterface $exec, $sql, array $params = null) {
47 $conn = $exec->getConnection();
48 $exec->setConnection(new pq\Connection(PQ_TEST_DSN));
49 $exec->execute(new \pq\Query\Writer($sql, $params), function(){});
50 $exec->setConnection($conn);
53 class QueryLogger implements \SplObserver
57 function __construct($logfile = null) {
58 if (!isset($logfile)) {
59 $logfile = __DIR__."/query.log";
61 if (!$this->fp = @fopen($logfile, "a")) {
62 throw new \RuntimeException(error_get_last()["message"]);
66 function __destruct() {
67 if (is_resource($this->fp)) {
72 function update(\SplSubject $executor) {
73 $result = $executor->getResult();
75 fprintf($this->fp, "[%s] R %s\n",
76 date_create()->format("Y-m-d H:i:s"),
78 "S" => $result->statusMessage,
79 "N" => $result->numRows,
80 "C" => $result->numCols,
81 "A" => $result->affectedRows
83 } elseif (($query = $executor->getQuery())) {
84 fprintf($this->fp, "[%s] Q %s %% %s\n",
85 date_create()->format("Y-m-d H:i:s"),
86 preg_replace("/\s+/", " ", $query),
87 json_encode($query->getParams()));