403Webshell
Server IP : 192.158.238.246  /  Your IP : 3.144.16.26
Web Server : LiteSpeed
System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64
User : jenniferflocom ( 1321)
PHP Version : 8.1.32
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : ON  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/orm/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/orm/__pycache__/loading.cpython-37.pyc
B

��4]�}�@s4dZddlmZddlZddlmZddlmZddlmZddlm	Z	dd	l
mZdd
l
mZddl
mZddl
mZd
dlmZd
dlm
Z
d
dlm
Ze
��Zdd�Ze
�d�d-dd��Zdd�Zd.dd�Zd/dd�Zd0dd�Zd1dd�Zdd �Zd!d"�Zd#d$�Zd%d&�Z d'd(�Z!Gd)d*�d*e"�Z#d+d,�Z$dS)2z�private module containing functions used to convert database
rows into object instances and associated state.

the functions here are called primarily by Query, Mapper,
as well as some of the attribute loading strategies.

�)�absolute_importN�)�
attributes)�exc)�
path_registry)�strategy_options)�_DEFER_FOR_STATE)�_SET_DEFERRED_EXPIRED)�	_none_set)�	state_str�)�utilc

#szt��_i�_�j}�jo4t�j�dko4�jdj}|rP|rDt}n�fdd�}y�t	t
���fdd��jD���\�}|s�t�d|��x�i�_
�jr����j�}|s�Pn���}|rЈd��fdd�|D�}n��fd	d�|D�}x"�j��D]\}	}
|
��|	�q�W|�rt�||�}x|D]}|V�q W�js�Pq�WWn6tk
�rt}z���t�|�Wd
d
}~XYnXd
S)z$Return an ORM result as an iterator.rrcstdd�t�j|�D��S)Ncss$|]\}}|jrt|�n|VqdS)N)Zuse_id_for_hash�id)�.0�ent�item�r�I/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/orm/loading.py�	<genexpr>8sz/instances.<locals>.filter_fn.<locals>.<genexpr>)�tuple�zip�	_entities)�row)�queryrr�	filter_fn6szinstances.<locals>.filter_fncsg|]}|������qSr)Z
row_processor)r�query_entity)�context�cursorrrr�
<listcomp>@szinstances.<locals>.<listcomp>�resultcsg|]}�|��qSrr)rr)�procrrrUscs"g|]���fdd��D���qS)csg|]}|���qSrr)rr )rrrrXsz(instances.<locals>.<listcomp>.<listcomp>r)r)�keyed_tuple�process)rrrXsN)�
_new_runid�runid�post_load_pathsZ_has_mapper_entitiesZ_only_return_tuples�lenrZsupports_single_entityr�listrr
�lightweight_named_tuple�partialsZ
_yield_perZ	fetchmanyZfetchall�items�invokeZunique_list�	Exception�closeZraise_from_cause)
rrr�filtered�
single_entityr�labelsZfetchZrows�path�	post_loadr�errr)rrr!r r"rr�	instances#sP

r4zsqlalchemy.orm.queryTc
	s|j��r����j}z�d�_t|j�dk}|rdt|jd�j�rZ��fdd�|D�}nt|�}n��fdd�t|j�D�}g}dd�|jD�}t	�
