From a561ebb42148c72638f943e44191da07c16df7f6 Mon Sep 17 00:00:00 2001 From: Stefan Majewsky Date: Wed, 13 May 2026 01:11:30 +0200 Subject: return a concrete type from Wrap() to enable non-Oblast DB operations --- benchmark/internal/oblast_pgx/handle.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'benchmark/internal/oblast_pgx/handle.go') diff --git a/benchmark/internal/oblast_pgx/handle.go b/benchmark/internal/oblast_pgx/handle.go index 6a88e2b..7ccc9ea 100644 --- a/benchmark/internal/oblast_pgx/handle.go +++ b/benchmark/internal/oblast_pgx/handle.go @@ -43,8 +43,8 @@ type wrappedHandle struct { inner Handle } -// Prepare implements the [handle.Handle] interface. -func (h wrappedHandle) Prepare(ctx context.Context, query string, repeated bool) (handle.Statement, error) { +// OblastPrepare implements the [handle.Handle] interface. +func (h wrappedHandle) OblastPrepare(ctx context.Context, query string, repeated bool) (handle.Statement, error) { if !repeated { return wrappedUnpreparedStatement{query, h.inner}, nil } @@ -74,8 +74,8 @@ func deallocate(ctx context.Context, h Handle, stmt *pgconn.StatementDescription } } -// Query implements the [handle.Handle] interface. -func (h wrappedHandle) Query(ctx context.Context, query string, args []any) (handle.Rows, error) { +// OblastQuery implements the [handle.Handle] interface. +func (h wrappedHandle) OblastQuery(ctx context.Context, query string, args []any) (handle.Rows, error) { rows, err := h.inner.Query(ctx, query, args...) return wrappedRows{rows}, err } -- cgit v1.2.3