sql

package

v0.4.12 Latest Latest Go to latest Published: Jan 16, 2025 License: GPL-3.0 Imports: 7 Imported by: 0

Details

View Source

const (
	UniqueViolationCode = "23505"
)

View Source

var (
	ErrNilQuery = errors.New("sql query cannot be nil")
	ErrNilRow   = errors.New("sql row cannot be nil")
)

func Close(db *sql.DB) error

Close closes the SQL connection

func Connect(
	driverName, dataSourceName string,
	config *Config,
) (*sql.DB, error)

Connect returns a new SQL connection

func CreateTransaction(db *sql.DB, fn func(tx *sql.Tx) error) error

CreateTransaction creates a transaction for the database

func IsUniqueViolationError(err error) (bool, string)

IsUniqueViolationError checks if the error is a unique violation error

func RunQueriesConcurrently(
	db *sql.DB,
	queries ...func(db *sql.DB) error,
) *[]error

RunQueriesConcurrently runs multiple queries concurrently

func RunQueriesConcurrentlyWithCancel(
	db *sql.DB,
	queries ...func(db *sql.DB, ctx context.Context) error,
) *[]error

RunQueriesConcurrentlyWithCancel runs multiple queries concurrently with a cancel context

type Config struct {
	MaxOpenConnections    int
	MaxIdleConnections    int
	ConnectionMaxLifetime time.Duration
}

Config struct

func NewConfig(
	maxOpenConnections int,
	maxIdleConnections int,
	connectionMaxLifetime time.Duration,
) *Config

NewConfig creates a new configuration

func (c *Config) Close(db *sql.DB) error

Close closes the SQL connection

func (c *Config) Connect(
	driverName, dataSourceName string,
) (*sql.DB, error)

Connect returns a new SQL connection

Path	Synopsis
service