vaimdev
diff --git a/‎src/databricks/sql/client.py‎
Lines changed: 13 additions & 0 deletions b/‎src/databricks/sql/client.py‎
Lines changed: 13 additions & 0 deletions
@@ -5,6 +5,7 @@
 import requests
 import json
 import os
+from databricks.sql.thrift_api.TCLIService import ttypes
 
 from databricks.sql import __version__
 from databricks.sql import *
@@ -225,6 +226,11 @@ def __del__(self):
     def get_session_id(self):
         return self.thrift_backend.handle_to_id(self._session_handle)
 
+    def get_session_protocol_version(self):
+        return self.thrift_backend.extract_protocol_version_from_handle(
+            self._session_handle
+        )
+
     def get_session_id_hex(self):
         return self.thrift_backend.handle_to_hex_id(self._session_handle)
 
@@ -501,6 +507,13 @@ def execute(
         """
         if parameters is None:
             parameters = []
+        elif (
+            self.connection.get_session_protocol_version()
+            < ttypes.TProtocolVersion.SPARK_CLI_SERVICE_PROTOCOL_V8
+        ):
+            raise Error(
+                "Parameterized operations are not supported by this server. DBR 14.1 is required."
+            )
         else:
             parameters = named_parameters_to_tsparkparams(parameters)