reactCsvImporter ($5) · Snippets

When commenting out the queries in line 41 and 49, everything is fine. But as soon as i have this lines 41 to 43 and 49 to 51 in the code, i get this exception ...

PHP Fatal error:  Call to a member function setError() on null in /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/mysql/src/Protocal/Parser.php on line 331
PHP Stack trace:
PHP   1. {main}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/importPrices.php:0
PHP   2. React\EventLoop\StreamSelectLoop->run() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/importPrices.php:48
PHP   3. React\EventLoop\StreamSelectLoop->waitForStreamActivity() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:205
PHP   4. call_user_func:{/var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:238}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:238
PHP   5. React\Stream\DuplexResourceStream->handleData() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:238
PHP   6. Evenement\EventEmitter->emit() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/stream/src/DuplexResourceStream.php:193
PHP   7. call_user_func_array:{/var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
PHP   8. React\Stream\Util::React\Stream\{closure}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
PHP   9. Evenement\EventEmitter->emit() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/stream/src/Util.php:71
PHP  10. call_user_func_array:{/var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
PHP  11. React\MySQL\Protocal\Parser->parse() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
PHP  12. React\MySQL\Protocal\Parser->onError() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/mysql/src/Protocal/Parser.php:214

Fatal error: Call to a member function setError() on null in /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/mysql/src/Protocal/Parser.php on line 331

Call Stack:
    0.0003     240936   1. {main}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/importPrices.php:0
    0.0135    1471336   2. React\EventLoop\StreamSelectLoop->run() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/importPrices.php:48
    0.0371    2002416   3. React\EventLoop\StreamSelectLoop->waitForStreamActivity() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:205
    0.0371    2003168   4. call_user_func:{/var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:238}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:238
    0.0371    2003200   5. React\Stream\DuplexResourceStream->handleData() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/event-loop/src/StreamSelectLoop.php:238
    0.0372    2069472   6. Evenement\EventEmitter->emit() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/stream/src/DuplexResourceStream.php:193
    0.0372    2069520   7. call_user_func_array:{/var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
    0.0372    2069856   8. React\Stream\Util::React\Stream\{closure}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
    0.0372    2070160   9. Evenement\EventEmitter->emit() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/stream/src/Util.php:71
    0.0372    2070208  10. call_user_func_array:{/var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70}() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
    0.0372    2070544  11. React\MySQL\Protocal\Parser->parse() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/evenement/evenement/src/Evenement/EventEmitterTrait.php:70
    0.0406    2035408  12. React\MySQL\Protocal\Parser->onError() /var/www/freibier.bergfreunde.de/htdocs/_bf/2018.int-v5/vendor/react/mysql/src/Protocal/Parser.php:214

Sounds oddly familiar… https://github.com/friends-of-reactphp/mysql/issues/70

The MySQL project is currently in beta and undergoing some major changes. Reach out if you want to sponsor some improvements 😉 🎉

Also note that this will fire a lot of concurrent queries which end up being queued due to MySQL's protocol design. You may want to use https://github.com/clue/reactphp-flux to throttle the input stream when queries are already running.