ksqlserver

Nov 13, 2022

Changes in this version

+ type SQLRows struct

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

Jul 19, 2022

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 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