Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/orm/__pycache__/persistence.cpython-39.pyc
Ðазад
a _�h� � @ s d Z ddlmZ ddlmZ ddlZddlmZ ddlmZ ddlmZ dd lm Z dd lm Z dd l m Z dd l mZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ dd� Zdd� ZdTdd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Z dUd#d$�Z dVd%d&�Z d'd(� Z d)d*� Z dWd,d-�Z!dXd.d/�Z"d0d1� Z#d2d3� Z$d4d5� Z%d6d7� Z&d8d9� Z'd:d;� Z(d<d=� Z)d>d?� Z*d@dA� Z+G dBdC� dCe,�Z-G dDdE� dEe-�Z.G dFdG� dGe-�Z/G dHdI� dIe-�Z0G dJdK� dKe-�Z1G dLdM� dMe.e0�Z2G dNdO� dOe.e1�Z3G dPdQ� dQe/e0�Z4G dRdS� dSe/e1�Z5dS )Yz�private module containing functions used to emit INSERT, UPDATE and DELETE statements on behalf of a :class:`_orm.Mapper` and its descending mappers. The functions here are called only by the unit of work functions in unitofwork.py. � )�chain)�groupbyN� )� attributes)� evaluator)�exc)�loading)�sync)�_entity_descriptor)� state_str� )�sql)�util)� expression)� _from_objectsc s �j }t|�}|jjr td��|rT|rDdd� |D �}dd� |D �}q\dd� |D �}nt|�}|�|�� |j�� D ]\\} } �� | �s�qp� �fdd�t | � �fdd�|D �d ||d �D �} t |d || | | |d � qp|�r|�r�j } d d� �j D �} |D ]$\}�| t�fd d�| D ��f|_q�d S )NzJconnection_callable / per-instance sharding not supported in bulk_insert()c S s g | ]}||j f�qS � ��dict��.0�stater r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/orm/persistence.py� <listcomp>7 � z _bulk_insert.<locals>.<listcomp>c S s g | ] \}}|�qS r r )r r �dict_r r r r 8 r c S s g | ] }|j �qS r r r r r r r : r c 3 s2 | ]*\}}}}}}}}d ||�� |||fV qd S �Nr ) r r � state_dict�params�mp�conn� value_params� has_all_pks�has_all_defaults�� connection�mapperr r � <genexpr>C s$ ��z _bulk_insert.<locals>.<genexpr>c 3 s | ]}d |�� fV qd S r r �r �mappingr# r r r& Y r T)�bulk�return_defaults� render_nulls�� bookkeepingc S s g | ] }|j �qS r ��key�r �pr r r r k r c s g | ] }� | �qS r r )r r/ )r r r r o r )� base_mapper�_cached_connection_dict�session�connection_callable�NotImplementedError�listr$ �_sorted_tables�items�isa�_collect_insert_commands�_emit_insert_statementsZ_identity_classZ_identity_key_props�tupler/ )r% �mappings�session_transaction�isstatesr* r+ r2 �cached_connections�states�table� super_mapper�recordsZ identity_clsZidentity_propsr r )r$ r r% r � _bulk_insert# sR � �� � �rF c s� �j }t|�}�j��jr*�jjh�����fdd�� |rd|rT� �fdd�|D �}qldd� |D �}nt|�}|jjr|t d��|� |��|j � � D ]J\}}�� |�s�q�td |��fdd�|D �d d �} t|d |||| d d � q�d S ) Nc s t �� fdd�� j �� D ��S )Nc 3 s, | ]$\}}|�j v s |� v r||fV qd S r )�committed_state�r �k�v)� search_keysr r r r& s �z6_bulk_update.<locals>._changed_dict.<locals>.<genexpr>)r r9 )r% r )rK �r r � _changed_dict~ s �z#_bulk_update.<locals>._changed_dictc s g | ]}� �|��qS r r r )rM r% r r r � r z _bulk_update.<locals>.<listcomp>c S s g | ] }|j �qS r r r r r r r � r zJconnection_callable / per-instance sharding not supported in bulk_update()c 3 s. | ]&}d |�� �j r |�j j nd fV qd S r )�_version_id_propr/ r' r# r r r& � s ���z _bulk_update.<locals>.<genexpr>T)r) Fr, )r2 r3 Z_primary_key_propkeysrN r/ �unionr7 r4 r5 r6 r$ r8 r9 r: �_collect_update_commands�_emit_update_statements) r% r> r? r@ Zupdate_changed_onlyr2 rA rC rD rE r )rM r$ r% rK r � _bulk_updates sH � ���rR Fc C s |s0| j s0t| |�D ]}t| |g|dd� qdS g }g }t| �}t| ||�D ]B\}}} } } } } | sf| r||�||| | | f� qL|�||| | f� qL| j�� D ]N\}} || jvr�q�t ||�}t |||�}t | ||| ||� t | ||| ||� q�t | |tdd� |D �dd� |D ��� dS )a; Issue ``INSERT`` and/or ``UPDATE`` statements for a list of objects. This is called within the context of a UOWTransaction during a flush operation, given a list of states to be flushed. The base mapper in an inheritance hierarchy handles the inserts/ updates for all descendant mappers. T)�singleNc s s$ | ] \}}}}||||d fV qdS )FNr )r r r r% r$ r r r r& � s �zsave_obj.<locals>.<genexpr>c s s& | ] \}}}}}||||d fV qdS )TNr )r r r r% r$ �update_version_idr r r r& s �)�batch� _sort_states�save_objr3 �_organize_states_for_save�appendr8 r9 � _pks_by_tabler; rP rQ r< � _finalize_insert_update_commandsr )r2 rB �uowtransactionrS r �states_to_update�states_to_insertrA r r% r$ � has_identity� row_switchrT rC �insert�updater r r rW � sp � � �� � ����rW c sr t | �}tt| ||��}| j�� D ]J\�� �� jvr6q"� �fdd�|D �}t| |�||�}t| ||� �|� q"dS )z\Issue UPDATE statements on behalf of a relationship() which specifies post_update. c 3 sH | ]@\}}}}�|j v r||||� jd ur:� �||� j�nd fV qd S r )rZ �version_id_col�#_get_committed_state_attr_by_column)r r r Z sub_mapperr$ �r% rC r r r& s ����z post_update.<locals>.<genexpr>N)r3 r7 � _organize_states_for_post_updater8 r9 rZ � _collect_post_update_commands� _emit_post_update_statements)r2 rB r\ �post_update_colsrA r] rb r re r � post_update s* � � ��rj c C s� t | �}tt| ||��}| j}tt|�� ��D ]H}|| }||jvrHq.n|jrV|jrVq.t | |||�}t | |||||� q.|D ] \} } }} } |j � || | � q|dS )z�Issue ``DELETE`` statements for a list of objects. This is called within the context of a UOWTransaction during a flush operation. N) r3 r7 �_organize_states_for_deleter8 �reversed�keysrZ ZinheritsZpassive_deletes�_collect_delete_commands�_emit_delete_statements�dispatchZ after_delete) r2 rB r\ rA �states_to_deleteZtable_to_mapperrC r% �deleter r r$ rT r r r � delete_obj; s< � ���rs c c sH t | ||�D �]4\}}}}t|j�}|jp2|�|�}d } } |sR|j�|||� n|j�|||� |jrv|�|||� |s�||jj v r�|jj | } t � | �} |� | �s�|� | �s�t�dt|�|t| �f ��| �d|t|�t| �� |�| � | } |s�| �r.|jdu�r.|�| �r| n|| �r$| jn||j�} |||||| | fV q dS )aT Make an initial pass across a set of states for INSERT or UPDATE. This includes splitting out into distinct lists for each, calling before_insert/before_update, obtaining key information for each state including its dictionary, mapper, the connection to use for the execution per state, and the identity flag. NzJNew instance %s with identity key %s conflicts with persistent instance %szPdetected row switch for identity %s. will update %s, remove %s from transaction)�_connections_for_states�boolr/ �_identity_key_from_staterp Z before_insertZ before_updateZ _validate_polymorphic_identityr4 � identity_mapr �instance_stateZwas_already_deleted� is_deleted�orm_exc� FlushErrorr Z _log_debugZremove_state_actionsrc rd r ) r2 rB r\ r r r% r$ r_ Z instance_keyr` rT �instance�existingr r r rX i s\ � � � ��� ��rX c C s t | ||�S )z�Make an initial pass across a set of states for UPDATE corresponding to post_update. This includes obtaining key information for each state including its dictionary, mapper, the connection to use for the execution per state. )rt )r2 rB r\ r r r rf � s rf c c s^ t | ||�D ]L\}}}}|j�|||� |jdurD|�|||j�}nd}|||||fV q dS )z�Make an initial pass across a set of states for DELETE. This includes calling out before_delete and obtaining key information for each state including its dictionary, mapper, the connection to use for the execution per state. N)rt rp Z before_deleterc rd )r2 rB r\ r r r% r$ rT r r r rk � s � �rk c c s� |D �]x\}}}}| |j vr qi } i } |j| } |j| } t| ��|�D ]l} || }| | }|du rt|| vrt|stqHqH|s�t|d�s�t|tj�r�t|d�r�|� � n|| |< qH|| |j < qH|s�|j | � | �� dd� | D ��D ] }d| |< q�|r�|�r$|j | �| �}|jj�r |j| �| �}nd}nd }}|jdu�rh|jdu�rh|j|j| v �rh|�d�| |jj < ||| ||| ||fV qdS )zSIdentify sets of values to use in INSERT statements for a list of states. N�__clause_element__c S s g | ] }|j �qS r r. �r �cr r r r r z,_collect_insert_commands.<locals>.<listcomp>TF)rZ �_propkey_to_colZ _insert_cols_evaluating_none�set� intersection�hasattr� isinstancer � ClauseElementr~ r/ Z_insert_cols_as_none� differenceZ_pk_keys_by_table�issubsetr2 �eager_defaultsZ_server_default_cols�version_id_generatorrc �_cols_by_table)rC r^ r) r* r+ r r r% r$ r r �propkey_to_colZ eval_none�propkey�value�colZcolkeyr! r" r r r r; � sp � �� � � �� ����� �r; c # sf |D �]Z\}�}}}||j vr q|j | }i } |j| � |rpt� �fdd�t� �����|j| �D ��} d} n�i } t� ��|j�D ]n} �| } � | }t| d�s�t | t j �r�t| d�r�| � � n| | |< q�|j | j�| |j| �dur�| | |j< q�|jj�r|j| �| �} nd} |du�r�|j|j| v �r�|�s~| �s~| �s~|j�� D ].}|j |j j�|�tj�}|j �rL �q~�qLq|j}| �o�| }|| |j < |�s�|j| v�r�|j du�r�|� |�}|| |j< n |j du �r�|�r�|| |j< n| �s�| �s�qd}d}|�r4t� �fdd�t� ��|j| �D ��}n�i }|D ]�}|j| j} |j | j�|�tj �}|j �r�|j �r�d||f| jv �r�d}|j d ||j < | �!|jd� n |j d ||j < || v �r�d}n|j"d ||j < ||j du �r<t#�$d ||f ���q<| �s | �r.| �%|� |�| ||| | |fV q|r|j&| D ]"\}}t'�(|||||| |j)� �q<qdS ) at Identify sets of values to use in UPDATE statements for a list of states. This function works intricately with the history system to determine exactly what values should be updated as well as how the row should be matched within an UPDATE statement. Includes some tricky scenarios where the primary key of an object might have been changed. c 3 s | ]}� | j �| fV qd S r r. �r r� �r� r r r r& X s �z+_collect_update_commands.<locals>.<genexpr>Tr~ NFc 3 s" | ]}� | j ��|�fV qd S r )�_label�getr� r� r r r& � s �Z pk_cascadedr zCCan't update table %s using NULL for primary key value on column %s)*rZ r� r r� r� r� Z_pk_attr_keys_by_tablerG r� r� r r� r~ �manager�implZis_equalr/ r2 r� Z _server_onupdate_default_colsr� rc r� �_columntoproperty�values� get_historyr �PASSIVE_NO_INITIALIZE�addedr� r� � PASSIVE_OFFZdeleted�popZ unchangedrz r{ rb �_table_to_equatedr �populate�passive_updates)r\ rC r] r) r r% r$ rT �pksr r r" r� r� r� �prop�historyZ no_params�valr! Zexpect_pk_cascadedZ pk_params�m� equated_pairsr r� r rP 6 s � ���� �� � ��� ����� ��� �� ���� �� � �rP c c s, |D �] \}}}}} |j | } i } d} |j| D ]|} | | v rX|j||| tjd�| | j< q0| |v sj| jdur0|j| }|j|j j � ||tj �}|j r0|j d }|| | j < d} q0| r| du�r|j|j| v �r|j} | | | j< t|j ��r| j | v�r|jdu�r|�| �}|| | j < ||||| fV qdS )zrIdentify sets of values to use in UPDATE statements for a list of states within a post_update operation. F)ZpassiveNr T)rZ r� Z_get_state_attr_by_columnr r� r� Zonupdater� r� r/ r� r� r� r� rc ru r� )r2 r\ rC r] ri r r r% r$ rT r� r Zhasdatar� r� r� r� r� r r r rg � sP � � � �� ��� rg c c s� |D ]�\}}}}}||j vr qi } |j | D ]6} |�||| � | | j< } | du r,t�d|| f ��q,|dur�|j|j| v r�|| |jj< | |fV qdS )zSIdentify values to use in DELETE statements for a list of states to be deleted.NzHCan't delete from table %s using NULL for primary key value on column %s)rZ rd r/ rz r{ rc r� ) r2 r\ rC rq r r r% r$ rT r r� r� r r r rn ' s< � ������� rn Tc s� � j duo� j � j� v �� ��fdd�}| �d�f|�}t|dd� �D �]2\\} } } } } }d}t|�}|}d}| s�|�� }d }n8|r�| s�� jjr�|�� }d }n� j dur�|�� j �}d }|s�| jj n| jj }|o�| jj }| o� }| �rL|D ]Z\}}}� } }} } | � |� |�|�}|�r:t� |�||||jjd |d � ||j7 }|}q�n�|�s�|}|D ]V\}}}� } }} } || � ||�}|�r�t� |�||||jjd |d � ||j7 }�qZn�d d � |D �}|�p�|�o�t|�d k}|| � ||�}||j7 }|D ]<\}}}� } }} } |�r�t� |�||||jjd |d � �q�|�rf|t|�k�r|t�d �jt|�|f ��qH�rHt�d|jj � qHdS )z`Emit UPDATE statements corresponding to value lists collected by _collect_update_commands().Nc sl t �� } � j� D ]"}| j�|t j|j|jd�k� q�r^| j�� jt j� jj� jjd�k� �� | �}|S �N)�type_) r �and_rZ �clausesrY � bindparamr� �typerc rb ��clauser� �stmt�r% Zneeds_version_idrC r r � update_stmt_ s ���� z,_emit_update_statements.<locals>.update_stmtrb c S s* | d t | d �t| d �| d | d fS �N� r � � � �r� ru ��recr r r �<lambda>z s �z)_emit_update_statements.<locals>.<lambda>r FTc S s g | ] }|d �qS �r r �r r� r r r r � r z+_emit_update_statements.<locals>.<listcomp>r �MUPDATE statement on table '%s' expected to update %d row(s); %d were matched.�MDialect %s does not support updated rowcount - versioning cannot be verified.)rc r� �_memor r7 r* r2 r� �dialect�supports_sane_rowcount� supports_sane_rowcount_returning� supports_sane_multi_rowcount�executer� � _postfetch�context�compiled_parameters�rowcount�lenrz �StaleDataError� descriptionr �warn�dialect_description) r2 r\ rA r% rC rb r- r� � cached_stmtr$ Z paramkeys�hasvaluer" r! rE �rows� statementr* �assert_singlerow�assert_multirow�allow_multirowr r r r r� �check_rowcount� multiparamsr r� r rQ N s ��� ��� � �� � � �� � �� � � ����rQ c C s� | � d|f|j�}t|dd� �D �]�\\}} } } } } |}|rV| sN| jrN|jjs�| r�| s�t| �} dd� | D �}|| �||�}|r�t| |j j �D ]B\\}}}}}}} } }|r�t ||||||||d� q�t |||� q�q | s�| jr�|� � }n|jdu�r |� |j�}| D ]�\}}}}}}} } |�r2|�|�|�|�}n|| �||�}|j j}|du�r�t||j| �D ]D\}}|j| } |du�rd||v �s�|�| j�du �rd||| j< �qd|�r|�r�t |||||||j j d |d� n t |||� �qq dS ) z`Emit INSERT statements corresponding to value lists collected by _collect_insert_commands().ra c S s* | d t | d �t| d �| d | d fS r� r� r� r r r r� " s �z)_emit_insert_statements.<locals>.<lambda>c S s g | ] }|d �qS r� r r� r r r r 9 r z+_emit_insert_statements.<locals>.<listcomp>FNr )r� ra r r� r� Zimplicit_returningr7 r� �zipr� r� r� �_postfetch_bulk_saver* rc r� Zinserted_primary_keyrZ r� r� r/ ) r2 r\ rA r% rC ra r- r� r$ Zpkeysr� r! r" rE r� r� r� r r r � mapper_recr r Zlast_inserted_params�result� primary_key�pkr� r� r r r r< s� �� ������ �� � �� � �� � r< c s� � j duo� j � j� v �� ��fdd�}| �d�f|�}t|dd� �D �]X\}} d} t| �} |d } � j du rx| jjn| jj} | o�| jj} � p�| }|s�| }| D ]D\}}}} }|| � ||�}t ||�||||j j d � | |j 7 } q�nrdd � | D �}| �p| �ot|�d k}|| � ||�}| |j 7 } | D ],\}}}} }t ||�||||j j d � �q.|�r�| t| �k�r�t�d �jt| �| f ��qH�rHt�d |jj � qHdS ) zeEmit UPDATE statements corresponding to value lists collected by _collect_post_update_commands().Nc s� t �� } � j� D ]"}| j�|t j|j|jd�k� q�r^| j�� jt j� jj� jjd�k� �� | �}� jd ur~|� � j�}|S r� ) r r� rZ r� rY r� r� r� rc rb r* r� r� r r r� � s$ ���� z1_emit_post_update_statements.<locals>.update_stmtrj c S s | d t | d �fS )N� r� )r� r� r r r r� � r z._emit_post_update_statements.<locals>.<lambda>r c S s g | ]\}}}}}|�qS r r )r r r r� r r r r r r � s �z0_emit_post_update_statements.<locals>.<listcomp>r r� r� )rc r� r� r r7 r� r� r� r� r� �_postfetch_post_updater� r� r� r� rz r� r� r r� r� )r2 r\ rA r% rC rb r� r� r/ rE r� r$ r� r� r� r� r r r� r r� r� r r� r rh � s� ��� �� � �� � ����rh c sR � j duo� j � j� v �� ��fdd�}| �d�f|�}t|dd� �D �]\}} dd� | D �} || }t| �} d } d } �r�|jjs�|jjr�d } | D ]}|�||�}| |j 7 } q�q�t � d |jj � |�|| � n|�|| �}�s�d } |j } | j rH| d krH| | krH|jj�st| �dkrH| �r6t � d�j| | f � qHt�d�j| | f ��qHdS )z`Emit DELETE statements corresponding to value lists collected by _collect_delete_commands().Nc sh t �� } � j� D ]"}| j�|t j|j|jd�k� q�r^| j�� jt j� jj� jjd�k� �� | �S r� ) r r� rZ r� rY r� r/ r� rc rr )r� r� �r% Zneed_version_idrC r r � delete_stmt s � ���z,_emit_delete_statements.<locals>.delete_stmtrr c S s | d S )Nr r r� r r r r� r z)_emit_delete_statements.<locals>.<lambda>c S s g | ] \}}|�qS r r )r r r$ r r r r ! r z+_emit_delete_statements.<locals>.<listcomp>���Fr zMDialect %s does not support deleted rowcount - versioning cannot be verified.Tr z�DELETE statement on table '%s' expected to delete %d row(s); %d were matched. Please set confirm_deleted_rows=False within the mapper configuration to prevent this warning.)rc r� r� r r� r� r� r� r� r� r r� r� Zconfirm_deleted_rowsr� rz r� )r2 r\ rA r% rC rr r� r� r$ ZrecsZ del_objects�expectedZ rows_matchedZ only_warnr r� r r� r ro sf ��� �� ���� � �� ��ro c s |D �]\� }}}}|j rF� �� fdd�|j D ��}|rF� �� j|� g }| jrd|�� j�|j�� |j dur�|j du r�|j j � j v r�|�|j j g� |r�| �� �� _ tj|j�|�� j � |d� |s�|j�||� � n|j�||� � |j du r|j dur||j j du rt�d��qdS )zzfinalize state on states that have been inserted or updated, including calling after_insert/after_update events. c sB g | ]:}|j r |jr8|j� jv s8|j s|js|j� jvr|j�qS r )Zexpire_on_flush�deferredr/ r r0 rL r r r i s �z4_finalize_insert_update_commands.<locals>.<listcomp>NF)Z refresh_stateZonly_load_propsz2Instance does not contain a non-NULL version value)Z_readonly_propsZunmodified_intersection�_expire_attributesr r� �extendZ_unloaded_non_objectr� Z&_server_default_plus_onupdate_propkeysrc r� rN r/ Zunloadedrv r Z load_on_identr4 �queryrp Z after_insertZ after_updaterz r{ ) r2 r\ rB r r% r$ r_ �readonlyZ toload_nowr rL r r[ ` sR ������ ����r[ c s� |� |�rd S |jjj}|jjj}� jd urL� j� j| v rLt|�� jg }t� j j j �} | rbg } |D ]D} | j |v rf| � j v rf|| j |� j | j < | rf| �� j | j � qf| r�| rƈ j j � ||| � |r�|�|j� fdd�|D �� d S )Nc s" g | ]}|� j v r� j | j�qS r �r� r/ r �r% r r r � s �z*_postfetch_post_update.<locals>.<listcomp>)ry r� �compiled�prefetch� postfetchrc r� r7 ru � class_managerrp � refresh_flushr/ r� rY r� r ) r% r\ rC r r r� r � prefetch_cols�postfetch_colsr� �load_evt_attrsr� r r� r r� � s8 ��� ��r� c s� |j jj} |j jj} |j jj�� jdurH� j� j| v rHt| �� jg } t� j j j �} | r^g } �r�|j j } | dur��D ]B}|j r�|j jr�qv� j�|�}|rv| | ||j< | rv| �|j� qv| D ]D}|j|v r�|� jv r�||j |� j| j< | r�| �� j| j� q�| �r"| �r"� j j � ||| � |�rF|�rF| ��fdd�|D �� | �rh|�|j� fdd�| D �� � j| D ]"\}}t�||||||� j� �qrdS )z�Expire attributes in need of newly persisted database state, after an INSERT or UPDATE statement has proceeded for that state.Nc s g | ]}|j r|� vr|�qS r )r� )r r� )�returning_colsr r r s �z _postfetch.<locals>.<listcomp>c s" g | ]}|� j v r� j | j�qS r r� r r� r r r s �)r� r� r� r� Z returningrc r� r7 ru r� rp r� Zreturned_defaultsr� Zisinsertr� r� r/ rY r� r� r r� r r� r� )r% r\ rC r r r� r r Zisupdater� r� r� r� �rowr� r� r� r� r� r )r% r� r r� � sl �� � �� �� �r� c C s& | j | D ]\}}t�|||� q d S r )r� r Zbulk_populate_inherit_keys)r% r rC r� r� r r r r� / s r� c c s` |j jr|j j}n|j�| �}d}t| |�D ].}|rB|| |�� �}|jj}||j||fV q,dS )z�Return an iterator of (state, state.dict, mapper, connection). The states are sorted according to _sort_states, then paired with the connection they should be using for the given unit of work transaction. N) r4 r5 Z transactionr$ rV �objr� r% r )r2 r\ rB r5 r$ r r% r r r rt 4 s rt c s t �� fdd��S )Nc s | j � jd�S )N)Zcompiled_cache)Zexecution_optionsZ_compiled_cache)r �r2 r r r� Q s �z)_cached_connection_dict.<locals>.<lambda>)r Z PopulateDictr� r r� r r3 N s �r3 c C s� t |�}t dd� |D ��}|�|� zt|| jd�}W n< tyr } z$tjt�d| �|d� W Y d }~n d }~0 0 t|t � d�d�| S )Nc s s | ]}|j d ur|V qd S r r. )r �sr r r r& Y r z _sort_states.<locals>.<genexpr>r. z^Could not sort objects by primary key; primary key values must be sortable in Python (was: %s)�Zreplace_contextZ insert_order) r� �difference_update�sortedZ_persistent_sortkey_fn� TypeErrorr �raise_�sa_exc�InvalidRequestError�operator� attrgetter)r% rB �pending� persistentZpersistent_sorted�errr r r rV W s( � ��� ��rV c @ sr e Zd ZdZdd� Zdd� Zedd� �Zedd � �Z d d � Z d d � Z dd� Z e �d�dd� �Zdd� Zdd� ZdS )�BulkUDz;Handle bulk update and deletes via a :class:`_query.Query`.c C s$ |� d�| _| j�� | _| �� d S )NF)Zenable_eagerloadsr� Z _bind_mapperr% �_validate_query_state��selfr� r r r �__init__q s zBulkUD.__init__c C s� ddd t jfddd t jfdddt jfdd dt jfd d dt jfd d dt jffD ].\}}}}|t| j|�|�sLt�d|f ��qLd S )NZ_limitzlimit()�_offsetzoffset()Z _order_byz order_by()FZ _group_byz group_by()Z _distinctz distinct()Z _from_objz2join(), outerjoin(), select_from(), or from_self()r zCCan't call Query.update() or Query.delete() when %s has been called)r� �is_�eq�getattrr� r� r� )r �attrZmethnameZnotset�opr r r r v s" �� ��z BulkUD._validate_query_statec C s | j jS r )r� r4 �r r r r r4 � s zBulkUD.sessionc G sj z || }W nP t y\ } z8tjt�dd�tdd� |D ��� �|d� W Y d }~nd }~0 0 ||� S d S )Nz3Valid strategies for session synchronization are %sz, c s s | ]}t |�V qd S r )�repr)r �xr r r r& � r z"BulkUD._factory.<locals>.<genexpr>r� )�KeyErrorr r� r� � ArgumentError�joinr� )�cls�lookup�synchronize_session�arg�klassr r r r �_factory� s ��� zBulkUD._factoryc C s4 | � � | �� | �� | �� | �� | �� d S r )�_do_before_compile�_do_pre�_do_pre_synchronize�_do_exec�_do_post_synchronize�_do_postr r r r �exec_� s z BulkUD.exec_c C s | j �|| j�| _| jj| _d S r )r� Z _execute_crudr% r� r� )r r� r r r � _execute_stmt� s zBulkUD._execute_stmtc C s t � �d S r )r6 r r r r r � s zBulkUD._do_before_compilezsqlalchemy.orm.queryc C s� | j }|�|�| _t|jd |j�r�t� }|jD ].}t||j�sN|�� q`q0|�t |j �� q0t |�dkrxt � d��q�|�� | _n|�d�jj| _|j}|jr�|�� d S )Nr r zLThis operation requires only one Table or entity be specified as the target.)r� Z QueryContextr� r� Z _entitiesZ _ColumnEntityr� �clearrb r �columnr� r� r� r� � primary_tableZ_only_entity_zeror% Z local_tabler4 Z _autoflush)r Zquerylibr� ZtablesZentr4 r r r r � s( � � zBulkUD._do_prec C s d S r r r r r r r � s zBulkUD._do_pre_synchronizec C s d S r r r r r r r � s zBulkUD._do_post_synchronizeN)�__name__� __module__� __qualname__�__doc__r r �propertyr4 � classmethodr r r r r � dependenciesr r r r r r r r n s "r c @ s e Zd ZdZdd� Zdd� ZdS )� BulkEvaluatezDBulkUD which does the 'evaluate' method of session state resolution.c C s d S r r )r �evaluator_compilerr r r �_additional_evaluators� s z#BulkEvaluate._additional_evaluatorsc s� | j }|�� j�z8t���}|jd ur4|�|j�� ndd� � | �|� W n> tjy� } z$t j t � d| �|d� W Y d }~n d }~0 0 � �fdd�|j j�� D �| _d S )Nc S s dS )NTr )r� r r r �eval_condition� s z8BulkEvaluate._do_pre_synchronize.<locals>.eval_conditionztCould not evaluate current criteria in Python: "%s". Specify 'fetch' or False for the synchronize_session parameter.)Zfrom_c s8 g | ]0\\}}}}t |��rt�|�js� |�r|�qS r )� issubclassr rx Zexpired)r r r� Zidentity_tokenr� �r. Z target_clsr r r � s �z4BulkEvaluate._do_pre_synchronize.<locals>.<listcomp>)r� � _mapper_zero�class_r ZEvaluatorCompiler� whereclause�processr- ZUnevaluatableErrorr r� r� r� r4 rw r9 �matched_objects)r r� r, r r r0 r r � s( ��� �z BulkEvaluate._do_pre_synchronizeN)r$ r% r& r' r- r r r r r r+ � s r+ c @ s e Zd ZdZdd� ZdS )� BulkFetchzABulkUD which does the 'fetch' method of session state resolution.c C sB | j }|j}|�� }|j�| jj�}|j|| j|j d�� � | _ d S )N)r% r ) r� r4 Z_compile_contextr� Zwith_only_columnsr# r� r� r% �_paramsZfetchall� matched_rows)r r� r4 r� Z select_stmtr r r r s � �z BulkFetch._do_pre_synchronizeN)r$ r% r& r' r r r r r r6 s r6 c s\ e Zd ZdZ� fdd�Zedd� �Zdd� Zedd � �Z ed d � �Z d d � Z dd� Z � Z S )� BulkUpdatez BulkUD which handles UPDATEs.c s t t| ��|� || _|| _d S r )�superr9 r r� � update_kwargs)r r� r� r; �� __class__r r r s zBulkUpdate.__init__c C s t �tttd�||||�S �N)�evaluate�fetchF)r r �BulkUpdateEvaluate�BulkUpdateFetchr9 )r r� r r� r; r r r �factory s ��zBulkUpdate.factoryc C s8 | j jjr4| j jjD ] }|| j | �}|d ur|| _ qd S r )r� rp Zbefore_compile_update�r �fnZ new_queryr r r r ( s z BulkUpdate._do_before_compilec C s� g }t | jd�r| j�� n| jD ]t\}}| jr�t|tj�rXt| j|�}|�|� |�� q�t|t j �rv|�|� |�� q�|� ||f� q |� ||f� q |S )Nr9 ) r� r� r9 r% r� r � string_typesr r� Z_bulk_update_tuplesr �QueryableAttributerY )r r� rI rJ �descr r r �_resolved_values/ s � � zBulkUpdate._resolved_valuesc C s� g }| j D ]�\}}t|tj�r2|�|j|f� q nt|d�rD|�� }| jr�t|t j �r�z| jj | }W n t j yz Y q�0 |�|j|f� q t�d| ��q |S )Nr~ zInvalid expression type: %r)rI r� r rG rY r/ r� r~ r% r Z ColumnElementr� rz ZUnmappedColumnErrorr� r� )r r� rI rJ r r r r �"_resolved_values_keys_as_propnamesC s" �z-BulkUpdate._resolved_values_keys_as_propnamesc C sH | j }| j�dd�s t|�}tj| j| jj|fi | j��}| � |� d S )NZpreserve_parameter_orderF) rI r; r� r r rb r# r� r3 r )r r� r� r r r r Z s ��zBulkUpdate._do_execc C s | j j}|j�| � d S r )r� r4 rp Zafter_bulk_update�r r4 r r r r i s zBulkUpdate._do_post)r$ r% r& r' r r) rC r r( rI rJ r r � __classcell__r r r< r r9 s r9 c sD e Zd ZdZ� fdd�Zedd� �Zdd� Zdd � Zd d � Z � Z S ) � BulkDeletez BulkUD which handles DELETEs.c s t t| ��|� d S r )r: rM r r r< r r r q s zBulkDelete.__init__c C s t �tttd�||�S r> )r r �BulkDeleteEvaluate�BulkDeleteFetchrM )r r� r r r r rC t s ��zBulkDelete.factoryc C s8 | j jjr4| j jjD ] }|| j | �}|d ur|| _ qd S r )r� rp Zbefore_compile_deleterD r r r r � s z BulkDelete._do_before_compilec C s t �| j| jj�}| �|� d S r )r rr r# r� r3 r )r r� r r r r � s zBulkDelete._do_execc C s | j j}|j�| � d S r )r� r4 rp Zafter_bulk_deleterK r r r r � s zBulkDelete._do_post) r$ r% r& r' r r) rC r r r rL r r r< r rM n s rM c @ s e Zd ZdZdd� Zdd� ZdS )rA zSBulkUD which handles UPDATEs using the "evaluate" method of session resolution.c C s4 i | _ | j}|D ] \}}|�t�|��| j |< qd S r )�value_evaluatorsrJ r4 r Z_literal_as_binds)r r, r� r/ r� r r r r- � s �z)BulkUpdateEvaluate._additional_evaluatorsc C s� | j j}t� }t| j�� �}| jD ]�}t�|�t� |� }}|j � |�}|D ] }||v rL| j| |�||< qL|j j �|d |� |�|t|�� |�|t|��|�� |�|� q"|�|� d S r )r� r4 r� r7 rP rm r5 r rx � instance_dictZ unmodifiedr� r� rp �refreshZ_commitr� r� �add�_register_altered) r r4 rB Zevaluated_keysr� r r Z to_evaluater/ r r r r � s$ � � z'BulkUpdateEvaluate._do_post_synchronizeN)r$ r% r& r' r- r r r r r rA � s rA c @ s e Zd ZdZdd� ZdS )rN zSBulkUD which handles DELETEs using the "evaluate" method of session resolution.c C s | j j�dd� | jD �� d S )Nc S s g | ]}t �|��qS r )r rx )r r� r r r r � r z;BulkDeleteEvaluate._do_post_synchronize.<locals>.<listcomp>)r� r4 �_remove_newly_deletedr5 r r r r r � s �z'BulkDeleteEvaluate._do_post_synchronizeN�r$ r% r& r' r r r r r rN � s rN c @ s e Zd ZdZdd� ZdS )rB zPBulkUD which handles UPDATEs using the "fetch" method of session resolution.c s� | j j� | j �� �t� fdd��fdd�| jD �D ��}| j}tdd� |D ��}|D ] }|�|j�}|rT� �||� qT� � |� d S )Nc s& g | ] }|� j v rt�� j | ��qS r )rw r rx )r � identity_key)r4 r r r � s �z8BulkUpdateFetch._do_post_synchronize.<locals>.<listcomp>c s g | ]}� � t|���qS r )� identity_key_from_primary_keyr7 )r r� )� target_mapperr r r � s ��c s s | ]\}}|V qd S r r rH r r r r& � r z7BulkUpdateFetch._do_post_synchronize.<locals>.<genexpr>) r� r4 r1 r� r8 rJ r� r Z _expire_staterT )r rB r� �attribr Z to_expirer )r4 rY r r � s ��� z$BulkUpdateFetch._do_post_synchronizeNrV r r r r rB � s rB c @ s e Zd ZdZdd� ZdS )rO zPBulkUD which handles DELETEs using the "fetch" method of session resolution.c C sR | j j}| j �� }| jD ]4}|�t|��}||jv r|�t� |j| �g� qd S r ) r� r4 r1 r8 rX r7 rw rU r rx )r r4 rY r� rW r r r r � s � ���z$BulkDeleteFetch._do_post_synchronizeNrV r r r r rO � s rO )F)FFF)F)T)T)6r' � itertoolsr r r� � r r r rz r r �baser r r� r r r Zsql.baser rF rR rW rj rs rX rf rk r; rP rg rn rQ r< rh ro r[ r� r� r� rt r3 rV �objectr r+ r6 r9 rM rA rN rB rO r r r r �<module> sp PE V-.Q � Y � :8. � I � s]F)` h-\#)
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка