remove implementation for variant type, mark variant tests as skipped

Author: sfc-gh-mkubik

DESCRIPTION.md

@@ -21,6 +21,7 @@ Source code is also available at: https://github.com/snowflakedb/snowflake-conne
   - Lower log levels from info to debug for some of the messages to make the output easier to follow.
   - Allow the connector to inherit a UUID4 generated upstream, provided in statement parameters (field: `requestId`), rather than automatically generate a UUID4 to use for the HTTP Request ID.
   - Fix expired S3 credentials update and increment retry when expired credentials are found.
+  - Add `snowflake_type` parameter to execute method of a cursor. When set to `OBJECT` or `ARRAY` it allows binding of these semi-structured types.
 
 - v3.14.0(March 03, 2025)
   - Bumped pyOpenSSL dependency upper boundary from <25.0.0 to <26.0.0.

src/snowflake/connector/connection.py

@@ -1671,8 +1671,10 @@ def _get_snowflake_type_and_binding(
         )
 
     @staticmethod
-    def _is_semi_structured_type(snowflake_type: str):
-        return snowflake_type in ("OBJECT", "ARRAY", "VARIANT")
+    def _server_side_binding_supported(snowflake_type: str):
+        if snowflake_type == "VARIANT":
+            logger.warning("Server side binding for VARIANT type is not supported.")
+        return snowflake_type in ("OBJECT", "ARRAY")
 
     def _process_server_side_semi_structured_bindings(
         self, cursor: SnowflakeCursor | None, params: Sequence, snowflake_type: str
@@ -1727,38 +1729,6 @@ def _process_server_side_semi_structured_bindings(
                             "errno": ER_NOT_SUPPORT_DATA_TYPE,
                         },
                     )
-        elif snowflake_type == "VARIANT":
-            snowflake_type = "TEXT"
-            for idx, v in enumerate(params):
-                if isinstance(v, str) or v is None:
-                    processed_params[str(idx + 1)] = {
-                        "type": snowflake_type,
-                        "fmt": "json",
-                        "value": v,
-                    }
-                else:
-                    value = None
-                    try:
-                        value = json.dumps(v)
-                    except TypeError:
-                        Error.errorhandler_wrapper(
-                            self,
-                            cursor,
-                            ProgrammingError,
-                            {
-                                "msg": "Attempted to insert value {} as {} but the it's of an unsupported type: {}.".format(
-                                    v, snowflake_type, type(v)
-                                ),
-                                "errno": ER_NOT_SUPPORT_DATA_TYPE,
-                            },
-                        )
-
-                    if value is not None:
-                        processed_params[str(idx + 1)] = {
-                            "type": snowflake_type,
-                            "fmt": "json",
-                            "value": value,
-                        }
 
         return processed_params
 
@@ -1773,7 +1743,7 @@ def _process_params_qmarks(
             return None
         processed_params = {}
 
-        if self._is_semi_structured_type(snowflake_type):
+        if self._server_side_binding_supported(snowflake_type):
             processed_params = self._process_server_side_semi_structured_bindings(
                 cursor, params, snowflake_type
             )

test/integ/test_bindings.py

@@ -492,6 +492,7 @@ def test_binding_insert_date(conn_cnx, db_parameters):
 
 @pytest.mark.skipolddriver
 def test_binding_variant(conn_cnx):
+    pytest.skip("Server side binding of VARIANT type is not supported")
     bind_query = "INSERT INTO TEST_TABLE1 SELECT (?)"
     with conn_cnx(paramstyle="qmark") as cnx, cnx.cursor() as cursor:
         snowflake_type = "VARIANT"