Package dev.frostlake

Class ConcurrentDatabaseEngine

java.lang.Object

dev.frostlake.ConcurrentDatabaseEngine

public class ConcurrentDatabaseEngine
extends Object

Thread-safe wrapper around DatabaseEngine for concurrent multi-user access Manages sessions and ensures proper isolation between concurrent requests

Constructor Summary

Constructors

Constructor	Description
ConcurrentDatabaseEngine()
ConcurrentDatabaseEngine(EngineConfig config)	A concurrent wrapper honoring the given configuration (database.default / schema.default).

Method Summary

Modifier and Type	Method	Description
SessionContext	createSession()
ExecutionResult	execute(String sql, SessionContext session)	Execute SQL in a session context
ExecutionResult	execute(String sql, SessionContext session, Boolean clientAutoCommit)	Execute SQL in a session context, the session first following the autocommit mode the client declares for this request (see SessionContext.followClientAutoCommit(Boolean)).
ResultSet	executeQuery(String sql, SessionContext session)	Execute query and return single result set
int	getActiveSessionCount()
DatabaseEngine	getEngine()
SessionContext	getOrCreateSession(String sessionId)
SessionContext	getSession(String sessionId)
SessionManager	getSessionManager()
void	removeSession(String sessionId)
void	shutdown()	Shutdown the concurrent engine

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConcurrentDatabaseEngine

public ConcurrentDatabaseEngine()

ConcurrentDatabaseEngine

public ConcurrentDatabaseEngine(EngineConfig config)

A concurrent wrapper honoring the given configuration (database.default / schema.default).

Method Details

execute

public ExecutionResult execute(String sql,
 SessionContext session)

Execute SQL in a session context

execute

public ExecutionResult execute(String sql,
 SessionContext session,
 Boolean clientAutoCommit)

Execute SQL in a session context, the session first following the autocommit mode the client declares for this request (see SessionContext.followClientAutoCommit(Boolean)).

Parameters:

sql - the statement text

session - the session to run in

clientAutoCommit - the request's autocommit mode, or null when it declares none

Returns:

the statement's result

executeQuery

public ResultSet executeQuery(String sql,
 SessionContext session)

Execute query and return single result set

createSession

public SessionContext createSession()

getOrCreateSession

public SessionContext getOrCreateSession(String sessionId)

getSession

public SessionContext getSession(String sessionId)

removeSession

public void removeSession(String sessionId)

getActiveSessionCount

public int getActiveSessionCount()

getEngine

public DatabaseEngine getEngine()

getSessionManager

public SessionManager getSessionManager()

shutdown

public void shutdown()

Shutdown the concurrent engine