storage

Aug 18, 2024

Changes in this version

+ type SqlDB struct

+ func (db SqlDB) Close() error

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

+ func (db SqlDB) Query(query string, args ...any) (*sql.Rows, error)

+ func (db SqlDB) QueryRow(query string, args ...any) *sql.Row

+ func (db SqlDB) TableExists(tableName string) (bool, error)

+ func (db SqlDB) Tx(fn TxFunc) error

+ type TxFunc func(db DB) error

Mar 11, 2024

Changes in this version

+ type MSSQLAdapter struct

+ func (m MSSQLAdapter) ConvertGenericPlaceholders(query string, argsCount int) string

+ func (m MSSQLAdapter) CreateDSN(cfg configloader.ConnectionConfig) string

+ func (m MSSQLAdapter) DatabaseName(executor sqlExecutor) (string, error)

+ func (m MSSQLAdapter) TableExists(executor sqlExecutor, tableName string) (bool, error)

+ type SqliteAdapter struct

+ func (s SqliteAdapter) ConvertGenericPlaceholders(query string, argsCount int) string

+ func (s SqliteAdapter) CreateDSN(cfg configloader.ConnectionConfig) string

+ func (s SqliteAdapter) DatabaseName(executor sqlExecutor) (string, error)

+ func (s SqliteAdapter) TableExists(executor sqlExecutor, tableName string) (bool, error)

Mar 11, 2024

Changes in this version

+ type DB struct

+ func NewDB(cfg configloader.ConnectionConfig) (DB, error)

+ func (db *DB) Tx(fn txFunc) error

+ func (db DB) Close() error

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

+ func (db DB) Query(query string, args ...any) (*sql.Rows, error)

+ func (db DB) QueryRow(query string, args ...any) *sql.Row

+ func (db DB) TableExists(tableName string) (bool, error)

+ type DBAdapter interface

+ ConvertGenericPlaceholders func(query string, argsCount int) string

+ CreateDSN func(cfg configloader.ConnectionConfig) string

+ DatabaseName func(executor sqlExecutor) (string, error)

+ TableExists func(executor sqlExecutor, tableName string) (bool, error)

+ type MySQLAdapter struct

+ func (m MySQLAdapter) ConvertGenericPlaceholders(query string, argsCount int) string

+ func (m MySQLAdapter) CreateDSN(cfg configloader.ConnectionConfig) string

+ func (m MySQLAdapter) DatabaseName(executor sqlExecutor) (string, error)

+ func (m MySQLAdapter) TableExists(executor sqlExecutor, tableName string) (bool, error)

+ type PostgresqlAdapter struct

+ func (p PostgresqlAdapter) ConvertGenericPlaceholders(query string, argsCount int) string

+ func (p PostgresqlAdapter) CreateDSN(cfg configloader.ConnectionConfig) string

+ func (p PostgresqlAdapter) DatabaseName(executor sqlExecutor) (string, error)

+ func (p PostgresqlAdapter) TableExists(executor sqlExecutor, tableName string) (bool, error)

Mar 9, 2024

Changes in this version

+ var ErrUnsupportedDriver = fmt.Errorf("unsupported driver, supported drivers are %s", supportedDrivers)

Mar 2, 2024

Changes in this version

+ var ErrMalformedConnectionString = errors.New("malformed database connection parameters provided")

+ var ErrUnableToConnect = errors.New("unable to open connection to database")

Jan 14, 2024

Changes in this version

+ func DBConnect(driver string, connectionParams string) (*sql.DB, error)

+ func DBConnectionString(cfg *configloader.ConnectionConfig) string