tarantool

package

v1.2.1 Latest Latest Go to latest Published: Oct 23, 2025 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var ErrIsNotSupportedByThisDriver = errors.New("is not supported by this driver")

View Source

var (
	ErrTransactionAlreadyClosed = errors.New("transaction already closed")
)

func NewTx(stream *tarantool.Stream) sqlex.Tx

type Connection interface {
	Do(req tarantool.Request) *tarantool.Future
	NewStream() (*tarantool.Stream, error)
	Close() error
}

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

func Open(dsn string) (*DB, error)

func (db *DB) BeginTx(ctx context.Context, _ *sql.TxOptions) (sqlex.Tx, error)

func (db *DB) Close() error

func (db *DB) ExecContext(ctx context.Context, query string, args ...any) (sqlex.Result, error)

func (db *DB) Ping() error

func (db *DB) QueryContext(ctx context.Context, query string, args ...any) (sqlex.Rows, error)

type Done bool

Done implements [Result] for an INSERT or UPDATE operation which mutates a number of rows.

func (Done) LastInsertId() (int64, error)

func (v Done) RowsAffected() (int64, error)

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

func (s *Stmt) ExecContext(ctx context.Context, args ...any) (sqlex.Result, error)

Path	Synopsis
mocktarantool