database

package
v0.4.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 22, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const SQLiteEnabled = true

Variables

View Source 
var AllTypes = []*DBType{
	TypeMySQL,
	TypePostgres,
	TypeSQLite,
	TypeSQLServer,
}
View Source 
var TypeMySQL = &DBType{Key: "mysql", Title: "MySQL", Quote: "`", Placeholder: "?", SupportsReturning: false}
View Source 
var TypePostgres = &DBType{Key: "postgres", Title: "PostgreSQL", Quote: `"`, Placeholder: "$", SupportsReturning: true}
View Source 
var TypeSQLServer = &DBType{Key: "sqlserver", Title: "SQL Server", Quote: `"`, Placeholder: "@", SupportsReturning: true}
View Source 
var TypeSQLite = &DBType{Key: "sqlite", Title: "SQLite", Quote: `"`, Placeholder: "$", SupportsReturning: true}

Functions

func ArrayToString 

func ArrayToString(a []string) string

func MapScan added in v0.4.4 

func MapScan(row *sqlx.Rows) (util.ValueMap, error)

func QueryFieldDescs added in v0.4.4 

func QueryFieldDescs(fields util.FieldDescs, query string, argOffset int) (string, []any, error)

func RegistryKeys added in v0.2.1 

func RegistryKeys() []string

func SQLDelete 

func SQLDelete(table string, where string, _ *DBType) string

func SQLInClause 

func SQLInClause(column string, numParams int, offset int, dbt *DBType) string

func SQLInsert 

func SQLInsert(table string, columns []string, rows int, dbt *DBType) string

func SQLInsertReturning 

func SQLInsertReturning(table string, columns []string, rows int, returning []string, dbt *DBType) string

func SQLSelect 

func SQLSelect(columns string, tables string, where string, orderBy string, limit int, offset int, dbt *DBType) string

func SQLSelectGrouped 

func SQLSelectGrouped(columns string, tables string, where string, groupBy string, orderBy string, limit int, offset int, dbt *DBType) string

func SQLSelectSimple 

func SQLSelectSimple(columns string, tables string, dbt *DBType, where ...string) string

func SQLUpdate 

func SQLUpdate(table string, columns []string, where string, dbt *DBType) string

func SQLUpdateReturning 

func SQLUpdateReturning(table string, columns []string, where string, returned []string, dbt *DBType) string

func SQLUpsert 

func SQLUpsert(table string, columns []string, rows int, conflicts []string, updates []string, dbt *DBType) string

func StringToArray 

func StringToArray(s string) []string

func UUIDFromGUID added in v0.2.12 

func UUIDFromGUID(x any) *uuid.UUID

Types

type DBType 

type DBType struct {
	Key               string `json:"key"`
	Title             string `json:"title"`
	Quote             string `json:"-"`
	Placeholder       string `json:"-"`
	SupportsReturning bool   `json:"-"`
}

func TypeByKey added in v0.4.4 

func TypeByKey(key string) *DBType

func (*DBType) PlaceholderFor added in v0.4.0 

func (t *DBType) PlaceholderFor(idx int) string

func (*DBType) Quoted added in v0.4.0 

func (t *DBType) Quoted(s string) string

type MySQLParams 

type MySQLParams struct {
	Host     string `json:"host"`
	Port     int    `json:"port,omitempty"`
	Username string `json:"username"`
	Password string `json:"password,omitempty"`
	Database string `json:"database,omitempty"`
	Schema   string `json:"schema,omitempty"`
	MaxConns int    `json:"maxConns,omitempty"`
	Debug    bool   `json:"debug,omitempty"`
}

func MySQLParamsFromEnv 

func MySQLParamsFromEnv(key string, defaultUser string, prefix string) *MySQLParams

func MySQLParamsFromMap added in v0.4.4 

func MySQLParamsFromMap(m util.ValueMap) *MySQLParams

type PostgresParams 

type PostgresParams struct {
	Host     string `json:"host"`
	Port     int    `json:"port,omitempty"`
	Username string `json:"username"`
	Password string `json:"password,omitempty"`
	Database string `json:"database,omitempty"`
	Schema   string `json:"schema,omitempty"`
	MaxConns int    `json:"maxConns,omitempty"`
	Debug    bool   `json:"debug,omitempty"`
}

func PostgresParamsFromEnv 

func PostgresParamsFromEnv(key string, defaultUser string, prefix string) *PostgresParams

func PostgresParamsFromMap added in v0.4.4 

func PostgresParamsFromMap(m util.ValueMap) *PostgresParams

type SQLServerParams added in v0.2.12 

type SQLServerParams struct {
	Host     string `json:"host"`
	Port     int    `json:"port,omitempty"`
	Username string `json:"username"`
	Password string `json:"password,omitempty"`
	Database string `json:"database,omitempty"`
	Schema   string `json:"schema,omitempty"`
	MaxConns int    `json:"maxConns,omitempty"`
	Debug    bool   `json:"debug,omitempty"`
}

func SQLServerParamsFromEnv added in v0.2.12 

func SQLServerParamsFromEnv(key string, defaultUser string, prefix string) *SQLServerParams

func SQLServerParamsFromMap added in v0.4.4 

func SQLServerParamsFromMap(m util.ValueMap) *SQLServerParams

type SQLiteParams 

type SQLiteParams struct {
	File     string `json:"file"`
	User     string `json:"user,omitempty"`
	Password string `json:"password,omitempty"`
	Schema   string `json:"schema,omitempty"`
	Debug    bool   `json:"debug,omitempty"`
}

