amphp \ mysql не возвращает все записи - PullRequest
Новая
       10

amphp \ mysql не возвращает все записи

0 голосов
/ 28 августа 2018

Я новичок в amphp, так что прости меня, если что-то покажется глупым.

Мы начали использовать amphp \ mysql для запуска пула соединений для концепции потоков. У нас есть таблица «content», в которой 100 тыс. Записей. Попытка перечислить для дальнейшей обработки, но показывает только 42 записи. Кроме того, не имеет никакого заявления LIMIT.

Чего мне не хватает в моем коде?

Ниже приведен код: 

require "vendor/autoload.php";
use Amp\Loop;
use Amp\Artax\Request;
use Amp\Artax\Response;

$db = ''; 
Amp\Loop::run(function () {
        $client = new Amp\Artax\DefaultClient;
        $db = Amp\Mysql\pool("host=".$this->conn_prop['db_host']."; user=".$this->conn_prop['db_user']."; pass=".$this->conn_prop['db_passwd']."; db=".$this->conn_prop['db_name']);

        $statement = (yield $db->query("SELECT registration_id,w_id,ip,device_type FROM content WHERE active_status='1' AND  ip !=''"));
        $cnt = 0;
                while (yield $statement->advance()) {
                echo $cnt++;
                $row = $statement->getCurrent();
                if(!empty($row)){
                var_dump($row);
                .................
                ................
                }   
                }   
});
...