mirror of
https://github.com/danog/postgres.git
synced 2024-12-12 09:29:57 +01:00
41 lines
1.2 KiB
PHP
41 lines
1.2 KiB
PHP
#!/usr/bin/env php
|
|
<?php
|
|
|
|
require \dirname(__DIR__) . '/vendor/autoload.php';
|
|
|
|
use Amp\Postgres;
|
|
use Amp\Postgres\Transaction;
|
|
use Amp\Sql\Result;
|
|
use Amp\Sql\Statement;
|
|
|
|
Amp\Loop::run(function () {
|
|
$config = Postgres\ConnectionConfig::fromString('host=localhost user=postgres');
|
|
|
|
$pool = Postgres\pool($config);
|
|
|
|
yield $pool->query('DROP TABLE IF EXISTS test');
|
|
|
|
/** @var Transaction $transaction */
|
|
$transaction = yield $pool->beginTransaction();
|
|
|
|
yield $transaction->query('CREATE TABLE test (domain VARCHAR(63), tld VARCHAR(63), PRIMARY KEY (domain, tld))');
|
|
|
|
/** @var Statement $statement */
|
|
$statement = yield $transaction->prepare('INSERT INTO test VALUES (?, ?)');
|
|
|
|
yield $statement->execute(['amphp', 'org']);
|
|
yield $statement->execute(['google', 'com']);
|
|
yield $statement->execute(['github', 'com']);
|
|
|
|
/** @var Result $result */
|
|
$result = yield $transaction->execute('SELECT * FROM test WHERE tld = :tld', ['tld' => 'com']);
|
|
|
|
$format = "%-20s | %-10s\n";
|
|
\printf($format, 'TLD', 'Domain');
|
|
while ($row = yield $result->continue()) {
|
|
\printf($format, $row['domain'], $row['tld']);
|
|
}
|
|
|
|
yield $transaction->rollback();
|
|
});
|