/var/opt/nydus/ops/mysql/connector/django/__pycache__
NameSizeModeActions
base.cpython-312.pyc266180644editdlrm
client.cpython-312.pyc37860644editdlrm
compiler.cpython-312.pyc4360644editdlrm
creation.cpython-312.pyc3370644editdlrm
features.cpython-312.pyc14810644editdlrm
introspection.cpython-312.pyc180040644editdlrm
operations.cpython-312.pyc39790644editdlrm
schema.cpython-312.pyc16690644editdlrm
validation.cpython-312.pyc3450644editdlrm
__init__.cpython-312.pyc1770644editdlrm
Edit: /var/opt/nydus/ops/mysql/connector/django/__pycache__/base.cpython-312.pyc (26618B)
N j_dZddlZddlmZmZddlmZmZmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZddlmZdd lmZmZdd lmZdd lmZ ddlZ dd l!m"Z"dd l#m$Z$ddl%m&Z&ddlm'Z'm(Z(m)Z) ddl,m-Z-dZ.ddl/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:ddl;me jzj~Z?e jzjZ@e jzjZAe jzjZBerddlCmDZDmEZEdede)fdZFGd d!ZGGd"d#eZHGd$d%e"ZIy#e*$rZ+ede+e+dZ+[+wwxYw#e*$rdZ.YwxYw)&aDjango database Backend using MySQL Connector/Python. This Django database backend is heavily based on the MySQL backend from Django. Changes include: * Support for microseconds (MySQL 5.6.3 and later) * Using INFORMATION_SCHEMA where possible * Using new defaults for, for example SQL_AUTO_IS_NULL Requires and comes with MySQL Connector/Python v8.0.22 and later: http://dev.mysql.com/downloads/connector/python/ N)datetimetime) TYPE_CHECKINGAnyDict GeneratorIteratorListOptionalSequenceSetTupleUnion)settings)ImproperlyConfigured)IntegrityError)BaseDatabaseWrapper) dateparsetimezone)cached_property)MySQLConvertibleType)MySQLConverter) HexLiteral)PooledMySQLConnection)ParamsSequenceOrDictTypeRowType StrOrBytesz&Error loading mysql.connector module: )datetime_to_mysqlTF)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditor)DatabaseValidation)MySQLConnectionAbstractMySQLCursorAbstractvaluereturnctjrtj|rHt j d|dt tj}tj||}|jtjjd}tr t|}|S|jdS)zDEquivalent to DateTimeField.get_db_prep_value. Used only by raw SQL.z!MySQL received a naive datetime (z$) while time zone support is active.N)tzinfoz%Y-%m-%d %H:%M:%S.%f)rUSE_TZris_naivewarningswarnRuntimeWarningget_default_timezone make_aware astimezoneutcreplace HAVE_CEXTrstrftime)r)default_timezonemysql_datetimes L/opt/nydus/tmp/pip-target-a90h98xg/lib/python/mysql/connector/django/base.py$adapt_datetime_with_timezone_supportr<is   U # MM3E7;66  (<<> ''/?@E  .667  1% 8 >>0 11c "eZdZdZdZddZedeee fdeee ffdZ ede e e de e e fdZ dd ede ee e eee ffde ed fd Zd ede ee e eee ffde ed fd Zd edefdZdeefdZy) CursorWrapperzWrapper around MySQL Connector/Python's cursor class. The cursor class is defined by the options passed to MySQL Connector/Python. If buffered option is True in those options, MySQLCursorBuffered will be used. )iiiir*Nc||_yN)cursorselfrBs r;__init__zCursorWrapper.__init__s -3 r=argsc|s|St|}|jD]$\}}t|tst |||<&|SrA)dictitems isinstancerr<)rFnew_argskeyr)s r;_adapt_execute_args_dictz&CursorWrapper._adapt_execute_args_dictsHK:**,JC%* DU K 'r=c|s|St|}t|D]$\}}t|tst |||<&t |SrA)list enumeraterJrr<tuple)rFrKiargs r;_adapt_execute_argsz!CursorWrapper._adapt_execute_argssKK:oFAs#x(B3G &Xr=query)r(NNc`d}t|tr|j|}n|j|} |jj ||S#t jj$r=}|jd|jvrtt|jdd}~wwxYw)zExecutes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. Nr) rJrHrMrTrBexecutemysql connectorOperationalErrorrFcodes_for_integrityerrorrrQ)rDrUrFrKexcs r;rWzCursorWrapper.executes8< dD !44T:H//5H ;;&&uh7 7// xx{d;;;$eCHHo6D@  sAB-08B((B-c |jj||S#tjj$r=}|j d|j vrtt|j dd}~wwxYw)zExecutes the given operation This wrapper method around the executemany()-method of the cursor is mainly needed to re-raise using different exceptions. rN) rB executemanyrXrYrZrFr[rrQ)rDrUrFr\s r;r^zCursorWrapper.executemanysf ;;**5$7 7// xx{d;;;$eCHHo6D@  sA88A33A8attrc.t|j|S)z%Return an attribute of wrapped cursor)getattrrBrDr_s r; __getattr__zCursorWrapper.__getattr__st{{D))r=c,t|jS)z&Return an iterator over wrapped cursor)iterrBrDs r;__iter__zCursorWrapper.__iter__sDKK  r=)rBr(r*NrA)__name__ __module__ __qualname____doc__r[rE staticmethodrstrrrMr r rTrrrWr^rrcr rrgr=r;r?r?~sO 4 3,,-  c'' (   x 456  (/0 1  "   (/0$s ? 0 (/0$s ? &***!(7+!r=r?c eZdZUdZdZiddddddd d d d d ddddddddd dd ddddddddddd d!d dd"d#d$d d%d&d'd(d)d* Zd+Zd,d-d.d-d/d0d1d2d.d.d-d-d3 Zd4Zd5d6d7d8d9d:d;Z dZej ZeZeZeZeZeZeZeZd?e d@e dAddAe"fd[Z?xZ@S)^DatabaseWrapperz Represent a database connection.rX AutoFieldzinteger AUTO_INCREMENT BigAutoFieldzbigint AUTO_INCREMENT BinaryFieldlongblob BooleanFieldbool CharFieldzvarchar(%(max_length)s) DateFielddate DateTimeFieldz datetime(6) DecimalFieldz+numeric(%(max_digits)s, %(decimal_places)s) DurationFieldbigint FileField FilePathField FloatFieldzdouble precision IntegerFieldintegerBigIntegerFieldIPAddressFieldzchar(15)GenericIPAddressFieldzchar(39) JSONFieldjsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENTsmallintlongtextztime(6)zchar(32)) NullBooleanField OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerField SlugFieldSmallAutoFieldSmallIntegerField TextField TimeField UUIDField) tinyblobblob mediumblobrttinytexttext mediumtextrrz= %szLIKE %szLIKE CAST(%s AS BINARY)z> %sz>= %sz< %sz<= %s) exactiexactcontains icontainsgtgteltlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z+LIKE CAST(CONCAT('%%', {}, '%%') AS BINARY)zLIKE CONCAT('%%', {}, '%%')z%LIKE CAST(CONCAT({}, '%%') AS BINARY)zLIKE CONCAT({}, '%%')z%LIKE CAST(CONCAT('%%', {}) AS BINARY)zLIKE CONCAT('%%', {}))rrrrrrNisolation_level>read committedrepeatable readread uncommitted serializablerFkwargsr*cHt||i||jjd}|rZ|jdt |_|jdt }t|t s td||_ yt |_ t |_y)NOPTIONSuse_pureconverter_classzXConverter class should be a subclass of mysql.connector.django.base.DjangoMySQLConverter) superrE settings_dictgetr7 _use_pureDjangoMySQLConverter issubclassProgrammingError converter)rDrFroptionsr __class__s r;rEzDatabaseWrapper.__init__Is $)&)$$((3 $[[]CDN%kk!$Oo/CD&G-.DN13DN!*]DNr=r_c2|jdryt)Nmysql_isF)rAttributeErrorrbs r;rczDatabaseWrapper.__getattr__]s ??: &r=c,ddi}|j}|dr|d|d<|dr|d|d<|dr|d|d<|d jd r |d |d <n |d r|d |d <|d rt|d |d<|jdijdr |dd|d<tj |d<t jjjjg|d< |dj}|jdd}|r[|j}||jvr=djdt!|jD}t#d|d|d||_|j'||S#t($rY|SwxYw)Nconsume_resultsTUSERuserNAMEdatabasePASSWORDpasswdHOST/ unix_sockethostPORTportr init_commandraise_on_warnings client_flagsrz, c3(K|] }d|d yw)'Nrn).0levels r; z8DatabaseWrapper.get_connection_params..s-2O!E7! 2Osz%Invalid transaction isolation level 'z' specified. Use one of z , or None.)rrintrrDEBUGrXrY constants ClientFlag FOUND_ROWScopypoplowerisolation_levelsjoinsortedrrupdateKeyError)rDrrrr valid_levelss r;get_connection_paramsz%DatabaseWrapper.get_connection_paramsbs t **  *62F6N  !.v!6F:   $,Z8F8   + +C 0$1&$9F= ! 6 "*62F6N   v!67F6N   Y + / / ?%29%=n%MF> "'/nn"# OO % % 0 0 ; ;" ~  #I.335G%kk*;TBO"1"7"7"9"$*?*??#'99-289N9N2O-$L/??PQ22>zK$3D MM' "     s*BF FF conn_paramsr'c^d|vr t|d<tjjdi|}|S)Nrrn)rrXrYconnect)rDrcnxs r;get_new_connectionz"DatabaseWrapper.get_new_connections3 K /-AK) *oo%%4 4 r=c g}|jjr|jd|jr,|jd|jj |r9|j 5}|j dj|dddd|jvr |j|jdyy#1swY8xYw#t$r!|j|jdYywxYw)NzSET SQL_AUTO_IS_NULL = 0z(SET SESSION TRANSACTION ISOLATION LEVEL z; AUTOCOMMIT) featuresis_sql_auto_is_null_enabledappendrupperrBrWrrset_autocommitr_set_autocommit)rD assignmentsrBs r;init_connection_statez%DatabaseWrapper.init_connection_states == 4 4   9 :      :''--/02  &tyy56 4-- - G##D$6$6|$DE . " G$$T%7%7 %EF Gs4!C ,C C'DDnamecL|jj}t|SrA) connectionrBr?)rDrrBs r; create_cursorzDatabaseWrapper.create_cursors'')V$$r=cN tj|y#t$rYywxYwrA)r _rollbackNotSupportedErrorrfs r;rzDatabaseWrapper._rollbacks'   ) )$ /    s  $$ autocommitch|j5||j_dddy#1swYyxYwrA)wrap_database_errorsrr)rDrs r;rzDatabaseWrapper._set_autocommits#  & &)3DOO &' & &s(1cp|j5}|jddddy#1swYyxYw)z Disable foreign key checks, primarily for use in adding rows with forward references. Always return True to indicate constraint checks need to be re-enabled. zSET foreign_key_checks=0NT)rBrWrCs r;disable_constraint_checkingz+DatabaseWrapper.disable_constraint_checkings- [[]f NN5 6s,5cd|jc|_} |j5}|jdddd||_y#1swYxYw#||_wxYw)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackrBrW)rDrrBs r;enable_constraint_checkingz*DatabaseWrapper.enable_constraint_checkingsX /4T5H5H+^ 1&9:#1D #1D s!AAAA A A table_namesc|j5}||jj|}|D]}|jj||}|s"|jj ||}|D]k\}}}|j d|d|d|d|d|d|d|d |d |j D](} td |d | d d|d|d| dd|d|dm dddy#1swYyxYw)a] Check each table name in `table_names` for rows with invalid foreign key references. This method is intended to be used in conjunction with `disable_constraint_checking()` and `enable_constraint_checking()`, to determine if rows with invalid references were entered while constraint checks were off. Nz+ SELECT REFERRING.`z&`, REFERRING.`z ` FROM `z2` as REFERRING LEFT JOIN `zR` as REFERRED ON ( REFERRING.`z*` = REFERRED.`zE` ) WHERE REFERRING.`z4` IS NOT NULL AND REFERRED.`z"` IS NULL zThe row in table 'z' with primary key 'rz' has an invalid foreign key: .z contains a value 'rz.' that does not have a corresponding value in )rB introspectionrget_primary_key_columnget_key_columnsrWfetchallr) rDrrB table_nameprimary_key_column_name key_columns column_namereferenced_table_namereferenced_column_namebad_rows r;check_constraintsz!DatabaseWrapper.check_constraintssl[[]f""00<?**57''=&>?  $*??#4,0 =$$+AJ= 0)rrr)r!supports_column_check_constraints)rDrs r;data_type_check_constraintsz+DatabaseWrapper.data_type_check_constraintss/ == : :+>(;-@!  % $ r=c |j5}|jd|j}dddd|d|dt|dt|dt|dd S#1swY?xYw) zReturn MySQL server data.a2 SELECT VERSION(), @@sql_mode, @@default_storage_engine, @@sql_auto_is_null, @@lower_case_table_names, CONVERT_TZ('2001-01-01 01:00:00', 'UTC', 'UTC') IS NOT NULL Nrr)versionsql_modedefault_storage_enginesql_auto_is_nulllower_case_table_nameshas_zoneinfo_database)temporary_connectionrWfetchonerv)rDrBrows r;mysql_server_dataz!DatabaseWrapper.mysql_server_data&s & & (F NN //#C) 1vA&)!f $SV &*3q6l%)#a&\   ) (s "A11A:c|jr|jjS|j5}|jd|j dcdddS#1swYyxYw)Return MySQL version.zSELECT VERSION()rN)r server_infor%rWr&rCs r;mysql_server_infoz!DatabaseWrapper.mysql_server_infoAsQ ????.. .  & & (F NN- .??$Q') ( (s $A!!A*.c|jr|jjS|j}tjj di|5}|j}ddd|S#1swYSxYw)r*Nrn)rserver_versionrrXrYr)rDconfigconnr.s r; mysql_versionzDatabaseWrapper.mysql_versionJsb ????11 1++- __ $ $ .v .$.2.A.AN//s  A))A3cL|jr.t|jjjdS|j 5}|j d|j }dddtr|djdSdS#1swY.xYw)zReturn SQL mode.,zSELECT @@sql_modeNrrn)rsetr splitrBrWr&)rDrBr s r;r zDatabaseWrapper.sql_modeTs ??t//55c:; ; [[]f NN. /(HX8A;$$S)>>2>>]s "BB#c|j}|S)z1Return True if pure Python version is being used.)r)rDanss r;rzDatabaseWrapper.use_pure^sNN r=)r*NrA)Arhrirjrkvendor data_types_limited_data_types operators pattern_esc pattern_opsrr rm__annotations__rrXrYDatabaser%SchemaEditorClassr client_classr!creation_classr"features_classr#introspection_classr$ ops_classr&validation_classrrErvrcrrrrrrr?rrrrrr rrrrlrrr(r,rrr1r r propertyr __classcell__)rs@r;rprps`* F -/ z   .  V   E  . 2 (   8 * !" V#$#"#4 2%8.3'9JH -/-  I.YKA2=.;, K&*OXc])H,!L%N%N/"I)+c+S+T+( 0tCH~0dS> $&?? @G2%#%% 4$444T 10Xd3i-@0D0d4# T#s(^   4S>  4(3((uS#X?#c(??$r=rpc eZdZdZed dededeefdZ ed dededee fdZ de de eeffdZde de eeffd Zdedefd Zy) rzCustom converter for Django.Nr)dscr*cJtj|jdS)zXReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)r parse_timedecoder)rJs r;_time_to_pythonz$DjangoMySQLConverter._time_to_pythonjs ##ELL$9::r=c4|rtj|SdS)aoConnector/Python always returns naive datetime.datetime Connector/Python always returns naive timestamps since MySQL has no time zone support. - A naive datetime is a datetime that doesn't know its own timezone. Django needs a non-naive datetime, but in this method we don't need to make a datetime value time zone aware since Django itself at some point will make it aware (at least in versions 3.2.16 and 4.1.2) when USE_TZ=True. This may change in a future release, we need to keep an eye on this behaviour. Returns datetime.datetime() N)r_datetime_to_pythonrNs r;rQz(DjangoMySQLConverter._datetime_to_pythonrs"=B~11%8KtKr=c$|j|SrA _str_to_mysqlrDr)s r;_safestring_to_mysqlz)DjangoMySQLConverter._safestring_to_mysql!!%((r=c$|j|SrArSrUs r;_safetext_to_mysqlz'DjangoMySQLConverter._safetext_to_mysqlrWr=c$|j|SrA)_bytes_to_mysqlrUs r;_safebytes_to_mysqlz(DjangoMySQLConverter._safebytes_to_mysqls##E**r=rA)rhrirjrkrlbytesrr rrOrrQrmrrrVrYr\rnr=r;rres&;u;3;(4.;;L5LsLhx>PLL()#)%z8I2J)))eZ6G0H)++5+r=r)Jrkr/rrtypingrrrrr r r r r rr django.confrdjango.core.exceptionsr django.dbrdjango.db.backends.base.baser django.utilsrrdjango.utils.functionalrmysql.connector.typesrmysql.connectorrXmysql.connector.conversionrmysql.connector.custom_typesrmysql.connector.poolingrrrr ImportErrorerr_mysql_connectorrr7clientr creationr!rr"rr# operationsr$schemar% validationr&rYr DatabaseErrorrrZrmysql.connector.abstractsr'r(r<r?rprrnr=r;rtsI> #    !7$<,36X97=SS2I"&&0*(* -- OO55??33??33V22Z2*]!]!@D)DN )+>)+qX !GuM NTWWX Is* E 7E# E  EE #E-,E-