FM / postgresql

/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/dialects/postgresql/

/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/dialects/postgresql

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
array.py	11776	0644	edit dl rm
base.py	129248	0644	edit dl rm
dml.py	7790	0644	edit dl rm
ext.py	7739	0644	edit dl rm
hstore.py	12417	0644	edit dl rm
json.py	10103	0644	edit dl rm
pg8000.py	9722	0644	edit dl rm
provision.py	2008	0644	edit dl rm
psycopg2.py	37768	0644	edit dl rm
psycopg2cffi.py	1657	0644	edit dl rm
pygresql.py	8129	0644	edit dl rm
pypostgresql.py	2915	0644	edit dl rm
ranges.py	4622	0644	edit dl rm
zxjdbc.py	1415	0644	edit dl rm
__init__.py	2461	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/dialects/postgresql/zxjdbc.py (1415B)

# postgresql/zxjdbc.py
# Copyright (C) 2005-2021 the SQLAlchemy authors and contributors
# <see AUTHORS file>
#
# This module is part of SQLAlchemy and is released under
# the MIT License: http://www.opensource.org/licenses/mit-license.php

"""
.. dialect:: postgresql+zxjdbc
    :name: zxJDBC for Jython
    :dbapi: zxjdbc
    :connectstring: postgresql+zxjdbc://scott:tiger@localhost/db
    :driverurl: http://jdbc.postgresql.org/

"""
from .base import PGDialect
from .base import PGExecutionContext
from ...connectors.zxJDBC import ZxJDBCConnector

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):
        parts = connection.connection.dbversion.split(".")
        return tuple(int(x) for x in parts)

dialect = PGDialect_zxjdbc

# postgresql/zxjdbc.py # Copyright (C) 2005-2021 the SQLAlchemy authors and contributors # # # This module is part of SQLAlchemy and is released under # the MIT License: http://www.opensource.org/licenses/mit-license.php """ .. dialect:: postgresql+zxjdbc :name: zxJDBC for Jython :dbapi: zxjdbc :connectstring: postgresql+zxjdbc://scott:tiger@localhost/db :driverurl: http://jdbc.postgresql.org/ """ from .base import PGDialect from .base import PGExecutionContext from ...connectors.zxJDBC import ZxJDBCConnector 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): parts = connection.connection.dbversion.split(".") return tuple(int(x) for x in parts) dialect = PGDialect_zxjdbc