U rRd@s^ddlZddlZddlmZmZddlmZddlmZddlmZddl Z ddl Z ddl Z ddl mZddl mZmZmZddlmZdd lmZdd lmZdd lmZdd lmZdd l mZddlmZmZddl m!Z!ddl"m#Z#ddl$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3Gddde.Z4GdddZ5dS)N) defaultdict namedtuple)copy)List) OrderedDict)IntegrityError) ForeignKeyfuncinspect)json)Config)command)UNIQUE_VIOLATION)errors)close_all_sessions) CmfRelBaseCmfType)fields)models) CmfOrmErrorCmfOrmUniqueErrorCmfOrmIntegrityError) BaseModelMetaDEFAULT_DATASOURCE BaseModel CmfGM2MModel)BaseDataDriver BaseMapperMapperinc_select_count)imutable_deep_copycsXeZdZdZiZeZejj j eedZ e Z dZfddZeddZedd Zed d Zedmd d ZdnddZddZddZddZddZeddZddZddZddZd d!Zed"d#Z ed$d%Z!e"d&d'Z#dod)d*Z$edpe%e#d,d-d.Z&dqd/d0Z'ed1d2Z(ej)dfd3d4Z*ed5d6Z+ed7d8Z,d9d:Z-edrd;d<Z.dse#d=d>d?Z/d@dAZ0ddddd+ddBdCdDZ1dddEdFdGZ2ddd+ddHdIdJZ3dKdLZ4dMdNZ5dOdPZ6d+dQdRdSZ7dTdUZ8ddVdWdXZ9fdYdZZ:fd[d\Z;d]d^ZdcddZ?efdedfZ@dgdhZAdidjZBdkdlZCZDS)tSQLAlchemyDataDriveru dataproviders['default'] = { 'type': 'sqlalchemy', 'sqlachemy.url': 'postgresql://user:password@host/db', 'sqlachemy.echo': True, # Достаточно для отладки запросов в develop mode } # Для отладки в продакшене логгеры: sqlalchemy.engine - controls SQL echoing. set to logging.INFO for SQL query output, logging. DEBUG for query + result set output. These settings are equivalent to echo=True and echo="debug" on create_engine.echo, respectively. sqlalchemy.pool - controls connection pool logging. set to logging.INFO to log connection invalidation and recycle events; set to logging.DEBUG to additionally log all pool checkins and checkouts. These settings are equivalent to pool_echo=True and pool_echo="debug" on create_engine.echo_pool, respectively. sqlalchemy.dialects - controls custom logging for SQL dialects, to the extend that logging is used within specific dialects, which is generally minimal. sqlalchemy.orm - controls logging of various ORM functions to the extent that logging is used within the ORM, which is generally minimal. Set to logging.INFO to log some top-level information on mapper configurations. Example: logging.basicConfig() logging.getLogger('sqlalchemy.engine').setLevel(logging.INFO) )Zclass_registryZmetadataNcsTtj||tj|jfdd|D|_tjtjj |jd|_ | dS)NcSs*i|]"\}}|dr|ddd|qS)z sqlalchemy.r) startswithreplace).0kvr*./data_providers/sqlalchemy.py Fs z1SQLAlchemyDataDriver.__init__..)Zbind) super__init__ sqlalchemyZengine_from_configconfigitemsengineormZscoped_sessionZ sessionmakerSession init_metaselfargskwargs __class__r*r+r.AszSQLAlchemyDataDriver.__init__cCsVg}|jD]B\}}t|tr"q|jr:|d|ffq|jr|d|ffq|S)Nuniqueindex)rr1 issubclassrr<appendr=)cls cmf_modelZindexescmf_field_name cmf_fieldr*r*r+Z __get_indexesQs z"SQLAlchemyDataDriver.__get_indexescCs |j|}|r|j||SN)cached_queriesget move_to_end)r@keyretr*r*r+ get_query_s  zSQLAlchemyDataDriver.get_querycCs||j|<|jsZtdtddd}|d}|d}|dkrHd}|dkrTd}||_t|j|jkr|jjdd\}}td |dS) N SC_PAGE_SIZE SC_PHYS_PAGESiiF)ZlastzDEV: set_query evicted key )rEcached_queries_limitossysconflenpopitemprint)r@queryrHZsys_memsize_mbZ chunk_countZ queries_limitZ evicted_key_r*r*r+ set_queryhs zSQLAlchemyDataDriver.set_querycCs|j}|jrdSt|tjr(t}nt|tjr>tj}nt|tj r^t |j |j }n~t|tj r|t|jg}|jr|t|jtj||j|jdSt|tjrt}nt|tjrt|j}nt|tjrdSt|tjrdSt|tjrdSt|tjr dSt|tjr2dSt|tjrNtjdd}nt|tj rft!}nvt|tj"r~t}n^t|tj#rdSt|tj$rdSt|tj%rtj&}n$t|tj'rtj(}nt)d|tj|||j*|j|jdS)u0Создадим SA поле для моделиN) primary_keynullableT)timezoneu"Не найден тип поля )defaultrYrX)+ class_nameZvirtualr>rZ CmfBigIntr/ZBIGINTCmfIntZIntegerZ CmfNumericZNumericZ precisionZscaleCmfTUUIDStringZ max_lengthZ foreign_keyr?rZColumnrXrYZCmfTextZTEXTZCmfStr CmfRelationCmfGenericRelationZ CmfGenericM2MZ CmfDateRangeZCmfM2MZ CmfDateTime TIMESTAMPZCmfDateZDATEZCmfJson CmfBackrefCmfGenericBackrefZCmfBoolZBooleanZCmfTimeZTime Exceptionr[)r@Z _cmf_modelrCZ_db_field_name column_nameZsa_typer8r*r*r+_make_sa_column~sl            z$SQLAlchemyDataDriver._make_sa_columncCst|jj||d}|S)N)schema)r r2Z get_columns)r7 table_namerhcolumnsr*r*r+inspect_table_columnssz*SQLAlchemyDataDriver.inspect_table_columnscCs>|d|j}|}|d|d|d||dS)Nz alter table z add column  )rgtyper4executecommit)r7rirfZcmf_field_typeZsa_column_typesr*r*r+add_custom_columnsz&SQLAlchemyDataDriver.add_custom_columnc Csdddd}tjtjdddd|d<tjtjdddd|d <tjtjd dd |d <tjtjd dd |d<t|tf|}tj|j j }| }z| || Wn@tk r}z"|jtd|d|W5d}~XYnXdS)u5 Создаем М2М таблицу Tcustom.r$abstract __module__ __qualname__uID Объекта)captionrYr=left_iduID Элементаright_idИмя объекта)rwrYZleft_name_cacheuИмя элементаZright_name_cache-Ошбика создания таблицы : N)rFieldr^ CmfStr256rmrr/rh CreateTabledp_model __table__r4rnrore transactionrollbackrT)r7 model_namer9rAsmtprper*r*r+add_custom_m2m_models    z)SQLAlchemyDataDriver.add_custom_m2m_modelc Csdddd}tjtjddddddd|d <tjtjd dd |d <tjtjd ddddd|d<tjtjdddddd|d<tjtjddddd|d<t|tf|}|S)NTrrr$rsu)Идентификатор объектаu3Автоматически генерируетсяF)rwcommentrYrXreadonlyvisibleidrz)rwr=nameuСортировкаr)rwr=rrYr[ZordernouКодu3Код в реальном мире из жизни)rwr<rrrYcodeu:Код родителя в каскадном выборе)rwrrYr=Zchoice_parent_id)rr}r^r~r]ZCmfStr64rmr)r7rr9rAr*r*r+gen_custom_choice_modelsP      z,SQLAlchemyDataDriver.gen_custom_choice_modelc Cs~||}tj|jj}|}z|||Wn@t k rx}z"|j t d|d|W5d}~XYnXdS)ur Создаем пользовательский справочник выбора таблицу r{r|N) rr/rhrrrr4rnrorerrrT)r7rrArrprr*r*r+add_custom_choice_model s    z,SQLAlchemyDataDriver.add_custom_choice_modelcCs|j}|j|}|s|j}g}g}i}|jD].\}} |} ||| | } | dkrVq2|| q2||D]@\} } | dkr|t j d| ddiql|t j d| ql|||t |d}| dd|Dt ||jf|}||j|<|S) u] Вернём SA модель для CMF модели. TODO: db_name Nr<T)Z __tablename____table_args__cSsi|] }|j|qSr*r)r'cr*r*r+r,Fsz5SQLAlchemyDataDriver.dp_model_cls..)N)N)__name__models_registryrF tablenamerr1rgr?"_SQLAlchemyDataDriver__get_indexesr/ZIndextupleupdaterm sa_base_model)r@rArsa_modelrZ sa_columnsrZ__table_kwargs__rBrCZ sa_field_nameZ sa_columnZ index_typeZ index_tupleZsa_model_kwargsr*r*r+ dp_model_clss:   z!SQLAlchemyDataDriver.dp_model_clscCs ||SrD)r)r7rAr*r*r+rKszSQLAlchemyDataDriver.dp_modelcCs tt|jS)uG Вернём CMF модель для SA модели. )getattrrr)r7rr*r*r+rANszSQLAlchemyDataDriver.cmf_modelcCs t|tjSrD) isinstancer#r)r7Z dp_instancer*r*r+ is_instanceTsz SQLAlchemyDataDriver.is_instancecCs0i}|D]}|jj||jjj<qtj|d|S)N table_type)rrfullnamer/r3polymorphic_union)r7Z cmf_modelsaliasZtablesmodelr*r*r+ _union_modelsYsz"SQLAlchemyDataDriver._union_modelscCsXd}|d|kr&|d|d|dfS|d|krH|d|d|dfStd||dS)N)><==>=<==IN!=><<>NOT INLIKENOT LIKEILIKE NOT ILIKEz SIMILAR TOzNOT SIMILAR TOEXISTS NOT EXISTSrrrzInvalid filter operation)r)paramsZop_listr*r*r+ _parse_paramscs   z"SQLAlchemyDataDriver._parse_paramscCsddlm}m}t|tjr:|jdkr2||jd|j}nXt|t rt }|D]>}t|tjr|jdkrt||jd| |jqN| |qN|}|dkrd}|dkr||kS|dkr||kS|dkr||kS|d kr||kS|d kr||kS|d kr||kS|d kr| |S|d kr*| |S|dkr>| |S|dkrT| |S|dkrh| |S|dkr~| |S|||SdS)Nr print_debugr0.u<collect_filter_exp: Значение не загруженоZNULLrrrr)rr)rrrrrrrrr) cmf.includerr0rrr_valueDEBUGvaluelistr?in_ZlikeZilikeop)operfieldvalrr0new_valr)r*r*r+ _expressionpsR                     z SQLAlchemyDataDriver._expressionJoinDatazJleft_table, right_table, alias, left_field_name, right_model, right_modelsTc Cs |r|j}|j}nT|j|}|s.|||t|tjtjfrLt|tjrft d|jd|jd|jd}|r|d|n|}| }|s|rt d|d|jd|jddS|d } t |d krt j j| jj|d } n |||} ||| ||| |} | S) NuXНедопустимый тип поля для вложенной фильтрации .up. Вложенная фильтрация возможно только для CmfRelation и CmfGenericRelationZ_sub__ujНе возможно построить запрос для вложенной фильтрации по u, т.к. у поля u# не указаны related_modelsrrr)r\instance_classrrF_raise_invalid_fieldr>r`raCmfSubclassedGenericRelationrrelated_modelsrRr/r3Zaliasedrrrr) r7r left_table field_name from_aliasis_models_required field_clsZ alias_partmodels_ right_model right_table join_datar*r*r+_calc_join_datas6      z$SQLAlchemyDataDriver._calc_join_dataF)joinscCsb|r tndd|jD}|D]:}|j|kr2q"||jt|jj|j d|jjj k}q"|S)uP TODO cmf_deleted Все данные для необходимых присоединений в joins, добавим недостающие присоединения в запрос. froms могут быть от филдов, при этом без джойна, чтобы принудительно создать join нужен force = True. Или более продвинутый способ определения наличия нужного джойна. Сейчас при построении основного запроса, джойны принудительно добавляются. А при расчёте фильтров, когда нет алиасов от полей, джойн делается только если нет нужного алиаса. cSs"h|]}t|tjjjr|jqSr*)rr/sql selectableAliasr)r'rr*r*r+ sz3SQLAlchemyDataDriver._make_joins.._id) set statementlocate_all_fromsrZ outerjoinrrrrZleft_field_namer)rUrforceZavailable_joinsrr*r*r+ _make_joinss  z SQLAlchemyDataDriver._make_joinscCsdd}g}|dkrd}|jj}n|j}|dD]0}|||||}|||j}|j}|j}q.|S)Nr) rrrsplitrr?rrr)r7 join_pathrrrrrrr*r*r+_calc_joins_by_paths  z(SQLAlchemyDataDriver._calc_joins_by_pathcCs0t|jdd}t|d|jd|dS)N,z, u+ не существует у модели u, но есть: )strrr&rr\)rrZfields_r*r*r+rsz)SQLAlchemyDataDriver._raise_invalid_fieldc, Cs|s |dfSt|dtr`g}|D]0}|j|||||d\}} | dkrHq"|| q"|||fS|ddkr|j|dd||||dS|ddkr|j|dd|||tj|dS|ddkrt|dks|dd krtd |||d }|dfS| |\} } } t t | t r | j } t t | tr8| jj } t| ttfrg} | D]N}t t |t rr| |j n*t t |tr| |jj n | |qP| } d | kr| d \}}} |j|||d }|||}|d}|j}|j}d}n|dkr|jj}d}|j| }|s2td| d|jt |tjrV| d} |j| }|dkrl|| |t |tjr| dkrt| tst| tstd| ||| d kr| dk rtd| ||| dkr<|j|d||d}|dkrtd|d|j r|t!j"}| d krP|j#$|%|j&|k|j'|jk(}||fS|j#$|%|j&|k|j'|jk|)d|j*| (}n|+}||}|j,r|j-}|j.}n"|j/r|j.}|j-}n td||| d kr|j#$|%||k(}||fS|j#$|%||k|)d|| (}|| dkr4|n|fS| dkr|j|d||d}|dkrrtd|d|j0|ddd|d }|j}|j}|j#$|j1j}|j r|t!j"} | j}!|2|!| j*|j1jk}|%| j&|k| j'|jk}nh|j/rd!}"d"}#nd"}"d!}#|+}||} | j}!t3| |"}$t3| |#}%|2|!|%|j1jk}|%|$|k}t4|j1d#rpd#d$dg}&ng}&| r|&| g}&|j|&||j||d\}}&|%|&}|(}| 5d%r|}||fStd&| ||nft |tj6tj7fr| dkr| 5d%rd'nd(} dd| g} | dkr.td)| |||j|d||d}|dkrZtd|d*|j0|ddd|d }'|'j}(|'j})|j8d}*t3|)j1|*}+|j#$|+}|*d$|g}&t4|)j1d#r|&d#d$dgg}&| r|&| g}&|j|&|(|(j||)d\}}&|%|&}|(}| 5d%r|}||fSt |tjr@td+|d,| |||j9|j|| ||d}|dkrrtd|d-| d.||)| || fSdS)/Nr) field_tableZANDrOR)cmdrorder_by)rrutОперация order_by в фильтре должна быть в формате: ["order_by", "=", [поля..]]rr)rTFu Поле u не найдено у r)rruПравое значение для IN, NOT IN для m2m должно быть list, т.е. в квадратных скобках, например "field", "IN", "[obj.id]"uНедопустимая операция над m2m полем (сравнение = только на None), допустимые IN, NOT IN, = None)rrrrr with_aliasuВ таблице u3 нет поля id для фильтрации m2mruDНадо указать для поля либо left либо right)rruG нет поля id для фильтрации в подзапросе)rrxry cmf_deletedrzNOT uhНедопустимая операция над m2m полем, допустимые IN, NOT IN, = NonerrulНедопустимая операция над backref полем, допустимые EXISTS, NOT EXISTSu7 нет поля id для фильтрации backrefuФильтрация по u+ полю не поддерживаетсяu нет поля u для фильтрации):rrcollect_filter_expr?r/or_rRre order_queryrr>rmrrrrr rpartitionrrrrrrrrFrr\CmfRelationBaser CmfM2MBase _query_columnZ nested_fieldsrZ RelationCachesessionrUfilterZ parent_idZ parent_fieldexistsrZchild_id m2m_model_clsrightryrxleftrrjoinrhasattrr%rcrdbackref__mro__),r7Z in_filterrrrUrrZ filter_resr)ZexprrrZ_rightirrVrrrrZ field_column m2m_modelZ m2m_subqueryZ dp_m2m_modelZdp_m2m_field_selfZdp_m2m_field_theirZ self_columnZsub_dataZ sub_modelZ sub_tableZ sub_queryZ m2m_sa_modelZ m2m_tablemy_id_field_namesub_id_field_name my_sa_field sub_sa_fieldZsub_filter_expZ backref_dataZ backref_modelZ backref_tableZbackref_column_nameZbackref_columnr*r*r+rs             "                                         z'SQLAlchemyDataDriver.collect_filter_expcCs |dS)NZ _m2m_directr*rr*r*r+_m2m_depth_alias_namesz*SQLAlchemyDataDriver._m2m_depth_alias_namecCs |dS)NZ_m2m_idr*rr*r*r+_m2m_alias_namesz$SQLAlchemyDataDriver._m2m_alias_namecCsh|dg}t|tr t|}|r8t|dts8|g}|D]"\}}||jkr@||d|gq@|S)u Преобразуем обычные kwargs в продвинутый фильтр для однообразной логики фильтрования :param model: :param kwargs: :return: rrr) rFrrr loadsrr1rr?)r7rr9 smart_filterr(r)r*r*r+ _get_filters    z SQLAlchemyDataDriver._get_filtercCsl|r4|jD]$}t|tjjjr|j|jkr|}qt|j |d}|dk rh|rd| t | ddS|SdS)uДля полей "основной" таблицы не нужен префикс таблицы, для этого нужно указать with_alias=FalseNrr) rrrr/rrrrrrZlabelrr&)tablerfrUrZfrom_columnr*r*r+rsz"SQLAlchemyDataDriver._query_column parent_joincs|r |jn|jj}|D]\}|j|t|d}|dk rJ||q|r|r\|jp`gn|g} fdd| D} | s|q| dj} |r|j nd} |j | || dd} | sq|| |j |||| j | dqdS) u2Соберём поля и таблицы по fflrNcs>g|]6}|jrttjtjfrttjsqSr*)rrFr>r`rar)r'Z related_modelrrr*r+ s  z?SQLAlchemyDataDriver._select_joined_columns..rF)rr) rrrr1rboolr?Z right_modelsrrr_select_joined_columnsr)r7Zfflrrjrrr Zsub_fflrrZ fields_clsZ left_modelrrr*rr+rs4   z+SQLAlchemyDataDriver._select_joined_columnscOs(||}|}ddlm}|d|j|}t||} | rX| } | |} nht } g} g} | || | ||j | } |j | | dd} t | dkr|  d} t|| |t|dkr|j}tt|D]}|||||<q|||}|r$||||| \} }| |} | S)Nr CMF_CACHEzquery: T)rg{Gz?)rr4rrhashrrmrJZ_cloneZ with_sessiontimerrUrrWrRrXranger rr)r7rfull_fields_loadr8r9rrprrHrUZstart_calc_timerrjZclone_qpkeyrr Z filter_expr*r*r+ _create_querys4       z"SQLAlchemyDataDriver._create_query)rrslicegroup_by for_updatemappercOst|t } t|}||} || } |j|fd|i| } |j| ||d} |rb| j|} |rn| } | } |j | ||d}|r| |||| r| |S)Грубо селектим всю таблицу, фильтры: - в kwargs: поле -> значение rrrr)rr get_mappermap_args map_kwargsr with_labelsrrwith_for_updateall list_to_cmf _load_m2mpost_mapping_hook)r7rrrrrrr r8r9 mapper_is_my_argsqZsql_resZres_objsr*r*r+rAs6      zSQLAlchemyDataDriver.list)rrcs ||}||}|j|fd|i|}|r||fdd|D}|jj|jj|t fj | d} t |j| } g} | D]<} i} t|D]\}}| || |<q| d| d<| | q| S|jj|jjt g d} |j| }|S)r!rcsg|]}jj|qSr*)rr)r'rfrr*r+rlsz.SQLAlchemyDataDriver.count..Nrcount)r%r&rr'rrZ select_fromZfromsZwith_only_columnsr r1rrrrrn enumerater?Zscalar)r7rrrr8r9r.r/rjZcount_qres_listresrowZrow_resrrfr1r*r0r+r1[s>       "zSQLAlchemyDataDriver.count)rrrr c Ost|t }t|}||}||}|j|f|d|i|} | } |j| |ddgd} |rl| } | } | r|j | ||d} |j | g||d|r| | SdS)u Выбрать один объект по фильтру: - в args - первичный ключ(опционально) - в kwargs - другие поля: поле -> значениеrrrr"r#)r N) rrr$r%r&rr'rr(first object_to_cmfr+r,) r7rrrrr r8r9r-r/ sa_instanceZres_objr*r*r+rFs     zSQLAlchemyDataDriver.getc: s|r|s dSt|tfdddd}t|}tt}tt}tt}|D]&} || | || j| qN|D]t} tt| } |D]`} || sqt| | d} | rt| t j rt| t j r|| qt| t j t j fr|| | qqz|D]\} }g}|D]8} tt| j} | j | } | r t| t j r rt| | }|jdk rt|jdk r ||jq d|_|jdkrd|_| }t| |}|j}|dkrtd|| n`t| | d}|dk r|r ||q t| | d| }t| |d}|dkrtd|| |r |dd }|||| q |D]\} }tt| d} | slqNt|j| || |d d t|gd d }|D]T}|}||D]<} rt| | }||_|jdkr||_n t| | |qqqN|r|||| |q|D]\} }|D]} | j} || }t| | } t| t j r| jrt}| jd}|d fdd|Dg}tt|| f|ii}| D]D} |}!d| j kr|ddd gg}!|j| ||!d}"| |"|| j<q|sd dlm }#m!}$|#|$j"d| jd| jdq nVt#|dkrHtt$t%|&'}%n,t|(t)j*+dd|Dd'}%tt}&|%D]}'t|'|}(|&|(|'qg})|D]} |&| }*r$t| | }|*sg|_|jdkrg|_q|,|*|| |_|jdkrt-|j|_|).|jn<|*s:t| | gq|,|*|| }t| | ||).|q|)r||)|| |q t| t j r | j/rd}+d},nd}+d},| 0}-|1|-}.t|.|+}/t|.|,}0|(|/|02|/3fdd|D}1tt}2tt}3t|1D]@\}4}5|5r|4s&q|3|5|4|2|5dd |5q|2D]\} }6tt| } t|j| || d d |6g|d d})|)r||)|| ||)D]} |3| D]t}4||4D]d}7r|7| }8|8jdkrg|8_|8j| n0t|7| d}|dkrg}t|7| ||| qƐqqqX|D]f} r| | }9|9jdkr`g|9_|9jdkrxt-|9j|9_|94nt| | ddkr.obj_idcSsdd}t|S)NcSsttSrD)rrr*r*r*r+id_to_list_factoryszWSQLAlchemyDataDriver._load_m2m..model_to_id_factory..id_to_list_factory)r)r;r*r*r+model_to_id_factorysz;SQLAlchemyDataDriver._load_m2m..model_to_id_factory.u#Не загружено id поле:rrrF)rr rrrcsg|] }|qSr*r*r'or:r*r+r%sz2SQLAlchemyDataDriver._load_m2m..rr)rrrzORM: skip load field rz die no related modelsrcSsi|]\}}||jqSr*)r)r'r(mr*r*r+r,Csz2SQLAlchemyDataDriver._load_m2m..rrxrycsg|] }|qSr*r*r>r@r*r+rxs)rrr r)5rr rrr?r\rrr>rrrrZCmfBackrefBaser1rFrZ_oldZ id_fieldnamersetattr partitionr!r+rdictr"rrrrrrr0rrRnextitervaluesr)rUr/r3rr*rextendrrrrrZ apply_changes):r7Zobjsrr r<Zto_load_mappingZ my_objs_by_idZmy_objs_by_model_nameZmodels_by_rel_fieldsobjrrrrZ model_to_idZalready_loaded_obj_listrZ id_field_nameZid_fieldZid_field_valueZ field_valueZrel_model_nameZid_to_obj_listZ load_objsZload_objZ loaded_idZ models_listZobj_listZm2mqueryZbackref_field_nameZfilter_qZ field_fflZ rel_modelZmodel_query_filterr/rr0r3Zres_dictrZm2m_idZsub_objsZ ref_obj_listrrrrrrZ m2m_queryZ id_by_modelsZmy_id_by_sub_idZmy_idZsub_idZ sub_id_listZmy_objZmy_fieldZ obj_fieldr*)r9r:r+r+s                                                        zSQLAlchemyDataDriver._load_m2mcCs6g}|D](}t|tjr&||jq||q|SrD)rrrr?r)r7r8Znew_argsargr*r*r+r%s   zSQLAlchemyDataDriver.map_argscCs:i}|D](\}}t|tjr,|j||<q |||<q |SrD)r1rrrr)r7r9Z new_kwargsr(r)r*r*r+r&s    zSQLAlchemyDataDriver.map_kwargs) no_reloadc Os||}||}|}||j}|} t} | || z|| |j | gdWnt k r} z4|j t | jttrt| | t| | W5d} ~ XYn0tk r} z|j | W5d} ~ XYnXd|_|rdS| j| |d} | d| _| S)um no_reload - не загружать объект из базы и не возвращать ZobjectsNT) cmf_entity)r%r&r4rr;rr$ cmf_to_objectaddflushrrrrorigrlookuprrrreis_newr7r,) r7instancerKr8r9r._kwargsrprr8r rrIr*r*r+creates2        zSQLAlchemyDataDriver.createc s||}||}|}|j}tj}|tfdd|D} || | } z| | Wn0t k r} z|j | W5d} ~ XYnXS)u*TODO логическое удалениеc3s|]}t|VqdSrDrr'frTr*r+ sz.SQLAlchemyDataDriver.delete..N)r%r&r4rr;rmrXrrUrFdeletererr) r7rTr8r9r.rUrprrget_argsr8rr*rZr+r\s     zSQLAlchemyDataDriver.delete)rc s.||}||}|}|t}tj}|tfdd|D}|||} t } | | z|j | gdWn~t k r} z0|jt| jttrt| t| W5d} ~ XYn2tk r} z|j| W5d} ~ XYnXj} | j| |d} | | | _| S)Nc3s|]}t|VqdSrDrWrXrZr*r+r[sz.SQLAlchemyDataDriver.update..rL)rMr)r%r&r4rrmrXrrUrFrr$rNrPrrrrrQrrRrrrrerSr7r,)r7rTrr8r9rprrr]r8r rrSrIr*rZr+rs0      zSQLAlchemyDataDriver.updatecstdSrD)r-before_requestr7r:r*r+r^sz#SQLAlchemyDataDriver.before_requestcstdSrD)r-before_first_requestr_r:r*r+r`sz)SQLAlchemyDataDriver.before_first_requestcCs6ddlm}||||jdSNrr)rr cache_unlockZcache_transaction_startr4roremover7rr*r*r+ros   zSQLAlchemyDataDriver.commitcCs.ddlm}|||jdSra)rrrbr4rrcrdr*r*r+r s  zSQLAlchemyDataDriver.rollbackcOs|j||SrDr4rUr6r*r*r+rU&szSQLAlchemyDataDriver.querycOs|j||SrDrer6r*r*r+query_deprecated)sz%SQLAlchemyDataDriver.query_deprecatedcst|dSrD)r- make_models)r@rr:r*r+rg,sz SQLAlchemyDataDriver.make_modelscCs^ttD]P}tt|}t|tr|jr(q|jr<|j|jkrsF             ?