mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-09-30 08:41:15 +00:00
a034774e3a
This patch introduces the SQLServer system server. This service is supposed to be the only process/application talking to database storage. This makes things like locking and caching more reliable, easier to implement, and more efficient. In LibSQL we added a client component that does the ugly IPC nitty- gritty for you. All that's needed is setting a number of event handler lambdas and you can connect to databases and execute statements on them. Applications that wish to use this SQLClient class obviously need to link LibSQL and LibIPC.
76 lines
1.8 KiB
C++
76 lines
1.8 KiB
C++
/*
|
|
* Copyright (c) 2021, Jan de Visser <jan@de-visser.net>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include <LibSQL/SQLClient.h>
|
|
|
|
namespace SQL {
|
|
|
|
SQLClient::~SQLClient()
|
|
{
|
|
}
|
|
|
|
void SQLClient::connected(int connection_id)
|
|
{
|
|
if (on_connected)
|
|
on_connected(connection_id);
|
|
}
|
|
|
|
void SQLClient::disconnected(int connection_id)
|
|
{
|
|
if (on_disconnected)
|
|
on_disconnected(connection_id);
|
|
}
|
|
|
|
void SQLClient::connection_error(int connection_id, int code, String const& message)
|
|
{
|
|
if (on_connection_error)
|
|
on_connection_error(connection_id, code, message);
|
|
else
|
|
warnln("Connection error for connection_id {}: {} ({})", connection_id, message, code);
|
|
}
|
|
|
|
void SQLClient::execution_error(int statement_id, int code, String const& message)
|
|
{
|
|
if (on_execution_error)
|
|
on_execution_error(statement_id, code, message);
|
|
else
|
|
warnln("Execution error for statement_id {}: {} ({})", statement_id, message, code);
|
|
}
|
|
|
|
void SQLClient::execution_success(int statement_id, bool has_results, int created, int updated, int deleted)
|
|
{
|
|
if (on_execution_success)
|
|
on_execution_success(statement_id, has_results, created, updated, deleted);
|
|
else
|
|
outln("{} row(s) created, {} updated, {} deleted", created, updated, deleted);
|
|
}
|
|
|
|
void SQLClient::next_result(int statement_id, Vector<String> const& row)
|
|
{
|
|
if (on_next_result) {
|
|
on_next_result(statement_id, row);
|
|
return;
|
|
}
|
|
bool first = true;
|
|
for (auto& column : row) {
|
|
if (!first)
|
|
out(", ");
|
|
out("\"{}\"", column);
|
|
first = false;
|
|
}
|
|
outln();
|
|
}
|
|
|
|
void SQLClient::results_exhausted(int statement_id, int total_rows)
|
|
{
|
|
if (on_results_exhausted)
|
|
on_results_exhausted(statement_id, total_rows);
|
|
else
|
|
outln("{} total row(s)", total_rows);
|
|
}
|
|
|
|
}
|