Update examples

amphp · Oct 14, 2018 · 6306f4f · 6306f4f
1 parent 9b51bbe
commit 6306f4f
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 5 deletions.
diff --git a/examples/basic.php b/examples/basic.php
@@ -6,8 +6,12 @@
 use Amp\Postgres;
 
 Amp\Loop::run(function () {
+    $host = 'localhost';
+    $port = Postgres\ConnectionConfig::DEFAULT_PORT;
+    $user = 'postgres';
+
     /** @var \Amp\Postgres\Connection $connection */
-    $connection = yield Postgres\connect(new Postgres\ConnectionConfig('host=localhost user=postgres'));
+    $connection = yield Postgres\connect(new Postgres\ConnectionConfig($host, $port, $user));
 
     /** @var \Amp\Postgres\ResultSet $result */
     $result = yield $connection->query('SHOW ALL');

diff --git a/examples/listen.php b/examples/listen.php
@@ -7,7 +7,11 @@
 use Amp\Postgres;
 
 Loop::run(function () {
-    $pool = Postgres\pool(new Postgres\ConnectionConfig('host=localhost user=postgres'));
+    $host = 'localhost';
+    $port = Postgres\ConnectionConfig::DEFAULT_PORT;
+    $user = 'postgres';
+
+    $pool = Postgres\pool(new Postgres\ConnectionConfig($host, $port, $user));
 
     $channel = "test";
 

diff --git a/examples/multi-listen.php b/examples/multi-listen.php
@@ -8,7 +8,11 @@
 use Amp\Postgres;
 
 Loop::run(function () {
-    $pool = Postgres\pool(new Postgres\ConnectionConfig('host=localhost user=postgres'));
+    $host = 'localhost';
+    $port = Postgres\ConnectionConfig::DEFAULT_PORT;
+    $user = 'postgres';
+
+    $pool = Postgres\pool(new Postgres\ConnectionConfig($host, $port, $user));
 
     $channel1 = "test1";
     $channel2 = "test2";

diff --git a/examples/transaction.php b/examples/transaction.php
@@ -6,12 +6,16 @@
 use Amp\Postgres;
 
 Amp\Loop::run(function () {
-    $pool = Postgres\pool(new Postgres\ConnectionConfig('host=localhost user=postgres'));
+    $host = 'localhost';
+    $port = Postgres\ConnectionConfig::DEFAULT_PORT;
+    $user = 'postgres';
+
+    $pool = Postgres\pool(new Postgres\ConnectionConfig($host, $port, $user));
 
     yield $pool->query('DROP TABLE IF EXISTS test');
 
     /** @var \Amp\Postgres\Transaction $transaction */
-    $transaction = yield $pool->transaction();
+    $transaction = yield $pool->beginTransaction();
 
     yield $transaction->query('CREATE TABLE test (domain VARCHAR(63), tld VARCHAR(63), PRIMARY KEY (domain, tld))');