16 abstract class Converter implements pq\Converter
20 function __construct(\pq\Types $types) {
21 $this->types = $types;
25 class HStoreConverter extends Converter
27 function convertTypes() {
28 return [ $this->types["hstore"]->oid ];
31 function convertFromString($string, $type) {
32 return eval("return [$string];");
35 function convertToString($data, $type) {
37 foreach ($data as $k => $v) {
39 $string .= sprintf("\"%s\"=>\"%s\",", addslashes($k), addslashes($v));
41 $string .= sprintf("\"%s\"=>NULL,", addslashes($k));
48 class IntVectorConverter extends Converter
50 function convertTypes() {
52 $this->types["int2vector"]->oid,
53 $this->types["oidvector"]->oid
57 function convertFromString($string, $type) {
58 return array_map("intval", explode(" ", $string));
61 function convertToString($data, $type) {
62 return implode(" ", $data);
66 class JSONConverter extends Converter
68 function convertTypes() {
69 return [ $this->types["json"]->oid ];
72 function convertFromString($string, $type) {
73 return json_decode($string, true);
76 function convertToString($data, $type) {
77 return json_encode($data);
83 function __construct($data) {
86 function __toString() {
87 return (string) $this->data;
91 $c = new pq\Connection(PQ_DSN);
92 $c->exec("CREATE EXTENSION IF NOT EXISTS hstore");
93 $t = new pq\Types($c);
95 $c->setConverter(new HStoreConverter($t));
96 $c->setConverter(new IntVectorConverter($t));
97 if (!defined("pq\\Types::JSON")) {
98 $c->setConverter(new JSONConverter($t));
100 $r = $c->execParams("SELECT \$1 as hs, \$2 as iv, \$3 as oids, \$4 as js, \$5 as ia, \$6 as ta, \$7 as ba, \$8 as da, \$9 as dbl, \$10 as bln, ".
101 "\$11 as dt1, \$12 as dt2, \$13 as dt3, \$14 as dt4, \$15 as dt5, \$16 as dt6, \$17 as dt7, \$18 as dt8, \$19 as txta ",
114 2345124, 1431341, 1343423
119 "obj" => (object) array(
127 array(array(array(1,2,3))),
128 array(array("a\"","b}",null)),
144 [new Text(0), new Text(" or "), new Text(true)],
148 $t["int2vector"]->oid,
149 $t["oidvector"]->oid,
159 $t["timestamp"]->oid,
160 $t["timestamptz"]->oid,
163 $t["timestamp"]->oid,
164 $t["timestamptz"]->oid,
169 var_dump($r->fetchAll());
273 object(pq\DateTime)#%d (4) {
277 string(26) "%d-%d-%d 00:00:00.000000"
284 object(pq\DateTime)#%d (4) {
286 string(11) "Y-m-d H:i:s"
288 string(26) "%d-%d-%d %d:%d:%d.000000"
295 object(pq\DateTime)#%d (4) {
297 string(13) "Y-m-d H:i:s.u"
299 string(26) "%d-%d-%d %d:%d:%d.000000"
306 object(pq\DateTime)#%d (4) {
308 string(14) "Y-m-d H:i:s.uO"
310 string(26) "%d-%d-%d %d:%d:%d.000000"
317 object(pq\DateTime)#%d (4) {
321 string(26) "%d-%d-%d 00:00:00.000000"
328 object(pq\DateTime)#%d (4) {
330 string(11) "Y-m-d H:i:s"
332 string(26) "%d-%d-%d %d:%d:%d.000000"
339 object(pq\DateTime)#%d (4) {
341 string(13) "Y-m-d H:i:s.u"
343 string(26) "%d-%d-%d %d:%d:%d.000000"
350 object(pq\DateTime)#%d (4) {
352 string(14) "Y-m-d H:i:s.uO"
354 string(26) "%d-%d-%d %d:%d:%d.000000"