|
@@ -108,13 +108,20 @@ class HttpServerRedisToSql
|
|
|
if (!empty($batchsql)) {
|
|
if (!empty($batchsql)) {
|
|
|
$pdo = DB::getPdo();
|
|
$pdo = DB::getPdo();
|
|
|
$sqlstr = implode(";", $batchsql);
|
|
$sqlstr = implode(";", $batchsql);
|
|
|
- $erowcount = $pdo->exec($sqlstr);
|
|
|
|
|
|
|
+ $erowcount = 0;
|
|
|
|
|
+ try {
|
|
|
|
|
+ $erowcount = $pdo->exec($sqlstr);
|
|
|
|
|
+ } catch (\Exception $e) {
|
|
|
|
|
+ echo "发生异常:" . $e->getCode() . ' ---- ' . $e->getMessage() . "\n";
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
if (!$erowcount) {
|
|
if (!$erowcount) {
|
|
|
echo "\n发生错误:" . $pdo->errorCode() . ' ---- ' . $pdo->errorInfo() . "\n";
|
|
echo "\n发生错误:" . $pdo->errorCode() . ' ---- ' . $pdo->errorInfo() . "\n";
|
|
|
echo "错误sql: " . $sqlstr . "\n\n";
|
|
echo "错误sql: " . $sqlstr . "\n\n";
|
|
|
} else {
|
|
} else {
|
|
|
echo "成功运行:" . count($batchsql) . " 条!\n";
|
|
echo "成功运行:" . count($batchsql) . " 条!\n";
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
}
|
|
}
|
|
|
$redis->close();
|
|
$redis->close();
|
|
|
echo "总请求数" . $this->httpserver->account->get() . " 单个线程消耗时间: " . (microtime(true) - $begint) . " s \n";
|
|
echo "总请求数" . $this->httpserver->account->get() . " 单个线程消耗时间: " . (microtime(true) - $begint) . " s \n";
|