diff options
| author | Stefan Majewsky <majewsky@gmx.net> | 2026-07-31 21:39:56 +0200 |
|---|---|---|
| committer | Stefan Majewsky <majewsky@gmx.net> | 2026-07-31 23:35:23 +0200 |
| commit | 656e5dcce132716b39005814407224f989aa8c2d (patch) | |
| tree | ab0a6d3a046170f0ace6a6e4ab3668ce0af811ae /benchmark/internal | |
| parent | a2f8d7a68f324d5b4086148571f990409425e22a (diff) | |
| download | go-oblast-656e5dcce132716b39005814407224f989aa8c2d.tar.gz | |
replace types Handle, DB, Conn, Tx with their gg/gsql equivalents
Diffstat (limited to 'benchmark/internal')
| -rw-r--r-- | benchmark/internal/oblast_pgx/handle.go | 14 | ||||
| -rw-r--r-- | benchmark/internal/oblast_pgx/results.go | 14 | ||||
| -rw-r--r-- | benchmark/internal/oblast_pgx/statement.go | 18 |
3 files changed, 23 insertions, 23 deletions
diff --git a/benchmark/internal/oblast_pgx/handle.go b/benchmark/internal/oblast_pgx/handle.go index 845fbe4..4bd72bd 100644 --- a/benchmark/internal/oblast_pgx/handle.go +++ b/benchmark/internal/oblast_pgx/handle.go @@ -12,7 +12,7 @@ import ( "github.com/jackc/pgx/v5" "github.com/jackc/pgx/v5/pgconn" "github.com/jackc/pgx/v5/pgxpool" - "go.xyrillian.de/oblast/handle" + "go.xyrillian.de/gg/gsql" ) type Handle interface { @@ -27,7 +27,7 @@ var ( _ Handle = pgx.Tx(&pgxpool.Tx{}) ) -func Wrap(h Handle) handle.Handle { +func Wrap(h Handle) gsql.Handle { switch h := h.(type) { case *pgx.Conn: return wrappedHandle{h} @@ -46,8 +46,8 @@ type wrappedHandle struct { inner Handle } -// OblastPrepare implements the [handle.Handle] interface. -func (h wrappedHandle) OblastPrepare(ctx context.Context, query string, repeated bool) (handle.Statement, error) { +// GSQLPrepare implements the [gsql.Handle] interface. +func (h wrappedHandle) GSQLPrepare(ctx context.Context, query string, repeated bool) (gsql.Statement, error) { if !repeated { return wrappedUnpreparedStatement{query, h.inner}, nil } @@ -74,7 +74,7 @@ func deallocate(ctx context.Context, h Handle, stmt *pgconn.StatementDescription case *pgx.Conn: return h.Deallocate(ctx, stmt.Name) case *pgxpool.Conn: - panic("unreachable") // because func OblastPrepare() does not return a wrappedPreparedStatement for this underlying type + panic("unreachable") // because func GSQLPrepare() does not return a wrappedPreparedStatement for this underlying type case pgx.Tx: return h.Conn().Deallocate(ctx, stmt.Name) default: @@ -82,8 +82,8 @@ func deallocate(ctx context.Context, h Handle, stmt *pgconn.StatementDescription } } -// OblastQuery implements the [handle.Handle] interface. -func (h wrappedHandle) OblastQuery(ctx context.Context, query string, args []any) (handle.Rows, error) { +// GSQLQuery implements the [gsql.Handle] interface. +func (h wrappedHandle) GSQLQuery(ctx context.Context, query string, args []any) (gsql.Rows, error) { rows, err := h.inner.Query(ctx, query, args...) return wrappedRows{rows}, err } diff --git a/benchmark/internal/oblast_pgx/results.go b/benchmark/internal/oblast_pgx/results.go index 3ccb5ce..f842d36 100644 --- a/benchmark/internal/oblast_pgx/results.go +++ b/benchmark/internal/oblast_pgx/results.go @@ -9,16 +9,16 @@ import ( "github.com/jackc/pgx/v5" "github.com/jackc/pgx/v5/pgconn" - "go.xyrillian.de/oblast/handle" + "go.xyrillian.de/gg/gsql" ) type wrappedRows struct { inner pgx.Rows } -var _ handle.Rows = wrappedRows{} +var _ gsql.Rows = wrappedRows{} -// Columns implements the [handle.Rows] interface. +// Columns implements the [gsql.Rows] interface. func (r wrappedRows) Columns() ([]string, error) { descriptions := r.inner.FieldDescriptions() result := make([]string, len(descriptions)) @@ -28,23 +28,23 @@ func (r wrappedRows) Columns() ([]string, error) { return result, nil } -// Close implements the [handle.Rows] interface. +// Close implements the [gsql.Rows] interface. func (r wrappedRows) Close() error { r.inner.Close() return nil } -// Err implements the [handle.Rows] interface. +// Err implements the [gsql.Rows] interface. func (r wrappedRows) Err() error { return r.inner.Err() } -// Next implements the [handle.Rows] interface. +// Next implements the [gsql.Rows] interface. func (r wrappedRows) Next() bool { return r.inner.Next() } -// Scan implements the [handle.Rows] interface. +// Scan implements the [gsql.Rows] interface. func (r wrappedRows) Scan(args ...any) error { return r.inner.Scan(args...) } diff --git a/benchmark/internal/oblast_pgx/statement.go b/benchmark/internal/oblast_pgx/statement.go index d81c579..0a33c73 100644 --- a/benchmark/internal/oblast_pgx/statement.go +++ b/benchmark/internal/oblast_pgx/statement.go @@ -8,7 +8,7 @@ import ( "database/sql" "github.com/jackc/pgx/v5/pgconn" - "go.xyrillian.de/oblast/handle" + "go.xyrillian.de/gg/gsql" ) type wrappedPreparedStatement struct { @@ -23,38 +23,38 @@ type wrappedUnpreparedStatement struct { } var ( - _ handle.Statement = wrappedPreparedStatement{} - _ handle.Statement = wrappedUnpreparedStatement{} + _ gsql.Statement = wrappedPreparedStatement{} + _ gsql.Statement = wrappedUnpreparedStatement{} ) -// Close implements the [handle.Statement] interface. +// Close implements the [gsql.Statement] interface. func (s wrappedPreparedStatement) Close() error { return deallocate(s.ctx, s.handle, s.statement) } -// Close implements the [handle.Statement] interface. +// Close implements the [gsql.Statement] interface. func (s wrappedUnpreparedStatement) Close() error { return nil } -// Exec implements the [handle.Statement] interface. +// Exec implements the [gsql.Statement] interface. func (s wrappedPreparedStatement) Exec(ctx context.Context, args []any) (sql.Result, error) { result, err := s.handle.Exec(ctx, s.statement.Name, args...) return wrappedResult{result}, err } -// Exec implements the [handle.Statement] interface. +// Exec implements the [gsql.Statement] interface. func (s wrappedUnpreparedStatement) Exec(ctx context.Context, args []any) (sql.Result, error) { result, err := s.handle.Exec(ctx, s.query, args...) return wrappedResult{result}, err } -// QueryRow implements the [handle.Statement] interface. +// QueryRow implements the [gsql.Statement] interface. func (s wrappedPreparedStatement) QueryRow(ctx context.Context, args, slots []any) error { return s.handle.QueryRow(ctx, s.statement.Name, args...).Scan(slots...) } -// QueryRow implements the [handle.Statement] interface. +// QueryRow implements the [gsql.Statement] interface. func (s wrappedUnpreparedStatement) QueryRow(ctx context.Context, args, slots []any) error { return s.handle.QueryRow(ctx, s.query, args...).Scan(slots...) } |
