lxd: github.com/lxc/lxd/lxd/db/query Index | Files

package query

import "github.com/lxc/lxd/lxd/db/query"

Package query implements helpers around database/sql to execute various kinds of very common SQL queries.


Package Files

config.go count.go doc.go dump.go expr.go objects.go retry.go slices.go transaction.go

func Count Uses

func Count(tx *sql.Tx, table string, where string, args ...interface{}) (int, error)

Count returns the number of rows in the given table.

func CountAll Uses

func CountAll(tx *sql.Tx) (map[string]int, error)

CountAll returns a map associating each table name in the database with the total count of its rows.

func DeleteObject Uses

func DeleteObject(tx *sql.Tx, table string, id int64) (bool, error)

DeleteObject removes the row identified by the given ID. The given table must have a primary key column called 'id'.

It returns a flag indicating if a matching row was actually found and deleted or not.

func Dump Uses

func Dump(tx *sql.Tx, schema string, schemaOnly bool) (string, error)

Dump returns a SQL text dump of all rows across all tables, similar to sqlite3's dump feature

func InsertStrings Uses

func InsertStrings(tx *sql.Tx, stmt string, values []string) error

InsertStrings inserts a new row for each of the given strings, using the given insert statement template, which must define exactly one insertion column and one substitution placeholder for the values. For example: InsertStrings(tx, "INSERT INTO foo(name) VALUES %s", []string{"bar"}).

func IsRetriableError Uses

func IsRetriableError(err error) bool

IsRetriableError returns true if the given error might be transient and the interaction can be safely retried.

func Params Uses

func Params(n int) string

Params returns a parameters expression with the given number of '?' placeholders. E.g. Params(2) -> "(?, ?)". Useful for IN and VALUES expressions.

func Retry Uses

func Retry(f func() error) error

Retry wraps a function that interacts with the database, and retries it in case a transient error is hit.

This should by typically used to wrap transactions.

func SelectConfig Uses

func SelectConfig(tx *sql.Tx, table string, where string, args ...interface{}) (map[string]string, error)

SelectConfig executes a query statement against a "config" table, which must have 'key' and 'value' columns. By default this query returns all keys, but additional WHERE filters can be specified.

Returns a map of key names to their associated values.

func SelectIntegers Uses

func SelectIntegers(tx *sql.Tx, query string, args ...interface{}) ([]int, error)

SelectIntegers executes a statement which must yield rows with a single integer column. It returns the list of column values.

func SelectObjects Uses

func SelectObjects(stmt *sql.Stmt, dest Dest, args ...interface{}) error

SelectObjects executes a statement which must yield rows with a specific columns schema. It invokes the given Dest hook for each yielded row.

func SelectStrings Uses

func SelectStrings(tx *sql.Tx, query string, args ...interface{}) ([]string, error)

SelectStrings executes a statement which must yield rows with a single string column. It returns the list of column values.

func SelectURIs Uses

func SelectURIs(stmt *sql.Stmt, f func(a ...interface{}) string, args ...interface{}) ([]string, error)

SelectURIs returns a list of LXD API URI strings for the resource yielded by the given query.

The f argument must be a function that formats the entity URI using the columns yielded by the query.

func Transaction Uses

func Transaction(db *sql.DB, f func(*sql.Tx) error) error

Transaction executes the given function within a database transaction.

func UpdateConfig Uses

func UpdateConfig(tx *sql.Tx, table string, values map[string]string) error

UpdateConfig updates the given keys in the given table. Config keys set to empty values will be deleted.

func UpsertObject Uses

func UpsertObject(tx *sql.Tx, table string, columns []string, values []interface{}) (int64, error)

UpsertObject inserts or replaces a new row with the given column values, to the given table using columns order. For example:

UpsertObject(tx, "cars", []string{"id", "brand"}, []interface{}{1, "ferrari"})

The number of elements in 'columns' must match the one in 'values'.

type Dest Uses

type Dest func(i int) []interface{}

Dest is a function that is expected to return the objects to pass to the 'dest' argument of sql.Rows.Scan(). It is invoked by SelectObjects once per yielded row, and it will be passed the index of the row being scanned.

Package query imports 11 packages (graph) and is imported by 32 packages. Updated 2020-10-22. Refresh now. Tools for package owners.