dazzle-php / pgsql

examples/base_example.php

Spacing +5 added lines, -5 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-require_once __DIR__.'/../vendor/autoload.php';
+require_once __DIR__ . '/../vendor/autoload.php';
 
 use Dazzle\Loop\Loop;
 use Dazzle\Loop\Model\SelectLoop;
@@ -18,12 +18,12 @@ 
     'dbname' => 'postgres'
 ]);
 
-$db->start()->then(function (Connection $conn) use ($loop) {
-    $conn->query('select \'ok\'')->then(function (Tuple $ret) use ($loop) {
+$db->start()->then(function(Connection $conn) use ($loop) {
+    $conn->query('select \'ok\'')->then(function(Tuple $ret) use ($loop) {
         print_r($ret->fetchRow());
     });
-    $conn->prepare('select \'ok\'')->then(function (Prepared $prepared) use ($loop) {
-        $prepared->execPreparedStmt()->then(function (TupleResultStatement $ret) use ($loop) {
+    $conn->prepare('select \'ok\'')->then(function(Prepared $prepared) use ($loop) {
+        $prepared->execPreparedStmt()->then(function(TupleResultStatement $ret) use ($loop) {
             print_r($ret->fetchRow());
             $loop->stop();
         });

examples/transaction_example.php

Spacing +10 added lines, -10 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-require_once __DIR__.'/../vendor/autoload.php';
+require_once __DIR__ . '/../vendor/autoload.php';
 
 use Dazzle\Loop\Loop;
 use Dazzle\PgSQL\Database;
@@ -18,29 +18,29 @@ 
     'dbname' => 'postgres'
 ]);
 
-$db->on('transaction:begin', function () use ($loop, $db) {
-    echo 'Transaction Stated'.PHP_EOL;
+$db->on('transaction:begin', function() use ($loop, $db) {
+    echo 'Transaction Stated' . PHP_EOL;
 });
 
-$db->on('transaction:end', function () use ($loop, $db) {
-    $db->getConnection()->then(function (ConnectionInterface $conn) use ($loop) {
+$db->on('transaction:end', function() use ($loop, $db) {
+    $db->getConnection()->then(function(ConnectionInterface $conn) use ($loop) {
         $conn->query('select * from demo order by id desc limit 1')
-        ->then(function (TupleResultStatement $tuple) use ($loop) {
+        ->then(function(TupleResultStatement $tuple) use ($loop) {
             print_r($tuple->fetchAll());
             $loop->stop();
-            echo 'Transaction End'.PHP_EOL;
+            echo 'Transaction End' . PHP_EOL;
         });
     });
 });
 
 $db->beginTransaction()
- ->then(function (TransactionInterface $trans) use ($loop) {
+ ->then(function(TransactionInterface $trans) use ($loop) {
     $trans->query('select * from demo order by id desc limit 1')
-    ->then(function (TupleResultStatement $tuple) {
+    ->then(function(TupleResultStatement $tuple) {
         print_r($tuple->fetchAll());
     });
     $trans->execute('insert into demo default values')
-    ->then(function (CommandResult $result) use ($trans) {
+    ->then(function(CommandResult $result) use ($trans) {
         if ($result->getAffectedRows() > 0) {
             $trans->rollback();
         }

src/PgSQL/Database.php

Spacing +10 added lines, -10 removed lines

@@ -8,7 +8,7 @@ 
 use Dazzle\PgSQL\Transaction\Transaction;
 use Dazzle\Promise\Promise;
 use Dazzle\Throwable\Exception;
-use Dazzle\PgSQL\Transaction\TransactionInterface ;
+use Dazzle\PgSQL\Transaction\TransactionInterface;
 use Dazzle\Throwable\Exception\Runtime\ExecutionException;
 
 class Database extends BaseEventEmitter implements DatabaseInterface
@@ -18,42 +18,42 @@ 
     /**
      * @var int
      */
-    const STATE_INIT                 = 0;
+    const STATE_INIT = 0;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_PENDING      = 4;
+    const STATE_CONNECT_PENDING = 4;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_FAILED       = 2;
+    const STATE_CONNECT_FAILED = 2;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_SUCCEEDED    = 6;
+    const STATE_CONNECT_SUCCEEDED = 6;
 
     /**
      * @var int
      */
-    const STATE_AUTH_PENDING         = 5;
+    const STATE_AUTH_PENDING = 5;
 
     /**
      * @var int
      */
-    const STATE_AUTH_FAILED          = 3;
+    const STATE_AUTH_FAILED = 3;
 
     /**
      * @var int
      */
-    const STATE_AUTH_SUCCEEDED       = 7;
+    const STATE_AUTH_SUCCEEDED = 7;
 
     /**
      * @var int
      */
-    const STATE_DISCONNECT_PENDING   = 8;
+    const STATE_DISCONNECT_PENDING = 8;
 
     /**
      * @var int
@@ -203,7 +203,7 @@ 
             return Promise::doResolve($trans);
         }
         //bad method: append 1 callback
-        return $this->start()->success(function ($_) {
+        return $this->start()->success(function($_) {
             $trans = new Transaction($this->connector, $this);
 
             return $trans->begin();

src/PgSQL/Connection/Connector.php

Spacing +2 added lines, -2 removed lines

@@ -24,7 +24,7 @@ 
 
     public function __construct($config)
     {
-        $this->stream = pg_connect($config, \PGSQL_CONNECT_ASYNC|\PGSQL_CONNECT_FORCE_NEW);
+        $this->stream = pg_connect($config, \PGSQL_CONNECT_ASYNC | \PGSQL_CONNECT_FORCE_NEW);
         $this->conn = new Connection();
     }
 
@@ -45,7 +45,7 @@ 
         $promise = $this->conn->getPromise();
 
         return $promise
-               ->success(function (ConnectorInterface $connector) use ($connection) {
+               ->success(function(ConnectorInterface $connector) use ($connection) {
                    $connection->setConnector($connector);
 
                    return $connection;

src/PgSQL/Transaction/Transaction.php

Spacing +3 added lines, -3 removed lines

@@ -63,7 +63,7 @@ 
             return Promise::doResolve($this);
         }
 
-        return $this->connector->execute('BEGIN')->success(function (CommandResultStatement $result) {
+        return $this->connector->execute('BEGIN')->success(function(CommandResultStatement $result) {
             if ($result) {
                 $this->emitter->emit('transaction:begin');
             }
@@ -78,7 +78,7 @@ 
      */
     public function commit()
     {
-       return $this->connector->execute('COMMIT')->success(function (CommandResultStatement $result) {
+       return $this->connector->execute('COMMIT')->success(function(CommandResultStatement $result) {
            if ($result) {
                $this->emitter->emit('transaction:end');
            }
@@ -93,7 +93,7 @@ 
      */
     public function rollback()
     {
-       return $this->connector->execute('ROLLBACK')->success(function (CommandResultStatement $result) {
+       return $this->connector->execute('ROLLBACK')->success(function(CommandResultStatement $result) {
            if ($result) {
                $this->emitter->emit('transaction:end');    
            }

src/PgSQL/Result/Result.php

Spacing +1 added lines, -1 removed lines

@@ -1,7 +1,7 @@
 <?php
 namespace Dazzle\PgSQL\Result;
 
-interface Result extends CommandResultStatement,TupleResultStatement
+interface Result extends CommandResultStatement, TupleResultStatement
 {
 
 }
\ No newline at end of file

src/PgSQL/Statement/StatementAwareTrait.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 
     public function getParams()
     {
-        return $this->params?:[];
+        return $this->params ?: [];
     }
 
     public function setSQL($sql)

src/PgSQL/Statement/Statement.php

Spacing +1 added lines, -1 removed lines

@@ -4,7 +4,7 @@
 use Dazzle\PgSQL\Connection\ConnectorInterface;
 use Dazzle\Promise\DeferredInterface;
 
-interface Statement extends DeferredInterface,StatementHandler
+interface Statement extends DeferredInterface, StatementHandler
 {
     public function getSQL();
     public function setSQL($sql);