@@ -112,9 +112,6 @@ func (c *conn) ExecContext(ctx context.Context, query string, args []driver.Name
112
112
defer log .Duration (msg , start )
113
113
114
114
corrId := driverctx .CorrelationIdFromContext (ctx )
115
- if len (args ) > 0 && c .session .ServerProtocolVersion < cli_service .TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V8 {
116
- return nil , dbsqlerrint .NewDriverError (ctx , dbsqlerr .ErrParametersNotSupported , nil )
117
- }
118
115
119
116
exStmtResp , opStatusResp , err := c .runQuery (ctx , query , args )
120
117
log , ctx = client .LoggerAndContext (ctx , exStmtResp )
@@ -159,10 +156,6 @@ func (c *conn) QueryContext(ctx context.Context, query string, args []driver.Nam
159
156
log , _ := client .LoggerAndContext (ctx , nil )
160
157
msg , start := log .Track ("QueryContext" )
161
158
162
- if len (args ) > 0 && c .session .ServerProtocolVersion < cli_service .TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V8 {
163
- return nil , dbsqlerrint .NewDriverError (ctx , dbsqlerr .ErrParametersNotSupported , nil )
164
- }
165
-
166
159
// first we try to get the results synchronously.
167
160
// at any point in time that the context is done we must cancel and return
168
161
exStmtResp , opStatusResp , err := c .runQuery (ctx , query , args )
0 commit comments