From 207cc872be504832ecb7549a90e3119b146955b9 Mon Sep 17 00:00:00 2001 From: hantmac Date: Fri, 30 Dec 2022 16:05:13 +0800 Subject: [PATCH] fix execute --- databend_sqlalchemy/__init__.py | 2 +- databend_sqlalchemy/connector.py | 8 ++------ 2 files changed, 3 insertions(+), 7 deletions(-) diff --git a/databend_sqlalchemy/__init__.py b/databend_sqlalchemy/__init__.py index 14ff319..5eea3d2 100644 --- a/databend_sqlalchemy/__init__.py +++ b/databend_sqlalchemy/__init__.py @@ -1,4 +1,4 @@ #!/usr/bin/env python -VERSION = (0, 0, 6) +VERSION = (0, 0, 8) __version__ = '.'.join(str(x) for x in VERSION) diff --git a/databend_sqlalchemy/connector.py b/databend_sqlalchemy/connector.py index a71f600..d7086e2 100644 --- a/databend_sqlalchemy/connector.py +++ b/databend_sqlalchemy/connector.py @@ -54,7 +54,7 @@ def escape_item(self, item): elif isinstance(item, datetime): return self.escape_string(item.strftime("%Y-%m-%d %H:%M:%S")) else: - raise Exception("Unsupported object {}".format(item)) + return self.escape_string(item) _escaper = ParamEscaper() @@ -170,10 +170,6 @@ def close(self): def execute(self, operation, parameters=None, is_response=True): """Prepare and execute a database operation (query or command). """ - if parameters is None or not parameters: - sql = operation - else: - sql = operation % _escaper.escape_args(parameters) self._reset_state() @@ -181,7 +177,7 @@ def execute(self, operation, parameters=None, is_response=True): self._uuid = uuid.uuid1() if is_response: - column_types, response = self._db.execute(sql, with_column_types=True) + column_types, response = self._db.execute(operation, parameters, with_column_types=True) self._process_response(column_types, response) def executemany(self, operation, seq_of_parameters):