Rǻi2HUddlmZddlmZmZddlmZddlmZ ddl m Z ddl mZddlmZdd lmZdd lmZmZmZdd lmZdd lmZmZmZmZe j<d Ze e!zZ"de#d<Gdde$e jJZ&GddeZ'Gdde'Z(Gdde'Z)y)) annotations)ABCabstractmethod)reduce)xor)_typing)BrokenHydrationObject) iter_items)BrokenRecordError)NodePath Relationship)Point)DateDateTimeDurationTime_Tz t.TypeAlias_KceZdZUdZded<ddZdZfdZdfd ZeZ ddZ d Z dfd Z dfd Z ddd Zdd ZdddZddZddZdZddZxZS) Recordz Immutable, ordered collection of key-value pairs. It is generally closer to a :func:`collections.namedtuple` than to a :class:`OrderedDict` in as much as iteration of the collection will yield values rather than keys. z tuple[str] _Record__keyscg}g}t|D]'\}}|j||j|)tj||}t||_|SN)r appendtuple__new__r)clsiterablekeysvalueskeyvalueinsts I/opt/lhia/marcimex/agent/venv/lib/python3.12/site-packages/neo4j/_data.pyrzRecord.__new__;s^$X. !JC KK  MM%  !}}S&)Dk  c@td|d|j|dS)NzRecord contains broken data at z ('z'))r r)selfindexs r&_broken_record_errorzRecord._broken_record_errorEs+ -eWC E8J7K2 N  r'c~t||}t|tr|j ||j |Sr)super __getitem__ isinstancer r+error)r)r*r$ __class__s r&_super_getitem_singlezRecord._super_getitem_singleJs9#E* e2 3++E2 C r'c djdt|jt|dD}d|j j d|dS)N c30K|]\}}|d|yw)=N).0fieldr$s r& z"Record.__repr__..Qs' ugQui  sTstrict<>)joinziprr-__iter__r1__name__)r)fieldsr1s r&__repr__zRecord.__repr__PsX # UW-/!   4>>**+1VHA66r'ct|tj}t|tj}|rV|rTtjtj|}t |t |k(xrt |t |k(S|r;tjtj|}t |t |k(S|r;tjtj|}t |t |k(StS)a Compare this record with another object for equality. In order to be flexible regarding comparison, the equality rules for a record permit comparison with any other Sequence or Mapping. :param other: :returns: )r/tSequenceMappingcastlistdictNotImplemented)r)othercompare_as_sequencecompare_as_mappings r&__eq__z Record.__eq__[s) ;'qyy9 #5FF199e,E:e,JdtE{1J J FF1::u-E:e, , FF199e,E:e, ,! !r'cZtttt|j Sr)r xor_operatormaphashitemsr)s r&__hash__zRecord.__hash__sslCdjjl$;<>#dF4"@A A 5JJsOE--e4 4  sA00 A<;A<c |jjt|}d|cxkrt |krn|S|j |S|S#t$r|cYSwxYw)z Obtain a value from the record by key. The ``default`` is returned if the key does not exist. :param key: a key :param default: default value :returns: a value r)rr*str ValueErrorlenr2r)r#defaultr*s r&getz Record.getsg KK%%c#h/E  !D !N--e4 4N  N s$A AAc8t|tr7d|cxkrt|jkr|St |t |t|t r |jj |St|#t$r}t||d}~wwxYw)zi Return the index of the given item. :param key: a key :returns: index rN) r/intrbrr^r`r*raKeyError TypeError)r)r#excs r&r*z Record.indexs c3 C*#dkk** +S/ !*S/ ! S ! -{{((--C.  -sm, -sA?? B BBc^ |j|}||S#ttf$r|cYSwxYw)aI Obtain a single value from the record by index or key. If no index or key is specified, the first value is returned. If the specified item does not exist, the default value is returned. :param key: an index or key :param default: default value :returns: a single value )r*r^rhrcs r&r$z Record.values; JJsOE; H% N s ,,c,t|jS)zU Return the keys of the record. :returns: list of key names )rJrrVs r&r!z Record.keyss DKK  r'c|r1g}|D](} |j|}|j||*|St|S#t$r|jdYTwxYw)aA Return the values of the record. The values returned can optionally be filtered to include only certain values by index or key. :param keys: indexes or keys of the items to include; if none are provided, all values will be included :returns: list of values N)r*rrhrJr)r!dr#rZs r&r"z Record.valuessl A && 3AHHT!W%  &HDz  #HHTN#s?AAcT|r@g}|D]7} |j|}|j|j|||f9|St t |Dcgc]"}|j||j |f$c}S#t$r|j|dfYwxYwcc}w)z~ Return the fields of the record as a list of key and value tuples. :returns: a list of value tuples N)r*rrrhrangerbr2rns r&rUz Record.itemss A 88 3AHHdkk!nd1g67  8H3t9% [[^T77: ;   *HHc4[)*  sB'B%B"!B"c`tjt|j|S)a Return the record as a dictionary. Return the keys and values of this record as a dictionary, optionally including only certain values by index or key. Keys provided in the items that are not in the record will be inserted with a value of :data:`None`; indexes provided that are out of bounds will trigger an :exc:`IndexError`. This function provides a convenient but opinionated way to transform the record into a mostly JSON serializable format. It is mainly useful for interactive sessions and rapid prototyping. The transformation works as follows: * Nodes are transformed into dictionaries of their properties. * No indication of their original type remains. * Not all information is serialized (e.g., labels and element_id are absent). * Relationships are transformed to a tuple of ``(start_node, type, end_node)``, where the nodes are transformed as described above, and type is the relationship type name (:class:`str`). * No indication of their original type remains. * No other information (properties, element_id, start_node, end_node, ...) is serialized. * Paths are transformed into lists of nodes and relationships. No indication of the original type remains. * :class:`list` and :class:`dict` values are recursively transformed. * Every other type remains unchanged. * Spatial types and durations inherit from :class:`tuple`. Hence, they are JSON serializable, but, like graph types, type information will be lost in the process. * The remaining temporal types are not JSON serializable. You will have to implement a custom serializer should you need more control over the output format. :param keys: Indexes or keys of the items to include. If none are provided, all values will be included. :returns: dictionary of values, keyed by field name :raises: :exc:`IndexError` if an out-of-bounds index is specified. )RecordExporter transformrKrU)r)r!s r&dataz Record.datas)h))$ztzz4/@*ABBr')r7)returnr`)rMobjectrvbool)rvzt.Iterator[t.Any])r#z _K | slicervt.Anyr)r#r`rdrwrvry)r#rrvrg)rN)r#rrdrwrvry)rvz list[str])r!rrvz list[t.Any])r!rrvzdict[str, t.Any])rB __module__ __qualname____doc____annotations__rr+r2rD__str__rPrWrAr.rer*r$r!r"rUru __classcell__)r1s@r&rr0ss   7G"0= 5 5  5(!(&!0 *4Cr'rc eZdZdZedZy)DataTransformerzEAbstract base class for transforming data from one form into another.cy)z{ Transform a value, or collection of values. :param x: input value :returns: output value Nr7)r)xs r&rtzDataTransformer.transform4sr'N)rBrzr{r|rrtr7r'r&rr1sO  r'rceZdZdZdZy)rsz:Transformer class used by the :meth:`.Record.data` method.c t|trjt|St|tr]jt|j |j jjt|jfSt|trj|j g}t|jD]i\}}|jj|j j|jj|j|dzk|St|ttt t"t$t&fr|St|t(j*t(j,fr't/|}|t1j|St|t(j2r*t/|}|fd|j5DS|S)Nrc3JK|]\}}|j|fywr)rt)r8kr[r)s r&r:z+RecordExporter.transform..Ws#D$!Q4>>!,-Ds #)r/r rtrKr start_noder1rBend_noderrY relationshipsrnodesr`rrrrrrFrGSettyperSrHrU)r)rpathrZ relationshiptyps` r&rtzRecordExporter.transformAsv a >>$q'* * < (tALL12 $$tAJJ/0  4 NN1<<01D#,Q__#= << DNN<+A+A+J+JKL DNN1771q5>:; <K CdHhG HH AJJ. /q'Cs4>>1-. . 199 %q'CD!'')DD DHr'N)rBrzr{r|rtr7r'r&rsrs>s Dr'rsc.eZdZdZeddZdZdZy)RecordTableRowExporterz;Transformer class used by the :meth:`.Result.to_df` method.cF|jddjddS)N\z\\.z\.)replace)r#s r&_escape_map_keyz&RecordTableRowExporter._escape_map_key_s {{4(00e<\}}j|j|jD]}|@yw)prefixN _transformrrU)r8rr[itemr)s r&r:z3RecordTableRowExporter.transform..fsW 1$..q1(eg     sAA)r/rFrHrrU)r)rrs` r&rtz RecordTableRowExporter.transformcs@!QYY'''1g     r'ct|trJd|jd|ji}|j fd|j D|St|t rd|jd|jjd|jjd|jji}|j fd|j D|St|ttfr|iSt|tjrtfd t!|DSt|tj"r+t%|}|fd |j DS|iS) Nz ().element_idz ().labelsc36K|]\}}d||fyw)z().prop.Nr7r8rr[rs r&r:z4RecordTableRowExporter._transform..t%Itq!6((1#.2Iz ->.element_idz->.start.element_idz->.end.element_idz->.typec36K|]\}}d||fyw)z->.prop.Nr7rs r&r:z4RecordTableRowExporter._transform..}rrc3~K|]4\}}j|d|jD]}|6yw)z[].rN)rrU)r8rZr[rrr)s r&r:z4RecordTableRowExporter._transform..sWAq OOA3/,%' s:=c 3K|]C\}}j|dj|jD]}|Eyw)z{}.rNr)r8rr[rrr)s r&r:z4RecordTableRowExporter._transform..scAq OOd.B.B1.E-FG,%' sA A )r/r element_idlabelsupdaterUrrrr1rBrr`rFrGrKrYrHr)r)rrresrs` ` r&rz!RecordTableRowExporter._transformns` a (-(!,,()$ahhC JJIqwwyI IJ < ((-(!,,(-. 0G0G(+,ajj.C.C('"AKK$8$8 C JJIqwwyI IJ D#; 'A;  1:: &%aL 199 %q'CGGI A; r'N)r#r`rvr`)rBrzr{r| staticmethodrrtrr7r'r&rr\s!E==  %r'rN)* __future__rabcrr functoolsroperatorrrRr rF_codec.hydrationr _confr exceptionsr graphr rrspatialrtimerrrrTypeVarrrgr`rr}rrHrrrsrr7r'r&rs"#(3) QYYt_)K~CUAII~CB  c  _<7_7r'