core_db

Documentation

Index

• type DbSource
  • func (s *DbSource) OpenConnection() (*sqlx.DB, error)
  • func (s *DbSource) UseConnection(f func(*sqlx.DB) error) error
  • func (s *DbSource) UseTransaction(db *sqlx.DB, opts *sql.TxOptions, f func(*sqlx.Tx) error) error
• type IDbConnection

Types

type DbSource

type DbSource struct {
	DriverName     string `json:"driverName" yaml:"driver-name"`
	DataSourceName string `json:"dataSourceName" yaml:"data-source-name"`
}

func (*DbSource) OpenConnection

func (s *DbSource) OpenConnection() (*sqlx.DB, error)

func (*DbSource) UseConnection

func (s *DbSource) UseConnection(f func(*sqlx.DB) error) error

func (*DbSource) UseTransaction

func (s *DbSource) UseTransaction(db *sqlx.DB, opts *sql.TxOptions, f func(*sqlx.Tx) error) error

type IDbConnection

type IDbConnection interface {
	sqlx.Queryer
	sqlx.Execer

	DriverName() string

	Get(dest any, query string, args ...any) error

	Select(dest any, query string, args ...any) error

	NamedQuery(query string, arg any) (*sqlx.Rows, error)

	NamedExec(query string, arg any) (sql.Result, error)
}