x d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ G d d e Z G d
d e Z
G d d
e Z e Z dS )a
.. dialect:: mysql+oursql
:name: OurSQL
:dbapi: oursql
:connectstring: mysql+oursql://:@[:]/
:url: http://packages.python.org/oursql/
.. note::
The OurSQL MySQL dialect is legacy and is no longer supported upstream,
and is **not tested as part of SQLAlchemy's continuous integration**.
The recommended MySQL dialects are mysqlclient and PyMySQL.
Unicode
-------
Please see :ref:`mysql_unicode` for current recommendations on unicode
handling.
)BIT) MySQLDialect)MySQLExecutionContext )types)utilc e Zd Zd ZdS )
_oursqlBITc dS )z'oursql already converts mysql bits, so.N )selfdialectcoltypes t/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/dialects/mysql/oursql.pyresult_processorz_oursqlBIT.result_processor( s t N)__name__
__module__ __qualname__r r r r r
r
' s# r r
c $ e Zd Zed ZdS ) MySQLExecutionContext_oursqlc 8 | j dd S )N_oursql_plain_queryF)execution_optionsget)r
s r plain_queryz(MySQLExecutionContext_oursql.plain_query/ s %))*?GGGr N)r r r propertyr r r r r r . s2
H H XH H Hr r c 8 e Zd ZdZej rdZdZdZdZ dZ
e Z ej
ej ej ej eei Zed Zd dZd Zd Zd Zd Z d d Z d d Z d d
Z d dZ d dZ d dZ d dZ!d Z"d Z# d dZ$d Z%d Z&d Z'd Z(d dZ)d dZ*d dZ+dS ) MySQLDialect_oursqloursqlTc t d S )Nr )
__import__)clss r dbapizMySQLDialect_oursql.dbapiE s (###r Nc v |r |j r| |d dS | || dS )zMProvide an implementation of
*cursor.execute(statement, parameters)*.Tr N)r execute)r
cursor statement
parameterscontexts r
do_executez MySQLDialect_oursql.do_executeI sL 2w* 2 NN9$N 7 7 7 7 7 NN9j 1 1 1 1 1r c X | dd d S )NBEGINTr& )r( r' r
connections r do_beginz MySQLDialect_oursql.do_beginR s- ##G#>>>>>r c D t j r|j | }nG| j }|j | | | }d|z }| d ||z d S )Nz'%s'Tr ) r py2kr0 _escape_string_connection_charsetencodedecoder r' )r
r0 queryxidargcharsets r _xa_queryz MySQLDialect_oursql._xa_queryU s 9 '66s;;CC.G '66
7## fWoo
sl$$$>>FF CK
r c 4 | |d| d S )Nz XA BEGIN %sr= r
r0 r: s r do_begin_twophasez%MySQLDialect_oursql.do_begin_twophaseg s z=#66666r c b | |d| | |d| d S )N XA END %sz
XA PREPARE %sr? r@ s r do_prepare_twophasez'MySQLDialect_oursql.do_prepare_twophasej s4 z;444 z?C88888r Fc f |s| |d| | |d| d S )NrC zXA ROLLBACK %sr? r
r0 r: is_preparedrecovers r do_rollback_twophasez(MySQLDialect_oursql.do_rollback_twophasen s? 9 NN:{C 8 8 8 z#3S99999r c d |s| || | |d| d S )Nz XA COMMIT %s)rD r= rF s r do_commit_twophasez&MySQLDialect_oursql.do_commit_twophaseu s> 6 $ $Z 5 5 5 z>377777r c | t j | | d || S NTr3 )r has_tableconnectr )r
r0
table_nameschemas r rN z MySQLDialect_oursql.has_table~ s@ % 2 2t 2 L L
r c z t j | | d |fd|i|S NTr3 rQ )r get_table_optionsrO r r
r0 rP rQ kws r rT z%MySQLDialect_oursql.get_table_options sV - 2 2t 2 L L
r c z t j | | d |fd|i|S rS )r get_columnsrO r rU s r rX z MySQLDialect_oursql.get_columns sV ' 2 2t 2 L L
r c x t j | | d fd|i|S rS )r get_view_namesrO r r
r0 rQ rV s r rZ z"MySQLDialect_oursql.get_view_names sS * 2 2t 2 L L
r c z t j | | d | S rM )r get_table_namesrO r r[ s r r] z#MySQLDialect_oursql.get_table_names s= + 2 2t 2 L L
r c t t j | | d fi |S rM )r get_schema_namesrO r )r
r0 rV s r r_ z$MySQLDialect_oursql.get_schema_names sI , 2 2t 2 L L
r c T t j | | d S rM )r
initializer r/ s r ra z MySQLDialect_oursql.initialize s- & *..4.HH
r c t j | | d d ||| S )NT)close_with_resultr3 )r _show_create_table_contextual_connectr )r
r0 tabler< full_names r rd z&MySQLDialect_oursql._show_create_table sQ . * *"&
+
D 99
r c t || j j r8|j d u o.d|j d vo |j d d S |j dv S )Nr( r closed)i i i i i )
isinstancer$ ProgrammingErrorerrnoargsendswith)r
er0 r( s r
is_disconnectz!MySQLDialect_oursql.is_disconnect sf a4 5 5 =4 1 AF1I-1F1I&&x00
7 <<
= = =& & &P - - -
r r N)
__doc__baser r r r r r r
r r r r r r r s 0 ' ' ' ' ' ' ! ! ! ! ! ! H H H H H#8 H H H O O O O O, O O Od r