dazzle-php / pgsql

src/PgSQL/Database.php

Doc Comments +1 added lines, -1 removed lines

@@ -236,7 +236,7 @@
      * Create configuration file.
      *
      * @param mixed[] $config
-     * @return mixed[]
+     * @return string
      */
     protected function createConfig($config = [])
     {

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();

Braces +8 added lines, -4 removed lines

@@ -136,7 +136,8 @@ 
         $this->connector = new Connector($this->config);
         $this->state = self::STATE_CONNECT_PENDING;
         $promise = $this->connector->getConnection();
-        if (!($sock = $this->connector->getSock())) {
+        if (!($sock = $this->connector->getSock()))
+        {
             return $promise->reject(new Exception('No server connection is currently open'));
         }
         $this->loop->addReadStream($sock, [$this->connector, 'connect']);
@@ -197,7 +198,8 @@ 
      */
     public function beginTransaction()
     {
-        if ($this->isStarted()) {
+        if ($this->isStarted())
+        {
             $trans = new Transaction($this->connector, $this);
 
             return Promise::doResolve($trans);
@@ -247,8 +249,10 @@ 
             'dbname'   => '',
         ];
         $config = array_merge($default, $config);
-        foreach ($config as $key => &$value) {
-            if (!$value) {
+        foreach ($config as $key => &$value)
+        {
+            if (!$value)
+            {
                 unset($config[$key]);
                 continue;
             }

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

Indentation +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
 });
 
 $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) {
         print_r($tuple->fetchAll());

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();
         }

Braces +2 added lines, -1 removed lines

@@ -41,7 +41,8 @@
     });
     $trans->execute('insert into demo default values')
     ->then(function (CommandResult $result) use ($trans) {
-        if ($result->getAffectedRows() > 0) {
+        if ($result->getAffectedRows() > 0)
+        {
             $trans->rollback();
         }
     });

src/PgSQL/Connection/Connector.php

Indentation +4 added lines, -4 removed lines

@@ -45,11 +45,11 @@
         $promise = $this->conn->getPromise();
 
         return $promise
-               ->success(function (ConnectorInterface $connector) use ($connection) {
-                   $connection->setConnector($connector);
+                ->success(function (ConnectorInterface $connector) use ($connection) {
+                    $connection->setConnector($connector);
 
-                   return $connection;
-               });
+                    return $connection;
+                });
     }
 
     public function connect()

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;

Braces +16 added lines, -8 removed lines

@@ -54,32 +54,40 @@ 
 
     public function connect()
     {
-        switch ($polled = $this->poll()) {
+        switch ($polled = $this->poll())
+        {
             case \PGSQL_POLLING_FAILED:
                 return;
             case \PGSQL_POLLING_OK:
-                if ($this->isConnected() != true) {
+                if ($this->isConnected() != true)
+                {
                     $this->connected = true;
                     $this->conn->resolve($this);
 
                     return;
                 }
                 $retRsrc = \pg_get_result($this->stream);
-                if ($retRsrc) {
-                    if (empty($this->retQueue)) {
+                if ($retRsrc)
+                {
+                    if (empty($this->retQueue))
+                    {
                         
                         return;
                     }
                     $ret = array_shift($this->retQueue);
                     $ret->resolve($ret->handle($retRsrc));
-                } else {
-                    if (empty($this->queryQueue)) {
+                }
+                else
+                {
+                    if (empty($this->queryQueue))
+                    {
 
                         return;
                     }
                     $query = array_shift($this->queryQueue);
                     $ok = $query->execute($this);
-                    if (!$ok) {
+                    if (!$ok)
+                    {
                         $query->reject(new \Exception('failed'));
 
                         return;
@@ -92,7 +100,7 @@ 
     }
 
     public function prepare($sql)
-    {        
+    {
         $prepare = new PrepareQuery($sql);
         $this->appendQuery($prepare);
         $promise = $prepare->getPromise();

src/PgSQL/Transaction/Transaction.php

Indentation +12 added lines, -12 removed lines

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

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');    
            }

Braces +8 added lines, -4 removed lines

@@ -59,12 +59,14 @@ 
 
     public function begin()
     {
-        if ($this->isOpen()) {
+        if ($this->isOpen())
+        {
             return Promise::doResolve($this);
         }
 
         return $this->connector->execute('BEGIN')->success(function (CommandResultStatement $result) {
-            if ($result) {
+            if ($result)
+            {
                 $this->emitter->emit('transaction:begin');
             }
 
@@ -79,7 +81,8 @@ 
     public function commit()
     {
        return $this->connector->execute('COMMIT')->success(function (CommandResultStatement $result) {
-           if ($result) {
+           if ($result)
+           {
                $this->emitter->emit('transaction:end');
            }
 
@@ -94,7 +97,8 @@ 
     public function rollback()
     {
        return $this->connector->execute('ROLLBACK')->success(function (CommandResultStatement $result) {
-           if ($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/StatementHandler.php

Braces +1 added lines, -1 removed lines

@@ -3,7 +3,7 @@
 
 use Dazzle\PgSQL\Connection\ConnectorInterface;
 
-interface StatementHandler 
+interface StatementHandler
 {
     public function execute(ConnectorInterface $connector);
     public function handle($result);

src/PgSQL/Statement/StatementHandlerTrait.php

Braces +2 added lines, -1 removed lines

@@ -9,7 +9,8 @@
     public function handle($result)
     {
         $stat = pg_result_status($result, \PGSQL_STATUS_LONG);
-        switch ($stat) {
+        switch ($stat)
+        {
             case PGSQL_EMPTY_QUERY:
                 break;
             case PGSQL_COMMAND_OK:

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)