dbcl

package

v0.0.0-...-5ed304f Latest Latest Go to latest Published: Feb 16, 2024 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/magicpool-co/pool

Links

Open Source Insights

Documentation ¶

Index ¶

func ConvertDurationToInterval(duration time.Duration) string
func ExecBulkInsert(q Querier, table string, cols []string, objects []interface{}) error
func ExecBulkInsertUpdateAdd(q Querier, table string, insertCols, updateCols []string, ...) error
func ExecBulkInsertUpdateOverwrite(q Querier, table string, insertCols, updateCols []string, ...) error
func ExecBulkInsertUpdateSubtract(q Querier, table string, insertCols, updateCols []string, ...) error
func ExecInsert(q Querier, table string, cols []string, object interface{}) (uint64, error)
func ExecInsertNoID(q Querier, table string, cols []string, object interface{}) error
func ExecUpdate(q Querier, table string, updateCols, whereCols []string, updatedAt bool, ...) error
func FetchMigrations(path string, migrationFS *embed.FS) (map[string]string, error)
func GetBigInt(q Querier, query string, args ...interface{}) (*big.Int, error)
func GetFloat64(q Querier, query string, args ...interface{}) (float64, error)
func GetString(q Querier, query string, args ...interface{}) (string, error)
func GetTime(q Querier, query string, args ...interface{}) (time.Time, error)
func GetUint64(q Querier, query string, args ...interface{}) (uint64, error)
type Client
- func New(writeHost, readHost, port, name, user, pass string, ...) (*Client, error)
- func (c *Client) Begin() (*Tx, error)
- func (c *Client) Close()
- func (c *Client) DowngradeMigration() error
- func (c *Client) DowngradeMigrations() error
- func (c *Client) Ping() error
- func (c *Client) Reader() *sqlx.DB
- func (c *Client) UpgradeMigrations() error
- func (c *Client) Writer() *sqlx.DB
type NullBigInt
- func (n *NullBigInt) Scan(src interface{}) error
- func (n NullBigInt) Value() (driver.Value, error)
type Querier
type Tx
- func NewTx(tx *sqlx.Tx) *Tx
- func (tx *Tx) SafeCommit() error
- func (tx *Tx) SafeRollback() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConvertDurationToInterval ¶

func ConvertDurationToInterval(duration time.Duration) string

func ExecBulkInsert ¶

func ExecBulkInsert(q Querier, table string, cols []string, objects []interface{}) error

func ExecBulkInsertUpdateAdd ¶

func ExecBulkInsertUpdateAdd(
	q Querier,
	table string,
	insertCols, updateCols []string,
	objects []interface{},
) error

func ExecBulkInsertUpdateOverwrite ¶

func ExecBulkInsertUpdateOverwrite(
	q Querier,
	table string,
	insertCols, updateCols []string,
	objects []interface{},
) error

func ExecBulkInsertUpdateSubtract ¶

func ExecBulkInsertUpdateSubtract(
	q Querier,
	table string,
	insertCols, updateCols []string,
	objects []interface{},
) error

func ExecInsert ¶

func ExecInsert(q Querier, table string, cols []string, object interface{}) (uint64, error)

func ExecInsertNoID ¶

func ExecInsertNoID(q Querier, table string, cols []string, object interface{}) error

func ExecUpdate ¶

func ExecUpdate(
	q Querier,
	table string,
	updateCols, whereCols []string,
	updatedAt bool,
	obj interface{},
) error

func FetchMigrations ¶

func FetchMigrations(path string, migrationFS *embed.FS) (map[string]string, error)

func GetBigInt ¶

func GetBigInt(q Querier, query string, args ...interface{}) (*big.Int, error)

func GetFloat64 ¶

func GetFloat64(q Querier, query string, args ...interface{}) (float64, error)

func GetString ¶

func GetString(q Querier, query string, args ...interface{}) (string, error)

func GetTime ¶

func GetTime(q Querier, query string, args ...interface{}) (time.Time, error)

func GetUint64 ¶

func GetUint64(q Querier, query string, args ...interface{}) (uint64, error)

Types ¶

type Client ¶

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

func New ¶

func New(
	writeHost, readHost, port, name, user, pass string,
	migrations map[string]string,
) (*Client, error)

func (*Client) Begin ¶

func (c *Client) Begin() (*Tx, error)

func (*Client) Close ¶

func (c *Client) Close()

func (*Client) DowngradeMigration ¶

func (c *Client) DowngradeMigration() error

func (*Client) DowngradeMigrations ¶

func (c *Client) DowngradeMigrations() error

func (*Client) Ping ¶

func (c *Client) Ping() error

func (*Client) Reader ¶

func (c *Client) Reader() *sqlx.DB

func (*Client) UpgradeMigrations ¶

func (c *Client) UpgradeMigrations() error

func (*Client) Writer ¶

func (c *Client) Writer() *sqlx.DB

type NullBigInt ¶

type NullBigInt struct {
	BigInt *big.Int
	Valid  bool
}

func (*NullBigInt) Scan ¶

func (n *NullBigInt) Scan(src interface{}) error

Scan implements the Scanner interface.

func (NullBigInt) Value ¶

func (n NullBigInt) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Querier ¶

type Querier interface {
	Get(dest interface{}, query string, args ...interface{}) error
	Select(dest interface{}, query string, args ...interface{}) error
	Exec(query string, args ...interface{}) (sql.Result, error)
	NamedExec(query string, arg interface{}) (sql.Result, error)
	Rebind(query string) string
}

type Tx ¶

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

func NewTx ¶

func NewTx(tx *sqlx.Tx) *Tx

func (*Tx) SafeCommit ¶

func (tx *Tx) SafeCommit() error

func (*Tx) SafeRollback ¶

func (tx *Tx) SafeRollback() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL