db

Documentation

Index

• Variables
• func Close() error
• func Exec(query string, args ...any) (sql.Result, error)
• func Ping()
• func Query(query string, args ...any) (*sql.Rows, error)
• func QueryRow(query string, args ...any) *sql.Row
• type ConnectionURI
  • func ParseConnectionURI(connection_uri string) (ConnectionURI, error)
  • func (uri ConnectionURI) DSN(mods ...DSNModifier) string
• type DB
  • func Open() *DB
• type DSNModifier
• type Timestamp
  • func (t *Timestamp) Scan(value interface{}) error
  • func (t *Timestamp) Value() (driver.Value, error)
• type Tx
  • func Begin() (*Tx, error)
  • func (tx *Tx) Commit() error
  • func (tx *Tx) Exec(query string, args ...any) (sql.Result, error)
  • func (tx *Tx) Rollback() error

Variables

var CurrentTimestamp string

Functions

func Close

func Close() error

func Exec

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

func Ping

func Ping()

func Query

func Query(query string, args ...any) (*sql.Rows, error)

func QueryRow

func QueryRow(query string, args ...any) *sql.Row

Types

type ConnectionURI

type ConnectionURI struct {
	*url.URL

	Dialect string
	// contains filtered or unexported fields
}

func ParseConnectionURI

func ParseConnectionURI(connection_uri string) (ConnectionURI, error)

func (ConnectionURI) DSN

func (uri ConnectionURI) DSN(mods ...DSNModifier) string

type DB

type DB struct {
	*sql.DB
	URI ConnectionURI
}

func Open

func Open() *DB

type DSNModifier

type DSNModifier func(u *url.URL, q *url.Values)

type Timestamp

type Timestamp struct{ time.Time }

func (*Timestamp) Scan

func (t *Timestamp) Scan(value interface{}) error

func (*Timestamp) Value

func (t *Timestamp) Value() (driver.Value, error)

type Tx

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

func Begin

func Begin() (*Tx, error)

func (*Tx) Commit

func (tx *Tx) Commit() error

func (*Tx) Exec

func (tx *Tx) Exec(query string, args ...any) (sql.Result, error)

func (*Tx) Rollback

func (tx *Tx) Rollback() error