session

package

v0.1.1 Latest Latest Go to latest Published: Mar 12, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Manager struct {
	// contains filtered or unexported fields
}

Manager manages shared sessions, keyed by session ID.

func NewManager(connector *duckdb.Connector) *Manager

NewManager creates a new session manager.

func (m *Manager) Close()

Close closes all managed sessions.

func (m *Manager) GetOrCreate(sessionID string) *Session

GetOrCreate returns an existing session or creates a new one.

type Session struct {
	ID           string
	Engine       *engine.Engine
	PreviewLimit int
	// contains filtered or unexported fields
}

Session represents a DuckDB execution context.

func NewSession(id string, connector *duckdb.Connector) *Session

NewSession creates a new session with the given connector.

func (s *Session) Close() error

Close closes the session's engine.

func (s *Session) Execute(ctx context.Context, query string, sw *spool.StreamWriter) (*engine.QueryResult, error)

Execute runs a SQL query, streaming Arrow batches to the writer. Records are NOT accumulated in memory.

func (s *Session) ExecutionCount() int

ExecutionCount returns the current execution counter value.

func (s *Session) SetPreviewLimit(limit int)

SetPreviewLimit updates the preview row limit.