From 164893503c207fa6fc26e99666d54a6ebcb67d29 Mon Sep 17 00:00:00 2001 From: nithinkdb Date: Tue, 26 Dec 2023 10:08:19 -0800 Subject: [PATCH] Removed protocol check Signed-off-by: nithinkdb --- connection.go | 7 ------- 1 file changed, 7 deletions(-) diff --git a/connection.go b/connection.go index 87eb78a..041f05b 100644 --- a/connection.go +++ b/connection.go @@ -112,9 +112,6 @@ func (c *conn) ExecContext(ctx context.Context, query string, args []driver.Name defer log.Duration(msg, start) corrId := driverctx.CorrelationIdFromContext(ctx) - if len(args) > 0 && c.session.ServerProtocolVersion < cli_service.TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V8 { - return nil, dbsqlerrint.NewDriverError(ctx, dbsqlerr.ErrParametersNotSupported, nil) - } exStmtResp, opStatusResp, err := c.runQuery(ctx, query, args) log, ctx = client.LoggerAndContext(ctx, exStmtResp) @@ -159,10 +156,6 @@ func (c *conn) QueryContext(ctx context.Context, query string, args []driver.Nam log, _ := client.LoggerAndContext(ctx, nil) msg, start := log.Track("QueryContext") - if len(args) > 0 && c.session.ServerProtocolVersion < cli_service.TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V8 { - return nil, dbsqlerrint.NewDriverError(ctx, dbsqlerr.ErrParametersNotSupported, nil) - } - // first we try to get the results synchronously. // at any point in time that the context is done we must cancel and return exStmtResp, opStatusResp, err := c.runQuery(ctx, query, args)