db

Feb 20, 2025

Changes in this version

type Client

+ WithTransaction func(ctx context.Context, forWriting bool, f WithTransactionFunction) error

+ type WithTransactionFunction func(tx transaction.Client) error

Feb 4, 2025

Changes in this version

+ const InformerObjectCacheDBPath

+ func Sanitize(s string) string

+ type Client struct

+ func NewClient(c Connection, encryptor Encryptor, decryptor Decryptor) (*Client, error)

+ func (c *Client) BeginTx(ctx context.Context, forWriting bool) (TXClient, error)

+ func (c *Client) CloseStmt(closable Closable) error

+ func (c *Client) NewConnection() error

+ func (c *Client) Prepare(stmt string) *sql.Stmt

+ func (c *Client) QueryForRows(ctx context.Context, stmt transaction.Stmt, params ...any) (*sql.Rows, error)

+ func (c *Client) ReadInt(rows Rows) (int, error)

+ func (c *Client) ReadObjects(rows Rows, typ reflect.Type, shouldDecrypt bool) ([]any, error)

+ func (c *Client) ReadStrings(rows Rows) ([]string, error)

+ func (c *Client) Upsert(tx TXClient, stmt *sql.Stmt, key string, obj any, shouldEncrypt bool) error

+ type Closable interface

+ Close func() error

+ type Connection interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ Close func() error

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

+ Prepare func(query string) (*sql.Stmt, error)

+ type Decryptor interface

+ Decrypt func([]byte, []byte, uint32) ([]byte, error)

+ type Encryptor interface

+ Encrypt func([]byte) ([]byte, []byte, uint32, error)

+ type QueryError struct

+ Err error

+ QueryString string

+ func (e *QueryError) Error() string

+ func (e *QueryError) Unwrap() error

+ type Rows interface

+ Close func() error

+ Err func() error

+ Next func() bool

+ Scan func(dest ...any) error

+ type TXClient interface

+ Cancel func() error

+ Commit func() error

+ Exec func(stmt string, args ...any) error

+ Stmt func(stmt *sql.Stmt) transaction.Stmt

+ StmtExec func(stmt transaction.Stmt, args ...any) error