db

Documentation

Index

• func ExecVTOrc(query string, args ...any) (sql.Result, error)
• func IsSQLite() bool
• func OpenVTOrc() (db *sql.DB, err error)
• func QueryVTOrc(query string, argsArray []any, onRow func(sqlutils.RowMap) error) error
• func QueryVTOrcRowsMap(query string, onRow func(sqlutils.RowMap) error) error
• func ReadTimeNow() (timeNow string, err error)
• type DB
• type DummySQLResult
  • func (dummyRes DummySQLResult) LastInsertId() (int64, error)
  • func (dummyRes DummySQLResult) RowsAffected() (int64, error)

Functions

func ExecVTOrc

func ExecVTOrc(query string, args ...any) (sql.Result, error)

ExecVTOrc will execute given query on the vtorc backend database.

func IsSQLite

func IsSQLite() bool

func OpenVTOrc

func OpenVTOrc() (db *sql.DB, err error)

OpenTopology returns the DB instance for the vtorc backed database

func QueryVTOrc

func QueryVTOrc(query string, argsArray []any, onRow func(sqlutils.RowMap) error) error

QueryVTOrc

func QueryVTOrcRowsMap

func QueryVTOrcRowsMap(query string, onRow func(sqlutils.RowMap) error) error

QueryVTOrcRowsMap

func ReadTimeNow

func ReadTimeNow() (timeNow string, err error)

ReadTimeNow reads and returns the current timestamp as string. This is an unfortunate workaround to support both MySQL and SQLite in all possible timezones. SQLite only speaks UTC where MySQL has timezone support. By reading the time as string we get the database's de-facto notion of the time, which we can then feed back to it.

Types

type DB

type DB interface {
	QueryVTOrc(query string, argsArray []any, onRow func(sqlutils.RowMap) error) error
}

var (
	Db DB = (*vtorcDB)(nil)
)

type DummySQLResult

type DummySQLResult struct {
}

func (DummySQLResult) LastInsertId

func (dummyRes DummySQLResult) LastInsertId() (int64, error)

func (DummySQLResult) RowsAffected

func (dummyRes DummySQLResult) RowsAffected() (int64, error)