更改执行方法

zhouyangyang · zhouyangyang · commit 81e4335d955f · 2020-08-04T10:49:18.000+08:00
diff --git a/src/Sync.php b/src/Sync.php
@@ -101,13 +101,13 @@ private function executeAddTables($add_table_sql_collect)
     {
         $this->localConnector->query('SET FOREIGN_KEY_CHECKS=0');
         foreach ($add_table_sql_collect as $key => $sql) {
-            if ($this->localConnector->query($sql)) {
+            if ($this->localConnector->exec($sql)) {
                 $this->statistics['success']['ADD_TABLE'][] = $sql;
                 unset($add_table_sql_collect[$key]);
             } else {
                 $this->statistics['error']['ADD_TABLE'][] = $sql;
             }
         }
-        $this->localConnector->query('SET FOREIGN_KEY_CHECKS=1');
+        $this->localConnector->exec('SET FOREIGN_KEY_CHECKS=1');
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -101,13 +101,13 @@ private function executeAddTables($add_table_sql_collect)`
`101`	`101`	`{`
`102`	`102`	`$this->localConnector->query('SET FOREIGN_KEY_CHECKS=0');`
`103`	`103`	`foreach ($add_table_sql_collect as $key => $sql) {`
`104`		`- if ($this->localConnector->query($sql)) {`
	`104`	`+ if ($this->localConnector->exec($sql)) {`
`105`	`105`	`$this->statistics['success']['ADD_TABLE'][] = $sql;`
`106`	`106`	`unset($add_table_sql_collect[$key]);`
`107`	`107`	`} else {`
`108`	`108`	`$this->statistics['error']['ADD_TABLE'][] = $sql;`
`109`	`109`	`}`
`110`	`110`	`}`
`111`		`- $this->localConnector->query('SET FOREIGN_KEY_CHECKS=1');`
	`111`	`+ $this->localConnector->exec('SET FOREIGN_KEY_CHECKS=1');`
`112`	`112`	`}`
`113`	`113`	`}`