dxkite / suda

suda/src/database/struct/TableClassStructBuilder.php

Spacing +3 added lines, -3 removed lines

@@ -40,7 +40,7 @@ 
     public function __construct(string $object)
     {
         parent::__construct($object);
-        $this->classDoc = is_string($this->reflectObject->getDocComment())?$this->reflectObject->getDocComment():'';
+        $this->classDoc = is_string($this->reflectObject->getDocComment()) ? $this->reflectObject->getDocComment() : '';
     }
 
 
@@ -63,14 +63,14 @@ 
      * @param string $classDoc
      * @return array|null
      */
-    public static function readClassDocField(string $classDoc):?array
+    public static function readClassDocField(string $classDoc): ?array
     {
         if (preg_match_all(
             '/^.+\s+\@field(?:\-(?:serialize|json))?\s+(\w+)\s+(\w+)(?:\((.+?)\))?(.*?)$/im',
             $classDoc,
             $match
         ) > 0) {
-            return is_array($match)?$match:null;
+            return is_array($match) ? $match : null;
         }
         return null;
     }

suda/src/database/Binder.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
      */
     public static function index(string $name): string
     {
-        return '_' . $name . '_' . static::$index;
+        return '_'.$name.'_'.static::$index;
     }
 
     /**

suda/src/database/connection/Connection.php

Spacing +4 added lines, -4 removed lines

@@ -79,7 +79,7 @@ 
         $this->config = $config;
         $this->name = $name ?? 'anonymous';
         $this->observer = new NullObserver;
-        register_shutdown_function(function () {
+        register_shutdown_function(function() {
             $this->onBeforeSystemShutdown();
         });
     }
@@ -107,7 +107,7 @@ 
             try {
                 $this->pdo = $this->createPDO();
                 $this->id = static::$connectionCount;
-                static::$connectionCount ++;
+                static::$connectionCount++;
             } catch (PDOException $e) {
                 throw new SQLException(sprintf(
                     "%s connect database error:%s",
@@ -180,7 +180,7 @@ 
      */
     public function beginTransaction()
     {
-        $this->transaction ++;
+        $this->transaction++;
         if ($this->transaction == 1) {
             $this->pdo->beginTransaction();
         }
@@ -370,7 +370,7 @@ 
      * @param string $query
      * @return string
      */
-    public function prefix( string $query):string
+    public function prefix(string $query):string
     {
         // _:table 前缀控制
         $prefix = $this->getConfig('prefix', '');

suda/src/database/connection/MySQLConnection.php

Spacing +2 added lines, -2 removed lines

@@ -45,7 +45,7 @@ 
             $password = $this->config['password'] ?? '';
             $pdo = new PDO($this->getDsn(), $user, $password);
             $this->id = static::$connectionCount;
-            static::$connectionCount ++;
+            static::$connectionCount++;
             return $pdo;
         } catch (PDOException $e) {
             throw new SQLException(sprintf(
@@ -64,7 +64,7 @@ 
      */
     public function switchDatabase(string $database)
     {
-        return $this->query(new QueryStatement('USE `' . $database.'`'));
+        return $this->query(new QueryStatement('USE `'.$database.'`'));
     }
 
     public function rawTableName(string $name)

suda/src/database/connection/SQLiteConnection.php

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
         try {
             $pdo = new PDO($this->getDsn());
             $this->id = static::$connectionCount;
-            static::$connectionCount ++;
+            static::$connectionCount++;
             return $pdo;
         } catch (PDOException $e) {
             throw new SQLException(
@@ -62,7 +62,7 @@ 
      */
     public function switchDatabase(string $database)
     {
-        return $this->query(new QueryStatement('USE `' . $database.'`'));
+        return $this->query(new QueryStatement('USE `'.$database.'`'));
     }
 
     /**

suda/src/database/statement/PrepareTrait.php

Braces +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
                 $where = str_replace(':'.$name, $inSQL, $where);
             } elseif($value instanceof  Binder) {
                 $newWhereBinder[] = $value;
-            }else{
+            } else{
                 $newWhereBinder[] = new Binder($name, $value);
             }
         }

Spacing +6 added lines, -6 removed lines

@@ -25,7 +25,7 @@ 
             $fields = $reads;
         } else {
             $field = [];
-            $prefix = strlen($table) ?"`{$table}`." :'';
+            $prefix = strlen($table) ? "`{$table}`." : '';
             foreach ($reads as $want) {
                 $field[] = $prefix."`$want`";
             }
@@ -81,9 +81,9 @@ 
                 $newWhereBinder = array_merge($newWhereBinder, $binders);
                 $name = ltrim($name, ':');
                 $where = str_replace(':'.$name, $inSQL, $where);
-            } elseif($value instanceof  Binder) {
+            } elseif ($value instanceof  Binder) {
                 $newWhereBinder[] = $value;
-            }else{
+            } else {
                 $newWhereBinder[] = new Binder($name, $value);
             }
         }
@@ -103,7 +103,7 @@ 
     {
         list($inSQL, $binders) = $this->prepareInParameter($values, $name);
         $sql = $name.' IN ('.$inSQL.')';
-        return [$sql,$binders];
+        return [$sql, $binders];
     }
 
     /**
@@ -155,7 +155,7 @@ 
     protected function prepareQueryMark(string $sql, array $parameter)
     {
         $binders = [];
-        $query = preg_replace_callback('/\?/', function ($match) use (&$binders, $parameter) {
+        $query = preg_replace_callback('/\?/', function($match) use (&$binders, $parameter) {
             $index = count($binders);
             if (array_key_exists($index, $parameter)) {
                 $name = Binder::index($index);
@@ -184,7 +184,7 @@ 
     protected function mergeBinder(array $binderArray, array $parameter)
     {
         foreach ($parameter as $key => $value) {
-            if (! ($value instanceof Binder)) {
+            if (!($value instanceof Binder)) {
                 $value = new Binder($key, $value);
             }
             if (!in_array($value, $binderArray)) {

suda/src/database/DataAccess.php

Spacing +1 added lines, -1 removed lines

@@ -290,7 +290,7 @@
     protected static function createDefaultMiddleware(string $object, TableStruct $struct)
     {
         $reflectObject = new ReflectionClass($object);
-        $classDoc = is_string($reflectObject->getDocComment())?$reflectObject->getDocComment():'';
+        $classDoc = is_string($reflectObject->getDocComment()) ? $reflectObject->getDocComment() : '';
         if (preg_match('/@field-(serialize|json)\s+(\w+)/i', $classDoc, $matchs)) {
             return new TableStructMiddleware($object, $struct);
         }

suda/src/database/DataSource.php

Spacing +1 added lines, -1 removed lines

@@ -115,7 +115,7 @@
      * @return Connection
      * @throws SQLException
      */
-    public static function new(string $type, array $config, ?string $name = null): Connection
+    public static function new(string $type, array $config, ?string $name = null) : Connection
     {
         if (array_key_exists($type, static::$type)) {
             return new static::$type[$type]($config, $name);

suda/src/application/database/Database.php

Spacing +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
      */
     public static function getDataSourceFrom(ApplicationResource $resource, string $groupName)
     {
-        $group = $groupName === 'default' ? '': '-'. $groupName;
+        $group = $groupName === 'default' ? '' : '-'.$groupName;
         $dataSourceConfigPath = $resource->getConfigResourcePath('config/data-source'.$group);
         $dataSource = new DataSource;
         $observer = new DebugObserver(static::$application->debug());