kh ddlZddlZddlmZddlmZddlmZddlm Z ddl Z ddl m Z ddl m Z ddlmZmZdd lmZdd lmZdd lmZmZdd lmZdd lmZddlmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddlm.Z.ddl/m0Z0m1Z1m2Z2ddl3m4Z4m5Z5ej6e7Z8e89ej:dZ;GddZ<Gdde,Z=Gdd e=e-Z>e>dddfd!Z?dS)"N) OrderedDict)deepcopy)escape)warn)diff_match_patch)settings)ImproperlyConfiguredValidationError)no_style) Paginator) connectionsrouterfields) ForeignKey)QuerySet)TransactionManagementError set_rollback) force_str) mark_safe) gettext_lazy) exceptionswidgets)DeclarativeMetaclassModelDeclarativeMetaclass)Field)ErrorResult RowResult)atomic_if_using_transactionget_related_modelcLt|dot|jdS)z@ Determine if a model has natural foreign key functions natural_keyget_by_natural_key)hasattrobjectsmodels N/var/www/histauto/venv/lib/python3.11/site-packages/import_export/resources.pyhas_natural_foreign_keyr+"s/ 5- ( ( W +..c6eZdZdZdZdZedZdS)Diffcbt|||_g|_||_dSN)r._read_field_valuesleftrightnew)selfresourceinstancer4s r*__init__z Diff.__init__,s+++Hh??  r,cFt|||_dSr0)r.r1r3)r5r6r7s r* compare_withzDiff.compare_with1s,,Xx@@ r,cg}t}t|j|jD]\}}||kr |jrd}|t |t |}||||}t|}| ||S)N) rzipr2r3r4 diff_mainrdiff_cleanupSemanticdiff_prettyHtmlrappend)r5datadmpv1v2diffhtmls r*as_htmlz Diff.as_html4s  $)TZ00  FBRxxDHx==2 " >>D  $ $T * * *&&t,,DT??D KK     r,cDfd|DS)Nc:g|]}|S)export).0fr7s r* z+Diff._read_field_values..Cs%IIIq""IIIr,get_import_fields)clsr6r7s `r*r1zDiff._read_field_valuesAs)IIIIH,F,F,H,HIIIIr,N)__name__ __module__ __qualname__r8r:rH classmethodr1rKr,r*r.r.+sd AAA   JJ[JJJr,r.ceZdZdZdZedZedZedZedZ edZ dZ d Z d Z d ZdBd ZdZdZdZdZ dCdZ dCdZdBdZ dDdZdZdZdZdZdZdZdZdEdZd Z d!Z!d"Z"d#Z#d$Z$dBd%Z%d&Z&d'Z'd(Z(d)Z)d*Z*dBd+Z+d,Z,dEd-Z-d.Z. dFd/Z/d0Z0d1Z1d2Z2d3Z3d4Z4d5Z5d6Z6dBd7Z7dBd8Z8dBd9Z9d:Z:d;Z;dBd<ZZ>d?Z?d@Z@dAZAd S)GResourcez Resource defines how objects are mapped to their import and export representations and handle importing and exporting data. c bt|j|_g|_g|_g|_dS)z kwargs: An optional dict of kwargs. Subclasses can use kwargs to pass dynamic values to enhance import / exports. N)rrcreate_instancesupdate_instancesdelete_instancesr5kwargss r*r8zResource.__init__Ls5t{++ !# " "r,ctS)zJ Returns the class used to store the result of an import. )rr5s r*get_result_classzResource.get_result_class^s  r,ctS)zM Returns the class used to store the result of a row import. )r r`s r*get_row_result_classzResource.get_row_result_classes r,ctS)zT Returns the class used to store an error resulting from an import. )rr`s r*get_error_result_classzResource.get_error_result_classls  r,ctS)zV Returns the class used to display the diff for an imported instance. )r.r`s r*get_diff_classzResource.get_diff_classss  r,cn|jjtj|jjS|jjSr0)_metausing_dbr db_for_writer)r`s r*get_db_connection_namezResource.get_db_connection_namezs. :  &&tz'788 8:& &r,c^|jjttddS|jjS)NIMPORT_EXPORT_USE_TRANSACTIONST)riuse_transactionsgetattrrr`s r*get_use_transactionszResource.get_use_transactionss+ : & .8%EtLL L:. .r,c^|jjttddS|jjS)NIMPORT_EXPORT_CHUNK_SIZEd)ri chunk_sizerprr`s r*get_chunk_sizezResource.get_chunk_sizes+ : (8%?EE E:( (r,c |tdtdt|jS)NzOThe 'get_fields()' method is deprecated and will be removed in a future release stacklevel)rDeprecationWarninglistrvaluesr]s r* get_fieldszResource.get_fieldssB  "      DK&&(()))r,c|jD]\}}||kr|cStd|d|jd)z; Returns the field name for a given field. zField z does not exists in z resource)ritemsAttributeError __class__)r5field field_namerNs r*get_field_namezResource.get_field_namesi"[..00 " "MJEzz!!!! IU I I I I I   r,Nct)z| Initializes an object. Implemented in :meth:`import_export.resources.ModelResource.init_instance`. )NotImplementedErrorr5rows r* init_instancezResource.init_instances "###r,cfdD}|D]}|j|vrdS||S)zI Calls the :doc:`InstanceLoader `. c*g|]}j|SrKrrMrNr5s r*rOz)Resource.get_instance..sPPPqDKNPPPr,N)get_import_id_fields column_name get_instance)r5instance_loaderrimport_id_fieldsrs` r*rzResource.get_instancesmQPPPD4M4M4O4OPPP%  E ++ , ++C000r,c|jjs|||}|r|dfS||dfS)zW Either fetches an already existing instance or initializes a new one. FT)riforce_init_instancerr)r5rrr7s r*get_or_init_instancezResource.get_or_init_instancesQz- '((#>>H '&!!#&&,,r,c|jjS) rirr`s r*rzResource.get_import_id_fieldss z**r,c*fdjDS)z Returns the fields to be included in calls to bulk_update(). ``import_id_fields`` are removed because `id` fields cannot be supplied to bulk_update(). c0g|]}|jjv|SrKrrs r*rOz3Resource.get_bulk_update_fields..s(OOOa!4:3N*N*N*N*N*Nr,rr`s`r*get_bulk_update_fieldszResource.get_bulk_update_fieldss" POOO4;OOOOr,cjt|jdkr|s|s |jjj|j|n.#t $r!}||||Yd}~nd}~wwxYw|jdS#|jwxYwdSdS)z= Creates objects by calling ``bulk_create``. r batch_sizeN) lenrZrir)r' bulk_create Exceptionhandle_import_errorclearr5using_transactionsdry_run raise_errorsrresultes r*rzResource.bulk_creates t$ % % ) )/A ) ) .  (44)j5 B B B((LAAAAAAAA B%++-----%++---- * ) ) )s/+A B A5A0+B0A55BB.ct|jdkr|s|s |jjj|j||n.#t$r!}||||Yd}~nd}~wwxYw|j dS#|j wxYwdSdS)z= Updates objects by calling ``bulk_update``. rrN) rr[rir)r' bulk_updaterrrrrs r*rzResource.bulk_updates t$ % % ) )/A ) ) .  (44)//11)5  B B B((LAAAAAAAA B%++-----%++---- * ) ) )s/>AB& B'B>B&BB&&Cct|jdkr|s|s d|jD}|jjj|n.#t$r!}||||Yd}~nd}~wwxYw|j dS#|j wxYwdSdS)z Deletes objects by filtering on a list of instances to be deleted, then calling ``delete()`` on the entire queryset. rcg|] }|j SrKpk)rMos r*rOz(Resource.bulk_delete..sBBBqadBBBr,)pk__inN) rr\rir)r'filterdeleterrr)r5rrrr delete_idsrs r* bulk_deletezResource.bulk_deletes t$ % % ) )/A ) ) .BBD,ABBB   (//z/BBIIKKKK B B B((LAAAAAAAA B%++-----%++---- * ) ) )s0AA'&B0' B1B B0 BB00C Tc |i}n|}|jjrW |||n,#t $r}||}Yd}~nd}~wwxYw|rt |dS)a  Takes any validation errors that were raised by :meth:`~import_export.resources.Resource.import_instance`, and combines them with validation errors raised by the instance's ``full_clean()`` method. The combined errors are then re-raised as single, multi-field ValidationError. If the ``clean_model_instances`` option is False, the instances's ``full_clean()`` method is not called, and only the errors raised by ``import_instance()`` are re-raised. N)excludevalidate_unique)copyriclean_model_instances full_cleankeysr update_error_dict)r5r7import_validation_errorsrerrorsrs r*validate_instancezResource.validate_instances $ +FF-2244F : + 5 5##"KKMM$3$# 5 5 5,,V44 5  *!&)) ) * *s)A A:A55A:c L|j||fi||jjr8|r|j|n\|j|nA||s||rn||||j ||fi|dS)a Takes care of saving the object to the database. Objects can be created in bulk if ``use_bulk`` is enabled. :param instance: The instance of the object to be persisted. :param is_create: A boolean flag to indicate whether this is a new object to be created, or an existing object to be updated. :param row: A dict representing the import row. :param \**kwargs: See :meth:`import_row N) before_save_instanceriuse_bulkrZrAr[_is_using_transactions _is_dry_rundo_instance_saveafter_save_instance)r5r7 is_createrr^s r* save_instancezResource.save_instances "!(C::6::: :  7 7%,,X6666%,,X6666,,V44 79I9I&9Q9Q 7   ! !(I 6 6 6  399&99999r,c.|dS)a A method specifically to provide a single overridable hook for the instance save operation. For example, this can be overridden to implement update_or_create(). :param instance: The model instance to be saved. :param is_create: A boolean flag to indicate whether this is a new object to be created, or an existing object to be updated. N)save)r5r7rs r*rzResource.do_instance_save6s  r,c dSa Override to add additional logic. Does nothing by default. :param instance: A new or existing model instance. :param row: A ``dict`` containing key / value data for the row to be imported. :param \**kwargs: See :meth:`import_row` NrKr5r7rr^s r*rzResource.before_save_instanceB  r,c dSrrKrs r*rzResource.after_save_instanceOrr,c |j||fi||jjr|j|n?||s||rn||j||fi|dS)as Calls :meth:`instance.delete` as long as ``dry_run`` is not set. If ``use_bulk`` then instances are appended to a list for bulk import. :param instance: A new or existing model instance. :param row: A ``dict`` containing key / value data for the row to be imported. :param \**kwargs: See :meth:`import_row` N) before_delete_instancerirr\rArrrafter_delete_instancers r*delete_instancezResource.delete_instance\s $#Hc<w >4:3F > D//11 > >!%,0HII!!%3==== > >r,cdS)aG Returns ``True`` if ``row`` importing should delete instance. Default implementation returns ``False``. Override this method to handle deletion. :param row: A ``dict`` containing key / value data for the row to be imported. :param instance: A new or existing model instance. FrK)r5rr7s r* for_deletezResource.for_deletes ur,c|jjr|jjs|rdS|D]'}t |jt jr|j| vr>t| |}|j gn3t| |}t|t|krdSt!d|Dt!d|DkrdS| || |krdS)dS)a Returns ``True`` if ``row`` importing should be skipped. Default implementation returns ``False`` unless skip_unchanged == True and skip_diff == False. If skip_diff is True, then no comparisons can be made because ``original`` will be None. When left unspecified, skip_diff and skip_unchanged both default to ``False``, and rows are never skipped. By default, rows are not skipped if validation errors have been detected during import. You can change this behavior and choose to ignore validation errors by overriding this method. Override this method to handle skipping rows meeting certain conditions. Use ``super`` if you want to preserve default handling while overriding :: class YourResource(ModelResource): def skip_row(self, instance, original, row, import_validation_errors=None): # Add code here return super().skip_row(instance, original, row, import_validation_errors=import_validation_errors) :param instance: A new or updated model instance. :param original: The original persisted model instance. :param row: A ``dict`` containing key / value data for the row to be imported. :param import_validation_errors: A ``dict`` containing key / value data for any identified validation errors. FNc3$K|] }|jV dSr0rrMvs r* z$Resource.skip_row..Bs$881!$888888r,c3$K|] }|jV dSr0rrs r*rz$Resource.skip_row..Bs=CCADCCCCCCr,T)riskip_unchanged skip_diffrQrrrrrrr|cleanr get_valueallrsorted)r5r7originalrrrinstance_valuesoriginal_valuess r*skip_rowzResource.skip_rowsP ) z# (  5++--  E%,(@AA $CHHJJ66#'u{{3'7'7"8"8"+-BB48Q8Q8U8U8W8W3X3X ''3+?+??? 558888888FCC"1CCC==!55**eooh.G.GGGuuHtr,c>d|DS)z. Diff representation headers. c6g|]}t|jSrKrrrMrs r*rOz-Resource.get_diff_headers..Ns#SSS %+,,SSSr,rPr`s r*get_diff_headerszResource.get_diff_headersJs%TS$:P:P:R:RSSSSr,c dS)z Override to add additional logic. Does nothing by default. :param dataset: A ``tablib.Dataset``. :param \**kwargs: See :meth:`import_row` NrK)r5datasetr^s r* before_importzResource.before_importP  r,c dS)a6 Override to add additional logic. Does nothing by default. :param dataset: A ``tablib.Dataset``. :param result: A :class:`import_export.results.Result` implementation containing a summary of the import. :param \**kwargs: See :meth:`import_row` NrK)r5r rr^s r* after_importzResource.after_import[  r,c dS)z Override to add additional logic. Does nothing by default. :param row: A ``dict`` containing key / value data for the row to be imported. :param \**kwargs: See :meth:`import_row` NrK)r5rr^s r*before_import_rowzResource.before_import_rowir r,c dS)aY Override to add additional logic. Does nothing by default. :param row: A ``dict`` containing key / value data for the row to be imported. :param row_result: A ``RowResult`` instance. References the persisted ``instance`` as an attribute. :param \**kwargs: See :meth:`import_row` NrK)r5r row_resultr^s r*after_import_rowzResource.after_import_rowtrr,c tdtd||d|i|j||dfi|dS)NzThe 'after_import_instance' method is deprecated and will be replaced with 'after_init_instance(self, instance, new, row, **kwargs)' in a future release. Refer to Release Notes for details.rxry row_number)rr{rafter_init_instance)r5r7r4rr^s r*after_import_instancezResource.after_import_instancesk  H        ! MM<4 5 5 5  3???????r,c dS)ar Override to add additional logic. Does nothing by default. :param instance: A new or existing model instance. :param new: a boolean flag indicating whether instance is new or existing. :param row: A ``dict`` containing key / value data for the row to be imported. :param \**kwargs: See :meth:`import_row` NrK)r5r7r4rr^s r*rzResource.after_init_instances  r,ct|||r0||||rt j|dS)Nexc_info)rrappend_base_errorrer ImportError)r5rerrorrs r*rzResource.handle_import_errorso UU +++  K  $ $%BT%@%@%B%B5%I%I J J J  0(// / 0 0r,c |jj}|jjs |dd|j_|}|jjr||_d} |j|fi||||\}}|j |||fi||rtj |_ ntj |_ |s.t|}||||} |||r|r+tj|_ |s| |dnUtj|_ |||jjrt||_|j||fi||s| |dni} |j||fi|n,#t0$r} | | } Yd} ~ nd} ~ wwxYw||||| rtj|_ n5||| |j|||fi||j||fi||||jjr||_|s| |||s||_|s%|jjs| |_!|j"||fi|n#t0$r"} tj#|_ | |_$Yd} ~ nd} ~ wtJ$r} tj&|_ tO| tPstR*| d|j+,|-| ||dYd} ~ nd} ~ wwxYw|S)aZ Imports data from ``tablib.Dataset``. Refer to :doc:`import_workflow` for a more complete description of the whole import process. :param row: A ``dict`` of the 'row' to import. A row is a dict of data fields so can be a csv line, a JSON object, a YAML object etc. :param instance_loader: The instance loader to be used to load the model instance associated with the row (if there is one). :param \**kwargs: See below. :Keyword Arguments: * dry_run (``boolean``) -- A True value means that no data should be persisted. * use_transactions (``boolean``) -- A True value means that transactions will be rolled back. * row_number (``int``) -- The index of the row being imported. retain_instance_in_row_resultFNTrr)rnumber).rirstore_instancerrcstore_row_values row_valuesrrrr IMPORT_TYPE_NEW import_typeIMPORT_TYPE_UPDATErrgrIMPORT_TYPE_SKIPr:IMPORT_TYPE_DELETEadd_instance_infor7rrr rrrrrrskip_html_diffrHrFrIMPORT_TYPE_INVALIDvalidation_errorrIMPORT_TYPE_ERRORrrrrrrAre) r5rrr^rrrr7r4rFrrs r* import_rowzResource.import_rowsW.J( z( (. /))DJ %1T..0022 : & ($'J !B  "D "3 1 1& 1 1 1 55osKKMHc $D $XsC B B6 B B B F)2)B &&)2)E & B#H--,t**,,T8SAAsH--& 7 6-6-GJ*$6))$555-6-IJ*00:::z0A.6x.@.@ +(D(3AA&AAA$6))$555+-((D(3AA&AAAA&01/B/B000,,,,,, ==8S:RSS;-6-GJ****85MNNN&D&xcDDVDDD!DM(C::6:::,,X666:,3*2J' 7%%dH5557.6 + 1TZ%> 1"&,,..  !D !#z < t|jjtr|jjdkrtdt| |5|j |||| |fi|} | r=|s*| s|r%| rtd|| cdddS#1swxYwYdS)a Imports data from ``tablib.Dataset``. Refer to :doc:`import_workflow` for a more complete description of the whole import process. :param dataset: A ``tablib.Dataset``. :param raise_errors: Whether errors should be printed to the end user or raised regularly. :param use_transactions: If ``True`` the import process will be processed inside a transaction. :param collect_failed_rows: If ``True`` the import process will create a new dataset object comprising failed rows and errors. This can be useful for debugging purposes but will cause higher memory usage for larger datasets. See :attr:`~import_export.results.Result.failed_dataset`. :param rollback_on_validation_errors: If both ``use_transactions`` and ``rollback_on_validation_errors`` are set to ``True``, the import process will be rolled back in case of ValidationError. :param dry_run: If ``dry_run`` is set, or an error occurs, if a transaction is being used, it will be rolled back. :param \**kwargs: Metadata which may be associated with the import. Nsupports_transactionsFrz%Batch size must be a positive integerusingT)rqrlr rpfeaturesr rirrintrr!import_data_inner has_errorshas_validation_errorsr) r5r rrrocollect_failed_rowsrollback_on_validation_errorsr^ db_connection connectionr1rrs r* import_datazResource.import_data sP  ##88:: 3355  / '  !8%! !   '$9 '& &.9'T?T : ,4:0#66 -:>*:ORS:S:SDEE E ();= Q Q Q  +T+"#   F" 8 8$$&& 82 87=6R6R6T6T 8 T7777                  s:ADD!Dc ( |}||_t||_|} t ||5|j|fi|dddn #1swxYwY||j n.#t$r!} | || |Yd} ~ nd} ~ wwxYw|j ||} t||_|r||j t|dD]\} } t!t#|j | } t |o |j j |5|||| d|j| | fi|}dddn #1swxYwY|j jrBt|j|j jkrMt ||5|||||j j|dddn #1swxYwYt|j|j jkrMt ||5|||||j j|dddn #1swxYwYt|j|j jkrBt ||5|||||dddn #1swxYwY|||jri|| | |j|r!|| |jd|r'tAj!|jdj"| | n^|j#rW|$| | |j#|r|| |j#|rtAj!|j#| | |j%tLj'ks |j j(r|)||j jrtt ||5|||||||||||||||dddn #1swxYwY t ||5|j*||fi|dddn #1swxYwYn.#t$r!} | || |Yd} ~ nd} ~ wwxYw|S) Nr2r)rrr)rr)rr)r!r)+rar diff_headersr total_rowsrlr!r _check_import_id_fieldsheadersrrriinstance_loader_classadd_dataset_headers enumeraterr=rrr/rZrrr[rr\rincrement_row_result_totalrappend_error_rowappend_failed_rowrrrr-append_invalid_rowr&r r(report_skippedappend_row_resultr )r5r rrrr9r^rr;rridata_rowrrs r*r6zResource.import_data_innerXs)&&((**"3355LL3355  >,-?}UUU 6 6""755f555 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6  ( ( 9 9 9 9 > > >  $ $VQ = = = = = = = = >*::4II LL  8  & &w 7 7 7$Wa00I 5I 5KAxc'/8<<==C,">4:+>'>m   #*.@&'-T_#                z" t,--1FFF4*-  ((.#('+z'<#) )               t,--1FFF4*-  ((.#('+z'<#) )               t,--1FFF4*-((.f)  - -j 9 9 9  ''3 0ABBB&H,,S*2CA2FGGG$0")"-3A3, ))!S*2MNNN&O,,S*2MNNN$0"3A3&)*DDD:,E((444 :  ,-?}UUU    &f!  &f!  &f!                >,-?}UUU = =!!'6< > >  $ $VQ = = = = = = = = > sB10B ? B1 BB1BB11 C;CC)F55F9 <F9 %H11H5 8H5 /%J  J$ 'J$ LL L A RR#&R#+S$<S S$SS$S S$$ T.T  Tc,|dS)N import_order_get_ordered_field_namesr`s r*rzResource.get_import_order,,^<<.s1XXX!!%<.s(QQQ5Q %+,,QQQr,rm)r5rgris r*get_export_headerszResource.get_export_headerss)..?? QQ-QQQQr,c*|Sr0rPr`s r*get_user_visible_fieldsz Resource.get_user_visible_fields s%%'''r,c#Kt|ts |Ed{VdS|jrz|jjs|d}t ||}t|jD] }| |dzEd{V!dS| |Ed{VdS)Nrr)ru) rr_prefetch_related_lookupsqueryorder_byr rvrange num_pagesget_pageiterator)r5rY paginatorindexs r* iter_querysetzResource.iter_queryset#s(H-- K           / K>* 3$,,T22!(D,?,?,A,ABBIy233 9 9$--eai8888888888 9 9 ((D4G4G4I4I(JJ J J J J J J J J Jr,c |j|fi|||}|j|fi|}|dd}||}t j|}||D]'}|j|fd|i|}| |(|j ||fi||S)z Exports a resource. :param queryset: The queryset for export (optional). :returns: A ``tablib.Dataset``. Nri)rg)rCrg) rZ get_querysetr^rrqtablibDatasetr~rnrAr\)r5rYr^rirCr rrs r*rLzResource.export4s 8..v...  ((**H%4%h99&99 ?D99 ))-)HH.111%%h//  C$$SRR-R6RRA NN1    (G66v666r,ct}|j||}||ur|S|jD]\}}||jkr|cSt d|ddS)Nz,cannot identify field for export with name '')rrrrrr)r5target_field_namerrrs r*rfzResource._select_fieldMs((  17;;   L!%!2!2!4!4   J E$555 6 P.es(CCCQAUNNaNNNr,)tuplerprirrrrA)r5 order_field order_fieldsdefined_fieldsdeclared_fieldsrrrs @r*rRz!Resource._get_ordered_field_names[s WTZ==CDD %gdj(.K.K.Qr(R(RRCCCC.CCCC!%!2!2!4!4 3 3 J&&5+>U.//&&s+++  '>ii001   r,r0)NN)NT)F)FFNFF)BrSrTrU__doc__r8rVrarcrergrlrqrvr~rrrrrrrrrrrrrrrrrrrQrrrrrrr r rrrrrr/r=r6rrVrZr\r^rdrjrnrqrsr~rLrfrRrrrBrKr,r*rXrXFs ###$[ [ [ [ ''[' /// ))) ***    $$$$ 1 1 1---+++PPPRV...."RV....$ . . . .HL****<::::           <<<,        44446 2 2 2***4>>>6   CCCCJTTT                 @ @ @ @    0000fffV!&+JJJJX{{{z======            0 0 0    YYYYRRRR(((KKK"2 R R R555"777,,,,,,,,r,rX) metaclassceZdZdZeZidddddddejdejd ej d ej d ej d ej d ej dejdejdejdejdejdejdejejejejejejdZedZedZeejfdZedZedZdZd dZdZedZdS)! ModelResourcezH ModelResource is Resource subclass for handling Django models. ManyToManyFieldget_m2m_widget OneToOneField get_fk_widgetr CharField DecimalField DateTimeField DateField TimeField DurationField FloatField IntegerFieldPositiveIntegerFieldBigIntegerFieldPositiveBigIntegerFieldPositiveSmallIntegerFieldSmallIntegerFieldSmallAutoField) AutoField BigAutoFieldNullBooleanField BooleanField JSONFieldc\tjtjt |S)z. Prepare widget for m2m field r() functoolspartialrrr")rRrs r*rzModelResource.get_m2m_widgets/   $,=e,D,D    r,ct|}t|o |jj}t jt j||S)z6 Prepare widget for fk and o2o fields )r)use_natural_foreign_keys)r"r+rirrrrForeignKeyWidget)rRrr)rs r*rzModelResource.get_fk_widgetsU "%(( $E * * Qsy/Q !  $%=    r,cR|}d}tt|ddr|}|j|}|1|}t |t rt|||}n|jjD]U}|j|j }|2|}t |t rt|||}nV ddl m }n#t$rGdd}YnwxYwt ||r tjS|S)a  Returns the widget that would likely be associated with each Django type. Includes mapping of Postgres Array field. In the case that psycopg2 is not installed, we consume the error and process the field regardless. r<get_internal_typeNr) ArrayFieldceZdZdS):ModelResource.widget_from_django_field..ArrayFieldN)rSrTrUrKr,r*rrsDr,r)rarpr WIDGETS_MAPrrstrr__mro__rSdjango.contrib.postgres.fieldsrrrSimpleArrayWidget)rRrNdefaultr internal_type widget_result base_classrs r*widget_from_django_fieldz&ModelResource.widget_from_django_fields GA2D99 : : 2//11M++M::  $"F&#&& 1-f--a00  k1   # 3 3J4G H H  ,*F!&#..9!5f!5!5a!8!8E -  EEEEEEE     !Z(( 100 s'C..DDc i}|jjr5|jj|i}||t |jt jr!|jdur|ddd|S)z= Returns widget kwargs for given field_name. T)coerce_to_string allow_blank) rirrr issubclassrrrblank)rRr django_field widget_kwargs cls_kwargss r*widget_kwargs_for_fieldz%ModelResource.widget_kwargs_for_field s  9  -*..z2>>J   , , , |-v/? @ @ R"d**  d4!P!P Q Q Qr,c D||}|||}|}|}|jjo ||jjv}t |t rd|vr|jjs |s |dz }d|d<||||di|||j} | S)zU Returns a Resource Field instance for the given Django model field. ___idT key_is_id)rrrreadonlyrrK) rrrirrrrDEFAULT_RESOURCE_FIELDr) rRrrr FieldWidgetrrrhas_custom_widget_declarationrs r*field_from_django_fieldz%ModelResource.field_from_django_fields 22<@@ 33J MM    I  A* 0A"A & |Z 0 0 .K''I6(1(  I)-M+ &**#;//// ( +   r,cH|jjjS)z Returns a queryset of all objects for this model. Override this if you want to limit the returned queryset. )rir)r'rr`s r*rzModelResource.get_queryset;s z'++---r,Nc4|jS)z1 Initializes a new Django model. )rir)rs r*rzModelResource.init_instanceBsz!!!r,c ||}|std|jDr|}t|}|jt|jj g}|rc| } |D]} | |  | dS#| wxYwdSdSdS)zH Reset the SQL sequences after new objects are imported c3@K|]}|jtjkVdSr0)r&r r%)rMrs r*rz-ModelResource.after_import..Ns=  ;<< TZ-.L ##**,,# ,--t,,,,-LLNNNNNFLLNNNN # # # # # #s CC'cRt|jdr |jjS|jS)Nname)r&rirrS)rRs r*get_display_namezModelResource.get_display_name^s( 39f % % "9> !|r,r0)rSrTrUrrrr CharWidget DecimalWidgetDateTimeWidget DateWidget TimeWidgetDurationWidget FloatWidget IntegerWidget BooleanWidget JSONWidgetrrVrrWidgetrrrrrr rrKr,r*rrs/#+ o W'  -  /  W' W' / g) -  5 70 "7#8 $W%: W2!" '/#$*-#1-'-K2  [   [ "18***[*X  [ [B..."""" ###,[r,rc @d}|i}|i}|i}|D]A\}}t|ts'td|dt |jBi|d|i}t dt f|} |jdz} d| i} | ||D]N\}} t| s'td|d t | jd |} || | | <Ot}|| |f| S) aM Factory for creating ``ModelResource`` class for given Django model. This factory function creates a ``ModelResource`` class dynamically, with support for custom fields, methods. :param model: Django model class :param resource_class: Base resource class (default: ModelResource) :param meta_options: Meta options dictionary :param custom_fields: Dictionary mapping field names to Field object :param dehydrate_methods: Dictionary mapping field names to dehydrate method (Callable) :returns: ModelResource class cfd}|S)Nc|Sr0rK)r5rfuncs r*wrapperzNmodelresource_factory.._create_dehydrate_func_wrapper..wrappers499 r,rK)rrs` r*_create_dehydrate_func_wrapperz=modelresource_factory.._create_dehydrate_func_wrappers#     r,Nzcustom_fields['z!'] must be a Field instance, got r)MetarXzdehydrate_methods['z'] must be callable, got dehydrate_) rrrrtyperSrrrar)r)resource_class meta_options custom_fieldsdehydrate_methodsrrrmeta_class_attrsrresource_class_nameresource_class_attrsrc method_namers r*modelresource_factoryres4    *0022 E%'' .*..E{{+..   8,777  #3 4 4D.:5 .../5577SS F /j//F||,//  0:// ,J,J6,R,R[)))I 9(>*;=Q R RRr,)@rlogging collectionsrrrrGrwarningsrrr django.confrdjango.core.exceptionsr r django.core.management.colorr django.core.paginatorr django.dbr rdjango.db.modelsrdjango.db.models.fields.relatedrdjango.db.models.queryrdjango.db.transactionrrdjango.utils.encodingrdjango.utils.safestringrdjango.utils.translationrrr<rr declarativerrrresultsrrr utilsr!r" getLoggerrSr addHandler NullHandlerr+r.rXrrrKr,r*rs###### ------ HHHHHHHH111111++++++))))))))######666666++++++JJJJJJJJ++++++------666666!!!!!!!!HHHHHHHH----------AAAAAAAA  8 $ $%'%''(((JJJJJJJJ6XXXXX-XXXXv"AAAAAH(AAAAAL! DSDSDSDSDSDSr,