|
@@ -94,7 +94,7 @@ class HttpServerRedisToSql
|
|
|
$this->httpserver->account->add();
|
|
$this->httpserver->account->add();
|
|
|
|
|
|
|
|
$batchsql = [];
|
|
$batchsql = [];
|
|
|
- $max = 5000;
|
|
|
|
|
|
|
+ $max = 100;
|
|
|
|
|
|
|
|
for ($i = 0; $i < $max; $i++) {
|
|
for ($i = 0; $i < $max; $i++) {
|
|
|
$now = $redis->rpop(self::SQLKEY);
|
|
$now = $redis->rpop(self::SQLKEY);
|
|
@@ -112,11 +112,11 @@ class HttpServerRedisToSql
|
|
|
try {
|
|
try {
|
|
|
$erowcount = $pdo->exec($sqlstr);
|
|
$erowcount = $pdo->exec($sqlstr);
|
|
|
} catch (\Exception $e) {
|
|
} catch (\Exception $e) {
|
|
|
- echo "发生异常:" . $e->getCode() . ' ---- ' . print_r($e->getMessage(),true) . "\n";
|
|
|
|
|
|
|
+ echo "发生异常:" . $e->getCode() . ' ---- ' . print_r($e->getMessage(), true) . "\n";
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if (!$erowcount) {
|
|
if (!$erowcount) {
|
|
|
- echo "\n发生错误:" . $pdo->errorCode() . ' ---- ' . $pdo->errorInfo() . "\n";
|
|
|
|
|
|
|
+ echo "\n发生错误:" . $pdo->errorCode() . ' ---- ' . print_r($pdo->errorInfo(), true) . "\n";
|
|
|
echo "错误sql: " . $sqlstr . "\n\n";
|
|
echo "错误sql: " . $sqlstr . "\n\n";
|
|
|
} else {
|
|
} else {
|
|
|
echo "成功运行:" . count($batchsql) . " 条!\n";
|
|
echo "成功运行:" . count($batchsql) . " 条!\n";
|