/var/opt/nydus/ops/mysql/connector/__pycache__
Edit: /var/opt/nydus/ops/mysql/connector/__pycache__/utils.cpython-312.pyc (28181B)
N j\ P U d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
mZmZmZmZmZmZmZmZmZmZmZmZmZmZ ddl m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% e rddl&m'Z' dd l(m)Z) dd
l*m+Z+m,Z, dd l-m.Z. d Z/e0e1d
< e2e3e
e)fZ4e#e$e2 e$e3 e$e
e$e) f e1d< de%e2e5f de2fdZ6de2de5fdZ7de2de5fdZ8de2de5fdZ9de2de5fdZ:de2de5fdZ;de2de5fdZ
de5de#e5e"e5 f fd Z?de5de"e#e"e5 d f fd Z@ d?de5d e"e5 de"e2 de#e5e5f fd ZAde5de2de#e5e2f fd!ZBde5de#e5e"e2 f fd"ZCde.deDfd#ZE d@d$e.d%e"eD d&e2ddfd'ZFde eDeDf fd(ZGde eDeDf fd)ZHde"e eDeDf fd*ZIde#eDeDeDf fd+ZJd,eDdeDfd-ZKd,eDde eDe eDge0f f fd.ZLd/eDde"e#eDeDf fd0ZMd1eDdeDfd2ZN dAd3e%e2e.f d4eDdeOfd5ZP e de eDe%eDe#eDeDf f f fd6 ZQd7eDde fd8ZRd9eDd:eDddfd;ZSd:eDddfd<ZT G d= d> ZUy)Bz
Utilities. N)Decimal) lru_cache) in_table_a1 in_table_b1 in_table_c3 in_table_c4 in_table_c5 in_table_c6 in_table_c7 in_table_c8 in_table_c9 in_table_c11 in_table_c12in_table_c21_c22 in_table_d1 in_table_d2)
TYPE_CHECKINGAnyCallableDictListOptionalTupleTypeUnion)MySQLConnectionAbstract )
HexLiteral)DEPRECATED_TLS_CIPHERSUITESDEPRECATED_TLS_VERSIONS)
StrOrBytesF__MYSQL_DEBUG__
NUMERIC_TYPESbufreturnc . t | t r| S t | t }}|dk( r| d S |dk r0|| dd|z
z z z
}t t j
d| d S || dd|z
z z z
}t t j
d| d S )z&Unpacks the given buffer to an integerr r s r4 int2storerC p s. 1uE =>> ;;tQ r6 c ^ | dk s| dkD r t d t j d| dd S )zb
Takes an unsigned integer (3 bytes) and packs it as a bytes-object.
Returns string.
r z%int3store requires 0 <= i <= 16777215r) r; r> s r4 int3storerG { s5 1uH @AA ;;tQ ! $$r6 c X | dk s| dkD r t d t j d| S )zb
Takes an unsigned integer (4 bytes) and packs it as a bytes-object.
Returns string.
r z'int4store requires 0 <= i <= 4294967295r) r; r> s r4 int4storerJ s. 1uJBCC ;;tQ r6 c X | dk s| dkD r t d t j d| S )zZ
Takes an unsigned integer (8 bytes) and packs it as string.
Returns string.
r z!int8store requires 0 <= i <= 2^64r+ r; r> s r4 int8storerM s0 1u((<== ;;tQ r6 c | dk s| dkD r t d | dk rt }n*| dk rt }n | dk rt }n| dk rt }nt
} || S )z
Takes an unsigned integers and packs it as a bytes-object.
This function uses int1store, int2store, int3store,
int4store or int8store depending on the integer value.
returns string.
r rL z!intstore requires 0 <= i <= 2^64r9 rA rE rI )r< r? rC rG rJ rM )r7
formed_strings r4 intstorerP s_ 1u((<==Cx!
e!
h !
j !
!
r6 c | dk s| dkD r t d | dk rt j d| S | dk rdt j d| z S | d k r d
t j d | dd z S d
t j d| z S )z|
Takes an unsigned integer and packs it as bytes,
with the information of how much bytes the encoded int takes.
r rL zRequires 0 <= i <= 2^64 r: rA rB rE r) rF r+ r; r> s r4 lc_intrV s
1u((2333w{{4##EzT1---H}T1-a222 V[[q) ))r6 sizec | d| }| |d |fS )zi
Reads bytes from a buffer.
Returns a tuple with buffer less the read bytes, and the bytes.
r N r$ rW ress r4
read_bytesr\ s a+C J r6 c | d dk( r| dd dfS dx}}| d }|dk r|}| d|z d | d|dz fS |dk( rd}n|dk( rd }n|d
k( rd }t | d|dz }| ||z dz d | |dz ||z dz fS ) u
Takes a buffer and reads a length coded string from the start.
This is how Length coded strings work
If the string is 250 bytes long or smaller, then it looks like this:
<-- 1b -->
+----------+-------------------------
| length | a string goes here
+----------+-------------------------
If the string is bigger than 250, then it looks like this:
<- 1b -><- 2/3/8 ->
+------+-----------+-------------------------
| type | length | a string goes here
+------+-----------+-------------------------
if type == ü:
length is code in next 2 bytes
elif type == ý:
length is code in next 3 bytes
elif type == þ:
length is code in next 8 bytes
NULL has a special value. If the buffer starts with û then
it's a NULL and we return None as value.
Returns a tuple (trucated buffer, bytes).
r rR r N rF r* r5 )r$ r2 lsizefsts r4 read_lc_stringrf s @ 1v}AB FU
a&C
czAJL!3q6A:#677
cz
SUQY'
(F "$ %s519v~7I'J KKr6 .c g }dddd}t | }d}||k r| | }|dk( ry|dk( r|j d |d z
}nz|d
k r(|}|j | |d z ||d z z |d |z z
}nMd} || }t | |d z ||d z z }|j | |d z |z ||z |d z z |d |z |z z
}||k rt | S # t $ r Y yw xY w) zXReads all length encoded strings from the given buffer
Returns a list of bytes
r` rF r* )r_ ra rb r r9 NrR r r^ )r. appendKeyErrorr5 tuple)r$ byteslstsizesbuf_lenposfirstr2 rd s r4 read_lc_string_listrp s,
')H!! $E#hG
C
-C C< C< OOD ! 1HC| S1W#'0B CDq6z! !%LE !cAg#'1B!CDC!GeOfuna6P QRq5y6))/ -2 ?
s 2C
CCendc |
| t d | | j | }| |dz d | d| fS | t | | S t d # t $ r}t d |d}~ww xY w)zr
Reads a string up until a character or for a given size.
Returns a tuple (trucated buffer, string).
Nz&read_string() needs either end or sizez end byte not present in bufferr r z.read_string() needs either end or size (weird))r< indexr\ )r$ rq rW idxerrs r4 read_stringrv / s {t|ABB
H))C.C C!GIAc
++ #t$$
E
FF
H =>C G Hs A
A$ A A$c , t | d| }| |d |fS )zMRead an integer from buffer
Returns a tuple (truncated buffer, int)
r Nrc rZ s r4 read_intrx H s%
#a+
C J r6 c h | s t d | d }|dk( r| dd dfS |dk r| dd t | fS |dk( r!| dd t j d| dd d fS |d k( r$| d
d t j d | dd
d z d fS |d
k( r!| dd t j d| dd d fS t d )z
Takes a buffer and reads an length code string from the start.
Returns a tuple with buffer less the integer and the integer read.
z
Empty buffer.r rR r Nr_ rF z>/ *
o 0H D
3I9~"A,$$&C aL''-33C8E F3K
1 M
1 Ms
A#B??C c i } t j j dd }t j j | r{t |d 5 }|D ]] }|j d }t
| dk7 r#|d j }|d j d j d
}|| |< _ d d d | S | S # 1 sw Y | S xY w) ztParse the contents of /etc/lsb-release file.
Returns:
A dictionary containing release information.
r z lsb-releaser r r r` r r r r Nr )r lsb_release_filer r r r r s r4 _parse_lsb_releaser s Fww||FM: ww~~&'
"W
5 JJsO y>Q& l((*!! ++D177< #s
! 6 M6M 6 Ms
A#B??C c i } t t j dd 5 } t j d| }|j
t j j }|D ]^ }|j d }t | dk7 r#|d j d
d j }|d j d
}|| |< ` ddd | S # t
$ r Y ddd yw xY w# 1 sw Y | S xY w)ztParse the output of the lsb_release command.
Returns:
A dictionary containing release information.
wr r ) lsb_releasez-a)stderrN:r` r _r )r r devnull
subprocess check_outputOSErrordecodesysgetfilesystemencoding
splitlinesr r. replacer r )r r stdoutlinesr r r r s r4 _parse_lsb_release_commandr s F
bjj# 0G ,,-B7SF
c 7 7 9:EEGD
3I9~"A,&&sC0668C aL&&t,E F3K
1 M
1 0
1 Ms. C.CBC. C+ C.*C++C..C8c t } | r5| j dd | j dd | j dd fS t } | r5| j dd | j dd | j dd fS t } | r5| j dd | j d d | j d
d fS y ) aN Tries to determine the name of the Linux OS distribution name.
First tries to get information from ``/etc/os-release`` file.
If fails, tries to get the information of ``/etc/lsb-release`` file.
And finally the information of ``lsb-release`` command.
Returns:
A tuple with (`name`, `version`, `codename`)
distrib_idr~ distrib_releasedistrib_codenamedistributor_idreleasecodenamename
version_idversion_codename)r~ r~ r~ )r getr r )r s r4 linux_distributionr s (:';F
JJ|R ( JJ(" - JJ)2 .
(
)F
JJ' , JJy" % JJz2 &
F
JJvr " JJ|R ( JJ)2 .
r6 unicode_strc > | rt j | d dv ryy)zGet the readiness direction of the unicode string.
We assume that the direction is "L-to-R" if the first character does not
indicate the direction is "R-to-L" or an "AL" (Arabic Letter).
r )RALR-to-LzL-to-R) unicodedata
bidirectional)r s r4 _get_unicode_read_directionr s+ {00Q @ E r6 c t | }|dk( r/t | d rt | d s t d dt iS dt iS )at
1) The characters in section 5.8 MUST be prohibited.
2) If a string contains any RandALCat character, the string MUST NOT
contain any LCat character.
3) If a string contains any RandALCat character, a RandALCat
character MUST be the first character of the string, and a
RandALCat character MUST be the last character of the string.
r r zvInvalid unicode Bidirectional sequence, if the first character is RandALCat, the final charactermust be RandALCat too.z7Bidirectional Characters requirement 2 [StringPrep, d2])r r r< r )r read_dirs r4 _get_unicode_direction_ruler s] +;7H 8KN+ KO0L )
J;WW
F{ SSr6 normalized_strc
h t t t t t t t
t t t t t d } |j t | | D ]0 }|j D ] \ }} || s|dk7 s||fc c S 2 y# t $ r}| t | fcY d}~S d}~ww xY w)a Check for Prohibited Output according to rfc4013 profile.
This profile specifies the following characters as prohibited input:
- Non-ASCII space characters [StringPrep, C.1.2]
- ASCII control characters [StringPrep, C.2.1]
- Non-ASCII control characters [StringPrep, C.2.2]
- Private Use characters [StringPrep, C.3]
- Non-character code points [StringPrep, C.4]
- Surrogate code points [StringPrep, C.5]
- Inappropriate for plain text characters [StringPrep, C.6]
- Inappropriate for canonical representation characters [StringPrep, C.7]
- Change display properties or deprecated characters [StringPrep, C.8]
- Tagging characters [StringPrep, C.9]
In addition of checking of Bidirectional Characters [StringPrep, Section 6]
and the Unassigned Code Points [StringPrep, A.1].
Returns:
A tuple with ("probited character", "breaked_rule")
) z4Space characters that contains the ASCII code pointsz&Space characters non-ASCII code pointsz(Unassigned Code Points [StringPrep, A.1]z.Non-ASCII space characters [StringPrep, C.1.2]z,ASCII control characters [StringPrep, C.2.1]z(Private Use characters [StringPrep, C.3]z+Non-character code points [StringPrep, C.4]z'Surrogate code points [StringPrep, C.5]z9Inappropriate for plain text characters [StringPrep, C.6]zGInappropriate for canonical representation characters [StringPrep, C.7]zDChange display properties or deprecated characters [StringPrep, C.8]z$Tagging characters [StringPrep, C.9]Nr )r r r r r r r r
r r r
updater r< r items)r rulesru charrulefuncs r4 "validate_normalized_unicode_stringr s 2 AM2>4?:F8H4?7B3>EPS^P[0;
E (
0 @A ++-JD$DzdckTz! (
( s3x''(s B B1 B,&B1,B1a_stringc | D cg c] }t | rdnt | rdn| }}dj | }t j d| }|sy|S c c}w )a( normalizes a unicode string according to rfc4013
Normalization of a unicode string according to rfc4013: The SASLprep profile
of the "stringprep" algorithm.
Normalization Unicode equivalence is the specification by the Unicode
character encoding standard that some sequences of code points represent
essentially the same character.
This method normalizes using the Normalization Form Compatibility
Composition (NFKC), as described in rfc4013 2.2.
Returns:
Normalized unicode string according to rfc4013.
r r~ NFKC)r r r r normalize)r r nstr_listnstrs r4 normalize_unicode_stringr C sm * D D![->rDH
779 D
.D K s #Apayloadr c t | t r| S t | t r t | S t | t s t | j | S t | S # t
$ r}t
d |d}~ww xY w)z(Initialize a bytearray from the payload.r z payload must be a str or bytesN)r, r/ r- bytesencodeAttributeErrorr< )r r ru s r4 init_bytearrayr h s} '9%'3 !! gu % H W^^X^ >? ? W H =>C G Hs A% % A?. A::A?c ddd} t j dk( rtdt j d v rd| d< n6dt j d v rd | d< nt j | d< d
t j d | d < | S t j
| d< t j d
k( r dt j d | d < | S dj t dd | d < | S )z4Return a dict with the platform arch and OS version.r~ )archversionnt64r x86_64r 32i386zWindows-r r DarwinzmacOS--r` )
r r platform architecture win32_vermachinesystemmac_verr r )plats r4 get_platformr y s =?23ND ww$ 8((*1- -#DL
X**,Q/
/!DL#002DL $X%7%7%9!%<$=>Y K
'')V ?? ( &x'7'7'9!'<&= >DO K "hh'9';Aa'@ ADO Kr6 fullpathc " t | t s t d | j dd \ }}t j
| }t
|| }|S # t $ r t d| d dt t f$ r}t | |d}~ww xY w)a( Import an object from a fully qualified module path.
Args:
obj (str): A string representing the fully qualified name of the object.
Returns:
Object: The imported object.
Raises:
ValueError: If the object can't be imported.
.. versionadded:: 8.0.33
z]'fullpath' should be a str representing the fully qualified name of the object to be imported.r zNo callable named ''N) r, r r< rsplit importlib
import_modulegetattrr ModuleNotFoundError)r
module_str callable_strmoduleobjru s r4
import_objectr s h $
$
,#+??3#:
L((4fl+ J F.xj:;E / 0 ,C5"+,s 6A 'B<
B Bcipher_as_ossl tls_versionc | t j |i j v r!d| d}t j |t
yy)aI Emits a warning if a deprecated cipher is being utilized.
Args:
cipher: Must be ingested as OpenSSL name.
tls_versions: TLS version to check the cipher against.
Raises:
DeprecationWarning: If the cipher is flagged as deprecated
according to the OSSA cipher list.
z$This connection is using TLS cipher [ which is now deprecated and will be removed in a future release of MySQL Connector/Python.N)r r valueswarningswarnDeprecationWarning)r
r warn_msgs r4 warn_ciphersuites_deprecatedr sR 488bIPPRR2>2B C&
&
h 23
Sr6 c V | t v r!d| d}t j |t yy)a Emits a warning if a deprecated TLS version is being utilized.
Args:
tls_versions: TLS version to check.
Raises:
DeprecationWarning: If the TLS version is flagged as deprecated
according to the OSSA cipher list.
z%This connection is using TLS version r
N)r r r r )r r s r4 warn_tls_version_deprecatedr s: --3K= A&
&
h 23
.r6 c \ e Zd ZdZdeddfdZdedefdZded eddf fd
Zdefd Z xZ
S ) GenericWrapperzr8 s :
A $ M Q
uT#YU T']D"? 2Lj%U %xhuos6J0K'L %T G G % G 3-G 5%< G2 % s uUCZ'8 >U >uUHSM%9 : >46
6s 6 EG '
'!)# '>A ' ' 4S> *DcN (HT#s(^$< ."E#sC- 0 "J S S TS TT#xt ?T:T5U T811
eCHo 1h"s "s "L 4 43 44 4(4S 4T 4� #0r6