db

Nov 28, 2024

Changes in this version

+ func Close(db DB) error

+ func Connect(db DB) error

+ func MigrateDown(database *sql.DB, logger logger.Logger, files fs.FS)

+ func MigrateFixDown(database *sql.DB, logger logger.Logger, files fs.FS, ver int)

+ func MigrateFixUp(database *sql.DB, logger logger.Logger, files fs.FS, ver int)

+ func MigrateUp(database *sql.DB, logger logger.Logger, files fs.FS)

+ func NewPostgresDB(logger logger.Logger) (*sql.DB, error)

+ type DB interface

+ Begin func() (*sql.Tx, error)

+ Close func() error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Ping func() error

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type DBLogger struct

+ func NewDBLogger(db *sql.DB, logger logger.Logger) DBLogger

+ func (d DBLogger) Begin() (*sql.Tx, error)

+ func (d DBLogger) Close() error

+ func (d DBLogger) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (d DBLogger) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (d DBLogger) Ping() error

+ func (d DBLogger) Prepare(query string) (*sql.Stmt, error)

+ func (d DBLogger) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

+ func (d DBLogger) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (d DBLogger) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (d DBLogger) QueryRow(query string, args ...interface{}) *sql.Row

+ func (d DBLogger) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type PostgresListener struct

+ Callbacks map[string]func(data string)

+ Listener *pq.Listener

+ func NewPostgresListner(logger logger.Logger) *PostgresListener

+ func (p *PostgresListener) Close()

+ func (p *PostgresListener) Listen(channel string, callback func(data string))

+ func (p *PostgresListener) Ping()

+ func (p *PostgresListener) Start()

+ func (p *PostgresListener) Unlisten(channel string)