driver

Documentation

Index

• type Result
  • func (r *Result) LastInsertId() (int64, error)
  • func (r *Result) RowsAffected() (int64, error)
• type Rows
  • func (r *Rows) Close() error
  • func (r *Rows) ColumnTypeDatabaseTypeName(index int) string
  • func (r *Rows) ColumnTypeScanType(index int) reflect.Type
  • func (r *Rows) Columns() []string
  • func (r *Rows) Next(dest []driver.Value) error
• type SQLiteOGConn
  • func NewConnection(ctx context.Context, dbname string, grpcConn *grpc.ClientConn, ...) (*SQLiteOGConn, error)
  • func (c *SQLiteOGConn) Begin() (driver.Tx, error)
  • func (c *SQLiteOGConn) Close() error
  • func (c *SQLiteOGConn) DoCallbackDance(ctx context.Context) error
  • func (c *SQLiteOGConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)
  • func (c *SQLiteOGConn) IsValid() bool
  • func (c *SQLiteOGConn) Ping(ctx context.Context) error
  • func (c *SQLiteOGConn) Prepare(query string) (driver.Stmt, error)
  • func (c *SQLiteOGConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
  • func (c *SQLiteOGConn) ResetSession(ctx context.Context) error
• type SQLiteOGConnector
  • func (c *SQLiteOGConnector) Connect(ctx context.Context) (driver.Conn, error)
  • func (c *SQLiteOGConnector) Driver() driver.Driver
• type SQLiteOGDriver
  • func (d *SQLiteOGDriver) Open(dsn string) (driver.Conn, error)
  • func (d *SQLiteOGDriver) OpenConnector(dsn string) (driver.Connector, error)
• type SQLiteOGStmt
  • func (s *SQLiteOGStmt) Close() error
  • func (s *SQLiteOGStmt) Exec(args []driver.Value) (driver.Result, error)
  • func (s *SQLiteOGStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)
  • func (s *SQLiteOGStmt) NumInput() int
  • func (s *SQLiteOGStmt) Query(args []driver.Value) (driver.Rows, error)
  • func (s *SQLiteOGStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

Types

type Result

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

func (*Result) LastInsertId

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

func (*Result) RowsAffected

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

type Rows

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

func (*Rows) Close

func (r *Rows) Close() error

func (*Rows) ColumnTypeDatabaseTypeName

func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

func (*Rows) ColumnTypeScanType

func (r *Rows) ColumnTypeScanType(index int) reflect.Type

func (*Rows) Columns

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

func (*Rows) Next

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

type SQLiteOGConn

type SQLiteOGConn struct {
	ID       string
	DBName   string
	GRPCConn *grpc.ClientConn
	OGClient pb.SqliteOGClient
	Funcs    map[string]callbackFunc
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(ctx context.Context, dbname string, grpcConn *grpc.ClientConn, callbacksEnabled bool, callbacks map[string]callbackFunc) (*SQLiteOGConn, error)

func (*SQLiteOGConn) Begin

func (c *SQLiteOGConn) Begin() (driver.Tx, error)

func (*SQLiteOGConn) Close

func (c *SQLiteOGConn) Close() error

func (*SQLiteOGConn) DoCallbackDance

func (c *SQLiteOGConn) DoCallbackDance(ctx context.Context) error

func (*SQLiteOGConn) ExecContext

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

func (*SQLiteOGConn) IsValid

func (c *SQLiteOGConn) IsValid() bool

func (*SQLiteOGConn) Ping

func (c *SQLiteOGConn) Ping(ctx context.Context) error

func (*SQLiteOGConn) Prepare

func (c *SQLiteOGConn) Prepare(query string) (driver.Stmt, error)

func (*SQLiteOGConn) QueryContext

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

func (*SQLiteOGConn) ResetSession

func (c *SQLiteOGConn) ResetSession(ctx context.Context) error

type SQLiteOGConnector

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

func (*SQLiteOGConnector) Connect

func (c *SQLiteOGConnector) Connect(ctx context.Context) (driver.Conn, error)

func (*SQLiteOGConnector) Driver

func (c *SQLiteOGConnector) Driver() driver.Driver

type SQLiteOGDriver

type SQLiteOGDriver struct {
	Funcs            map[string]callbackFunc
	CallbacksEnabled bool
}

func (*SQLiteOGDriver) Open

func (d *SQLiteOGDriver) Open(dsn string) (driver.Conn, error)

func (*SQLiteOGDriver) OpenConnector

func (d *SQLiteOGDriver) OpenConnector(dsn string) (driver.Connector, error)

type SQLiteOGStmt

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

func (*SQLiteOGStmt) Close

func (s *SQLiteOGStmt) Close() error

func (*SQLiteOGStmt) Exec

func (s *SQLiteOGStmt) Exec(args []driver.Value) (driver.Result, error)

func (*SQLiteOGStmt) ExecContext

func (s *SQLiteOGStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

func (*SQLiteOGStmt) NumInput

func (s *SQLiteOGStmt) NumInput() int

func (*SQLiteOGStmt) Query

func (s *SQLiteOGStmt) Query(args []driver.Value) (driver.Rows, error)

func (*SQLiteOGStmt) QueryContext

func (s *SQLiteOGStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)