driver

package

v1.1.0 Latest Latest Go to latest Published: Jun 3, 2026 License: MIT Imports: 5 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func NewPostgresDB(ctx context.Context, dataSource string) (*SqlDB, error)

func NewYugabyteDB(ctx context.Context, dataSource string) (*SqlDB, error)

func (s *SqlDB) BeginTx(ctx context.Context) (*SqlTx, error)

func (s *SqlDB) Close() error

Close is not thread-safe method

func (s *SqlDB) Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)

func (s *SqlDB) Ping(ctx context.Context, timeout time.Duration) error

func (s *SqlDB) Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)

func (s *SqlDB) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

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

func (t *SqlTx) Commit(ctx context.Context) error

func (t *SqlTx) Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)

func (t *SqlTx) Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)

func (t *SqlTx) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

func (t *SqlTx) Rollback(ctx context.Context) error