adapters

package

v1.1.1-beta Latest Latest Go to latest Published: Jul 29, 2025 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type DBAdapter interface {
	Query(ctx context.Context, query string) (DBRows, error)
	Exec(ctx context.Context, query string) (DBResult, error)
}

DBAdapter defines the interface for database operations needed by the event store

type DBResult interface {
	RowsAffected() (int64, error)
}

DBResult defines the interface for execution results

type DBRows interface {
	Next() bool
	Scan(dest ...interface{}) error
	Close() error
}

DBRows defines the interface for query result rows

type PGXAdapter struct {
	// contains filtered or unexported fields
}

PGXAdapter implements DBAdapter for pgxpool.Pool

func NewPGXAdapter(pool *pgxpool.Pool) *PGXAdapter

NewPGXAdapter creates a new PGX adapter

func (p *PGXAdapter) Exec(ctx context.Context, query string) (DBResult, error)

func (p *PGXAdapter) Query(ctx context.Context, query string) (DBRows, error)

type SQLAdapter struct {
	// contains filtered or unexported fields
}

SQLAdapter implements DBAdapter for sql.DB

func NewSQLAdapter(db *sql.DB) *SQLAdapter

NewSQLAdapter creates a new SQL adapter

func (s *SQLAdapter) Exec(ctx context.Context, query string) (DBResult, error)

func (s *SQLAdapter) Query(ctx context.Context, query string) (DBRows, error)

type SQLXAdapter struct {
	// contains filtered or unexported fields
}

SQLXAdapter implements DBAdapter for sqlx.DB

func NewSQLXAdapter(db *sqlx.DB) *SQLXAdapter

NewSQLXAdapter creates a new SQLX adapter

func (s *SQLXAdapter) Exec(ctx context.Context, query string) (DBResult, error)

func (s *SQLXAdapter) Query(ctx context.Context, query string) (DBRows, error)