xIf[zddlZddlZddlZddlmZmZmZddlmZdZ dZ dZ Gddej j ZdS) N)STATUS TPC_STATEINFO)versionutf8mb4utf8mb4_general_ci@ceZdZdZdZfdZejjfdZ fdZ dZ dZ dZ d Zd efd Zd Zd efdZdZdZGddeZdZd/dZdZd/dZdZedZejdZedZ edZ!edZ"edZ#edZ$ed Z%ed!Z&ed"Z'ed#Z(ed$Z)ed%Z*ed&Z+ed'Z,ed(Z-ed)Z.ed*Z/e/jd+Z/ed,Z0ed-Z1e!Z2ed.Z3xZ4S)0 Connectionz MariaDB Connector/Python Connection Object Handles the connection to a MariaDB or MySQL database server. It encapsulates a database session. Connections are created using the method mariadb.connect() c<|jrtjddS)Nz#Invalid connection or not connected)_closedmariadbProgrammingErrorselfs G/var/www/piapp/venv/lib/python3.11/site-packages/mariadb/connections.py _check_closedzConnection._check_closed*s0 < <*,;<< < < <cd|_d|_d|_d|_d|_d|_t j|_d|_| dd}| dd}| dd|_ d|vra| d}tj tjtj dkrd |vrtjd d |vrMt#|d t$s2| d d}d D]}||vr|||d |z<d|d <t'j|i|||_||_dS)zh Establishes a connection to a database server and returns a connection object. Nr autocommitF reconnect converterhostz3.3.0,z>Host failover list requires MariaDB Connector/C 3.3.0 or newerssl)cacertcapathkeycipherzssl_%sT)_socket_used_last_executed_statement_Connection__pool_Connection__last_usedrNONE tpc_state_xidpop _convertergetrVersionrmariadbapi_versionr isinstanceboolsuper__init__rauto_reconnect) rargskwargsrrrrr __class__s rr1zConnection.__init__/sy   (,%  " ZZ e44 JJ{E22  **[$77 V  ::f%%Dw9::w''((,/4KK.0:;;; F??:fUmT#B#B?**UD))C@ 6 6#::-0XF8c>* F5M$)&)))$'rc |||fi|}t|tjjstjd|z|S)a Returns a new cursor object for the current connection. If no cursorclass was specified, a cursor with default mariadb.Cursor class will be created. Optional keyword parameters: - buffered = True If set to False the result will be unbuffered, which means before executing another statement with the same connection the entire result set must be fetched. Please note that the default was False for MariaDB Connector/Python versions < 1.1.0. - dictionary = False Return fetch values as dictionary. - named_tuple = False Return fetch values as named tuple. This feature exists for compatibility reasons and should be avoided due to possible inconsistency. - cursor_type = CURSOR.NONE If cursor_type is set to CURSOR.READ_ONLY, a cursor is opened for the statement invoked with cursors execute() method. - prepared = False When set to True cursor will remain in prepared state after the first execute() method was called. Further calls to execute() method will ignore the sql statement. - binary = False Always execute statement in MariaDB client/server binary protocol. In versions prior to 1.1.0 results were unbuffered by default, which means before executing another statement with the same connection the entire result set must be fetched. fetch* methods of the cursor class by default return result set values as a tuple, unless named_tuple or dictionary was specified. The latter one exists for compatibility reasons and should be avoided due to possible inconsistency in case two or more fields in a result set have the same name. If cursor_type is set to CURSOR.READ_ONLY, a cursor is opened for the statement invoked with cursors execute() method. z'%s is not an instance of mariadb.cursor)rr.r_mariadbcursorr)r cursorclassr4r8s rr8zConnection.cursorYsrb T,,V,,&'"2"9:: F*,<>D,EFF F rc||jr|j|dStdSN)rr$_close_connectionr0close)rr5s rr=zConnection.closesR   !   " 4 4T : : : : : GGMMOOOOOrc0| |Sr;)rrs r __enter__zConnection.__enter__s + rcX| |dSr;)rr=)rexc_typeexc_valexc_tbs r__exit__zConnection.__exit__s(  rc||jtjkrt jd|d|dS)zA Commit any pending transaction to the database. z6commit() is not allowed if a TPC transaction is activeCOMMITNrr'rr&rr_execute_command_read_responsers rcommitzConnection.commitso  >IN * **,IJJ J h''' rc||jtjkrt jd|d|dS)av Causes the database to roll back to the start of any pending transaction Closing a connection without committing the changes first will cause an implicit rollback to be performed. Note that rollback() will not work as expected if autocommit mode was set to True or the storage engine does not support transactions." z8rollback() is not allowed if a TPC transaction is activeROLLBACKNrGrs rrollbackzConnection.rollbackso  >IN * **,GHH H j))) ridc|t|tstjdd|z}|||dS)z This function is used to ask the server to kill a database connection specified by the processid parameter. The connection id can be be retrieved by SHOW PROCESSLIST sql command. zid must be of type int.zKILL %sN)rr.intrrrHrI)rrNstmts rkillzConnection.killsp "c"" F*+DEE E2~ d### rc||d|dS)z Start a new transaction which can be committed by .commit() method, or cancelled by .rollback() method. BEGINN)rrHrIrs rbeginzConnection.beginsB  g&&& rnew_dbc<|||_dS)z Gets the default database for the current connection. The default database can also be obtained or changed by database attribute. N)rdatabase)rrVs r select_dbzConnection.select_dbs!  rc|jS)z Returns a tuple representing the version of the connected server in the following format: (MAJOR_VERSION, MINOR_VERSION, PATCH_VERSION) )server_version_infors rget_server_versionzConnection.get_server_versions ''rc||jsdS|}|d|}~|S)zT Shows error, warning and note messages from last executed command. Nz SHOW WARNINGS)rwarningsr8executefetchall)rr8rets r show_warningszConnection.show_warningss[   4'''oo  rc"eZdZdZfdZxZS)Connection.xida xid(format_id: int, global_transaction_id: str, branch_qualifier: str) Creates a transaction ID object suitable for passing to the .tpc_*() methods of this connection. Parameters: - format_id: Format id. If not set default value `0` will be used. - global_transaction_id: Global transaction qualifier, which must be unique. The maximum length of the global transaction id is limited to 64 characters. - branch_qualifier: Branch qualifier which represents a local transaction identifier. The maximum length of the branch qualifier is limited to 64 characters. cvt|ts'tjdt |jt|t s'tjdt |jt|t s'tjdt |jt|tkrtjdt|tkrtjd|dkrd}t ||||fS)Nzargument 1 must be int, not %szargument 2 must be str, not %szargument 3 must be str, not %sz*Maximum length of transaction_id exceeded.z,Maximum length of branch_qualifier exceeded.r) r.rPrrtype__name__str__mane__len_MAX_TPC_XID_SIZEr0__new__)r format_idtransaction_idbranch_qualifierr5s rrmzConnection.xid.__new__s^i-- I.08/3I/GIIInc22 N.08/3N/C/C/LNNN.44 N.08/3N/C/C/LNNN>""%666.0JKKK#$$'888.0LMMMA~~ 77??4)*8*:*<== =r)rh __module__ __qualname____doc__rm __classcell__r5s@rxidrdsB  & = = = = = = = = =rrvc|t|jdkr'tjdt|jd|dd|dd|d} |||n#tj$rwxYwtj |_ ||_ d S) a= Parameter: xid: xid object which was created by .xid() method of connection class Begins a TPC transaction with the given transaction ID xid. This method should be called outside of a transaction (i.e. nothing may have executed since the last .commit() or .rollback()). Furthermore, it is an error to call .commit() or .rollback() within the TPC transaction. A ProgrammingError is raised, if the application calls .commit() or .rollback() during an active TPC transaction. rvargument 1 must be xid not %sz XA BEGIN 'rf','',rN) rrgrhrrrHrIErrorrXIDr'r(rrvrQs r tpc_beginzConnection.tpc_begin)s  99  & &*,459#YY5GII I '+.a&&&#a&&&#a&&A   ! !$ ' ' '    ! ! ! !}     " s 2)BB-Nc||s|j}|jtjkrt jd|)|jtjkrt jd|rAt|j dkr)t jdt|j z|jtjkrtd|dd|d d |d }| | | n,#t j $rd|_tj|_wxYwd |dd|d d |d }|jtjkr|d z} | || n,#t j $rd|_tj|_wxYwd|_tj|_dS)a Optional parameter:" xid: xid object which was created by .xid() method of connection class. When called with no arguments, .tpc_commit() commits a TPC transaction previously prepared with .tpc_prepare(). If .tpc_commit() is called prior to .tpc_prepare(), a single phase commit is performed. A transaction manager may choose to do this if only a single resource is participating in the global transaction. When called with a transaction ID xid, the database commits the given transaction. If an invalid transaction ID is provided, a ProgrammingError will be raised. This form should be called outside of a transaction, and is intended for use in recovery." Transaction not started.NzTransaction is not prepared.rvrxXA END 'rfryrzr{rz XA COMMIT 'z ONE PHASE) rr(r'rr&rrPREPARErgrhrHrIr|r~s r tpc_commitzConnection.tpc_commitFs$  )C >Y^ + +*+EFF F ;4>Y->>>*+IJJ J  J499%..*,46:3ii6H,IJJ J >I- - - -,/FFFCFFFCFFCD  ! !$ ' ' ' ##%%%%=     !*  ,/q6663q6663q66B >I- - -,&D   ! !$ ' ' '    ! ! ! !}   DI&^DN    "s=D)D;6)F )G c||jtjkrt jd|jtjkrt jd|j}d|dd|dd|d} ||| n,#tj $rd |_tj|_wxYwd |dd|dd|d} ||| n,#tj $rd |_tj|_wxYwtj|_d S) aF Performs the first phase of a transaction started with .tpc_begin(). A ProgrammingError will be raised if this method was called outside of a TPC transaction. After calling .tpc_prepare(), no statements can be executed until .tpc_commit() or .tpc_rollback() have been called. rz)Transaction is already in prepared state.rrfryrzr{rNz XA PREPARE ') rr'rr&rrrr(rHrIr|r~s r tpc_preparezConnection.tpc_prepare}s  >Y^ + +*+EFF F >Y. . .*,=>> >i(+AAA?   ! !$ ' ' '    ! ! ! !}   DI&^DN   " -0FFFCFFFCFFC   ! !$ ' ' '    ! ! ! !}   DI&^DN   #*s )B66)C)D**)Ec4||jtjkrt jd|rAt |jdkr)t jdt |jz|s|j}|jtj krtd|dd|dd|d }| | | n,#tj $rd |_tj|_wxYwd |dd|dd|d } | || n,#tj $rd |_tj|_wxYwtj |_d S) a Parameter: xid: xid object which was created by .xid() method of connection class Performs the first phase of a transaction started with .tpc_begin(). A ProgrammingError will be raised if this method outside of a TPC transaction. After calling .tpc_prepare(), no statements can be executed until .tpc_commit() or .tpc_rollback() have been called. rrvrxrrfryrzr{rNz XA ROLLBACK ') rr'rr&rrrgrhr(rrHrIr|r~s r tpc_rollbackzConnection.tpc_rollbacks  >Y^ + +*+EFF F  J499%..*,46:3ii6H,IJJ J )C >I- - - -,/FFFCFFFCFFCD  ! !$ ' ' ' ##%%%%=     !*  .1VVVSVVVSVVD   ! !$ ' ' '    ! ! ! !}   DI&^DN   #*sC'')D1)E)Fc||}|d|}~|S)z Returns a list of pending transaction IDs suitable for use with tpc_commit(xid) or .tpc_rollback(xid). z XA RECOVER)rr8r_r`)rr8results r tpc_recoverzConnection.tpc_recoversL |$$$""  rch||tjS)z$Get default database for connection.)r_mariadb_get_inforSCHEMArs rrXzConnection.databases, %%dk222rc| |dt|z|dS#tj$rwxYw)zSet default database.zUSE %sN)rrHrirIrr|)rschemas rrXzConnection.databasesr    ! !(S[["8 9 9 9    ! ! ! ! !}     s 9AA"ch||tjS)z Returns the user name for the current connection or empty string if it can't be determined, e.g. when using socket authentication. )rrrUSERrs ruserzConnection.users, %%di000rctS)zc Client character set. For MariaDB Connector/Python it is always utf8mb4. )_DEFAULT_CHARSETrs r character_setzConnection.character_sets  rch||tjS)zClient capability flags.)rrrCLIENT_CAPABILITIESrs rclient_capabilitieszConnection.client_capabilities- %%d&>???rch||tjS)zServer capability flags.)rrrSERVER_CAPABILITIESrs rserver_capabilitieszConnection.server_capabilities rrch||tjS)z_ Extended server capability flags (only for MariaDB database servers). )rrrEXTENDED_SERVER_CAPABILITIESrs rextended_server_capabilitiesz'Connection.extended_server_capabilitiess- %%d&GHHHrch||tjS)zp Database server TCP/IP port. This value will be 0 in case of a unix socket connection. )rrrPORTrs r server_portzConnection.server_ports, %%di000rch||tjS)zUnix socket name.)rrr UNIX_SOCKETrs r unix_socketzConnection.unix_socket&- %%d&6777rch||tjS)z&Name or IP address of database server.)rrrHOSTrs r server_namezConnection.server_name-s, %%di000rctS)zClient character set collation)_DEFAULT_COLLATIONrs r collationzConnection.collation4s "!rch||tjS)z-Server version in alphanumerical format (str))rrrSERVER_VERSIONrs r server_infozConnection.server_info:s- %%d&9:::rch||tjS)z0TLS cipher suite if a secure connection is used.)rrr SSL_CIPHERrs r tls_cipherzConnection.tls_cipherAs, %%do666rch||tjS)z4TLS protocol version if a secure connection is used.)rrr TLS_VERSIONrs r tls_versionzConnection.tls_versionHrrch||tjS)z, Return server status flags )rrr SERVER_STATUSrs r server_statuszConnection.server_statusOs- %%d&8999rch||tjS)z Server version in numerical format. The form of the version number is VERSION_MAJOR * 10000 + VERSION_MINOR * 100 + VERSION_PATCH )rrrSERVER_VERSION_IDrs rserver_versionzConnection.server_versionXs- %%d&<===rc||j}t|dz t|dzdz |dzfS)zW Returns numeric version of connected database server in tuple format. i'd)rrrP)rrs rr[zConnection.server_version_infodsR %GeO$$Wu_+,,#  rcl|t|jtjzS)a9 Toggles autocommit mode on or off for the current database connection. Autocommit mode only affects operations on transactional table types. Be aware that rollback() will not work, if autocommit mode was switched on. By default autocommit mode is set to False." )rr/rr AUTOCOMMITrs rrzConnection.autocommitps/ D&)::;;;rc|t||jkrdS |dt |z|dS#t j$rwxYw)NzSET AUTOCOMMIT=%s)rr/rrHrPrIrr|)rmodes rrzConnection.autocommits  :: ( ( F   ! !"5D "A B B B    ! ! ! ! !}     s 9A++A<c|}|jstj||_n7||jkrtj||_|jS)z/Returns the socket used for database connection)fileno) _get_socketr!socketr)rfnos rrzConnection.socketsj  | 5!=444DLL DL'')) ) )!=444DL|rc| |n#tj$rYdSwxYwdS)z Returns true if the connection is alive. A ping command will be send to the server for this purpose, which means this function might fail if there are still non processed pending result sets. FT)rpingrr|rs ropenzConnection.opensS   IIKKKK}   55 ts +>>c8||jS)z) Alias for connection_id )r connection_idrs r thread_idzConnection.thread_ids !!rr;)5rhrqrrrsrr1rcursorsCursorr8r=r?rDrJrMrPrRrUrirYr\rbtuplervrrrrrpropertyrXsetterrrrrrrrrrrrrrrr[rrrcharacter_set_namerrtrus@rr r s<<< ((((((((((T")!76666p    $ s         (((   +=+=+=+=+=e+=+=+=Z:5(5(5(5(n$+$+$+L++++++++Z   33X3 __11X1  X @@X@ @@X@ IIXI11X188X8 11X1 ""X" ;;X; 77X7 88X8 ::X: > >X >  X  < <X <  X X"' ""X"""""rr )rrmariadb.cursorsmariadb.constantsrrr packagingrrrrlr7 connectionr rrrs( 5555555555)Q "Q "Q "Q "Q "!,Q "Q "Q "Q "Q "r