Sha256: e0218c881eaed03c87e56efbc0454149ff03ba886d86e835bd47e07536161efe
Contents?: true
Size: 1.27 KB
Versions: 16
Compression:
Stored size: 1.27 KB
Contents
// Copyright (c) 2017-2022 Snowflake Computing Inc. All rights reserved.
package gosnowflake
import (
"context"
"database/sql/driver"
)
type snowflakeStmt struct {
sc *snowflakeConn
query string
}
func (stmt *snowflakeStmt) Close() error {
logger.WithContext(stmt.sc.ctx).Infoln("Stmt.Close")
// noop
return nil
}
func (stmt *snowflakeStmt) NumInput() int {
logger.WithContext(stmt.sc.ctx).Infoln("Stmt.NumInput")
// Go Snowflake doesn't know the number of binding parameters.
return -1
}
func (stmt *snowflakeStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error) {
logger.WithContext(stmt.sc.ctx).Infoln("Stmt.ExecContext")
return stmt.sc.ExecContext(ctx, stmt.query, args)
}
func (stmt *snowflakeStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error) {
logger.WithContext(stmt.sc.ctx).Infoln("Stmt.QueryContext")
return stmt.sc.QueryContext(ctx, stmt.query, args)
}
func (stmt *snowflakeStmt) Exec(args []driver.Value) (driver.Result, error) {
logger.WithContext(stmt.sc.ctx).Infoln("Stmt.Exec")
return stmt.sc.Exec(stmt.query, args)
}
func (stmt *snowflakeStmt) Query(args []driver.Value) (driver.Rows, error) {
logger.WithContext(stmt.sc.ctx).Infoln("Stmt.Query")
return stmt.sc.Query(stmt.query, args)
}
Version data entries
16 entries across 16 versions & 1 rubygems