benchmarks

Documentation

Index

• type SQLAdapter
  • func NewSQLAdapter(db *sql.DB) SQLAdapter
  • func (s SQLAdapter) BeginTx(ctx context.Context) (ksql.Tx, 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
  • 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

Types

type SQLAdapter

type SQLAdapter struct {
	*sql.DB
}

SQLAdapter adapts the sql.DB type to be compatible with the `DBAdapter` interface

func NewSQLAdapter

func NewSQLAdapter(db *sql.DB) SQLAdapter

NewSQLAdapter returns a new instance of SQLAdapter with the provided database instance.

func (SQLAdapter) BeginTx

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

BeginTx implements the Tx interface

func (SQLAdapter) ExecContext

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

ExecContext implements the DBAdapter interface

func (SQLAdapter) QueryContext

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

QueryContext implements the DBAdapter interface

type SQLTx

type SQLTx struct {
	*sql.Tx
}

SQLTx is used to implement the DBAdapter interface and implements the Tx interface

func (SQLTx) Commit

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

Commit implements the Tx interface

func (SQLTx) ExecContext

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

ExecContext implements the Tx interface

func (SQLTx) QueryContext

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

QueryContext implements the Tx interface

func (SQLTx) Rollback

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

Rollback implements the Tx interface