SNOW-1247646: Update the logging level from INFO to DEBUG when logging the executed query using SnowflakeCursor.execute (#1904)

Author: sfc-gh-jdu

DESCRIPTION.md

@@ -23,8 +23,9 @@ Source code is also available at: https://github.com/snowflakedb/snowflake-conne
   - Added support for parsing structured type information in schema queries.
   - Bumped platformdirs from >=2.6.0,<4.0.0 to >=2.6.0,<5.0.0
   - Updated diagnostics to use system$allowlist instead of system$whitelist.
-  - Update `write_pandas` to skip TABLE IF NOT EXISTS in truncate mode.
+  - Updated `write_pandas` to skip TABLE IF NOT EXISTS in truncate mode.
   - Improved cleanup logic for connection to rely on interpreter shutdown instead of the `__del__` method.
+  - Updated the logging level from INFO to DEBUG when logging the executed query using `SnowflakeCursor.execute`.
 
 - v3.7.1(February 21, 2024)
 

src/snowflake/connector/cursor.py

@@ -922,6 +922,7 @@ def execute(
         if not command:
             logger.warning("execute: no query is given to execute")
             return None
+        logger.debug("query: [%s]", self._format_query_for_log(command))
 
         _statement_params = _statement_params or dict()
         # If we need to add another parameter, please consider introducing a dict for all extra params
@@ -966,16 +967,13 @@ def execute(
         m = DESC_TABLE_RE.match(query)
         if m:
             query1 = f"describe table {m.group(1)}"
-            if logger.getEffectiveLevel() <= logging.WARNING:
-                logger.info(
-                    "query was rewritten: org=%s, new=%s",
-                    " ".join(line.strip() for line in query.split("\n")),
-                    query1,
-                )
+            logger.debug(
+                "query was rewritten: org=%s, new=%s",
+                " ".join(line.strip() for line in query.split("\n")),
+                query1,
+            )
             query = query1
 
-        if logger.getEffectiveLevel() <= logging.INFO:
-            logger.info("query: [%s]", self._format_query_for_log(query))
         ret = self._execute_helper(query, **kwargs)
         self._sfqid = (
             ret["data"]["queryId"]
@@ -988,7 +986,7 @@ def execute(
             if "data" in ret and "sqlState" in ret["data"]
             else None
         )
-        logger.info("query execution done")
+        logger.debug("query execution done")
 
         self._first_chunk_time = get_time_millis()
 

test/integ/test_cursor.py

@@ -1276,7 +1276,7 @@ def test_desc_rewrite(conn, caplog):
                 cur.execute(f"desc {table_name}")
                 assert (
                     "snowflake.connector.cursor",
-                    20,
+                    10,
                     "query was rewritten: org=desc {table_name}, new=describe table {table_name}".format(
                         table_name=table_name
                     ),