Skip to content

Commit 5b87db5

Browse files
committed
Add PrepareContext methof
1 parent 443b1b3 commit 5b87db5

1 file changed

Lines changed: 17 additions & 8 deletions

File tree

go/database/sql/connection.go

Lines changed: 17 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -30,17 +30,17 @@ func (s *sqlCommenterConn) Query(query string, args []driver.Value) (driver.Rows
3030
return nil, driver.ErrSkip
3131
}
3232
ctx := context.Background()
33-
extendedQuery := s.withComment(ctx, query)
34-
return queryer.Query(extendedQuery, args)
33+
commentedQuery := s.withComment(ctx, query)
34+
return queryer.Query(commentedQuery, args)
3535
}
3636

3737
func (s *sqlCommenterConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error) {
3838
queryer, ok := s.Conn.(driver.QueryerContext)
3939
if !ok {
4040
return nil, driver.ErrSkip
4141
}
42-
extendedQuery := s.withComment(ctx, query)
43-
return queryer.QueryContext(ctx, extendedQuery, args)
42+
commentedQuery := s.withComment(ctx, query)
43+
return queryer.QueryContext(ctx, commentedQuery, args)
4444
}
4545

4646
func (s *sqlCommenterConn) Exec(query string, args []driver.Value) (driver.Result, error) {
@@ -49,17 +49,26 @@ func (s *sqlCommenterConn) Exec(query string, args []driver.Value) (driver.Resul
4949
return nil, driver.ErrSkip
5050
}
5151
ctx := context.Background()
52-
extendedQuery := s.withComment(ctx, query)
53-
return execor.Exec(extendedQuery, args)
52+
commentedQuery := s.withComment(ctx, query)
53+
return execor.Exec(commentedQuery, args)
5454
}
5555

5656
func (s *sqlCommenterConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error) {
5757
execor, ok := s.Conn.(driver.ExecerContext)
5858
if !ok {
5959
return nil, driver.ErrSkip
6060
}
61-
extendedQuery := s.withComment(ctx, query)
62-
return execor.ExecContext(ctx, extendedQuery, args)
61+
commentedQuery := s.withComment(ctx, query)
62+
return execor.ExecContext(ctx, commentedQuery, args)
63+
}
64+
65+
func (s *sqlCommenterConn) PrepareContext(ctx context.Context, query string) (stmt driver.Stmt, err error) {
66+
preparer, ok := s.Conn.(driver.ConnPrepareContext)
67+
if !ok {
68+
return nil, driver.ErrSkip
69+
}
70+
commentedQuery := s.withComment(ctx, query)
71+
return preparer.PrepareContext(ctx, commentedQuery)
6372
}
6473

6574
func (s *sqlCommenterConn) Raw() driver.Conn {

0 commit comments

Comments
 (0)