func SQLiteParamsFromEnv 

func SQLiteParamsFromEnv(key string, prefix string) *SQLiteParams

func SQLiteParamsFromMap added in v0.4.4 

func SQLiteParamsFromMap(m util.ValueMap) *SQLiteParams

type Service 

type Service struct {
	Key          string  `json:"key"`
	DatabaseName string  `json:"database,omitempty"`
	SchemaName   string  `json:"schema,omitempty"`
	Username     string  `json:"username,omitempty"`
	Debug        bool    `json:"debug,omitempty"`
	Type         *DBType `json:"type"`
	ReadOnly     bool    `json:"readonly,omitempty"`
	// contains filtered or unexported fields
}

func NewService 

func NewService(
	typ *DBType, key string, dbName string, schName string, username string, debug bool, db *sqlx.DB, stringRep string, logger util.Logger,
) (*Service, error)

func OpenDefaultMySQL 

func OpenDefaultMySQL(ctx context.Context, logger util.Logger) (*Service, error)

func OpenDefaultPostgres 

func OpenDefaultPostgres(ctx context.Context, logger util.Logger) (*Service, error)

func OpenDefaultSQLServer added in v0.2.12 

func OpenDefaultSQLServer(ctx context.Context, logger util.Logger) (*Service, error)

func OpenDefaultSQLite 

func OpenDefaultSQLite(ctx context.Context, logger util.Logger) (*Service, error)

func OpenMySQL added in v0.4.2 

func OpenMySQL(ctx context.Context, key string, prefix string, logger util.Logger) (*Service, error)

func OpenMySQLDatabase 

func OpenMySQLDatabase(ctx context.Context, key string, params *MySQLParams, logger util.Logger) (*Service, error)

func OpenPostgres 

func OpenPostgres(ctx context.Context, key string, prefix string, logger util.Logger) (*Service, error)

func OpenPostgresDatabase 

func OpenPostgresDatabase(ctx context.Context, key string, params *PostgresParams, logger util.Logger) (*Service, error)

func OpenSQLServer added in v0.2.12 

func OpenSQLServer(ctx context.Context, key string, prefix string, logger util.Logger) (*Service, error)

func OpenSQLServerDatabase added in v0.2.12 

func OpenSQLServerDatabase(ctx context.Context, key string, params *SQLServerParams, logger util.Logger) (*Service, error)

func OpenSQLite 

func OpenSQLite(ctx context.Context, key string, prefix string, logger util.Logger) (*Service, error)

func OpenSQLiteDatabase 

func OpenSQLiteDatabase(ctx context.Context, key string, params *SQLiteParams, logger util.Logger) (*Service, error)

func RegistryGet added in v0.2.1 

func RegistryGet(key string) (*Service, error)

func (*Service) Close 

func (s *Service) Close() error

func (*Service) Conn 

func (s *Service) Conn(ctx context.Context) (*sql.Conn, error)

func (*Service) Delete 

func (s *Service) Delete(ctx context.Context, q string, tx *sqlx.Tx, expected int, logger util.Logger, values ...any) (int, error)

func (*Service) DeleteOne 

func (s *Service) DeleteOne(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) error

func (*Service) Exec 

func (s *Service) Exec(ctx context.Context, q string, tx *sqlx.Tx, expected int, logger util.Logger, values ...any) (int, error)

func (*Service) Get 

func (s *Service) Get(ctx context.Context, row any, q string, tx *sqlx.Tx, logger util.Logger, values ...any) error

func (*Service) Healthcheck 

func (s *Service) Healthcheck(dbName string, db *sqlx.DB) error

func (*Service) Insert 

func (s *Service) Insert(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) error

func (*Service) InsertMap added in v0.4.4 

func (s *Service) InsertMap(ctx context.Context, table string, m util.ValueMap, tx *sqlx.Tx, logger util.Logger, values ...any) error

func (*Service) Prepare added in v0.2.12 

func (s *Service) Prepare(ctx context.Context, q string) (*sqlx.Stmt, error)

func (*Service) Query 

func (s *Service) Query(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) (*sqlx.Rows, error)

func (*Service) Query2DArray 

func (s *Service) Query2DArray(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) ([][]any, error)

func (*Service) QueryKVMap 

func (s *Service) QueryKVMap(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) (util.ValueMap, error)

func (*Service) QueryRows 

func (s *Service) QueryRows(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) ([]util.ValueMap, error)

func (*Service) QuerySingleRow 

func (s *Service) QuerySingleRow(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) (util.ValueMap, error)

func (*Service) Select 

func (s *Service) Select(ctx context.Context, dest any, q string, tx *sqlx.Tx, logger util.Logger, values ...any) error

func (*Service) SingleBool added in v0.2.1 

func (s *Service) SingleBool(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) (bool, error)

func (*Service) SingleInt 

func (s *Service) SingleInt(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) (int64, error)

func (*Service) StartTransaction 

func (s *Service) StartTransaction(logger util.Logger) (*sqlx.Tx, error)

func (*Service) Stats 

func (s *Service) Stats() sql.DBStats

func (*Service) String added in v0.4.4 

func (s *Service) String() string

func (*Service) Update 

func (s *Service) Update(ctx context.Context, q string, tx *sqlx.Tx, expected int, logger util.Logger, values ...any) (int, error)

func (*Service) UpdateOne 

func (s *Service) UpdateOne(ctx context.Context, q string, tx *sqlx.Tx, logger util.Logger, values ...any) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.