j.GUdZddlmZddlZddlZddlmZmZddl m Z ddl m Z ej rddlZddlmZdd lmZneZd Zd ed <d Zd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZ d ed<dZ!d ed<dZ"d ed<d Z#d ed!<d"Z$d ed"<d#Z%d ed#<d$Z&d ed%<dZ'd&ed'<Gd(d)Z(e(Z)ej r'ej*ej+ej,ej,fe(dfZ- dLdMd0Z.dNd2Z/dOd4Z0dPd:Z1e d;Gd<d=Z2Gd>d?Z3Gd@dAZ4GdBdCe5Z6GdDdEeej7FZ8GdGdHeej7FZ9dIZ:dJZ;dKZ, c8g|]}d|S)z'{}')rZ).0r^s r0 z%Bookmark.__repr__..s%;m;m;mRTFMM"r2r0rRrRs~ ' ' ' 'pppp """"Xr2rRc`eZdZdZdZddZddZdd Zedd Z e ddZ dS) BookmarksaBContainer for an immutable set of bookmark string values. Bookmarks are used to causally chain sessions. See :meth:`Session.last_bookmarks` or :meth:`AsyncSession.last_bookmarks` for more information. Use addition to combine multiple Bookmarks objects:: bookmarks3 = bookmarks1 + bookmarks2 c,t|_dSr.)r[ _raw_valuesrhs r0r1zBookmarks.__init__s$;;r2r+r@c ddttt |jS)razrb)rZrfmapreprrgrsrhs r0rizBookmarks.__repr__s@+11 IIc$t'7 8 899 : :   r2r4c*t|jS)z-True if there are bookmarks in the container.)r4rsrhs r0rkzBookmarks.__bool__sD$%%%r2r3ct|tr.|s|S|}|j|jz|_|StS)z!Add multiple containers together.)r6rq __class__rsr7)r/r3rets r0__add__zBookmarks.__add__sM eY ' '   ..""C".1BBCOJr2t.FrozenSet[str]c|jS)zThe raw bookmark values. You should not need to access them unless you want to serialize bookmarks. :returns: immutable list of bookmark string values :rtype: frozenset[str] )rsrhs r0 raw_valueszBookmarks.raw_valuess r2rSt.Iterable[str]c||}g}|D]}t|ts/tdt | |dn&#t $r}td|d|d}~wwxYw||t||_ |S)aCreate a Bookmarks object from a list of raw bookmark string values. You should not need to use this method unless you want to deserialize bookmarks. :param values: ASCII string values (raw bookmarks) :type values: Iterable[str] z)Raw bookmark values must be str. Found {}rUz The value z is not ASCIIN) r6r@ TypeErrorrZtyperVrXrYrWr[rs)clsrSobjr]valuer_s r0from_raw_valueszBookmarks.from_raw_valuesscee  $ $EeS)) @!++16$u+++>+>@@@ K W%%%%% K K K !Be!B!B!BCCJ K   U # # # ##I.. sA,, B6B  BNrmrn)r3rqr+rq)r+r|)rSrr+rq) r:r;r<r=r1rirkr{ror~ classmethodrr>r2r0rqrqs  '''    &&&&    X  [r2rqceZdZdZddZeddZedd Zedd Zee d d Z ddZ dS) ServerInfozE Represents a package of information relating to a Neo4j server. addressr protocol_versionVersionc0||_||_i|_dSr.)_address_protocol_version _metadata)r/rrs r0r1zServerInfo.__init__7s !1!r2r+c|jS)z/ Network address of the remote server. )rrhs r0rzServerInfo.address<s }r2c|jS)z Bolt protocol version with which the remote server communicates. This is returned as a :class:`.Version` object, which itself extends a simple 2-tuple of (major, minor) integers. )rrhs r0rzServerInfo.protocol_versionBs %%r2r@cPt|jdS)zS Server agent string by which the remote server identifies itself. server)r@rgetrhs r0agentzServerInfo.agentKs" 4>%%h//000r2zfThe connection id is considered internal information and will no longer be exposed in future versions.c6|jdS)z= Unique identifier for the remote server connection. connection_id)rrrhs r0rzServerInfo.connection_idRs ~!!/222r2metadatadictr,c:|j|dS)z Update server information with extra metadata. This is typically drawn from the metadata received after successful connection initialisation. N)rupdate)r/rs r0rzServerInfo.updateZs h'''''r2N)rr rr)r+r )r+rrm)rrr+r,) r:r;r<r=r1rorrrrrrr>r2r0rr3s"""" X &&&X&111X1 ZDEE33EEX3 ((((((r2rcNeZdZfdZfdZdZd dZed dZxZ S) rcHt||Sr.)super__new__)rvrys r0rzVersion.__new__dswwsA&&&r2cd|jjtS)Nz{}{})rZryr:rri)r/rys r0rizVersion.__repr__gs,}}T^4egg6F6F6H6HIIIr2cRdtt|S)N.)rfrur@rhs r0__str__zVersion.__str__jsxxC'''r2r+bytesctd}t|D]\}}d|cxkrdksntdt|trHt |ddz|| dz <t |d|dz dz|| dz <t |dz|| dz <t |S)NrzToo many version componentsr) bytearray enumeraterYr6listintr)r/birs r0to_byteszVersion.to_bytesms aLLdOO + +DAq::::A:::: !>???!T"" +!u --1"q& 1" 6771"q& E NN1"q& Qxxr2rct|}t|dkrtd|ddks |ddkrtdt|d|dS)Nrz.Byte representation must be exactly four bytesrrz!First two bytes must contain zeror)rlenrYr)rrs r0 from_byteszVersion.from_bytesysk aLL q66Q;;MNN N Q4199! @AA Aquae$$$r2)r+r)rrr+r) r:r;r<rrirrrr __classcell__)rys@r0rrbs'''''JJJJJ(((    %%%[%%%%%r2rcVeZdZdZejd dZejd dZd S) BookmarkManageraClass to manage bookmarks throughout the driver's lifetime. Neo4j clusters are eventually consistent, meaning that there is no guarantee a query will be able to read changes made by a previous query. For cases where such a guarantee is necessary, the server provides bookmarks to the client. A bookmark is an abstract token that represents some state of the database. By passing one or multiple bookmarks along with a query, the server will make sure that the query will not get executed before the represented state(s) (or a later state) have been established. The bookmark manager is an interface used by the driver for keeping track of the bookmarks and this way keeping sessions automatically consistent. Configure the driver to use a specific bookmark manager with :ref:`bookmark-manager-ref`. This class is just an abstract base class that defines the required interface. Create a child class to implement a specific bookmark manager or make use of the default implementation provided by the driver through :meth:`.GraphDatabase.bookmark_manager()`. .. note:: All methods must be concurrency safe. .. versionadded:: 5.0 .. versionchanged:: 5.3 The bookmark manager no longer tracks bookmarks per database. This effectively changes the signature of almost all bookmark manager related methods: * :meth:`.update_bookmarks` has no longer a ``database`` argument. * :meth:`.get_bookmarks` has no longer a ``database`` argument. * The ``get_all_bookmarks`` method was removed. * The ``forget`` method was removed. .. versionchanged:: 5.8 Stabilized from experimental. previous_bookmarkst.Collection[str] new_bookmarksr+r,cdS)zHandle bookmark updates. :param previous_bookmarks: The bookmarks used at the start of a transaction :param new_bookmarks: The new bookmarks retrieved at the end of a transaction Nr>r/rrs r0update_bookmarksz BookmarkManager.update_bookmarkss  r2cdS)zuReturn the bookmarks stored in the bookmark manager. :returns: The bookmarks for the given database Nr>rhs r0 get_bookmarkszBookmarkManager.get_bookmarkss r2Nrrrrr+r,r+r)r:r;r<r=abcabstractmethodrrr>r2r0rrsg%%N              r2r) metaclassceZdZdZejd dZejje_ejd dZejje_d S) AsyncBookmarkManagera}Same as :class:`.BookmarkManager` but with async methods. The driver comes with a default implementation of the async bookmark manager accessible through :attr:`.AsyncGraphDatabase.bookmark_manager()`. .. versionadded:: 5.0 .. versionchanged:: 5.3 See :class:`.BookmarkManager` for changes. .. versionchanged:: 5.8 Stabilized from experimental. rrrr+r,c KdSr.r>rs r0rz%AsyncBookmarkManager.update_bookmarkss r2c KdSr.r>rhs r0rz"AsyncBookmarkManager.get_bookmarkss  r2Nrr) r:r;r<r=rrrrrr>r2r0rrs       /?G    ,9AMr2rc t|}|jrtd|jrtd|jt kr-td|jt|jtkrt}t}n|jtkrt}t}n|jtkrt}t}n|jtkrt}t}n|jt krt}t}nk|jt"krt}t}nLtd|jttttt t"g|||fS)Nz$Username is not supported in the URIz$Password is not supported in the URIz+Uri scheme {!r} have been renamed. Use {!r}zURI scheme {!r} is not supported. Supported URI schemes are {}. Examples: bolt://host[:port] or neo4j://host[:port][?routing_context])rusernamerrAr$rrZrrrrrrrrrrr)uriparsed driver_type security_types r0parse_neo4j_urirsg c]]F I !GHHH I !GHHH }/// !N!U!UV\Vceu!v!vwww / ) )! 0 A A A! = 0 0 0! , * * *" 0 B B B" = 1 1 1" ,  "i"p"p M7& 8'   " "     v --r2c|tS|ttfvr$d|}t||S)NzUnsupported access mode {})rr rZr) access_modemsgs r0check_access_moder sE; 555*11+>> %%% r2c |siSi}t|d}|D]^}||}t|dkrtd|d|d|d|d}|std|d |d |d |||<_|S) zP Parse the query portion of a URI to generate a routing context dictionary. Trz&Duplicated query parameters with key 'z ', value 'z' found in query string ''rzInvalid parameters:'=z' in query string 'z'.)rrr)querycontextr)key value_listrs r0parse_routing_contextrs  G%&&J_ z??a  $${~{~{~AKAKAKMRMRMR&STT T1  o$$[^[^[^`e`e`eglglgl%mnn n Nr2r.)r?r@rAr@r(r%r+r#)rFr@r+r#)rKr@r+r#) r&r%r'r%r(r%r$r%r)r*r+r#)=r= __future__rrtypingt urllib.parserr_metar exceptionsr TYPE_CHECKINGtyping_extensionster _Protocol addressingr objectr __annotations__rrrrrrrrrrrrrrrr r!r# AuthTokenUnionTupleAny_TAuthrErJrNrPrRrqrtuplerABCMetarrrrrr>r2r0rsM"#"""""  ******?""""777777#######I$ ####% %%%%* ****, ,,,,*DDDDD+&,,,,&<<<<