Package ai.acolite.agentsdk.core.memory

Class SQLiteSession

java.lang.Object

ai.acolite.agentsdk.core.memory.SQLiteSession

All Implemented Interfaces:

Session, AutoCloseable

public class SQLiteSession
extends Object
implements Session, AutoCloseable

SQLiteSession - Database-backed session storage

Stores conversation history in SQLite database with full persistence. Suitable for: - Production applications requiring data persistence - Multi-session management - Conversation history across restarts

Schema: - agent_sessions: Session metadata (session_id, created_at, updated_at) - agent_messages: Conversation items (session_id, item_json, timestamp, sequence_num)

Thread-safety: Each operation uses the connection in a thread-safe manner. WAL mode enables concurrent reads while writes are happening.

Ported from TypeScript OpenAI Agents SDK Source: https://github.com/openai/openai-agents-js (DrizzleSession pattern)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	addItems(List<AgentInputItem> items)	addItems
CompletableFuture<Void>	clearSession()	clearSession
void	close()
static SQLiteSession	fromFile(String sessionId, Path dbPath)	Create SQLiteSession with file-based database.
CompletableFuture<List<AgentInputItem>>	getItems(Double limit)	getItems
CompletableFuture<String>	getSessionId()	getSessionId
static SQLiteSession	inMemory(String sessionId)	Create SQLiteSession with in-memory database.
CompletableFuture<Optional<AgentInputItem>>	popItem()	popItem

Methods inherited from class java.lang.Object

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

Method Details

inMemory

public static SQLiteSession inMemory(String sessionId)
                              throws SQLException

Create SQLiteSession with in-memory database. Data is lost when connection closes.

Parameters:

sessionId - Unique session identifier

Returns:

SQLiteSession instance

Throws:

SQLException - if database initialization fails

fromFile

public static SQLiteSession fromFile(String sessionId,
 Path dbPath)
                              throws SQLException

Create SQLiteSession with file-based database. Data persists across application restarts.

Parameters:

sessionId - Unique session identifier

dbPath - Path to SQLite database file

Returns:

SQLiteSession instance

Throws:

SQLException - if database initialization fails

getSessionId

public CompletableFuture<String> getSessionId()

Description copied from interface: Session

getSessionId

Specified by:

getSessionId in interface Session

Returns:

CompletableFuture

getItems

public CompletableFuture<List<AgentInputItem>> getItems(Double limit)

Description copied from interface: Session

getItems

Specified by:

getItems in interface Session

Parameters:

limit - Double

Returns:

CompletableFutureinvalid input: '<'List>

addItems

public CompletableFuture<Void> addItems(List<AgentInputItem> items)

Description copied from interface: Session

addItems

Specified by:

addItems in interface Session

Parameters:

items - List

Returns:

CompletableFuture

popItem

public CompletableFuture<Optional<AgentInputItem>> popItem()

Description copied from interface: Session

popItem

Specified by:

popItem in interface Session

Returns:

CompletableFutureinvalid input: '<'Optional>

clearSession

public CompletableFuture<Void> clearSession()

Description copied from interface: Session

clearSession

Specified by:

clearSession in interface Session

Returns:

CompletableFuture

close

public void close()
           throws SQLException

Specified by:

close in interface AutoCloseable

Throws:

SQLException