ksqlite

Oct 20, 2023

Changes in this version

+ func New(_ context.Context, connectionString string, config ksql.Config) (ksql.DB, error)

+ func NewFromSQLDB(db *sql.DB) (ksql.DB, error)

+ type SQLAdapter struct

+ func NewSQLAdapter(db *sql.DB) SQLAdapter

+ func (s SQLAdapter) BeginTx(ctx context.Context) (ksql.Tx, error)

+ func (s SQLAdapter) Close() error

+ func (s SQLAdapter) ExecContext(ctx context.Context, query string, args ...interface{}) (ksql.Result, error)

+ func (s SQLAdapter) QueryContext(ctx context.Context, query string, args ...interface{}) (ksql.Rows, error)

+ type SQLRows struct

+ func (p SQLRows) Scan(args ...interface{}) error

+ type SQLTx struct

+ func (s SQLTx) Commit(ctx context.Context) error

+ func (s SQLTx) ExecContext(ctx context.Context, query string, args ...interface{}) (ksql.Result, error)

+ func (s SQLTx) QueryContext(ctx context.Context, query string, args ...interface{}) (ksql.Rows, error)

+ func (s SQLTx) Rollback(ctx context.Context) error