d|�}	xh|D]`}
t|
�}xD|D]<}||d	k	r��jt�
||�t�||��iid
�||<q�W|�|	|��q�Wt|�S|�_Xd	S)z:Merge a result into this :class:`.Query` object's Session.Frrc	s,g|]$}�jt�|�t�|��iid��qS))�load�
_recursive�_resolve_conflict_map)�_merger�instance_state�
instance_dict)r�instance)r5�sessionrrr|sz merge_result.<locals>.<listcomp>cs g|]\}}t|�j�r|�qSr)�
isinstance�
_MapperEntity)r�i�e)�querylibrrr�scSsg|]
}|j�qSr)Z_label_name)rrrrrr�srN)r5r6r7)r<Z
_autoflush�	autoflushr&rr=r>r'�	enumerater
r(r8rr9r:�append�iter)
rAr�iteratorr5rBr/rZmapped_entities�keysr!rZnewrowr?r)r5rAr<r�merge_resultls<




rHcCs�|j�|�}|dk	rzt�|�}|jrv|tj@s4tjS|tj@sB|Sy|�||�Wn"t	j
k
rt|�|g�dSX|SdSdS)zqLook up the given key in the given session's identity map,
    check the object for expired state if found.

    N)�identity_map�getrr9ZexpiredZSQL_OKZPASSIVE_NO_RESULTZRELATED_OBJECT_OKZ
_load_expired�orm_exc�ObjectDeletedErrorZ_remove_newly_deleted)r<�keyZpassiver;�staterrr�get_from_identity�s


rOcCs6|dk	r|d}|d}nd}}t||||||d�S)z.Load the given identity key from the database.Nrr)�
refresh_state�with_for_update�only_load_props�identity_token)�load_on_pk_identity)rrMrPrQrR�identrSrrr�
load_on_ident�s
rVcs|dkr|��}|��n|��}|dk	r�|��}|j\}�d|krnt�fdd�t|j|�D��}	t�||	�}|�	|dd�}||_
t�fdd�t||j�D��}
|
|_|dk	r�d}||_
n|j
dk	r�d}|j
|_
nd}|jt|�||||d�d|_y|��Stjk
�rdSXdS)z6Load the given primary key identity from the database.Ncs"g|]\}}|dkr�|j�qS)N)rM)r�col�value)�_get_paramsrrr�sz'load_on_pk_identity.<locals>.<listcomp>TFcsg|]\}}�|j|f�qSr)rM)rZid_val�primary_key)rYrrr�s)�populate_existing�
version_checkrRrPrS)Z_cloneZ_get_conditionZ_mapper_zero�_get_clause�setrrZ�sql_utilZadapt_criterion_to_nullZ
_adapt_clauseZ
_criterion�dict�_paramsZ_for_update_argZ_get_options�boolZ	_order_by�onerKZ
NoResultFound)rZprimary_key_identityrPrQrRrS�q�mapperr]Znones�paramsr\r)rYrrT�sL





rTc	Ks�|r|�|�}
n|j}
i}|�|jd|�x<|
D]4}|rD|j|krDq0|j||||f|||d�|	��q0W|dk	r�||jk	r�|r�|j|}
n|}
|�|
�dS)N�memoized_setups)rR�column_collectionZmemoized_populators)	Z_iterate_polymorphic_propertiesZ_polymorphic_propertiesr^rrM�setup�polymorphic_on�columnsrD)rrerr1�adapterrhZwith_polymorphicrR�polymorphic_discriminator�kwZpoly_properties�quick_populatorsrX�pdrrr�_setup_entity_querys0


rqc	s$�
j�
�r�fdd��
D��
�
j�t�t���
j}	�dk	rR|	��
fdd��D��}	|��jdt	�}
x�|	D]�}||
k�r$|
|}|t
kr��d�|j|j
f�n�|tkr��d�|jd	f�nfd}
�r�j|}|dk	r�|�|d	�}
|
s�|�|d	�}
|
�r�d
�|j|
f�n|��|�
|���qh|��|�
|���qhW�j��jjj�rZ�jj|n|��jj��j�pr�
j�t�
jjj��t�
jjj��t�jjj����r��jjj�	tj �tj!��jj"��j#��j$��j%���sr|dk	�rrd|jf}|�jk�r&�j|j&dk�r&�
�'�j|j(d
|�}n�
�'d|�}|�rr||k	�rr�dk�sPt)�t*�||�}t+�,��|j-|||�t+�.�������r��j��dk�r��
�/���nd��
j0�r�t	j1�nt	j�����������	�
���
�����������fdd�}�
j2�r |�s ��s t3|��
|||��}|S)z`Produce a mapper level row processor callable
       which processes rows into mapped instances.csg|]}�j|�qSr)rk)r�c)rlrrrhsz'_instance_processor.<locals>.<listcomp>Nc3s|]}�j|VqdS)N)Z_props)r�k)rerrrpsz&_instance_processor.<locals>.<genexpr>rg�new�expireF�quick�loader))Zselectinload_polymorphicTZentitiesc

