db

package

v0.70.0 Latest Latest Go to latest Published: Jul 22, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

codeberg.org/kukichalang/kukicha

Links

Open Source Insights

Documentation ¶

Index ¶

func Close(pool Pool) error
func CloseRows(rows Rows) error
func Count(pool Pool, query string, args ...any) (int64, error)
func Exec(pool Pool, query string, args ...any) (int64, error)
func ExecCtx(h ctxpkg.Handle, pool Pool, query string, args ...any) (int64, error)
func Exists(pool Pool, query string, args ...any) (bool, error)
func LastInsertId(pool Pool, query string, args ...any) (int64, error)
func Ping(pool Pool) error
func RawDB(pool Pool) *sql.DB
func ScanAll[T any](rows Rows) ([]T, error)
func ScanOne[T any](rows Rows) (T, error)
func ScanRow[T any](row Row) (T, error)
func Transaction(pool Pool, fn func(Tx) error) error
func TransactionWith(pool Pool, opts TxOptions, fn func(Tx) error) error
func TxExec(tx Tx, query string, args ...any) (int64, error)
type IsolationLevel
- func AllIsolationLevel() []IsolationLevel
- func ParseIsolationLevel(s string) (IsolationLevel, error)
- func (e IsolationLevel) String() string
type Pool
- func NewPool(conn *sql.DB) Pool
- func Open(driver string, connString string) (Pool, error)
type Row
- func QueryRow(pool Pool, query string, args ...any) Row
- func TxQueryRow(tx Tx, query string, args ...any) Row
type Rows
- func Query(pool Pool, query string, args ...any) (Rows, error)
- func QueryCtx(h ctxpkg.Handle, pool Pool, query string, args ...any) (Rows, error)
- func TxQuery(tx Tx, query string, args ...any) (Rows, error)
type Tx
type TxOptions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Close ¶

func Close(pool Pool) error

func CloseRows ¶

func CloseRows(rows Rows) error

func Count ¶

func Count(pool Pool, query string, args ...any) (int64, error)

func Exec ¶

func Exec(pool Pool, query string, args ...any) (int64, error)

func ExecCtx ¶

func ExecCtx(h ctxpkg.Handle, pool Pool, query string, args ...any) (int64, error)

func Exists ¶

func Exists(pool Pool, query string, args ...any) (bool, error)

func LastInsertId ¶

func LastInsertId(pool Pool, query string, args ...any) (int64, error)

func Ping ¶

func Ping(pool Pool) error

func RawDB ¶

func RawDB(pool Pool) *sql.DB

func ScanAll ¶

func ScanAll[T any](rows Rows) ([]T, error)

func ScanOne ¶

func ScanOne[T any](rows Rows) (T, error)

func ScanRow ¶

func ScanRow[T any](row Row) (T, error)

func Transaction ¶

func Transaction(pool Pool, fn func(Tx) error) error

func TransactionWith ¶

func TransactionWith(pool Pool, opts TxOptions, fn func(Tx) error) error

func TxExec ¶

func TxExec(tx Tx, query string, args ...any) (int64, error)

Types ¶

type IsolationLevel ¶

type IsolationLevel string

const (
	IsolationLevelDefault         IsolationLevel = ""
	IsolationLevelReadUncommitted IsolationLevel = "read_uncommitted"
	IsolationLevelReadCommitted   IsolationLevel = "read_committed"
	IsolationLevelRepeatableRead  IsolationLevel = "repeatable_read"
	IsolationLevelSerializable    IsolationLevel = "serializable"
)

func AllIsolationLevel ¶

func AllIsolationLevel() []IsolationLevel

func ParseIsolationLevel ¶

func ParseIsolationLevel(s string) (IsolationLevel, error)

func (IsolationLevel) String ¶

func (e IsolationLevel) String() string

type Pool ¶

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

func NewPool ¶

func NewPool(conn *sql.DB) Pool

func Open ¶

func Open(driver string, connString string) (Pool, error)

type Row ¶

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

func QueryRow ¶

func QueryRow(pool Pool, query string, args ...any) Row

func TxQueryRow ¶

func TxQueryRow(tx Tx, query string, args ...any) Row

type Rows ¶

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

func Query ¶

func Query(pool Pool, query string, args ...any) (Rows, error)

func QueryCtx ¶

func QueryCtx(h ctxpkg.Handle, pool Pool, query string, args ...any) (Rows, error)

func TxQuery ¶

func TxQuery(tx Tx, query string, args ...any) (Rows, error)

type Tx ¶

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

type TxOptions ¶

type TxOptions struct {
	IsolationLevel IsolationLevel
	ReadOnly       bool
}

Source Files ¶

View all Source files

db.go

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