Skip to content

Commit 1f59d21

Browse files
committed
Fixed connection
Signed-off-by: nithinkdb <nithin.krishnamurthi@databricks.com>
1 parent 1c348fa commit 1f59d21

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

connection.go

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -392,6 +392,18 @@ func (c *conn) pollOperation(ctx context.Context, opHandle *cli_service.TOperati
392392
return statusResp, nil
393393
}
394394

395+
func (c *conn) CheckNamedValue(nv *driver.NamedValue) error {
396+
var err error
397+
if dbsqlParam, ok := nv.Value.(DbSqlParam); ok {
398+
nv.Name = dbsqlParam.Name
399+
dbsqlParam.Value, err = driver.DefaultParameterConverter.ConvertValue(dbsqlParam.Value)
400+
return err
401+
}
402+
403+
nv.Value, err = driver.DefaultParameterConverter.ConvertValue(nv.Value)
404+
return err
405+
}
406+
395407
var _ driver.Conn = (*conn)(nil)
396408
var _ driver.Pinger = (*conn)(nil)
397409
var _ driver.SessionResetter = (*conn)(nil)
@@ -400,3 +412,4 @@ var _ driver.ExecerContext = (*conn)(nil)
400412
var _ driver.QueryerContext = (*conn)(nil)
401413
var _ driver.ConnPrepareContext = (*conn)(nil)
402414
var _ driver.ConnBeginTx = (*conn)(nil)
415+
var _ driver.NamedValueChecker = (*conn)(nil)

0 commit comments

Comments
 (0)