sJ�r,�}|��}�|�}|j�k}d}d}n��t�fdd��D���f}��|�}|dk	r��|�}�|�}|j�k}|}d}�r�|s�t�||���nT�|d�r�dSd}d}d}�j��}�|�}�|�}||_�|_�|_	��
||�|s���r�|�r��s��s�|_�	|_t
��|||�	|���	|�r�|�rf��rN|jj�|���
�r~�
�j|���n��r~|jj�|�����s�|j�r���r���r�|�|��n|�|����rF��|d�n�|j}|�jk}|�r�|�s�d�r,t��|||�	|��}	|�r,��r |jj�|�|	�|�||	���rF�j�rF��|d�|S)NTFcsg|]}�|�qSrr)r�column)rrrr�sz:_instance_processor.<locals>._instance.<locals>.<listcomp>r�eager)�objr$rrJ�_validate_version_id�
class_managerZnew_instancerMrS�
session_idZ_add_unpresentZload_options�	load_path�_populate_full�manager�dispatchr5r<�refresh�modifiedZ_commitZ_commit_all�	add_state�unloadedr)�_populate_partialZinvoke_all_eagers)
rrNr;�dict_�isnewZcurrentload�loaded_instanceZidentitykeyr��to_load)rlr�identity_classrSr:r9�is_not_primary_key�load_evtr~�loaded_as_persistentrerR�persistent_evt�pk_colsr[�
populatorsr2�propagate_options�refresh_evt�refresh_identity_keyrPr$r}�session_identity_mapr\)rr�	_instance�s�






z&_instance_processor.<locals>._instance)4rZZ_identity_class�collections�defaultdictr'Z	_prop_set�intersectionrJrr
rrDrMZ_deferred_column_loaderr	rkZ_getterZcreate_row_processorr�rZ
_current_pathr1r<rIr[Zalways_refreshrbr|r�r5r�r�r9r:Zhash_keyr\r$rSZstrategyZ_should_selectin_loadZ
local_opts�AssertionError�_load_subclass_via_in�PostLoad�callable_for_pathre�for_context�_identity_key_from_state�allow_partial_pks�
issuperset�polymorphic_map�_decorate_polymorphic_switch)rerrr1rlrRrPrm�_polymorphic_from�propsroZproprW�getterZadapted_colrMZselectin_load_viaZ	callable_r�r)rlrr�rSr:r9r�r�r~r�rerRr�r�r[r�r2r�r�r�rPr$r}r�r\r�_instance_processorQs�






<
r�csP|j}t|jj�dk�|jr.|�|�\���n|j\�������fdd�}|S)Nrcsb|j}�j�f|j�f|j|d�}|jr:|�dd��||j�j�fdd�|D�d���dS)N)�
cache_pathcSs|��S)N)r[)rdrrr�<lambda>��z8_load_subclass_via_in.<locals>.do_load.<locals>.<lambda>cs,g|]$\}}�r|jddn|jd�qS)rr)rM)rrNZ
load_attrs)�zero_idxrrr�sz:_load_subclass_via_in.<locals>.do_load.<locals>.<listcomp>)Zprimary_keys)	rZ_with_lazyload_optionsZ
_with_options�parentZ_populate_existingZadd_criteriar<rf�all)rr1�statesZ	load_onlyZeffective_entityZ
orig_queryZq2)�disable_opt�
enable_optrdr�rr�do_load�s

z&_load_subclass_via_in.<locals>.do_load)rer&Zbase_mapperrZZis_aliased_classZ_subclass_load_via_inZ_subclass_load_via_in_mapper)rr1�entityrer�r)r�r�rdr�rr��sr�c	
Cs\|r�|j|_x |dD]\}	}
|
|�||	<qW|rfxX|dD]$\}	}|�|	d�|r<|j�|	�q<Wn&x$|dD]\}	}|rp|j�|	�qpWx |dD]\}	}||||�q�Wx�|dD]\}	}||||�q�Wn�||jk�r4||_x(|dD]\}	}
|	|kr�|
|�||	<q�WxH|dD]\}	}||||��qWn$x"|dD]\}	}||||��q>WdS)Nrvrurt�delayed�existing)r$�pop�expired_attributes�addr~)
rrrNr�r�r~r�r[r�rMr��set_callable�	populatorrrrr�s2rc
Cs2|s:|j|}x�|dD]\}	}
|	|kr|
|||�qWn�|}||j|<x(|dD]\}	}|	|krR||�||	<qRWx8|dD],\}	}|	|kr||�|	d�|r||j�|	�q|Wx(|dD]\}	}
|	|kr�|
|||�q�Wx(|dD]\}	}
|	|kr�|
|||�q�Wx,|dD] \}	}
|	|k�r
|
|||��q
W|S)Nr�rvrurtr�ry)r)r�r�r�)
rrrNr�r�r~r�r�r�rMr�r�r�rrrr��s2


