summaryrefslogtreecommitdiff
path: root/Userland/Services/SQLServer/SQLStatement.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'Userland/Services/SQLServer/SQLStatement.cpp')
-rw-r--r--Userland/Services/SQLServer/SQLStatement.cpp11
1 files changed, 5 insertions, 6 deletions
diff --git a/Userland/Services/SQLServer/SQLStatement.cpp b/Userland/Services/SQLServer/SQLStatement.cpp
index 3bd03dc89b..d4b9f583fc 100644
--- a/Userland/Services/SQLServer/SQLStatement.cpp
+++ b/Userland/Services/SQLServer/SQLStatement.cpp
@@ -12,9 +12,10 @@
namespace SQLServer {
-static HashMap<int, NonnullRefPtr<SQLStatement>> s_statements;
+static HashMap<u64, NonnullRefPtr<SQLStatement>> s_statements;
+static u64 s_next_statement_id = 0;
-RefPtr<SQLStatement> SQLStatement::statement_for(int statement_id)
+RefPtr<SQLStatement> SQLStatement::statement_for(u64 statement_id)
{
if (s_statements.contains(statement_id))
return *s_statements.get(statement_id).value();
@@ -22,8 +23,6 @@ RefPtr<SQLStatement> SQLStatement::statement_for(int statement_id)
return nullptr;
}
-static int s_next_statement_id = 0;
-
SQL::ResultOr<NonnullRefPtr<SQLStatement>> SQLStatement::create(DatabaseConnection& connection, StringView sql)
{
auto parser = SQL::AST::Parser(SQL::AST::Lexer(sql));
@@ -54,7 +53,7 @@ void SQLStatement::report_error(SQL::Result result)
remove_from_parent();
if (client_connection)
- client_connection->async_execution_error(statement_id(), (int)result.error(), result.error_string());
+ client_connection->async_execution_error(statement_id(), result.error(), result.error_string());
else
warnln("Cannot return execution error. Client disconnected");
@@ -129,7 +128,7 @@ void SQLStatement::next()
next();
});
} else {
- client_connection->async_results_exhausted(statement_id(), (int)m_index);
+ client_connection->async_results_exhausted(statement_id(), m_index);
}
}