Calling libasynql functions won't execute until we call another one.

Aboshxm2 commented 1 year ago

Describe the bug When you call any libasynql function, let's say executeSelect, the onSelect function will never executed until another libasynql function called. and the second libasynql function well never get it's results until another function is called...

Something I noticed is that the bug does not exist in older versions. (before DEV-182 https://github.com/poggit/libasynql/commit/f0d668c9699824bb8d2433421c2401d385099a45)

Sample code https://github.com/Aboshxm2/libasyncql_query_bug

sqlite.sql

-- #!sqlite
-- #{ libasyncql_query_bug.init
CREATE TABLE IF NOT EXISTS example_table (playerName TEXT PRIMARY KEY, kills INTEGER);
-- #}
-- #{ libasyncql_query_bug.select
-- # :playerName string
SELECT * FROM example_table WHERE playerName=:playerName;
-- #}
-- #{ libasyncql_query_bug.insert
-- # :playerName string
-- # :kills int
INSERT INTO example_table (playerName, kills) VALUES (:playerName, :kills)
-- #}

Main.php

    private DataConnector $database;

    protected function onEnable(): void
    {
        $this->database = libasynql::create($this, [
            "type" => "sqlite",
            "sqlite" => ["file" => "data.sqlite"],
            "worker-limit" => 1
        ], [
            "sqlite" => "sqlite.sql"
        ]);

        $this->database->executeGeneric("libasyncql_query_bug.init", [], null, function (SqlError $error): void {
            throw new $error;
        });
    }

    public function onCommand(CommandSender $sender, Command $command, string $label, array $args): bool
    {
        if(!isset($args[0])) {
            $sender->sendMessage("/test (insert|select)");
            return true;
        }

        if($args[0] === "insert") {

            if(count($args) < 3) {
                $sender->sendMessage("/test insert (playerName) (kills)");
                return true;
            }

            $this->database->executeInsert("libasyncql_query_bug.insert", ["playerName" => $args[1], "kills" => (int)$args[2]], function (int $_) {
                var_dump("insert query executed successfully.");
            }, function (SqlError $error): void {
                throw new $error;
            });

        }elseif($args[0] === "select") {

            if(count($args) < 2) {
                $sender->sendMessage("/test select (playerName)");
                return true;
            }

            $this->database->executeSelect("libasyncql_query_bug.select", ["playerName" => $args[1]], function (array $rows) {
                var_dump("select query executed successfully.");
                var_dump($rows);
            }, function (SqlError $error): void {
                throw new $error;
            });
        }

Expected behavior When I do /test insert player1 10, It should display "insert query executed successfully." in the console. but it doesn't. until I send another command /test insert player2 10

Tests 1: /test insert player1 10. resaults: nothing.

2: /test insert player1 10 then /test select player1. resaults:

"insert query executed successfully.".

3: /test insert player1 10 then /test select player1 then /test select player2 resaults:

"insert query executed successfully."`
"select query executed successfully."
array(1) {
  [0]=>
  array(2) {
    ["playerName"]=>
    string(2) "player1"
    ["kills"]=>
    int(1)
  }
}

4: /test insert player1 10 then /test select player2 then /test select player1 resaults:

"insert query executed successfully."`
"select query executed successfully."
array(0) {
}

Environment OS: linux PocketMine version: 4.12.2 PHP version: 8.0.17

I am sorry if there any misspelling. English is not my main language.