dazzle-php / pgsql

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

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/Database.php

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

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

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

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/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/PrepareQuery.php

Braces +2 added lines, -1 removed lines

@@ -53,7 +53,8 @@
     public function handle($result)
     {
         $stat = pg_result_status($result, \PGSQL_STATUS_LONG);
-        if ($stat != PGSQL_COMMAND_OK) {
+        if ($stat != PGSQL_COMMAND_OK)
+        {
             return new \Exception('error');
         }