JdbcSessionTask

Execution Configuration

Field	Type	Description
url *	String	JDBC Connection URL. Required for new sessions.
sql *	List<String>	A list of SQL statements to execute in sequence.
sessionId	String	Identifier to reuse an existing connection for transactions or subsequent queries.
user / password	String	Database credentials.
driver	String	Optional JDBC Driver Class Name. Auto-detected for H2, MySQL, and Postgres.
closeSession	Boolean	If true, closes the connection after this task completes. Default: false.

Task Lifecycle

• Initialization: Checks for an existing SessionState using the sessionId. If invalid or missing, it instantiates the driver (auto-detecting H2, MySQL, or Postgres if not specified) and establishes a new connection.
• Execution: Iterates through the sql list. For each statement:
  • Logs the query to the session transcript.
  • Executes the statement via the JDBC connection.
  • If a ResultSet is returned, it is converted into a Markdown table (limited to 100 rows).
  • If no result set, it reports the updateCount.
• Cleanup: If closeSession is enabled, the connection is closed and removed from the active session registry.

Embedded Invocation (Kotlin)

Use the UnifiedHarness to execute database tasks programmatically in headless environments.

import com.simiacryptus.cognotik.plan.tools.session.JdbcSessionTask.Companion.JdbcSession
import com.simiacryptus.cognotik.plan.tools.session.JdbcSessionTask.JdbcSessionTaskExecutionConfigData

fun runDatabaseQuery(harness: UnifiedHarness, dbUrl: String) {
    val config = JdbcSessionTaskExecutionConfigData(
        url = dbUrl,
        sql = listOf("SELECT TOP 5 * FROM audit_logs ORDER BY created_at DESC"),
        sessionId = "security-audit-01",
        task_description = "Fetch recent audit logs"
    )

    harness.runTask(
        taskType = JdbcSession,
        executionConfig = config,
        workspace = File("./workspace")
    )
}
            

LLM Prompt Context

The following segment is injected into the agent's context window to describe the tool's capabilities and active state:

JdbcSession - Execute SQL queries via JDBC in a stateful session.
** Specify the `url`, `user`, and `password` to start a new session.
** Use `sessionId` to reuse an existing connection for transactions or subsequent queries.
** Provide a list of `sql` statements to execute.

Active Sessions:
  ** Session security-audit-01 (valid=true)