"""
from sqlalchemy.connectors.zxJDBC import ZxJDBCConnector
-from sqlalchemy.dialects.postgresql.base import PGDialect
+from sqlalchemy.dialects.postgresql.base import PGDialect, PGExecutionContext
+
+class PGExecutionContext_zxjdbc(PGExecutionContext):
+
+ def create_cursor(self):
+ cursor = self._dbapi_connection.cursor()
+ cursor.datahandler = self.dialect.DataHandler(cursor.datahandler)
+ return cursor
+
class PGDialect_zxjdbc(ZxJDBCConnector, PGDialect):
jdbc_db_name = 'postgresql'
jdbc_driver_name = 'org.postgresql.Driver'
+ execution_ctx_cls = PGExecutionContext_zxjdbc
+
+ supports_native_decimal = True
+
+ def __init__(self, *args, **kwargs):
+ super(PGDialect_zxjdbc, self).__init__(*args, **kwargs)
+ from com.ziclix.python.sql.handler import PostgresqlDataHandler
+ self.DataHandler = PostgresqlDataHandler
+
def _get_server_version_info(self, connection):
return tuple(int(x) for x in connection.connection.dbversion.split('.'))