diff options
Diffstat (limited to 'benchmark/internal/oblast_pgx/statement.go')
| -rw-r--r-- | benchmark/internal/oblast_pgx/statement.go | 60 |
1 files changed, 0 insertions, 60 deletions
diff --git a/benchmark/internal/oblast_pgx/statement.go b/benchmark/internal/oblast_pgx/statement.go deleted file mode 100644 index 0a33c73..0000000 --- a/benchmark/internal/oblast_pgx/statement.go +++ /dev/null @@ -1,60 +0,0 @@ -// SPDX-FileCopyrightText: 2026 Stefan Majewsky <majewsky@gmx.net> -// SPDX-License-Identifier: Apache-2.0 - -package oblast_pgx - -import ( - "context" - "database/sql" - - "github.com/jackc/pgx/v5/pgconn" - "go.xyrillian.de/gg/gsql" -) - -type wrappedPreparedStatement struct { - ctx context.Context - statement *pgconn.StatementDescription - handle Handle -} - -type wrappedUnpreparedStatement struct { - query string - handle Handle -} - -var ( - _ gsql.Statement = wrappedPreparedStatement{} - _ gsql.Statement = wrappedUnpreparedStatement{} -) - -// Close implements the [gsql.Statement] interface. -func (s wrappedPreparedStatement) Close() error { - return deallocate(s.ctx, s.handle, s.statement) -} - -// Close implements the [gsql.Statement] interface. -func (s wrappedUnpreparedStatement) Close() error { - return nil -} - -// 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 [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 [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 [gsql.Statement] interface. -func (s wrappedUnpreparedStatement) QueryRow(ctx context.Context, args, slots []any) error { - return s.handle.QueryRow(ctx, s.query, args...).Scan(slots...) -} |
