发表新帖

协程Pdo并发写入报错

### 问题描述
协程并发，pod->execute() 执行报错，报错信息如下
CDbCommand 无法执行 SQL 语句: SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other unbuffered queries are active.  Consider using PDOStatement::fetchAll().  Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute. (framework/db/CDbCommand.php:411)

### Swoole版本，PHP版本，以及操作系统版本信息
Swoole版本：4.6.1
PHP版本：7.2.7
操作系统：Centos 7.2.7

### 相关代码
```php
 $chan = new \Swoole\Coroutine\Channel($xcNums);
 \Swoole\Coroutine::create(function () use ($chan) {
                $arrHeader = [];
                $context = \Co::getContext();
                $context->bizLog = clone $bizLog;
				$context->bizObj = new test();
               
                while (true) {
                    $message = $chan->pop();
                    $start = microtime(true) * 1000;
                    $startTime = microtime(true);
                    $arrMessage = json_decode($message->payload, true);
                    $retryNums = 1
                    $re = $bizObj->consumeMessage($arrMessage);   //里面是读写数据库的操作
                }
            });

}
```

### 你期待的结果是什么？实际看到的错误信息又是什么？

发布于4年前 · 32 次浏览 · 来自提问