postgresql

package

v0.8.0 Latest Latest Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

DB is a wrapper over *sql.DB,

func (db *DB) Close() error

Close shutsdown the database driver.

func (db *DB) CmpAndSwap(bucket, key, oldValue, newValue []byte) ([]byte, bool, error)

CmpAndSwap modifies the value at the given bucket and key (to newValue) only if the existing (current) value matches oldValue.

func (db *DB) CreateTable(bucket []byte) error

CreateTable creates a table in the database.

func (db *DB) Del(bucket, key []byte) error

Del deletes a row from the database.

func (db *DB) DeleteTable(bucket []byte) error

DeleteTable deletes a table in the database.

func (db *DB) Get(bucket, key []byte) ([]byte, error)

Get retrieves the column/row with given key.

func (db *DB) List(bucket []byte) ([]*database.Entry, error)

List returns the full list of entries in a column.

func (db *DB) Open(dataSourceName string, opt ...database.Option) error

Open creates a Driver and connects to the database with the given address and access details.

func (db *DB) Set(bucket, key, value []byte) error

Set inserts the key and value into the given bucket(column).

func (db *DB) Update(tx *database.Tx) error

Update performs multiple commands on one read-write transaction.