Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/ext/__pycache__/horizontal_shard.cpython-39.pyc
Ðазад
a _�h�# � @ sp d Z ddlmZ ddlmZ ddlmZ ddlmZ ddgZG dd� de�Z G d d � d e �Z G d d� de�Z d S ) a Horizontal sharding support. Defines a rudimental 'horizontal sharding' system which allows a Session to distribute queries and persistence operations across multiple databases. For a usage example, see the :ref:`examples_sharding` example included in the source distribution. � )�inspect)�util)�Query)�Session�ShardedSession� ShardedQueryc sP e Zd Z� fdd�Zdd� Zdd� Zdd� Zd� fd d � Zd� fd d � Z� Z S )r c s4 t t| �j|i |�� | jj| _| jj| _d | _d S �N)�superr �__init__�session� id_chooser� query_chooser� _shard_id)�self�args�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/ext/horizontal_shard.pyr s zShardedQuery.__init__c C s | � � }||_|S )z�Return a new query, limited to a single shard ID. All subsequent operations with the returned query will be against the single shard regardless of other state. )Z_cloner )r �shard_id�qr r r � set_shard! s zShardedQuery.set_shardc sd � �fdd�}� j d ur"|� j �S �jd ur6|�j�S g }����D ]}|�||�� qDt|�S d S )Nc s: | � j d< � _�j��� | d��� j�j�}��|� �S )Nr )�mapperr )� attributes�identity_token�_connection_from_sessionZ _bind_mapper�executeZ statement�_paramsZ instances)r �result��contextr r r �iter_for_shard. s ��z;ShardedQuery._execute_and_instances.<locals>.iter_for_shard)r r r �extend�iter)r r! r" �partialr r r r �_execute_and_instances- s z#ShardedQuery._execute_and_instancesc sf � ��fdd�}�j d ur$|�j �S d}g }����D ] }||�}||j7 }|�|� q6t||�S d S )Nc s$ �j � | �dd�}|���j�}|S )NT)r r �clauseZclose_with_result)r r r )r �connr �r r �stmtr r �exec_for_shardC s �z2ShardedQuery._execute_crud.<locals>.exec_for_shard� )r r �rowcount�append� ShardedResult)r r* r r+ r- �resultsr r r r) r � _execute_crudB s zShardedQuery._execute_crudNc s� |dur&t t| �j||fd|i|��S | j�|�}|r@|�|�}| �||�D ]2}t t| �j||fd|i|��}|durL| S qLdS dS )z�Override the default Query._identity_lookup method so that we search for a given non-token primary key identity across all possible identity tokens (e.g. shard ids). Nr )r r �_identity_lookupr �queryZ_set_lazyload_fromr ) r r �primary_key_identityr Zlazy_loaded_from�kwr r �objr r r r2 Y s. ��� ��� z ShardedQuery._identity_lookupc s< � �fdd�}|du r&�j dur&�j }tt��j|||d�S )z�Override the default Query._get_impl() method so that we emit a query to the DB for each possible identity token, if we don't have one already. c s\ �j d ur� �|�S t�|�}���|�D ](}��|�}� ||�}|d ur*| S q*d S d S r )r r Zto_listr r )r3 r4 �identr r �o�� db_load_fnr r r � _db_load_fn� s z+ShardedQuery._get_impl.<locals>._db_load_fnN)r )r r r � _get_impl)r r4 r: r r; r r9 r r< { s �zShardedQuery._get_impl)NN)N) �__name__� __module__� __qualname__r r r& r1 r2 r< � __classcell__r r r r r s �"c @ s( e Zd ZdZdZdd� Zedd� �ZdS )r/ a� A value object that represents multiple :class:`_engine.ResultProxy` objects. This is used by the :meth:`.ShardedQuery._execute_crud` hook to return an object that takes the place of the single :class:`_engine.ResultProxy`. Attribute include ``result_proxies``, which is a sequence of the actual :class:`_engine.ResultProxy` objects, as well as ``aggregate_rowcount`` or ``rowcount``, which is the sum of all the individual rowcount values. .. versionadded:: 1.3 ��result_proxies�aggregate_rowcountc C s || _ || _d S r rA )r rB rC r r r r � s zShardedResult.__init__c C s | j S r )rC )r r r r r- � s zShardedResult.rowcountN)r= r> r? �__doc__� __slots__r �propertyr- r r r r r/ � s r/ c sF e Zd Zdef� fdd� Zdd� Zd dd�Zd dd �Zd d � Z� Z S )r Nc s` t t| �jf d|i|�� || _|| _|| _i | _| j| _|dur\|D ]}| � ||| � qFdS )a Construct a ShardedSession. :param shard_chooser: A callable which, passed a Mapper, a mapped instance, and possibly a SQL clause, returns a shard ID. This id may be based off of the attributes present within the object, or on some round-robin scheme. If the scheme is based on a selection, it should set whatever state on the instance to mark it in the future as participating in that shard. :param id_chooser: A callable, passed a query and a tuple of identity values, which should return a list of shard ids where the ID might reside. The databases will be queried in the order of this listing. :param query_chooser: For a given Query, returns the list of shard_ids where the query should be issued. Results from all shards returned will be combined together into a single listing. :param shards: A dictionary of string shard names to :class:`~sqlalchemy.engine.Engine` objects. � query_clsN) r r r � shard_chooserr r �_ShardedSession__binds� connectionZconnection_callable� bind_shard)r rH r r ZshardsrG r �kr r r r � s zShardedSession.__init__c K sb |d ur<t |�}|jr0|jd }|d us,J �|S |jr<|jS | j||fi |��}|d ur^||_|S )Nr )r �keyr rH )r r �instancer5 �state�tokenr r r r �_choose_shard_and_assign� s z'ShardedSession._choose_shard_and_assignc K sN |d u r| � ||�}| jd ur.| jj||d�S | j|||d�jf i |��S d S )N)r )r rN )rQ Z transactionrJ �get_bindZ_contextual_connect)r r rN r r r r r rJ � s � �zShardedSession.connectionc K s" |d u r| j |||d�}| j| S )N)r' )rQ rI )r r r rN r' r5 r r r rR � s �zShardedSession.get_bindc C s || j |< d S r )rI )r r �bindr r r rK s zShardedSession.bind_shard)NNN)NNN) r= r> r? r r rQ rJ rR rK r@ r r r r r � s �( � N) rD � r r Z orm.queryr Z orm.sessionr �__all__r �objectr/ r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка