̧@ d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd
l
m Z G d d e Z G d
de Z
G d de e ZeZdS )a
.. dialect:: mysql+zxjdbc
:name: zxjdbc for Jython
:dbapi: zxjdbc
:connectstring: mysql+zxjdbc://:@[:]/
:driverurl: http://dev.mysql.com/downloads/connector/j/
.. note:: Jython is not supported by current versions of SQLAlchemy. The
zxjdbc dialect should be considered as experimental.
Character Sets
--------------
SQLAlchemy zxjdbc dialects pass unicode straight through to the
zxjdbc/JDBC layer. To allow multiple character sets to be sent from the
MySQL Connector/J JDBC driver, by default SQLAlchemy sets its
``characterEncoding`` connection property to ``UTF-8``. It may be
overridden via a ``create_engine`` URL parameter.
N )BIT) MySQLDialect)MySQLExecutionContext )types)util)ZxJDBCConnectorc e Zd Zd ZdS )
_ZxJDBCBitc d }|S )z@Converts boolean or byte arrays from MySQL Connector/J to longs.c ~ | | S t | t rt | S d}| D ]
}|dz |dz z }|} | S )Nr )
isinstanceboolint)valuevis t/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/dialects/mysql/zxjdbc.pyprocessz,_ZxJDBCBit.result_processor..process+ s\ } %&&
"5zz!A
(
(Fa$h'EL )selfdialectcoltyper s r result_processorz_ZxJDBCBit.result_processor( s r N)__name__
__module__ __qualname__r r r r r r ' s# r r c e Zd Zd ZdS ) MySQLExecutionContext_zxjdbcc | }| d | d }| |S )NzSELECT LAST_INSERT_ID()r )
create_cursorexecutefetchoneclose)r cursor lastrowids r
get_lastrowidz*MySQLExecutionContext_zxjdbc.get_lastrowid: sM ##%%0111OO%%a( r N)r r r! r+ r r r r# r# 9 s# r r# c z e Zd ZdZdZeZ ej e j
e j e j e
ei Z
d Zd Zd Zd ZdS )MySQLDialect_zxjdbcmysqlzcom.mysql.jdbc.Driverc | d }d | | D }dD ]"}| |d r
|| c S #t j d dS )z:Sniff out the character set in use for connection results.z%SHOW VARIABLES LIKE 'character_set%%'c , i | ]}|d |d S )r r r ).0rows r
z7MySQLDialect_zxjdbc._detect_charset..U s" DDD3AADDDr )character_set_connection
character_setNz@Could not detect the connection character set. Assuming latin1.latin1)r& _compat_fetchallgetr warn)r
connectionrsoptskeys r _detect_charsetz#MySQLDialect_zxjdbc._detect_charsetL s
G
H
HDD$*?*?*C*CDDD@ ! !CxxT""
!Cy
!
xr c $ t dd S )z+return kw arg dict to be sent to connect().zUTF-8false)characterEncodingyearIsDateType)dict)r s r _driver_kwargsz"MySQLDialect_zxjdbc._driver_kwargs` s ggFFFFr c t j d t |j }| d }|rt
| S d S )Nz\[SQLCode\: (\d+)\]r )recompilesearchstrargsgroupr )r exceptionmcs r _extract_error_codez'MySQLDialect_zxjdbc._extract_error_coded sX
J- . . 5 5c).6I6I J J
GGAJJ q66M r c $ |j }g }t j d }| |j D ]J} | t
| &# t $ r | | Y Gw xY wt | S )Nz[.\-]) r: rF rG split dbversionappendr
ValueErrortuple)r r: dbapi_conversionrns r _get_server_version_infoz,MySQLDialect_zxjdbc._get_server_version_infol s ) Jx ,-- " "A
"s1vv&&&&
"
"
"q!!!!!
"W~~ s "A B ?B N)r r r! jdbc_db_namejdbc_driver_namer# execution_ctx_clsr update_copyr colspecssqltypesTimer r r> rD rO rZ r r r r- r- B s L.4 t
x}c: N H (G G G r r- )__doc__rF baser r r r r` r connectors.zxJDBCr
r r# r- r r r r rf s *
' ' ' ' ' ' ! ! ! ! ! ! 0 0 0 0 0 0 $ #8 3 3 3 3 3 /< 3 3 3 l r