libSQL
A minimalistic implementation of asynchronous SQL for PHP.
Installation via DEVirion
Install the DEVirion plugin and start your server. This will create a virions folder in your server's root directory.
server_root
| -> plugins
| --> DEVirion.phar
| -> virions
- Download pre-compiled
.pharfiles can be downloaded from poggit. - Place the pre-compiled
.pharin thevirionsdirectory
Running from source code
Clone the repository via git git clone [email protected]:cooldogedev/libSQL.git. This will create a libSQL folder in your directory.
your_plugin
| -> src
| --> cooldogedev
| --> libSQL
- Place the
cooldogedev\libSQLfolder in yoursrcdirectory.
Examples
Retrieve all customer records
"sqlite", "sqlite" => [ "data-file" => "test.db" ] ] ); $query = new class extends SQLiteQuery { public function handleIncomingConnection(SQLite3 $connection): ?array { return $connection->query($this->getQuery())?->fetchArray() ?: null; } public function getQuery(): string { return "SELECT * FROM " . $this->getTable(); } }; $connector->submitQuery($query, "customers", function (?array $customers): void { if (!$customers) { echo "No customers found"; return; } foreach ($customers as $customer) { echo $customer["name"]; } }, function (PromiseError $error): void { echo "An error occurred with the message " . $error->getMessage(); } ); ">
$connector = new DatabaseConnector($this, [ "provider" => "sqlite", "sqlite" => [ "data-file" => "test.db" ] ] ); $query = new class extends SQLiteQuery { public function handleIncomingConnection(SQLite3 $connection): ?array { return $connection->query($this->getQuery())?->fetchArray() ?: null; } public function getQuery(): string { return "SELECT * FROM " . $this->getTable(); } }; $connector->submitQuery($query, "customers", function (?array $customers): void { if (!$customers) { echo "No customers found"; return; } foreach ($customers as $customer) { echo $customer["name"]; } }, function (PromiseError $error): void { echo "An error occurred with the message " . $error->getMessage(); } );
Create a new customer record
"sqlite", "sqlite" => [ "data-file" => "test.db" ] ] ); $query = new class extends SQLiteQuery { public function __construct( protected string $name = "John", protected string $lastName = "Smith", protected int $age = 40 ) {} public function getName(): string { return $this->name; } public function getLastName(): string { return $this->lastName; } public function getAge(): int { return $this->age; } public function handleIncomingConnection(SQLite3 $connection): bool { $statement = $connection->prepare($this->getQuery()); $statement->bindValue(":name", $this->getName()); $statement->bindValue(":lastName", $this->getLastName()); $statement->bindValue(":age", $this->getAge()); $statement->execute(); $statement->close(); return true; } public function getQuery(): string { return "INSERT OR IGNORE INTO " . $this->getTable() . " (name, lastName, age) VALUES (:name, :lastName, :age)"; } }; $connector->submitQuery($query, "customers", function (): void { echo "Successfully created a new record!"; }, function (PromiseError $error): void { echo "An error occurred with the message " . $error->getMessage(); } ); ">
$connector = new DatabaseConnector($this, [ "provider" => "sqlite", "sqlite" => [ "data-file" => "test.db" ] ] ); $query = new class extends SQLiteQuery { public function __construct( protected string $name = "John", protected string $lastName = "Smith", protected int $age = 40 ) {} public function getName(): string { return $this->name; } public function getLastName(): string { return $this->lastName; } public function getAge(): int { return $this->age; } public function handleIncomingConnection(SQLite3 $connection): bool { $statement = $connection->prepare($this->getQuery()); $statement->bindValue(":name", $this->getName()); $statement->bindValue(":lastName", $this->getLastName()); $statement->bindValue(":age", $this->getAge()); $statement->execute(); $statement->close(); return true; } public function getQuery(): string { return "INSERT OR IGNORE INTO " . $this->getTable() . " (name, lastName, age) VALUES (:name, :lastName, :age)"; } }; $connector->submitQuery($query, "customers", function (): void { echo "Successfully created a new record!"; }, function (PromiseError $error): void { echo "An error occurred with the message " . $error->getMessage(); } );
196 Dec 28, 2022
0 Jan 9, 2022
427 Dec 30, 2022
2.2k Jan 3, 2023
441 Dec 11, 2022
777 Dec 17, 2022
19 Nov 25, 2022
240 Dec 20, 2022
11 Nov 8, 2022
1 Mar 6, 2022
18 Dec 10, 2022
0 Jan 7, 2022
533 Dec 30, 2022
257 Dec 29, 2022
368 Dec 27, 2022
618 Dec 30, 2022
162 Dec 19, 2022
4 Apr 15, 2022