PgPhp/examples.php at master · derekchan/PgPhp · GitHub

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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
<?php

require_once __DIR__ . '/vendor/autoload.php';

function info () {
    $args = func_get_args();
    $fmt = array_shift($args);
    vprintf("{$fmt}\n", $args);
}

try {
    $dbh = new pg\Connection();
    $dbh->connect();
    info("Connected OK");
} catch (Exception $e) {
    info("Connect failed:\n%s", $e->getMessage());
}


/* Test code - Basic queries */
$q = new pg\Query('select * from da_table;insert into da_table (lady_curtain) values (\'Whale oil beef hooked\');');

$q = new pg\Query('select * from da_table where lady_curtain = \'K\';select * from da_table;update da_table set lady_curtain=\'Hiyah!!\' where lady_curtain=\'Hiyah!\'');

//$q = new pg\Query('copy copy_test from stdin with csv');
//$q->pushCopyData("1, Fooking Heel!\n2, Fooking Heel!\n3, Fooking Heel!\n4, Fooking Heel!\n5, Fooking Heel!\n6, Fooking Heel!\n7, Fooking Heel!\n8, Fooking Heel!");

try {
    //$dbh->debug = true;
    echo "Run Query\n";
    $dbh->runQuery($q);
} catch (Exception $e) {
    info("An Error response was returned:\n%s", $e->getMessage());
}
echo displayQueryResultSet($q->getResults());

$dbh->close();
return;


/** Test code - extended query protocol - Write command
//$dbh->debug = true;

$p = new pg\Statement($dbh);

$p->setSql('insert into da_table (moofark, floatie) values ($1, $2);');
$p->setName('st1');

echo "\nParse\n\n";
var_dump($p->parse());

echo "\nExecute\n\n";
echo displayQueryResultSet($p->execute(array('6969', '1.01')));

*/


/** Test code - extended query protocol - Select command
//$dbh->debug = true;

$p = new pg\Statement($dbh);

$p->setSql('select * from da_table n1');
$p->setName('st3');

echo "\nParse\n\n";
var_dump($p->parse());

echo "\n\nExecute:\n";
echo displayQueryResultSet($p->execute());
*/


/** Test code - notifications */
$dbh->addChannelListener("MyChan", function ($notification) {
        printf("Notification delivered OK!!!!\n");
    });

$dbh->testSelect();


$dbh->close();


// Return a string representation of the set of results
// in the given Query object
function displayQueryResultSet ($res) {
    $buff = '';
    foreach ($res as $i => $rPart) {
        if ($rPart instanceof pg\ResultSet) {
            $buff .= sprintf("Result Set: (%d results)\n", count($rPart));
            $rPart->fetchStyle = pg\ResultSet::ASSOC;
            foreach ($rPart as $row) {
                foreach ($row as $colName => $col) {
                    $buff .= "  $colName: $col";
                }
                $buff .= "\n";
            }
        } else if ($rPart instanceof pg\Result) {
            switch ($rPart->getResultType()) {
            case 'CommandComplete':
                $buff .= sprintf("CommandComplete: %s %d\n", $rPart->getCommand(), $rPart->getRowsAffected());
                break;
            case 'ErrorResponse':
                $eData = $rPart->getErrDetail();
                $buff .= sprintf("Error Response: Code %s, Message %s\n",
                                 $eData[pg\ERR_CODE], $eData[pg\ERR_MESSAGE]);
            }
        } else {
            $buff .= "\n[$i]: Unknown result type:\n" . print_r($rPart, true);
        }
    }
    return $buff;
}