ksql

Jan 4, 2023

Changes in this version

+ type Conn struct

+ func (c Conn) Begin() (driver.Tx, error)

+ func (c Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c Conn) Close() error

+ func (c Conn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (c Conn) OpenConnector(name string) (driver.Connector, error)

+ func (c Conn) Ping(ctx context.Context) error

+ func (c Conn) Prepare(query string) (driver.Stmt, error)

+ func (c Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c Conn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type Driver struct

+ func (ksql *Driver) Open(dsn string) (driver.Conn, error)

+ type Result struct

+ LError string

+ LastInserted int64

+ RError string

+ RowsAff int64

+ func (r Result) LastInsertId() (int64, error)

+ func (r Result) RowsAffected() (int64, error)

+ type Rows struct

+ func (r Rows) Close() error

+ func (r Rows) Columns() []string

+ func (r Rows) Next(dest []driver.Value) error

+ type Stmt struct

+ func (s Stmt) Close() error

+ func (s Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s Stmt) NumInput() int

+ func (s Stmt) Query(args []driver.Value) (driver.Rows, error)

+ type Tx struct

+ func (t Tx) Commit() error

+ func (t Tx) Rollback() error

+ type Value struct

+ Value []driver.Value

+ func (d *Value) GobDecode(b []byte) error

+ func (d *Value) GobEncode() ([]byte, error)