@@ -86,6 +86,34 @@ def execute_command(
86
86
async_op : bool ,
87
87
enforce_embedded_schema_correctness : bool ,
88
88
) -> Union ["ResultSet" , None ]:
89
+ """
90
+ Executes a SQL command or query within the specified session.
91
+
92
+ This method sends a SQL command to the server for execution and handles
93
+ the response. It can operate in both synchronous and asynchronous modes.
94
+
95
+ Args:
96
+ operation: The SQL command or query to execute
97
+ session_id: The session identifier in which to execute the command
98
+ max_rows: Maximum number of rows to fetch in a single fetch batch
99
+ max_bytes: Maximum number of bytes to fetch in a single fetch batch
100
+ lz4_compression: Whether to use LZ4 compression for result data
101
+ cursor: The cursor object that will handle the results
102
+ use_cloud_fetch: Whether to use cloud fetch for retrieving large result sets
103
+ parameters: List of parameters to bind to the query
104
+ async_op: Whether to execute the command asynchronously
105
+ enforce_embedded_schema_correctness: Whether to enforce schema correctness
106
+
107
+ Returns:
108
+ If async_op is False, returns a ResultSet object containing the
109
+ query results and metadata. If async_op is True, returns None and the
110
+ results must be fetched later using get_execution_result().
111
+
112
+ Raises:
113
+ ValueError: If the session ID is invalid
114
+ OperationalError: If there's an error executing the command
115
+ ServerOperationError: If the server encounters an error during execution
116
+ """
89
117
pass
90
118
91
119
@abstractmethod
0 commit comments