db

Documentation

Index

• func ClearVTOrcDatabase()
• func ExecVTOrc(query string, args ...any) (sql.Result, error)
• 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 ClearVTOrcDatabase

func ClearVTOrcDatabase()

ClearVTOrcDatabase is used to clear the VTOrc database. This function is meant to be used by tests to clear the database to get a clean slate without starting a new one.

func ExecVTOrc

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

ExecVTOrc will execute given query on the vtorc backend database.

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)