databricks · mattdeekay · Aug 16, 2023 · Aug 16, 2023 · Aug 16, 2023 · Aug 16, 2023
@@ -14,7 +14,7 @@
     CursorAlreadyClosedError,
 )
 from databricks.sql.thrift_backend import ThriftBackend
-from databricks.sql.utils import ExecuteResponse, ParamEscaper, inject_parameters
+from databricks.sql.utils import ExecuteResponse, ParamEscaper
 from databricks.sql.types import Row
 from databricks.sql.auth.auth import get_python_sql_connector_auth_provider
 from databricks.sql.experimental.oauth_persistence import OAuthPersistence
@@ -482,21 +482,17 @@ def _handle_staging_remove(self, presigned_url: str, headers: dict = None):
             )
 
     def execute(
-        self, operation: str, parameters: Optional[Dict[str, str]] = None
+        self, operation: str, parameters: Optional[Dict[str, Any]] = None
     ) -> "Cursor":
         """
         Execute a query and wait for execution to complete.
-        Parameters should be given in extended param format style: %(...)<s|d|f>.
+        Named parameters should be given in this format: :param.
         For example:
-            operation = "SELECT * FROM table WHERE field = %(some_value)s"
-            parameters = {"some_value": "foo"}
-            Will result in the query "SELECT * FROM table WHERE field = 'foo' being sent to the server
+            operation = "SELECT * FROM table WHERE field = :some_param"
+            parameters = {"some_param": "foo"}
+            Will result in the query with the parameters sent to the server for server-side parameterization
         :returns self
         """
-        if parameters is not None:
-            operation = inject_parameters(
-                operation, self.escaper.escape_args(parameters)
-            )
 
         self._check_not_closed()
         self._close_and_clear_active_result_set()
@@ -507,6 +503,7 @@ def execute(
             max_bytes=self.buffer_size_bytes,
             lz4_compression=self.connection.lz4_compression,
             cursor=self,
+            parameters=parameters,
             use_cloud_fetch=self.connection.use_cloud_fetch,
         )
         self.active_result_set = ResultSet(

@@ -1,6 +1,6 @@
 #!/usr/bin/env python
 #
-# Autogenerated by Thrift Compiler (0.17.0)
+# Autogenerated by Thrift Compiler (0.18.1)
 #
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
 #
@@ -45,7 +45,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
     print('  TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req)')
     print('  TCancelDelegationTokenResp CancelDelegationToken(TCancelDelegationTokenReq req)')
     print('  TRenewDelegationTokenResp RenewDelegationToken(TRenewDelegationTokenReq req)')
-    print('  TDBSqlGetLoadInformationResp GetLoadInformation(TDBSqlGetLoadInformationReq req)')
     print('')
     sys.exit(0)
 
@@ -251,12 +250,6 @@ elif cmd == 'RenewDelegationToken':
         sys.exit(1)
     pp.pprint(client.RenewDelegationToken(eval(args[0]),))
 
-elif cmd == 'GetLoadInformation':
-    if len(args) != 1:
-        print('GetLoadInformation requires 1 args')
-        sys.exit(1)
-    pp.pprint(client.GetLoadInformation(eval(args[0]),))
-
 else:
     print('Unrecognized method %s' % cmd)
     sys.exit(1)