fff

datainf/logic/HttpServerRedisToSql.php

@@ -108,12 +108,15 @@ class HttpServerRedisToSql
 
             if (!empty($batchsql)) {
                 $pdo = DB::getPdo();
+                DB::beginTransaction();
                 $sqlstr = implode(";", $batchsql);
                 $erowcount = 0;
                 try {
                     echo "\n SQL===> " . date('Y-m-d H:i:s') . "\n" . implode("\n", $batchsql) . "\n\n";
                     $erowcount = $pdo->exec($sqlstr);
+                    DB::commit();
                 } catch (\Exception $e) {
+                    DB::rollBack();
                     echo "发生异常：" . $e->getCode() . ' ---- ' . print_r($e->getMessage(), true) . "\n";
                 }