codekingpro/portable-devtools
115k
1�
2 ��j`� � �V � % S r SSKJr SSKJr SSKrSSKJr SSKrSSK r SSK3r4SSK5J r SSK6J r SSK7J
r
SS K8Jr SS9K10Jr SS K11Jr SS K12Jr SS
K13Jr SSK14Jr SSK15Jr SSKrSSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SSKJ r \( a* SSK J r SSK J!r! SSK J"r" SSKJ#r# SS KJ$r$ SS KJ%r% SS K&J'r' \RP " S S 9 " S! S"5 5 r) " S# S$\5 r*\\*\ S% 4 r+\," \*5 u r-r.r/ " S& S'5 r0 " S( S)\05 r1 " S* S+\ 5 r2 " S, S-\ 5 r3 " S. S/\Rh \Rj 5 r6 " S0 S15 r7 " S2 S3\75 r8 " S4 S5\85 r9 S? S@S6 jjr:0 r;S7\<S8' " S9 S:\75 r= " S; S<\=5 r> " S= S>\=5 r?g)Az%Base constructs for connection pools.� )� annotations)�dequeN)�Enum)�Any)�Callable)�cast)�Deque)�Dict)�List)�Optional)�Tuple)�
TYPE_CHECKING)�Union� )�event)�exc)�log)�util)�Literal)�Protocol)�Self)�DBAPIConnection)� DBAPICursor)�Dialect)�_DispatchCommon)�_ListenerFnType)�16dispatcher)� _InfoTypeT)�frozenc �@ � \ rS rSr% SrSrS\S' S\S' S\S' Srg )17�PoolResetState�1 z�describes the state of a DBAPI connection as it is being passed to18the :meth:`.PoolEvents.reset` connection pool event.19 20.. versionadded:: 2.0.0b321 22��transaction_was_reset�terminate_only� asyncio_safe�boolr$ r% r& � N)�__name__�23__module__� __qualname__�__firstlineno__�__doc__� __slots__�__annotations__�__static_attributes__r( � �ZD:\code\apps\devtools\python\user_packages\Python313\site-packages\sqlalchemy/pool/base.pyr! r! 1 s4 � �� L�I� � �24� �� � ��r1 r! c �$ � \ rS rSrSrSrSrSrSrg)�25ResetStyle�^ z1Describe options for "reset on return" behaviors.r � r r( N) r) r* r+ r, r- �reset_rollback� reset_commit�26reset_noner0 r( r1 r2 r4 r4 ^ s � �;��N��L��Jr1 r4 )TNF�commit�rollbackc �\ � \ rS rSrSrSrSrS S jrS S jrS
S jr S
S jr27SS jr SS jr S28r
g )� _ConnDialect�m z�partial implementation of :class:`.Dialect`29which provides DBAPI connection methods.30 31When a :class:`_pool.Pool` is combined with an :class:`_engine.Engine`,32the :class:`_engine.Engine` replaces this with its own33:class:`.Dialect`.34 35Fc �$ � UR 5 g �N)r; ��self�dbapi_connections r2 � do_rollback�_ConnDialect.do_rollbackz s � ��!�!�#r1 c �$ � UR 5 g r@ )r: rA s r2 � do_commit�_ConnDialect.do_commit} s � �� � �!r1 c �$ � UR 5 g r@ ��closerA s r2 � do_terminate�_ConnDialect.do_terminate� � � �� � � r1 c �$ � UR 5 g r@ rJ rA s r2 �do_close�_ConnDialect.do_close� rN r1 c � � [ S5 e)NzJThe ping feature requires that a dialect is passed to the connection pool.��NotImplementedErrorrA s r2 �_do_ping_w_event� _ConnDialect._do_ping_w_event� s � �!�
-�36� 37r1 c � � U$ r@ r( )rB �38connections r2 �get_driver_connection�"_ConnDialect.get_driver_connection� s � ��r1 r( N)rC �PoolProxiedConnection�return�None)rC r r\ r] )rC r r\ r' )rX r r\ r )r) r* r+ r, r- �is_async�
has_terminaterD rG rL rP rU rY r0 r( r1 r2 r= r= m s1 � �� �H��M�$�"�!�!�39� r1 r= c � � \ rS rSrSrSrg)�_AsyncConnDialect� Tr( N)r) r* r+ r, r^ r0 r( r1 r2 ra ra � s � ��Hr1 ra c � � \ rS rSrSS jrSrg)�_CreatorFnType� c � � g r@ r( �rB s r2 �__call__�_CreatorFnType.__call__� s � �3r1 r( N�r\ r �r) r* r+ r, rh r0 r( r1 r2 rd rd � s � �.r1 rd c � � \ rS rSrSS jrSrg)�_CreatorWRecFnType� c � � g r@ r( �rB �recs r2 rh �_CreatorWRecFnType.__call__� s � �Sr1 r( N)rq �ConnectionPoolEntryr\ r rk r( r1 r2 rm rm � s � �Hr1 rm c �� � \ rS rSr% SrS\S' S\S' S\S' \" 5 rS \S40' S \S ' S
\S' S\S' S% S&S jjr\ R S'S j5 r \ S(S j5 r
\
R S)S j5 r
\
R S*S j5 r
S+S jrSS. S,S jjrS-S jr S. S/S jjrS0S jrS*S jrS1S jrS2S jrS-S! jrS2S" jrS3S# jrS$rg)4�Pool� z)Abstract base class for connection pools.zdispatcher[Pool]�dispatch�log._EchoFlagType�echo�
Optional[str]�_orig_logging_namez Union[_ConnDialect, Dialect]�_dialect�)Union[_CreatorFnType, _CreatorWRecFnType]� _creator_argrm �_invoke_creator�float�_invalidate_timeNFc41 �� � U( a U=U l U l OSU l [ R " XS9 Xl X l SU l X�l [ R " U[ R SS/[ R / SQ[ R S/0S5 U l X0l U ( a U R R# U S S429 U( a Xpl U( a# U H u p�[& R( " X U435 M gg) a� 44Construct a Pool.45 46:param creator: a callable function that returns a DB-API47 connection object. The function will be called with48 parameters.49 50:param recycle: If set to a value other than -1, number of51 seconds between connection recycling, which means upon52 checkout, if this timeout is surpassed the connection will be53 closed and replaced with a newly opened connection. Defaults to -1.54 55:param logging_name: String identifier which will be used within56 the "name" field of logging records generated within the57 "sqlalchemy.pool" logger. Defaults to a hexstring of the object's58 id.59 60:param echo: if True, the connection pool will log61 informational output such as when connections are invalidated62 as well as when connections are recycled to the default log handler,63 which defaults to ``sys.stdout`` for output.. If set to the string64 ``"debug"``, the logging will include pool checkouts and checkins.65 66 The :paramref:`_pool.Pool.echo` parameter can also be set from the67 :func:`_sa.create_engine` call by using the68 :paramref:`_sa.create_engine.echo_pool` parameter.69 70 .. seealso::71 72 :ref:`dbengine_logging` - further detail on how to configure73 logging.74 75:param reset_on_return: Determine steps to take on76 connections as they are returned to the pool, which were77 not otherwise handled by a :class:`_engine.Connection`.78 Available from :func:`_sa.create_engine` via the79 :paramref:`_sa.create_engine.pool_reset_on_return` parameter.80 81 :paramref:`_pool.Pool.reset_on_return` can have any of these values:82 83 * ``"rollback"`` - call rollback() on the connection,84 to release locks and transaction resources.85 This is the default value. The vast majority86 of use cases should leave this value set.87 * ``"commit"`` - call commit() on the connection,88 to release locks and transaction resources.89 A commit here may be desirable for databases that90 cache query plans if a commit is emitted,91 such as Microsoft SQL Server. However, this92 value is more dangerous than 'rollback' because93 any data changes present on the transaction94 are committed unconditionally.95 * ``None`` - don't do anything on the connection.96 This setting may be appropriate if the database / DBAPI97 works in pure "autocommit" mode at all times, or if98 a custom reset handler is established using the99 :meth:`.PoolEvents.reset` event handler.100 101 * ``True`` - same as 'rollback', this is here for102 backwards compatibility.103 * ``False`` - same as None, this is here for104 backwards compatibility.105 106 For further customization of reset on return, the107 :meth:`.PoolEvents.reset` event hook may be used which can perform108 any connection activity desired on reset.109 110 .. seealso::111 112 :ref:`pool_reset_on_return`113 114 :meth:`.PoolEvents.reset`115 116:param events: a list of 2-tuples, each of the form117 ``(callable, target)`` which will be passed to :func:`.event.listen`118 upon construction. Provided here so that event listeners119 can be assigned via :func:`_sa.create_engine` before dialect-level120 listeners are applied.121 122:param dialect: a :class:`.Dialect` that will handle the job123 of calling rollback(), close(), or commit() on DBAPI connections.124 If omitted, a built-in "stub" dialect is used. Applications that125 make use of :func:`_sa.create_engine` should not use this parameter126 as it is handled by the engine creation strategy.127 128:param pre_ping: if True, the pool will emit a "ping" (typically129 "SELECT 1", but is dialect-specific) on the connection130 upon checkout, to test if the connection is alive or not. If not,131 the connection is transparently re-connected and upon success, all132 other pooled connections established prior to that timestamp are133 invalidated. Requires that a dialect is passed as well to134 interpret the disconnection error.135 136 .. versionadded:: 1.2137 138N)�echoflagr r; T)�noneNFr: �reset_on_returnF)�only_propagate)� logging_namer{ r �instance_logger�_creator�_recycler� � _pre_pingr � parse_user_argument_for_enumr4 r7 r9 r8 �_reset_on_returnry rw �_updater| r �listen) rB �creator�recyclery r� r� �events�dialect�pre_ping� _dispatch�fn�targets r2 �__init__�
Pool.__init__� s� � �X �:F� F�D� �� 7�&*�D� #� ���D�0� �
� �
� !�� �!�� $� A� A� ��)�)�J��+=��%�%�'<��'�'�(��
�139
�!140�� � � � � �M�M� !� !�)�E� !� B� � #�M� � $�141��� � �T�2�.� %� r1 c �. � U R R $ r@ )r| r^ rg s r2 � _is_asyncio�Pool._is_asyncio2 s � ��}�}�%�%�%r1 c � � U R $ r@ )r~ rg s r2 r� �
Pool._creator6 s � �� � � r1 c �< � Xl U R U5 U l g r@ )r~ �_should_wrap_creatorr )rB r� s r2 r� r� : s � � $�� $� 8� 8�� A�� r1 c � � U ? U ?g r@ )r~ r rg s r2 r� r� D s � �
� � � r1 c � ^� [ R " U R SS9nUR b [ UR 5 nOSn[ US 5 U-142 nUS US 4S/S4:X a [ [ U5 $ US:X a [ [ U5 $ [ [143 U5 mU4S j$ ! [ a [ [144 U5 mU4S js $ f = f)145z\Detect if creator accepts a single argument, or is sent146as a legacy style no-arg function.147 148T)�no_selfc � >� T" 5 $ r@ r( �rq �149creator_fns �r2 �<lambda>�+Pool._should_wrap_creator.<locals>.<lambda>V � �� �z�|r1 r � �connection_recordr@ r6 c � >� T" 5 $ r@ r( r� s �r2 r� r� i r� r1 ) r �get_callable_argspecr� � TypeErrorr rd �defaults�lenrm )rB r� �argspec� defaulted� positionalsr� s @r2 r� �Pool._should_wrap_creatorJ s� �� � ,��/�/��
�
�t�L�G�150 � � � '��G� ,� ,�-�I��I��'�!�*�o� �1� �
�A�J���151� #�)<�(=�w�'G� G��*�G�4� 4�
�A�
��*�G�4� 4� �n�g�6�J�+� +��+ � ,� �n�g�6�J�+� +� ,�s � B% �% C�C�� terminatec �x � U R R SU( a SOSU5 U( a U R R U5 g U R R U5 g ! [152 aH nU R R
SU( a SOS S3USS 9 [ U[ 5 ( d e S nAg S nAff = f)153Nz%s connection %rz Hard-closing�Closingz154Exception � terminating�closingz connection %rT��exc_info) �logger�debugr| rL rP �
BaseException�error�155isinstance� Exception)rB rX r� �es r2 �_close_connection�Pool._close_connectionk s� � �
� � ��� � '�N�Y� � 156�157
���
�
�*�*�:�6��
�
�&�&�z�2�� � � �K�K� � � �i�]�Y� G� H � !�� �
�
� �a��+�+�� ,�� �s �"A' � A' �'158B9�1>B4�4B9c � � [ U 5 $ )z6Called by subclasses to create a new ConnectionRecord.)�_ConnectionRecordrg s r2 �_create_connection�Pool._create_connection� s � � !��&�&r1 c �� � [ USS5 nU( a U R UR : a [ R " 5 U l U( a% [ USS5 ( a UR U5 ggg)ab Mark all connections established within the generation159of the given connection as invalidated.160 161If this pool's last invalidate time is before when the given162connection was created, update the timestamp til now. Otherwise,163no action is performed.164 165Connections with a start time prior to this pool's invalidation166time will be recycled upon next checkout.167�_connection_recordN�is_validF)�getattrr� � starttime�time�168invalidate)rB rX � exception�_checkinrq s r2 � _invalidate�Pool._invalidate� s[ � � �j�"6��=���d�+�+�c�m�m�;�$(�I�I�K�D� !� ��169�J��>�>� � !� !�)� ,� ?�8r1 c � � [ 5 e)z�Return a new :class:`_pool.Pool`, of the same class as this one170and configured with identical creation arguments.171 172This method is used in conjunction with :meth:`dispose`173to close out an entire :class:`_pool.Pool` and create a new one in174its place.175 176rS rg s r2 �recreate�
Pool.recreate� s
� � "�#�#r1 c � � [ 5 e)z�Dispose of this pool.177 178This method leaves the possibility of checked-out connections179remaining open, as it only affects connections that are180idle in the pool.181 182.. seealso::183 184 :meth:`Pool.recreate`185 186rS rg s r2 �dispose� Pool.dispose� �
� � "�#�#r1 c �, � [ R U 5 $ )z�Return a DBAPI connection from the pool.187 188The connection is instrumented such that when its189``close()`` method is called, the connection will be returned to190the pool.191 192)�_ConnectionFairy� _checkoutrg s r2 �connect� Pool.connect� s � � �)�)�$�/�/r1 c �& � U R U5 g)z�Given a _ConnectionRecord, return it to the :class:`_pool.Pool`.193 194This method is called when an instrumented DBAPI connection195has its ``close()`` method called.196 197N)�_do_return_conn�rB �records r2 � _return_conn�Pool._return_conn� s � �
� � �V�$r1 c � � [ 5 e)z7Implementation for :meth:`get`, supplied by subclasses.rS rg s r2 �_do_get� Pool._do_get� �
� � "�#�#r1 c � � [ 5 e)z?Implementation for :meth:`return_conn`, supplied by subclasses.rS r� s r2 r� �Pool._do_return_conn� r� r1 c � � [ 5 e)z6Returns a brief description of the state of this pool.rS rg s r2 �status� Pool.status� � � �!�#�#r1 ) r� r~ r| r� r r{ r� r� r� ry r� )�����NNTNNFN)r� r} r� �intry rx r� rz r� �_ResetStyleArgTyper� z+Optional[List[Tuple[_ListenerFnType, str]]]r� z&Optional[Union[_ConnDialect, Dialect]]r� r' r� z Optional[_DispatchCommon[Pool]]�r\ r' )r\ r} )r� r} r\ r] �r\ r] )r� r} r\ rm )rX r r� r' r\ r] )r\ rs �NT)rX r[ r� �Optional[BaseException]r� r' r\ r] )r\ ru )r\ r[ )r� rs r\ r] )r\ �str) r) r* r+ r, r- r/ r= r| r� r �hybridpropertyr� �propertyr� �setter�deleterr� r� r� r� r� r� r� r� r� r� r� r0 r( r1 r2 ru ru � s� � �3� � �198��%�%�-9�^�H�*�;�;�;�'�'���199 �"&�&*�.2�>B�:>� �59�H/�:�H/� �H/� � H/�200 $� H/� ,�
H/� <�H/� 8�H/� �H/� 3�H/�T 201���&� �&� �!� �!� �_�_�B�@�B�
�B� �B� ���!� �!�202 ,�@� ,� � ,�D AF��)��9=��
��.'� .2� � -�)�-� +�-� � -�203 204� -�,205$�
$� 0�%�$�206$�207$r1 ru c � � \ rS rSr% SrSrS\S' S\S' \R S S j5 r \R S
S j5 r208 S SS jjr Sr g209)�ManagesConnectioni� a Common base for the two connection-management interfaces210:class:`.PoolProxiedConnection` and :class:`.ConnectionPoolEntry`.211 212These two objects are typically exposed in the public facing API213via the connection pool event hooks, documented at :class:`.PoolEvents`.214 215.. versionadded:: 2.0216 217r( �Optional[DBAPIConnection]rC �
Optional[Any]�driver_connectionc � � [ 5 e)a Info dictionary associated with the underlying DBAPI connection218referred to by this :class:`.ManagesConnection` instance, allowing219user-defined data to be associated with the connection.220 221The data in this dictionary is persistent for the lifespan222of the DBAPI connection itself, including across pool checkins223and checkouts. When the connection is invalidated224and replaced with a new one, this dictionary is cleared.225 226For a :class:`.PoolProxiedConnection` instance that's not associated227with a :class:`.ConnectionPoolEntry`, such as if it were detached, the228attribute returns a dictionary that is local to that229:class:`.ConnectionPoolEntry`. Therefore the230:attr:`.ManagesConnection.info` attribute will always provide a Python231dictionary.232 233.. seealso::234 235 :attr:`.ManagesConnection.record_info`236 237 238rS rg s r2 �info�ManagesConnection.info s
� �0 "�#�#r1 c � � [ 5 e)a� Persistent info dictionary associated with this239:class:`.ManagesConnection`.240 241Unlike the :attr:`.ManagesConnection.info` dictionary, the lifespan242of this dictionary is that of the :class:`.ConnectionPoolEntry`243which owns it; therefore this dictionary will persist across244reconnects and connection invalidation for a particular entry245in the connection pool.246 247For a :class:`.PoolProxiedConnection` instance that's not associated248with a :class:`.ConnectionPoolEntry`, such as if it were detached, the249attribute returns None. Contrast to the :attr:`.ManagesConnection.info`250dictionary which is never None.251 252 253.. seealso::254 255 :attr:`.ManagesConnection.info`256 257rS rg s r2 � record_info� ManagesConnection.record_info+ s
� �, "�#�#r1 Nc � � [ 5 e)a Mark the managed connection as invalidated.258 259:param e: an exception object indicating a reason for the invalidation.260 261:param soft: if True, the connection isn't closed; instead, this262 connection will be recycled on next checkout.263 264.. seealso::265 266 :ref:`pool_connection_invalidation`267 268 269rS �rB r� �softs r2 r� � ManagesConnection.invalidateC s
� � "�#�#r1 �r\ r �r\ zOptional[_InfoType]�NF�r� r� r270 r' r\ r] )
r) r* r+ r, r- r. r/ r �ro_memoized_propertyr r r� r0 r( r1 r2 r� r� � s� � �� �I�/�/��( %�$��( 271� � �$� �$�2 272� � �$� �$�0 ?D�$�(�$�7;�$�
�$� $r1 r� c �: � \ rS rSrSrSr\SS j5 rSS jrSr g) rs iV a� Interface for the object that maintains an individual database273connection on behalf of a :class:`_pool.Pool` instance.274 275The :class:`.ConnectionPoolEntry` object represents the long term276maintenance of a particular connection for a pool, including expiring or277invalidating that connection to have it replaced with a new one, which will278continue to be maintained by that same :class:`.ConnectionPoolEntry`279instance. Compared to :class:`.PoolProxiedConnection`, which is the280short-term, per-checkout connection manager, this object lasts for the281lifespan of a particular "slot" within a connection pool.282 283The :class:`.ConnectionPoolEntry` object is mostly visible to public-facing284API code when it is delivered to connection pool event hooks, such as285:meth:`_events.PoolEvents.connect` and :meth:`_events.PoolEvents.checkout`.286 287.. versionadded:: 2.0 :class:`.ConnectionPoolEntry` provides the public288 facing interface for the :class:`._ConnectionRecord` internal class.289 290r( c � � [ 5 e)z3Return True the connection is currently checked outrS rg s r2 �in_use�ConnectionPoolEntry.in_usem s
� � "�#�#r1 c � � [ 5 e)zAClose the DBAPI connection managed by this connection pool entry.rS rg s r2 rK �ConnectionPoolEntry.closes r� r1 Nr� r� )291r) r* r+ r, r- r. r� r rK r0 r( r1 r2 rs rs V s% � ��( �I�
�$� �$�292$r1 rs c �� � \ rS rSr% SrSrS\S' S\S' S\S ' S293\S ' S&S'S jjrS
\S' \S(S j5 r \\294R " SS5 S)S j5 5 r Sr
S295\S' \296R S*S j5 r\297R S+S j5 r\S,S j5 r S& S-S jjrS&S.S jjr\S/S j5 r\S0S j5 rS1S jr S2 S3S jjrS4S jrS/S! jrS S".S5S# jjrS1S$ jr S%r g )6r� ix a� Maintains a position in a connection pool which references a pooled298connection.299 300This is an internal object used by the :class:`_pool.Pool` implementation301to provide context management to a DBAPI connection maintained by302that :class:`_pool.Pool`. The public facing interface for this class303is described by the :class:`.ConnectionPoolEntry` class. See that304class for public API details.305 306.. seealso::307 308 :class:`.ConnectionPoolEntry`309 310 :class:`.PoolProxiedConnection`311 312)�__pool� fairy_ref�finalize_callback�freshr� rC � __weakref__�__dict__z(Deque[Callable[[DBAPIConnection], None]]r r' r �'Optional[weakref.ref[_ConnectionFairy]]r r� r� c � � SU l S U l SU l S U l Xl U( a U R 5 [
5 U l g )NFr )r r r� rC �_ConnectionRecord__pool�_ConnectionRecord__connectr r )rB �poolr� s r2 r� �_ConnectionRecord.__init__� s; � ���313� ������ $�� �� � � �N�N� �!&��� r1 r� rC c �| � U R c g U R R R U R 5 $ r@ )rC r r| rY rg s r2 r �#_ConnectionRecord.driver_connection� s7 � � � � � (���;�;�'�'�=�=��%�%��
r1 �2.0zXThe _ConnectionRecord.connection attribute is deprecated; please use 'driver_connection'c � � U R $ r@ �rC rg s r2 rX � _ConnectionRecord.connection� � � � �$�$�$r1 r �_soft_invalidate_timec � � 0 $ r@ r( rg s r2 r �_ConnectionRecord.info� � � �� r1 c � � 0 $ r@ r( rg s r2 r � _ConnectionRecord.record_info� r. r1 c �" ^^^� [ ( a [ [ TR 5 5 mOTR 5 m TR 5 nTR 5 m[ TUTT5 n[ R " UUUU4S j5 =Tl
nT[ U' T( a TR R! SU5 U$ ! [314 aE n[ R " 5 TR USS9 S S S 5 e ! , ( d f e = fS nAff = f)NF��_fairy_was_createdc �2 >� [ b [ S TTU TSS9$ S $ )NF�r$ )�_finalize_fairy)�refry r" rq s ���r2 r� �,_ConnectionRecord.checkout.<locals>.<lambda>� s1 �� � #�.� ��#�t�S�$�e�� � � r1 z#Connection %r checked out from pool)r r r� r� �get_connectionr� r � safe_reraise�_checkin_failed�_should_log_debugr� �weakrefr7 r � _strong_ref_connection_recordsr� r� )�clsr" rC �err�fairyr7 ry rq s ` @@r2 �checkout�_ConnectionRecord.checkout� s� �� � �=��(�$�,�,�.�9�C��,�,�.�C� � "� 1� 1� 3� � �%�%�'�� ��'7��d�C�� %�k�k� �
� 315� 316��
�� /2�&�s�+� � �K�K� � �5�7G�
� � ��3 � ��"�"�$��#�#�C�E�#�B� %�
� %�$�
�� �s/ �B? �?317D� D � C8�/ D �8318D �D � Dc �@ � U R US9 U R US9 g )N�r� r2 )r� �checkin)rB r@ r3 s r2 r; �!_ConnectionRecord._checkin_failed� s& � �
���#�� � � � � 1� � 319r1 c � � U R c! U( a [ R " SU - 5 g S U l U R nU R nU R320 ( a8 U R321 R
5 nUb U" U5 U R322 ( a M8 UR R ( a UR R X 5 UR U 5 g )Nz Double checkin attempted on %s)323r r �warnrC r r �poprw rF r� )rB r3 rX r" � finalizers r2 rF �_ConnectionRecord.checkin� s� � � �>�>� !�&8�
�I�I�6��=� >� � ����*�*�324��{�{���$�$� �.�.�2�2�4�I��%��*�%� �$�$�$� �=�=� � � �M�M� !� !�*� 3� ���$� r1 c � � U R S L$ r@ )r rg s r2 r �_ConnectionRecord.in_use s � ��~�~�T�)�)r1 c � � U R $ r@ )r� rg s r2 �last_connect_time�#_ConnectionRecord.last_connect_time325 s � ��~�~� r1 c �@ � U R b U R 5 g g r@ )rC �_ConnectionRecord__closerg s r2 rK �_ConnectionRecord.close s � � � � � ,� �L�L�N� -r1 NFc �| � U R c g U( a1 U R R R U R X5 O0U R R R U R X5 UbQ U R R326 R
SU( a SOSU R UR R U5 O:U R R327 R
SU( a SOSU R 5 U( a [ R " 5 U l328 g U R SS9 S U l g )Nz*%sInvalidate connection %r (reason: %s:%s)zSoft � z%sInvalidate connection %rTr� ) rC r rw �soft_invalidater� r� r � __class__r) r� r+ rS r s r2 r� � _ConnectionRecord.invalidate s� � � � � � (� � � �K�K� � � 0� 0��%�%�t�
�
�K�K� � � +� +�D�,A�,A�4� K� �=� �K�K� � � #� #�<� ��R��%�%�� � �$�$��
�
�K�K� � � #� #�,� ��R��%�%�
� �)-����D� &� �L�L�4�L� (�$(�D� !r1 c � � SnU R c, U R R 5 U R 5 GO*U R R329 S:� am [ R " 5 U R -330 U R R331 :� a3 U R R R SU R 5 SnO�U R R U R :� a3 U R R R SU R 5 SnOLU R U R :� a2 U R R R SU R 5 SnU( a9 U R SS9 U R R 5 U R 5 U R c eU R $ )NFr� z)Connection %r exceeded timeout; recyclingTz=Connection %r invalidated due to pool invalidation; recyclingzCConnection %r invalidated due to local soft invalidation; recyclingr� ) rC r �clearr! r r� r� r� r� r� r+ rS )rB r� s r2 r9 � _ConnectionRecord.get_connection3 sT � ��� � � � (� �I�I�O�O� � �N�N� � �K�K� � �2� %�� � � �d�n�n�,�t�{�{�/C�/C�C� �K�K� � � #� #�;��%�%�
� �G�
�[�[�
)�
)�D�N�N�
:� �K�K� � � #� #� ��%�%�
�332 �G�
�
'�
'�$�.�.�
8� �K�K� � � #� #� ��%�%�
�333 �G� � �L�L�4�L� (� �I�I�O�O� � �N�N� ��$�$�0�0�0��$�$�$r1 c � � U R S L =( dC U R R U R :� =( d U R U R :� $ r@ )rC r r� r� r+ rg s r2 � _is_hard_or_soft_invalidated�._ConnectionRecord._is_hard_or_soft_invalidatedg sG � � � !� !�T� )�
=��{�{�+�+�d�n�n�<�
=��*�*�T�^�^�;� 334r1 r� c �V � U R R 5 U R R R ( a0 U R R R U R335 U 5 U R336 c eU R R
U R337 US9 S U l g )Nr� )r r[ r rw rK rC r� )rB r� s r2 �__close�_ConnectionRecord.__closen s� � � � � �$�$�&� �;�;� � � %� %� �K�K� � � &� &�t�'<�'<�d� C��$�$�0�0�0� � � �%�%� � !� !�Y� &� 338� !%�� r1 c �� � U R nS U l [ R " 5 U l UR U 5 =U l nUR339 R
SU5 SU l UR R ( aI UR R R UR 5 R U R U 5 UR R R UR 5 R U R U 5 g ! [ aY n[ R " 5 UR340 R
SU5 S S S 5 S nAg ! , ( d f S nAg = fS nAff = f)NzCreated new connection %rTzError on connect(): %s)r rC r� r� r r� r� r rw �
first_connect�341for_modify�exec_once_unless_exceptionr� �_exec_w_sync_on_first_runr� r r: )rB r" rX r� s r2 � __connect�_ConnectionRecord.__connectx s � ��{�{�� !%�� � E� !�Y�Y�[�D�N�15�1E�1E�d�1K� K�D� !�J� �K�K� � � 9�:� F� �D�J� �}�}�*�*��
�
�+�+�6�6��M�M��,�,�T�-B�-B�D�I�
�M�M� !� !� ,� ,��
�
�
�'�'��(=�(=�t�D�� � ?��"�"�$�� � �!�!�":�A�>� %�$�$�$�� ?�s6 �AD �342E;�"E6�7 E!�E6�!343E3 �+E6�3E6�6E;)r r+ rC r r r r� )T)r" ru r� r' �r\ r )r\ r� r r
)r" ru r\ r� )r@ r� r3 r' r\ r] )r3 r' r\ r] r� )r\ r� r� r r rj )r� r' r\ r] ) r) r* r+ r, r- r. r/ r� r� r r �344deprecatedrX r+ r r r � classmethodrB r; rF r rP rK r� r9 r^ rS r! r0 r( r1 r2 r� r� x s\ � ��" �I� @�?� �K�6�6��� )� 0�/�
�� �� � �_�_�
� )��345%� � � %� $%��5�$� � � �� �� 346� � �� �� �!� �!�H >B�347� �348�6:�349�
�350� �. �*� �*� � � � ��351 ?D� )�(� )�7;� )�
� )�B2%�h352� ,1� %�Er1 r� c � � USLnU( aB Uc e[ R US5 Uc eUR ULa gU b eUR n O1U( a* [ R [ R353 " U5 S5 UR R nU( a� USL =( d Un U( + n354UR R ( + =( d UR R n UR R =( a UR R n O USL n S=p�Sn U Gb2 U( a# U( a UR R SU 5 U( d Uc e[ UU UU5 nUR U L d eUR UUU U355S9 U ( aj U( a X&l
UR 5 U ( aF UR R ( a UR R! U 5 UR# U U S9 U ( aR U( aK U( aD S356U < S U ( d S OS
S3nUR R' U5 [. R0 " U5 U( a UR b UR3 5 Ub SUl SUl A AAg! [$ aP n
UR R' SSS9 U( a UR) U
S 9 [+ U
[, 5 ( d e Sn
A
N�Sn
A
ff = f! U ( aU U( aM U( aE S357U < S U ( d S OS
S3nUR R' U5 [. R0 " U5 f f f f = f)aK Cleanup for a :class:`._ConnectionFairy` whether or not it's already358been garbage collected.359 360When using an async dialect no IO can happen here (without using361a dedicated thread), since this is called outside the greenlet362context and with an already running loop. In this case function363will only log a message and raise a warning.364NTFz$Connection %r being returned to poolr# r� z!Exception during reset or similarr� rE zFThe garbage collector is trying to clean up non-checked-in connection z, which will be z*dropped, as it cannot be safely terminated�365terminatedz�. Please ensure that SQLAlchemy pooled connections are returned to the pool explicitly, either by calling ``close()`` or by using appropriate context managers to manage their lifecycle.)r> rJ r rC r= r7 r| r^ r_ r� r� r� �_reset�_pool�detachrw �close_detachedr� r� r� r� r� r� r rI rF r� )rC r� r" r7 ry r$ rA �
is_gc_cleanup�dont_restore_gcedrq �can_manipulate_connection�!can_close_or_terminate_connection� requires_terminate_for_closer� �messages r2 r6 r6 � s9 � �( �t�O�M���� ��&�*�*�3��5� �,�,�,� � &� &�c� 1� � �'�'�'�,�=�=�� �&�*�*�7�;�;�u�+=�t�D� �
�
�.�.���"�d�*�;�m��(5�$5�!��
�
�&�&� &� E�$�-�-�*E�*E� *�
�M�M� "� "� B�t�}�}�'B�'B� %�366 #�d�*��HL�L�!�',�$��#� �� �K�K� � �6�8H�
�9 #��(�4�4�4�(��$�%�� �� �)�)�-=�=� =�=� �L�L��&;� %� 6�
�
� �$�"&�K��L�L�N�4��}�}�3�3� �
�
�4�4�5E�F��*�*�(�">� +� � �-�,=�1�1A�0D� E'� A� E� )�'�'�
'� � � � �!�!�'�*�� � �'�"�� .� 8� 8� D��!�!�#�
��!%�� �#'�� ���
��O � � �K�K� � �3�d�
�
� !�!�,�,�q�,�1� �a��+�+�� ,��
�� �-�,=�1�1A�0D� E'� A� E� )�'�'�
'� � � � �!�!�'�*�� � �'�"�! ->�-�v�s- �B.J �367K.� AK)�$K1 �)K.�.K1 �1A Mz6Dict[weakref.ref[_ConnectionFairy], _ConnectionRecord]r> c � � \ rS rSrSrSr\R ( a SS jrSS jr SS jr368SS jr \ SS j5 r
\ SS j5 rSS369 jrSS jrSS jrSS
jrSrg)r[ i" a A connection-like adapter for a :pep:`249` DBAPI connection, which370includes additional methods specific to the :class:`.Pool` implementation.371 372:class:`.PoolProxiedConnection` is the public-facing interface for the373internal :class:`._ConnectionFairy` implementation object; users familiar374with :class:`._ConnectionFairy` can consider this object to be equivalent.375 376.. versionadded:: 2.0 :class:`.PoolProxiedConnection` provides the public-377 facing interface for the :class:`._ConnectionFairy` internal class.378 379r( c � � g r@ r( rg s r2 r: � PoolProxiedConnection.commit3 s � �#r1 c � � g r@ r( �rB �args�kwargss r2 �cursor� PoolProxiedConnection.cursor5 s � �Cr1 c � � g r@ r( rg s r2 r; � PoolProxiedConnection.rollback7 s � �Cr1 c � � g r@ r( �rB �keys r2 � __getattr__�!PoolProxiedConnection.__getattr__9 s � �r1 c � � [ 5 e)z_Return True if this :class:`.PoolProxiedConnection` still refers380to an active DBAPI connection.rS rg s r2 r� � PoolProxiedConnection.is_valid; �
� �381 "�#�#r1 c � � [ 5 e)zNReturn True if this :class:`.PoolProxiedConnection` is detached382from its pool.rS rg s r2 � is_detached�!PoolProxiedConnection.is_detachedB r� r1 c � � [ 5 e)a� Separate this connection from its Pool.383 384This means that the connection will no longer be returned to the385pool when closed, and will instead be literally closed. The386associated :class:`.ConnectionPoolEntry` is de-associated from this387DBAPI connection.388 389Note that any overall connection limiting constraints imposed by a390Pool implementation may be violated after a detach, as the detached391connection is removed from the pool's knowledge and control.392 393rS rg s r2 rq � PoolProxiedConnection.detachI s
� � "�#�#r1 c � � [ 5 e)a� Release this connection back to the pool.394 395The :meth:`.PoolProxiedConnection.close` method shadows the396:pep:`249` ``.close()`` method, altering its behavior to instead397:term:`release` the proxied connection back to the connection pool.398 399Upon release to the pool, whether the connection stays "opened" and400pooled in the Python process, versus actually closed out and removed401from the Python process, is based on the pool implementation in use and402its configuration and current state.403 404rS rg s r2 rK �PoolProxiedConnection.closeY r� r1 c � � U $ r@ r( rg s r2 � __enter__� PoolProxiedConnection.__enter__h s � �� r1 c �$ � U R 5 g r@ rJ )rB �exc_type� exc_value� tracebacks r2 �__exit__� PoolProxiedConnection.__exit__k s � � �405�406� �r1 Nr� �r~ r r r r\ r �r� r� r\ r r� )r\ r )r� r r� r r� r r\ r] )r) r* r+ r, r- r. �typingr r: r� r; r� r� r� r� rq rK r� r� r0 r( r1 r2 r[ r[ " s] � �407� �I�
���%�G�'�3�
�$� �$� �$� �$� $�
$� �r1 r[ c �� � \ rS rSr% SrSrS\S' S\S' SS jr\SS j5 r \SS408 j5 r409\SS j5 r S SS
jjr \
R SS j5 rSS jrSS jrSrg )�_AdhocProxiedConnectionip aL provides the :class:`.PoolProxiedConnection` interface for cases where410the DBAPI connection is not actually proxied.411 412This is used by the engine internals to pass a consistent413:class:`.PoolProxiedConnection` object to consuming dialects in response to414pool events that may not always have the :class:`._ConnectionFairy`415available.416 417�rC r� � _is_validr rC rs r� c �* � Xl X l SU l g r� r� )rB rC r� s r2 r� � _AdhocProxiedConnection.__init__� s � �418 !1� �"3� � ��r1 c �. � U R R $ r@ �r� r rg s r2 r �)_AdhocProxiedConnection.driver_connection� s � ��&�&�8�8�8r1 c � � U R $ r@ r( rg s r2 rX �"_AdhocProxiedConnection.connection� s � ��$�$�$r1 c � � U R $ )z�Implement is_valid state attribute.419 420for the adhoc proxied connection it's assumed the connection is valid421as there is no "invalidate" routine.422 423�r� rg s r2 r� � _AdhocProxiedConnection.is_valid� s � � �~�~� r1 Nc � � SU l g r r� r s r2 r� �"_AdhocProxiedConnection.invalidate� s � � ��r1 c �. � U R R $ r@ �r� r rg s r2 r �#_AdhocProxiedConnection.record_info� s � ��&�&�2�2�2r1 c �: � U R R " U0 UD6$ r@ �rC r� r} s r2 r� � _AdhocProxiedConnection.cursor� s � ��$�$�+�+�T�<�V�<�<r1 c �. � [ U R U5 $ r@ �r� rC r� s r2 r� �#_AdhocProxiedConnection.__getattr__� � � ��t�,�,�c�2�2r1 )r� r� rC )rC r r� rs )r\ r rj r� r r r
r� )r� r r\ r )r) r* r+ r, r- r. r/ r� r� r rX r� r� r �ro_non_memoized_propertyr r� r� r0 r( r1 r2 r� r� p s� � �� H�I�%�%�+�+� �)� � /� � �9� �9� �%� �%� � � � � ?D� �(� �7;� �
� �424 425�"�"�3� #�3�=�3r1 r� c �� � \ rS rSr% SrSrS\S' S\S' S\S ' S#S426 jrS \S ' \S$S
j5 r \\427R " SS5 S%S j5 5 r \
S& S'S jj5 rS(S jrS)S*S jjrS+S jr S,S jr\S-S j5 r\S.S j5 r\S.S j5 r\428R, S/S j5 r\429R0 S0S j5 r S1 S2S jjrS3S jrS4S jr S+S jr S+S jr S)S5S! jjr S"r g)6r� i� a� Proxies a DBAPI connection and provides return-on-dereference430support.431 432This is an internal object used by the :class:`_pool.Pool` implementation433to provide context management to a DBAPI connection delivered by434that :class:`_pool.Pool`. The public facing interface for this class435is described by the :class:`.PoolProxiedConnection` class. See that436class for public API details.437 438The name "fairy" is inspired by the fact that the439:class:`._ConnectionFairy` object's lifespan is transitory, as it lasts440only for the length of a specific DBAPI connection being checked out from441the pool, and additionally that as a transparent proxy, it is mostly442invisible.443 444.. seealso::445 446 :class:`.PoolProxiedConnection`447 448 :class:`.ConnectionPoolEntry`449 450 451)rC r� �_echorp �_counterr r ru r" r rC rx r� c �B � Xl SU l X l X0l X@l g )Nr )rp r� rC r� r� )rB r" rC r� ry s r2 r� �_ConnectionFairy.__init__� s! � � �452���
� 0� �"3� ��453r1 �Optional[_ConnectionRecord]r� c �J � U R c g U R R $ r@ r� rg s r2 r �"_ConnectionFairy.driver_connection� s# � � � "� "� *���&�&�8�8�8r1 r& zWThe _ConnectionFairy.connection attribute is deprecated; please use 'driver_connection'c � � U R $ r@ r( rg s r2 rX �_ConnectionFairy.connection� r* r1 Nc � � U( d3 [ R U5 nUb [ R " U5 Ul UR454 c S5 eUR c S5 eU=R S-
sl UR R ( d UR ( a UR S:w a U$ SnUS:� GaZ UR455 R nSUR456 l457 UR ( a� U( d� UR ( a& UR R SUR 5 UR R UR 5 nU( dL UR ( a& UR R SUR 5 [ R" " 5 eO7UR ( a& UR R S UR 5 UR R UR UR458 U5 U$ UR R) S5 UR+ 5 [ R8 " S5 e! [ R$ Ga( nUR& ( aH UR R) S459U5 UR460 R+ U5 UR- X7SS 9 OBUR R) S UR U5 UR461 R+ U5 UR462 R/ 5 Ul O]! [0 aP n[2 R4 " 5 UR463 R7 US
S9 AS S S 5 e ! , ( d f e = fS nAff = fUS- n S nAOeS nAf[0 aU n [2 R4 " 5 UR464 n465U466b U467R7 U S
S9 AS S S 5 e ! , ( d f e = fS n A ff = fUS:� a GMA GN�)Nz,can't 'checkout' a detached connection fairyz0can't 'checkout' an invalidated connection fairyr6 r r Fz Pool pre-ping on connection %sz;Pool pre-ping on connection %s failed, will invalidate poolz)Connection %s is fresh, skipping pre-pingzoDisconnection detected on checkout, invalidating all pooled connections prior to current timestamp (reason: %r)�r� zVDisconnection detected on checkout, invalidating individual connection %s (reason: %r)Tr2 z+Reconnection attempts exhausted on checkoutzThis connection is closed) r� rB r= r7 �currentr� rC r� rw r� r r� r� r� r| rU r �InvalidatePoolError�DisconnectionError�invalidate_poolr r� r� r9 r� r r: r; �InvalidRequestError) r? r" � threadconnsrA �attempts�connection_is_fresh�resultr� r@ �be_outerrq s r2 r� �_ConnectionFairy._checkout� sv � � �%�.�.�t�4�E��&�&-�k�k�%�&8� �#�
� $� $� 0� :� 9� :� 0�
� "� "� .� >� =� >� .� ���!����
�
�&�&�t�~�~�
�^�^�q�
��L� ����l�"'�":�":�"@�"@� �-2�E� $� $� *�S
��>�>�.� �;�;� �K�K� -� -� @� %� 6� 6� � "&� � �!?�!?� !� 2� 2�"�� &� $�{�{� $� � � 1� 1�%;�$)�$:�$:�!"�468 #&�"9�"9�";� ;� &� ��� � � �)�)� G� !� 2� 2��469 �
�
�&�&��*�*�E�,D�,D�e�� � �r
� � ���F�G�
�����%�%�&A�B�B��u �)�)� '
��$�$��K�K�$�$�9� � � �,�,�7�7��:��$�$�U��$�>��K�K�$�$�M� �.�.�� � �,�,�7�7��:�� �0�0�?�?�A� �*�� %� � �*�*�,� �0�0�@�@� �/3� A� � "� -� � -�,� �� ��" �A�
��� �
��&�&�(� �2�2�C����+�+� $�/3� ,� � � )� � )�(� ��
��Q ��l�lsz �'D1I �O4�/BN� L+�*N�+470N�5N �471 M/�& N �/472M= �9N � N�N�
O4� O/�4!O � O/� 473O, �(O/�/O4c �> � [ R U R U S9$ )N)rA )r� r� rp rg s r2 �_checkout_existing�#_ConnectionFairy._checkout_existingn s � � �)�)�$�*�*�D�)�A�Ar1 c 474 �r � [ U R U R U R S U R UU S9 g )N)r$ rA )r6 rC r� rp r� )rB r$ s r2 r� �_ConnectionFairy._checkinq s3 � �� � !� !� � #� #� �J�J� � �J�J�"7�� 475r1 c �$ � U R 5 g r@ r� rg s r2 �_close�_ConnectionFairy._close| s � � �
�
�r1 c 476 �� � UR R ( a: UR R U R U R [ UUUS95 U( d g UR477 [ L a� U( a9 U R ( a' UR R SU R 5 g g U R ( a& UR R SU R 5 UR R U 5 g UR478 [ L aS U R ( a& UR R SU R 5 UR R U 5 g g )Nr# z.Connection %s reset, transaction already resetz Connection %s rollback-on-returnz Connection %s commit-on-return)rw �resetrC r� r! r� r7 r� r� r� r| rD r8 rG )rB r" r$ r% r& s r2 ro �_ConnectionFairy._reset s � � �=�=� � � �M�M� � ��%�%��'�'� �*?�#1�!-��
� � � � � �N� 2�$��:�:��K�K�%�%�H� �-�-�� � �:�:��K�K�%�%�:� �-�-�� �
�
�)�)�$�/�
�
"�
"�l�
2��z�z�� � �!�!�4��)�)��
�M�M� #� #�D� )�
3r1 c �. � U R R $ r@ )rp r� rg s r2 �_logger�_ConnectionFairy._logger� s � ��z�z� � � r1 c � � U R S L$ r@ r( rg s r2 r� �_ConnectionFairy.is_valid� s � ��$�$�D�0�0r1 c � � U R S L $ r@ )r� rg s r2 r� � _ConnectionFairy.is_detached� s � ��&�&�$�.�.r1 c �L � U R c 0 $ U R R $ r@ )r� r rg s r2 r �_ConnectionFairy.info� s% � � � "� "� *��I��*�*�/�/� /r1 c �J � U R c g U R R $ r@ r� rg s r2 r � _ConnectionFairy.record_info� s# � � � "� "� *���*�*�6�6� 6r1 c �� � U R c [ R " S5 g U R ( a U R R XS9 U( d S U l U R 5 g g )Nz.Can't invalidate an already-closed connection.)r� r479 )rC r rI r� r� r� r s r2 r� �_ConnectionFairy.invalidate� s] � � � � � (� �I�I�F� G� � � "� "� � #� #� .� .�� .� >�� %)�D� !�
�M�M�O�
r1 c �X � U R c eU R R " U0 UD6$ r@ r� r} s r2 r� �_ConnectionFairy.cursor� s0 � ��$�$�0�0�0��$�$�+�+�T�<�V�<�<r1 c �. � [ U R U5 $ r@ r� r� s r2 r� � _ConnectionFairy.__getattr__� r� r1 c � � U R b� U R nS Ul S Ul U R R U R 5 U R480 R
5 U l S U l U R R R ( a1 U R R R U R U5 g g g r@ ) r� r rC rp r� r �copyrw rq rp s r2 rq �_ConnectionFairy.detach� s� � � � "� "� .��)�)�C� �C�M�#'�C� � �J�J� &� &�t�'>�'>� ?� � � ���(�D�I�&*�D� #��z�z�"�"�)�)��481�482�#�#�*�*�4�+@�+@�#�F� *� /r1 c �p � U =R S- sl U R S:X a U R 5 g g )Nr6 r �r� r� rg s r2 rK �_ConnectionFairy.close� s* � � �
�
���
� �=�=�A� � �M�M�O� r1 c �n � U =R S- sl U R S:X a U R US9 g g )Nr6 r r5 r� )rB �transaction_resets r2 �_close_special� _ConnectionFairy._close_special� s0 � � �
�
���
� �=�=�A� � �M�M�0A�M� B� r1 )r� r� r� rp rC r )r" ru rC r r� r� ry rx rj rj )NN)r" ru r� zOptional[threading.local]rA �Optional[_ConnectionFairy]r\ r� )r\ r� )F)r$ r' r\ r] r� )483r" ru r$ r' r% r' r& r' r\ r] )r\ zlog._IdentifiedLoggerTyper� r r
r r r� r� )r� r' r\ r] )!r) r* r+ r, r- r. r/ r� r� r r rk rX rl r� r� r� r� ro r� r� r� r r r� r r� r� r� rq rK r� r0 r( r1 r2 r� r� � s� � ��0�I� �J�%�%� � � �� � *� � -� �484 � � 4�3�
�9� �9�485 � �_�_�
� )��486%� � � %� � 26�,0� {C��{C� /�{C� *� {C�487 488� {C� �{C�zB� 489��)*��)*� $�)*� � )*�490 � )*� 491�
)*�V �!� �!� �1� �1� �/� �/� 492� � �0� �0� 493�"�"�7� #�7� ?D� �(� �7;� �
� � =�3�G�" �494C� Cr1 r� )FN)rC r� r� r� r" ru r7 r ry zOptional[log._EchoFlagType]r$ r' rA r� r\ r] )@r- �495__future__r � collectionsr � dataclasses�enumr � threadingr� r� r r r r r496 r r r
r r r= rV r r r r � util.typingr r r �engine.interfacesr r r r r r � sql._typingr � dataclassr! r4 r� �listr7 r8 r9 r= ra rd rm �497Identified� EventTargetru r� rs r� r6 r> r/ r[ r� r� r( r1 r2 �<module>r s� �� ,� "� � � � � �
� � � � � � � � � � � � � � � � !� "� ��3�/�+�'�'�"�'�
���d�#�)� )� $�)�X�� � �� � 3�4�6�� � ,0�498�+;� (�� �j� � �F� � �/�X� /�I�� I�{$�3�>�>�5�,�,� {$�| y$� y$�x $�+� $�DZE�+� ZE�J #(�(,�A�/�A�2�A� �A�499� A� &�A� �A� &�A� 500�A�T � � !� �501K� -� K�\83� 3� 83�vIC�,� ICr1