mirror of
https://github.com/danog/ext-pq.git
synced 2024-11-27 04:14:51 +01:00
68 lines
1.2 KiB
PHP
68 lines
1.2 KiB
PHP
--TEST--
|
|
copy
|
|
--SKIPIF--
|
|
<?php include "_skipif.inc"; ?>
|
|
--FILE--
|
|
<?php
|
|
echo "Test\n";
|
|
|
|
include "_setup.inc";
|
|
|
|
$c = new pq\Connection(PQ_DSN);
|
|
$c->exec("DROP TABLE IF EXISTS copy_test; CREATE TABLE copy_test (id serial, line text);");
|
|
|
|
$file = file(__FILE__);
|
|
|
|
$in = new pq\COPY($c, "copy_test (line)", pq\COPY::FROM_STDIN, "DELIMITER '\t'");
|
|
|
|
var_dump(
|
|
$c === $in->connection,
|
|
"copy_test (line)" === $in->expression,
|
|
pq\COPY::FROM_STDIN === $in->direction,
|
|
"DELIMITER '\t'" === $in->options
|
|
);
|
|
|
|
foreach ($file as $i => $line) {
|
|
$in->put(addcslashes($line, "\\\t"));
|
|
}
|
|
$in->end();
|
|
|
|
$out = new pq\COPY($c, "copy_test (line)", pq\COPY::TO_STDOUT, "DELIMITER '\t'");
|
|
|
|
var_dump(
|
|
$c === $out->connection,
|
|
"copy_test (line)" === $out->expression,
|
|
pq\COPY::TO_STDOUT === $out->direction,
|
|
"DELIMITER '\t'" === $out->options
|
|
);
|
|
|
|
while ($out->get($line)) {
|
|
$lines[] = stripcslashes($line);
|
|
}
|
|
|
|
var_dump($file == $lines);
|
|
|
|
if ($file != $lines) {
|
|
foreach (array_keys(array_diff($file, $lines)) as $idx) {
|
|
var_dump($idx, $file[$idx], $lines[$idx], "##############");
|
|
}
|
|
}
|
|
|
|
$c->exec("DROP TABLE copy_test");
|
|
|
|
?>
|
|
DONE
|
|
--EXPECT--
|
|
Test
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
bool(true)
|
|
DONE
|
|
|