sqlite3

Documentation

Index

• func Connect(conf activerecord.DatabaseConfig) (activerecord.Conn, error)
• type Conn
  • func (c *Conn) BeginTransaction(ctx context.Context) (activerecord.Conn, error)
  • func (c *Conn) Close() error
  • func (c *Conn) ColumnDefinitions(ctx context.Context, tableName string) ([]activerecord.ColumnDefinition, error)
  • func (c *Conn) CommitTransaction(ctx context.Context) error
  • func (c *Conn) Exec(ctx context.Context, sql string, args ...interface{}) error
  • func (c *Conn) ExecDelete(ctx context.Context, op *activerecord.DeleteOperation) error
  • func (c *Conn) ExecInsert(ctx context.Context, op *activerecord.InsertOperation) (id interface{}, err error)
  • func (c *Conn) ExecQuery(ctx context.Context, op *activerecord.QueryOperation, ...) (err error)
  • func (c *Conn) RollbackTransaction(ctx context.Context) error
• type Querier

Functions

func Connect

func Connect(conf activerecord.DatabaseConfig) (activerecord.Conn, error)

Types

type Conn

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

func (*Conn) BeginTransaction

func (c *Conn) BeginTransaction(ctx context.Context) (activerecord.Conn, error)

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) ColumnDefinitions

func (c *Conn) ColumnDefinitions(ctx context.Context, tableName string) (
	[]activerecord.ColumnDefinition, error,
)

func (*Conn) CommitTransaction

func (c *Conn) CommitTransaction(ctx context.Context) error

func (*Conn) Exec

func (c *Conn) Exec(ctx context.Context, sql string, args ...interface{}) error

func (*Conn) ExecDelete

func (c *Conn) ExecDelete(ctx context.Context, op *activerecord.DeleteOperation) error

func (*Conn) ExecInsert

func (c *Conn) ExecInsert(ctx context.Context, op *activerecord.InsertOperation) (
	id interface{}, err error,
)

func (*Conn) ExecQuery

func (c *Conn) ExecQuery(
	ctx context.Context, op *activerecord.QueryOperation, cb func(activesupport.Hash) bool,
) (
	err error,
)

func (*Conn) RollbackTransaction

func (c *Conn) RollbackTransaction(ctx context.Context) error

type Querier

type Querier interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
}