aboutsummaryrefslogtreecommitdiff
path: root/benchmark/internal/oblast_pgx
diff options
context:
space:
mode:
Diffstat (limited to 'benchmark/internal/oblast_pgx')
-rw-r--r--benchmark/internal/oblast_pgx/handle.go14
-rw-r--r--benchmark/internal/oblast_pgx/results.go14
-rw-r--r--benchmark/internal/oblast_pgx/statement.go18
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...)
}