r�c	Csd|j}|dkrdS|r |j|}|�|||j�||kr`t�dt|�|�|||j�||f��dS)NzWInstance '%s' has version id '%s' which does not match database-loaded version id '%s'.)�version_id_colrkZ_get_state_attr_by_columnrKZStaleDataErrorr)rerNr�rrlr�rrrr{s


r{c	s`|dk	r|�n�j��dkr �S�r.�j�������fdd�}t�|�����fdd�}|S)NcsTy�j|}Wn tk
r.td|��Yn"X|�kr<dSt|�����d�SdS)Nz*No such polymorphic_identity %r is defined)r�)r��KeyErrorr�r�)�
discriminatorZ
sub_mapper)rlrrer1rrr�configure_subclass_mapper.sz?_decorate_polymorphic_switch.<locals>.configure_subclass_mappercs,|�}|dk	r$�|}|r$||�S�|�S)Nr)rr�r�)�instance_fn�polymorphic_instancesrjrr�polymorphic_instanceDsz:_decorate_polymorphic_switch.<locals>.polymorphic_instance)rjrkr
ZPopulateDict)	r�rrerr1rmrlr�r�r)rlrr�rer1r�rjrrr�s	

r�c@sPeZdZdZdZdd�Zdd�Zdd�Zed	d
��Z	edd��Z
ed
d��ZdS)r�z:Track loaders and states for "post load" operations.

    )�loadersr��	load_keyscCsi|_t��|_d|_dS)N)r�r
�OrderedDictr�r�)�selfrrr�__init__Vs
zPostLoad.__init__cCs||j|<dS)N)r�)r�rN�	overwriterrrr�[szPostLoad.add_statecsv|js
dStj�|�}xP|j��D]B\}�}}}�fdd�|j��D�}|r"|||||jf|�|�q"W|j��dS)Ncs&g|]\}}|jj���r||f�qSr)r�reZisa)rrNr�)�limit_to_mapperrrrhsz#PostLoad.invoke.<locals>.<listcomp>)	r�rZPathRegistryZcoercer��valuesr*r��clear)r�rr1�tokenrw�argrnr�r)r�rr+bs
zPostLoad.invokecCs$|j�|j�}|dk	r |r ||_|S)N)r%rJr1r�)�clsrr1rR�plrrrr�pszPostLoad.for_contextcCs|j|jko||j|jjkS)N)r1r%r�)r�rr1rMrrr�path_existswszPostLoad.path_existsc	OsD|j|jkr|j|j}nt�}|j|j<|||||f|j|<dS)N)r1r%r�r�)	r�rr1r�r�Zloader_callabler�rnr�rrrr�~szPostLoad.callable_for_pathN)�__name__�
__module__�__qualname__�__doc__�	__slots__r�r�r+�classmethodr�r�r�rrrrr�Osr�c	sB|j}|st�dt|���t|j�}d}|r>|��j���}�j	r��j
s���||�}|dk	r�t|�
���t����d���|�d||d�}|dk�r$|r�|j}n<�fdd��jD�}|j�|�r�t�dt|�����|�}t�|�r�jr�t�|��rt�d	t|��dSt|�
��|||d
�}|�r>|dk�r>t�|��dS)z4initiate a column-based attribute refresh operation.zQInstance %s is not bound to a Session; attribute refresh operation cannot proceedFN�*)rRrPcsg|]}�j|j�qSr)Z_columntopropertyrM)rrW)rerrr�sz*load_scalar_attributes.<locals>.<listcomp>z_Instance %s cannot be refreshed - it's not  persistent and does not contain a full primary key.zwInstance %s to be refreshed doesn't contain a full primary key - can't be refreshed (and shouldn't be expired, either).)rPrR)r<rKZDetachedInstanceErrorrrbrMr��attrsrGZinheritsZconcreteZ_optimized_get_statementrVr�optionsr�LoadZundeferZfrom_statementrZr��sa_excZInvalidRequestErrorr�r
�issubsetr�r�r
Zwarn_limitedrL)	rerNZattribute_namesr<Zhas_keyr�	statementZidentity_keyZpk_attrsr)rer�load_scalar_attributes�sR




r�)T)NNN)NNNN)NNN)NNNN)%r��
__future__rr��rrrKrr�baserr	r
r
rr�Zsqlr_�counterr#r4ZdependenciesrHrOrVrTrqr�r�rr�r{r��objectr�r�rrrr�<module>sNI5

L
/
- 9"4:

Youez - 2016 - github.com/yon3zu
LinuXploit