B KLc@sddZddlZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddl mZddl mZd d ZGd d d eZd dZddZddZddZddZddZddZddZddZdd Zdd!d"ZGd#d$d$eZd%d&Z dd'd(Z!d)d*Z"dd,d-Z#dd/d0Z$dd1d2Z%dd4d5Z&d6d7Z'd8d9Z(dd:d;Z)Gdd?Z+d@dAZ,ddCdDZ-dEdFZ.ddGdHZ/GdIdJdJeZ0dKdLZ1GdMdNdNeZ2GdOdPdPeZ3dQdRZ4dSdTZ5dUdVZ6ddWdXZ7dYdZZ8d[d\Z9d]d^Z:dd_d`Z;dadbZZ?GdgdhdheZ@GdidjdjeZAGdkdldleBZCdmeC_DGdndmdmeZEdaFdodpZGdqdrZHddtduZIGdvdwdwejJZKddxdyZLdzd{ZMdd|d}ZNd~dZOePdZQePdZReReQfddZSeTdZUddZVGdddeTZWddZXddZYddZZddZ[ddZ\ePdZ]ddZ^ddZ_ddZ`dS)zRoutines to help with the creation, loading and introspection of modules, classes, hierarchies, attributes, functions, and methods. N)update_wrapper) _collections)compat)exccCs*tjr|d}t}|||S)Nzutf-8)rpy3kencodehashlibZmd5updateZ hexdigest)xmr:lib/python3.7/site-packages/sqlalchemy/util/langhelpers.pymd5_hexs   rc@s.eZdZdZdZd ddZddZdd Zd S) safe_reraiseaKReraise an exception after invoking some handler code. Stores the existing exception info before invoking so that it is maintained across a potential coroutine context switch. e.g.:: try: sess.commit() except: with safe_reraise(): sess.rollback() ) warn_only _exc_infoFcCs ||_dS)N)r)selfrrrr__init__:szsafe_reraise.__init__cCst|_dS)N)sysexc_infor)rrrr __enter__=szsafe_reraise.__enter__cCsz|dkr0|j\}}}d|_|jsvtj||dnFtjsb|jrb|jdrbtd|jd|jdfd|_tj||ddS)N)with_tracebackrzfAn exception has occurred during handling of a previous exception. The previous exception is: %s %s r)rrrZraise_rwarn)rtype_value tracebackexc_type exc_valueZexc_tbrrr__exit__@s  zsafe_reraise.__exit__N)F)__name__ __module__ __qualname____doc__ __slots__rrr rrrrr&s  rccsLt}|g}x:|rF|}||kr&qn |||||VqWdS)N)setpopaddextend__subclasses__)clsseenstackrrrwalk_subclassesWs r.cCs6t|tjr|Syt|Stk r0d|SXdS)Nzunprintable element %r) isinstancer string_typesstr Exception)elementrrrstring_or_unprintablees  r4cCsdddtd|jDS)N css|]}|VqdS)N)lower).0nrrr qsz(clsname_as_plain_name..z ([A-Z][a-z]+))joinrefindallr!)r+rrrclsname_as_plain_nameosr=cCs.t|ts|j}n|}|j}t||}||kS)z1Return True if the two class methods don't match.)r/type __class__r!getattr)Zinstance_or_clsZagainst_methodZ current_cls method_nameZcurrent_methodrrrmethod_is_overriddenus   rBcCsBg}x4|j|j|jfD] }t|dr,|}||qWt|S)zrdecode a slice object as sent to __getitem__. takes into account the 2.5 __index__() method, basically. __index__)startstopstephasattrrCappendtuple)ZslcZretr rrr decode_slices  rJc 'spt|}xb|D]Ztftfddtd}x2|D]}||kr:|||VPq:WtdqWdS)Ncs t|S)N)r1)i)baserrz!_unique_symbols..iz&exhausted namespace for symbol base %s)r& itertoolschainrZitertools_imapranger( NameError)ZusedbasesZpoolsymr)rLr_unique_symbolss   rUccs.x(|r(||d@}||V||N}qWdS)z6Call the given function given each nonzero bit from n.rNr)fnr8brrrmap_bitss rXcsfdd}t|S)z'A signature-matching decorator factory.c st|st|stdt|}i}t||}t|d|dd|jf}t |dd\}}t ||d}| t |dd |j|d <d |}| |||d |j it|||j}t|d |j|_||_t||S)Nznot a decoratable functionrrtargetrV)rZrVF)groupednamezDdef %(name)s(%(args)s): return %(target)s(%(fn)s, %(apply_kw)s) r!__func__)inspect isfunctionismethodr2rinspect_getfullargspec!_update_argspec_defaults_into_envrIr!rUdictr format_argspec_plusr"_exec_code_in_envr@ __defaults__ __wrapped__r) rVspecenvnamesZ targ_namefn_namemetadatacode decorated)rZrrdecorates"     zdecorator..decorate)r)rZror)rZr decorators rpcCs|jrxg}d}xJ|jD]@}t|jdkrLd|}|||<|||d7}q||qWt|}t||d<tj|S|SdS)zCgiven a FullArgSpec, convert defaults to be symbol names in an env.r)builtins __builtin__zx%drrYN)defaultsr>r"rHlistrIr FullArgSpec)rhriZ new_defaultsrKargr\elemrrrrbs     rbcCst||||S)N)exec)rmrirkrrrres recCst|tr0|j}|}d|r|nd|j|f}n|}}d|}|dd}t|}|dd=t|dd}||d <d |} |t|j d } t | | | |} t |d r|j \} } | j }|d krd|j |jf}t|d| ||fd}|| _ n|j | _ d|ddd| _ | j tjkr*td| j ftjs>t |drb||j_ t |jd s~| |f|j_ n||_ t |d s~| |f|_ | S)zProduce a wrapping function for the given cls or classmethod. Rationale here is so that the __init__ method of the class can serve as documentation for the function. zConstruct a new :class:`%s` object. This constructor is mirrored as a public API function; see :func:`sqlalchemy%s` for a full usage and argument description.z.%szSThis function is mirrored; see :func:`sqlalchemy%s` for a description of arguments..rF)r[r\z5def %(name)s(%(args)s): return cls(%(apply_kw)s) )r+symbolr! _linked_toNz%s.%sz.. container:: inherited_member This documentation is inherited from :func:`sqlalchemy%s`; this constructor, :func:`sqlalchemy%s`, creates a :class:`sqlalchemy%s` object. See that class for additional details describing this subclass.r sqlalchemyz0public_factory location %s is not in sys.modulesr])r/r>rr!splitrrardr{r"rxrGr|r$inject_docstring_textrsplitrmodules ImportErrorpy2kr])rZlocationZclass_locationrVZ callable_docZ location_namerhrlrmrirnZ linked_toZlinked_to_locationZ linked_to_docrrrpublic_factorys\             rc@s.eZdZd ddZddZddZdd ZdS) PluginLoaderNcCs||_i|_||_dS)N)groupimplsauto_fn)rrrrrrr@szPluginLoader.__init__cCs|jdS)N)rclear)rrrrrEszPluginLoader.clearcCs||jkr|j|S|jr:||}|r:||j|<|Sx2t|jD]"}|j|krH|j|j|<|SqHWtd|j|fdS)NzCan't load plugin: %s:%s) rrrZimportlib_metadata_getrr\loadrZNoSuchModuleError)rr\loaderimplrrrrHs       zPluginLoader.loadcsfdd}||j|<dS)Ncs:t}x$dddD]}t||}qWt|S)Nryr)rimport_r~r@)modtoken) modulepathobjnamerrr\s z#PluginLoader.register..load)r)rr\rrrr)rrrregister[szPluginLoader.register)N)r!r"r#rrrrrrrrr?s rcCsjy tj}Wn.tk r8t|}|dt|dfSX|j}|j}t|j d|t|j |@fSdS)Nrr) r^ZCO_VARKEYWORDSAttributeErrorrrabool__code__ co_argcountrt co_varnamesco_flags)rVZco_varkeywordsrhconargsrrr_inspect_func_argses  rcCs|dk}|rt}|jdd}|o>> format_argspec_plus(lambda self, a, b, c=3, **d: 123) {'args': '(self, a, b, c=3, **d)', 'self_arg': 'self', 'apply_kw': '(self, a, b, c=c, **d)', 'apply_pos': '(self, a, b, c, **d)'} rrrNz%s[0]rYrcSsd|S)N=r)r rrrrM3rNz%format_argspec_plus..)Z formatvaluecSsd|S)Nrr)r rrrrM<rN)rself_arg apply_posapply_kwapply_pos_proxiedapply_kw_proxiedrz)rcallablerainspect_formatargspeclenrc) rVr[rhrrrrZ num_defaultsZ name_argsZdefaulted_valsrrrrrrdsj"    (        rdcCsr|tjkr$|rdnd}|rdnd}n:y t||dStk r\|rHdnd}|rTdnd }YnXtd|||||d S) a format_argspec_plus with considerations for typical __init__ methods Wraps format_argspec_plus with error handling strategies for typical __init__ cases:: object.__init__ -> (self) other unreflectable (usually C) -> (self, *args, **kwargs) z(self)rz())r[z(self, *args, **kwargs)zself, *args, **kwargsz(*args, **kwargs)z*args, **kwargs)rrrrrr)objectrrdrrc)methodr[rZproxiedrrrformat_argspec_initUs   rrcsfdd}|S)zA class decorator that will copy attributes to a proxy class. The class to be instrumented must define a single accessor "_proxied". csd fdd }fdd}x6D].}t||rFtd||ft||||q(Wx6D].}t||r~td||ft||||q`Wx:D]2}t||rtd||ft||||ddqW|S) NFc st|}t|}d|ji}t||}t|dd}|j|d|d|d|dd}|rld |}|d <nd |}t|||j}t|d |j|_t |j d fd|_ |rt |}|S)Nr!F)r[rrrr)r\rrrrzLdef %(name)s(%(args)s): return target_cls.%(name)s(%(apply_kw_proxied)s) target_clszWdef %(name)s(%(args)s): return %(self_arg)s._proxied.%(name)s(%(apply_kw_proxied)s)r]zS.. container:: class_bases Proxied for the %s class on behalf of the %s class.r) r@rrar"rbrdr!rerfrr$ classmethod) r\clslevelrVrhriZcaller_argspecrlrmZproxy_fn)proxy_cls_sphinx_namertarget_cls_sphinx_namerr instruments4       z:create_proxy_methods..decorate..instrumentcsRj|d}|dk r.t|jdfd}nd}dd|i}t|d|id}|S)NzS.. container:: class_bases Proxied for the %s class on behalf of the %s class.rzdef set_(self, attr): self._proxied.%(name)s = attr def get(self): return self._proxied.%(name)s get.__doc__ = doc getset = property(get, set_)r\rgetset)rrrr$re)r\attrrrmr)rrrrrmakeprops z8create_proxy_methods..decorate..makepropz class %s already has a method %sT)r)F)rGrsetattr)r+rrmethZprop) attributes classmethodsmethodsrrrrrros$-      z&create_proxy_methods..decorater)rrrrrrror)rrrrrrrcreate_proxy_methodsvscrcCsJy t|Stk rD|tjkr2dgdddfSdgdddfSYnXdS)zinspect.getargspec with considerations for typical __init__ methods Wraps inspect.getargspec with error handling for typical __init__ cases:: object.__init__ -> (self) other unreflectable (usually C) -> (self, *args, **kwargs) rNrkwargs)rrarrr)rrrrgetargspec_inits   rcCs t|tjr|js|jS|SdS)zSAdjust the incoming callable such that a 'self' argument is not required. N)r/r MethodTyperr])Z func_or_clsrrrunbound_method_to_callablesrc sV|dkrg}n t|}tg}t}d}xt|D]\}}yt|j} Wntk rhw:Yq:X| j rzt | j p|d} |dkr| j r| j }| r| | j d| q| | j ddn$|fdd| j d| D| r:|ddt| j | d| j Dq:Wg} | fdd|D|dk rdt|rd| d dt|Dxr|D]f\} } | |krqny6t| }|k r|| kr| d | |fWntk rYnXqnW|r@x`|D]X\} } y6t| }|k r || kr | d | |fWntk r8YnXqWd jjd | fS) z}Produce a __repr__() based on direct association of the __init__() specification vs. same-named attributes present. Nrrcsg|] }|fqSrr)r7rv)missingrr 'sz generic_repr..cSsg|]\}}||fqSrr)r7rvdefaultrrrr-sc3s|]}tt|dVqdS)N)reprr@)r7rv)objrrr95szgeneric_repr..cSsg|] }t|qSr)r)r7valrrrr8sz%s=%rz%s(%s)z, )rto_listr OrderedDict enumeraterrarrrsrrr)rr ziprGr@itemsrHr2r?r!r:)rZ additional_kwZ to_inspectZ omit_kwargZpos_argsZkw_argsZvargsrKZinsprhZ default_lenoutputrvZdefvalrr)rrr generic_reprs`        rc@s6eZdZdZdZddZddZd dd Zd d Zd S)portable_instancemethodz_Turn an instancemethod into a (parent, name) pair to produce a serializable callable. )rZr\r __weakref__cCs|j|j|jdS)N)rZr\r)rZr\r)rrrr __getstate__Xsz$portable_instancemethod.__getstate__cCs&|d|_|d|_|dd|_dS)NrZr\rr)rZr\rr)rstaterrr __setstate___s  z$portable_instancemethod.__setstate__rcCs|j|_|j|_||_dS)N)rrZr!r\r)rrrrrrrdsz portable_instancemethod.__init__cOs ||jt|j|j||S)N)r rr@rZr\)rrvkwrrrris z portable_instancemethod.__call__N)r) r!r"r#r$r%rrrrrrrrrPs  rcs tjrt|tjrtS|ht|j}x|r|}tjrbt|tjrLq*fdd|jD}nfdd|jD}x |D]}| | |q|Wtj r|j dks*t |dsq*n|j dks*t |dsq*x2fdd|DD]}| | |qWq*WtS) aReturn an unordered sequence of all classes related to cls. Traverses diamond hierarchies. Fibs slightly: subclasses of builtin types are not returned. Thus class_hierarchy(class A(object)) returns (A, object), not A plus every class systemwide that derives from object. Old-style classes are discarded and hierarchies rooted on them will not be descended. c3s&|]}|krt|tjs|VqdS)N)r/r ClassType)r7_)hierrrr9sz"class_hierarchy..c3s|]}|kr|VqdS)Nr)r7r)rrrr9srqr*rrcsg|]}|kr|qSrr)r7r)rrrrsz#class_hierarchy..)rrr/rrrt__mro__r'rrHr(rr"rGr*)r+ZprocessrrSrWsr)rrclass_hierarchyns4          rccsFt|}x8|D]0}x*|jD] }||jkr||j|fVPqWqWdS)ziterate all the keys and attributes associated with a class, without using getattr(). Does not use getattr() so that class-sensitive descriptors (i.e. property.__get__()) are not called. N)dirrr)r+keyskeyrrrriterate_attributess    r self.proxyc s0|r |}n$dkrdfddt|D}x|D]}y&t||}t|dsPw4t|d|}Wntk rtw4YnXy2t|} t| d} t| ddd} Wntk rd } d } YnXd t} |dk r||ipi} t | | y|j | |_ Wntk rYnXt || |q4WdS) z9Automates delegation of __specials__ for a proxying type.N)r%__del____getattribute__Z __metaclass__rrcs6g|].}|dr|drt|s|kr|qS)__) startswithendswithrG)r7r )into_clsskiprrrs    z0monkeypatch_proxied_specials..rr]rrz(self, *args, **kw)z (*args, **kw)z?def %(method)s%(fn_args)s: return %(name)s.%(method)s%(d_args)s) rr@rGrrrarrlocalsZexec_rfr)rZfrom_clsrZonlyr\Z from_instanceZdundersrrVrhZfn_argsZd_argspyrir)rrrmonkeypatch_proxied_specialss<        rcCst|d|t|d|kS)z;Return True if the two methods are the same implementation.r])r@)Zmeth1Zmeth2rrrmethods_equivalents rc Csx|s|stdt|tr(t||r(|St|p>ddt|D}tt|}tj}t|trd|}n|svt}tj}nt|}||||r|St|t s|tjkrdpd}td||d |fGdd d t }|rd |j |_ t} x`t |D]T\} } | |krtd | t| s0td | | ft|| t| | | qW|| |r^|Std d || dS)aEnsure basic interface compliance for an instance or dict of callables. Checks that ``obj`` implements public methods of ``cls`` or has members listed in ``methods``. If ``required`` is not supplied, implementing at least one interface method is sufficient. Methods present on ``obj`` that are not in the interface are ignored. If ``obj`` is a dict and ``dict`` does not meet the interface requirements, the keys of the dictionary are inspected. Keys present in ``obj`` that are not in the interface will raise TypeErrors. Raises TypeError if ``obj`` does not meet the interface criteria. In all passing cases, an object with callable members is returned. In the simple case, ``obj`` is returned as-is; if dict processing kicks in then an anonymous class is returned. obj A type, instance, or dictionary of callables. cls Optional, a type. All public methods of cls are considered the interface. An ``obj`` instance of cls will always pass, ignoring ``required``.. methods Optional, a sequence of method names to consider as the interface. required Optional, a sequence of mandatory implementations. If omitted, an ``obj`` that provides at least one interface method is considered sufficient. As a convenience, required may be a type, in which case all public methods of the type are required. z2a class or collection of method names are requiredcSsg|]}|ds|qS)r)r)r7r rrrrsz as_interface..zany ofzall ofz%r does not implement %s: %sz, c@seZdZdZdS)z(as_interface..AnonymousInterfacezA callable-holding shell.N)r!r"r#r$rrrrAnonymousInterface6srZ Anonymousz%r: unknown in this interfacez%r=%r is not callablez,dictionary does not contain required keys %sN)rr/r>r&roperatorgegt intersectionrcr:rr!dictlike_iteritemsrrr staticmethodr() rr+rZrequiredZ interfaceZ implementedZcompliesZ qualifierrfoundrrrrr as_interfacesH!        rc@s6eZdZdZd ddZddZddZed d ZdS) memoized_propertyz2A read-only @property that is only evaluated once.NcCs||_|p|j|_|j|_dS)N)fgetr$r!)rrrrrrrQs zmemoized_property.__init__cCs&|dkr |S|||j|j<}|S)N)rrr!)rrr+resultrrr__get__Vszmemoized_property.__get__cCst||jdS)N)rresetr!)rrrrr_reset\szmemoized_property._resetcCs|j|ddS)N)rr')r+rr\rrrr _szmemoized_property.reset)N) r!r"r#r$rrr rr rrrrrNs  rcsfdd}t|S)zDecorate a method memoize its return value. Best applied to no-arg methods: memoization is not sensitive to argument values, and will always return the same value even when called with different arguments. cs<|f||fdd}j|_j|_||jj<S)NcsS)Nr)ar)rrrmemopsz6memoized_instancemethod..oneshot..memo)r!r$r)rrrr )rV)rroneshotms   z(memoized_instancemethod..oneshot)r)rVr r)rVrmemoized_instancemethodds rc@sNeZdZdZdZeZddZddZddZ Gd d d e Z e d d Z d S) HasMemoizedzyA class that maintains the names of memoized elements in a collection for easy cache clearing, generative, etc. rcCs"x|jD]}|j|dqWdS)N)_memoized_keysrr')rrwrrr_reset_memoizationss zHasMemoized._reset_memoizationscCs"x|jD]}||jkstqWdS)N)rrAssertionError)rrwrrr_assert_no_memoizationss z#HasMemoized._assert_no_memoizationscCs||j|<|j|hO_dS)N)rr)rrrrrr_set_memoized_attributes z#HasMemoized._set_memoized_attributec@s"eZdZdZdddZddZdS)zHasMemoized.memoized_attributezTA read-only @property that is only evaluated once. :meta private: NcCs||_|p|j|_|j|_dS)N)rr$r!)rrrrrrrs z'HasMemoized.memoized_attribute.__init__cCs8|dkr |S|||j|j<}|j|jhO_|S)N)rrr!r)rrr+rrrrrs z&HasMemoized.memoized_attribute.__get__)N)r!r"r#r$rrrrrrmemoized_attributes rcsfdd}t|S)z+Decorate a method memoize its return value.csN|f||fdd}j|_j|_||jj<|jjhO_S)NcsS)Nr)r r)rrrr szBHasMemoized.memoized_instancemethod..oneshot..memo)r!r$rr)rrrr )rV)rrr s  z4HasMemoized.memoized_instancemethod..oneshot)r)r+rVr r)rVrrs z#HasMemoized.memoized_instancemethodN)r!r"r#r$r% frozensetrrrrrrrrrrrrr{src@s$eZdZdZdZddZddZdS) MemoizedSlotszApply memoized items to an object using a __getattr__ scheme. This allows the functionality of memoized_property and memoized_instancemethod to be available to a class using __slots__. rcCs t|dS)N)r)rrrrr_fallback_getattrszMemoizedSlots._fallback_getattrcsdrtnptdrBtd}t||Stdrztdfdd}j|_|SSdS)NZ _memoizedz_memoized_attr_%sz_memoized_method_%scs6||fdd}j|_j|_t|S)NcsS)Nr)r r)rrrr sz8MemoizedSlots.__getattr__..oneshot..memo)r!r$r)rrr )rVrr)rrr s    z*MemoizedSlots.__getattr__..oneshot)rrrGr@rr$r)rrrr r)rVrrr __getattr__s    zMemoizedSlots.__getattr__N)r!r"r#r$r%rrrrrrrsrcCsDt|tjr<|}|dkr$dS|dkr0dStd|t|S)N)trueZyesZonyt1T)ZfalseZnoZoffr8f0FzString is not true/false: %r)r/rr0stripr6 ValueErrorr)rrrrasbools   r"csfdd}|S)zqReturn a callable that will evaluate a string as boolean, or one of a set of "alternate" string values. cs|kr |St|SdS)N)r")r)textrr bool_or_valuesz"bool_or_str..bool_or_valuer)r#r$r)r#r bool_or_strs r%cCs|dkr |St|S)zCoerce to integer.N)int)rrrrasintsr'cCsj|dkr |}||krft|tr,t|||sf||dk rf|tkrV|rVt||||<n|||||<dS)zIf 'key' is present in dict 'kw', coerce its value to type 'type\_' if necessary. If 'flexi_bool' is True, the string '0' is considered false when coercing to boolean. N)r/r>rr")rrrZ flexi_booldestrrrcoerce_kw_types  r)cs$t|}|ftfdd|DS)zbProduce a tuple structure that is cacheable using the __dict__ of obj to retrieve values c3s&|]}|jkr|j|fVqdS)N)r)r7k)rrrr9sz"constructor_key..)rrI)rr+rjr)rrconstructor_keysr+cs0t|}|fdd||D|||S)zInstantiate cls using the __dict__ of obj as constructor arguments. Uses inspect to match the named arguments of ``cls``. c3s&|]}|jkr|j|fVqdS)N)r)r7r*)rrrr9+sz#constructor_copy..)rr difference)rr+rrrjr)rrconstructor_copy"sr-cs&tjtdfdd}|S)z%Return a threadsafe counter function.rc s tSQRXdS)N)nextr)counterlockrr_next7szcounter.._next)r threadingLockrOcount)r1r)r/r0rr/0s  r/cCst|dr*|jdk r$t|jtr$tS|jSt|tr8tp:t}||trJtS||trXtS||trftSt|drttSt|drtSt|drtS|SdS)zGiven an instance or class, guess if it is or is acting as one of the basic collection types: list, set and dict. If the __emulates__ property is present, return that preferentially. __emulates__NrHr(r&)rGr5 issubclassr&r/r>rtrc)ZspecimenrZisarrrduck_type_collection>s&         r7cCs^t||r|St|trBtd|ddd|Dt|fntd||t|fdS)Nz8Argument '%s' is expected to be one of type %s, got '%s'z or css|]}d|VqdS)z'%s'Nr)r7r rrrr9fsz"assert_arg_type..z6Argument '%s' is expected to be of type '%s', got '%s')r/rIr ArgumentErrorr:r>)rvZargtyper\rrrassert_arg_type_s  $r9cstjrtdrFtSn(tdr0StdrFtStdtdddkrntdtdrfdd }|Std rtfd d  DStddS) z?Return a (key, value) iterator for almost any dict-like object.r iteritems __getitem__rNzObject '%r' is not dict-likeiterkeysc3s$xD]}||fVq WdS)N)r<)r)dictlikegetterrriteratorsz$dictlike_iteritems..iteratorrc3s|]}||fVqdS)Nr)r7r)r>rrr9sz%dictlike_iteritems..) rrrGrtrr:iterr@rr)r=r?r)r=r>rros        rcs(eZdZdZfddZddZZS) classpropertyaAA decorator that behaves like @property except that operates on classes rather than instances. The decorator is currently special when using the declarative module, but note that the :class:`~.sqlalchemy.ext.declarative.declared_attr` decorator should be used for this purpose with declarative. cs$tt|j|f|||j|_dS)N)superrArr$)rrrvr)r?rrrszclassproperty.__init__cCs ||S)N)r)Zdescrr+rrrrszclassproperty.__get__)r!r"r#r$rr __classcell__rr)r?rrAs  rAc@s$eZdZddZddZddZdS)hybridpropertycCs||_||_dS)N)rr)rrrrrrszhybridproperty.__init__cCs$|dkr||}|S||SdS)N)rr)rinstanceownerZclsvalrrrrs zhybridproperty.__get__cCs ||_|S)N)r)rrrrr classlevelszhybridproperty.classlevelN)r!r"r#rrrGrrrrrDsrDc@s(eZdZdZddZddZddZdS) hybridmethodz/Decorate a function as cls- or instance- level.cCs||_|_||_dS)N)rr]r)rrrrrrs zhybridmethod.__init__cCs*|dkr|j||jS|j||SdS)N)rrr?r)rrErFrrrrszhybridmethod.__get__cCs ||_|S)N)r)rrrrrrGszhybridmethod.classlevelN)r!r"r#r$rrrGrrrrrHsrHc@s.eZdZd ddZddZddZdd ZdS) _symbolNcCs@t|tjst|dkr t|}tt|}||_|r<||_ |S)zConstruct a new named symbol.N) r/rr0rhashr&__new__rIr\r$)rr\r canonicalvrrrrKs z_symbol.__new__cCst|jdt|ffS)Nr )r{r\r&)rrrr __reduce__sz_symbol.__reduce__cCst|S)N)r)rrrr__str__sz_symbol.__str__cCs d|jS)Nz symbol(%r))r\)rrrr__repr__sz_symbol.__repr__)NN)r!r"r#rKrNrOrPrrrrrIs rIr{c@s6eZdZdZiZejZdddZ e d ddZ dS) r{aA constant symbol. >>> symbol('foo') is symbol('foo') True >>> symbol('foo') A slight refinement of the MAGICCOOKIE=object() pattern. The primary advantage of symbol() is its repr(). They are also singletons. Repeated calls of symbol('name') will all return the same instance. The optional ``doc`` argument assigns to ``__doc__``. This is strictly so that Sphinx autoattr picks up the docstring we want (it doesn't appear to pick up the in-module docstring if the datamember is in a different module - autoattribute also blows up completely). If Sphinx fixes/improves this then we would no longer need ``doc`` here. Nc Cs@|j0|j|}|dkr2t||||j|<}|SQRXdS)N)_locksymbolsrrI)r+r\rrLrTrrrrKs  zsymbol.__new__FcCsbx>|D]2\}}||kr|S|r0||jkr0|S||kr |Sq W|dkrLdStd||fdS)aGiven a user parameter, parse the parameter into a chosen symbol. The user argument can be a string name that matches the name of a symbol, or the symbol object itself, or any number of alternate choices such as True/False/ None etc. :param arg: the user argument. :param choices: dictionary of symbol object to list of possible entries. :param name: name of the argument. Used in an :class:`.ArgumentError` that is raised if the parameter doesn't match any available argument. :param resolve_symbol_names: include the name of each symbol as a valid entry. NzInvalid value for '%s': %r)rr\rr8)r+rvchoicesr\Zresolve_symbol_namesrTZchoicerrrparse_user_argumentszsymbol.parse_user_argument)NN)F) r!r"r#r$rRrr2r3rQrKrrTrrrrr{s   cCst|_td7adS)zAssign a '_creation_order' sequence to the given instance. This allows multiple instances to be sorted in order of creation (typically within a single thread; the counter is not particularly threadsafe). rN)_creation_order)rErrrset_creation_order"s rVcOs<y |||Stk r6tdtddYnXdS)zXexecutes the given function, catches all exceptions and converts to a warning. z%s('%s') ignoredrrN)r2rrr)rrrrrrwarn_exception/s rWcCs>y$t||krd|d|S|SWntk r8|SXdS)Nz%s...r)rr)rZlen_rrrellipses_string:s  rYcs0eZdZdZfddZddZddZZS)_hash_limit_stringa/A string subclass that can only be hashed on a maximum amount of unique values. This is used for warnings so that we can send out parameterized warnings without the __warningregistry__ of the module, or the non-overridable "once" registry within warnings.py, overloading memory, cs@||d|}tt|||}td|t||f|_|S)Nz6 (this warning may be suppressed after %d occurrences)z%s_%d)rBrZrKrJ_hash)r+rnumrZ interpolatedr)r?rrrKOs  z_hash_limit_string.__new__cCs|jS)N)r[)rrrr__hash__Wsz_hash_limit_string.__hash__cCst|t|kS)N)rJ)rotherrrr__eq__Zsz_hash_limit_string.__eq__)r!r"r#r$rKr]r_rCrr)r?rrZDs  rZcCs(|rttj||dn t|tjdS)zdIssue a warning. If msg is a string, :class:`.exc.SAWarning` is used as the category. )rmN)_warnings_warnr SAWarning)msgrmrrrr^srcCs |rt|d|}t|tjdS)z\Issue a warning with a parameterized string, limiting the number of registrations. N)rZr`rra)rbrrrr warn_limitedks rdcCsyt|}Wn&tk r&d}YnBd}Yn4Xx0|dk rftd|jddrf|j}|d7}q8W|dk rtj |||ddntj ||dddS)Nrz^(?:sqlalchemy\.|alembic\.)r!rr) stacklevel) r _getframer!r;match f_globalsrf_backwarningsr)messagecategoryreframerrrr`us  r`csgfdd}|S)zNDecorate the given function to be a no-op after it is called exactly once.cs>}r:}y |||Sr2d|YnXdS)Nr)r'insert)rvrZ strong_fnZonce_fn)rVonceretry_on_exceptionrrgos  zonly_once..gor)rVrprqr)rVrorpr only_onces rrz%sqlalchemy/([a-z_]+/){0,2}[a-z_]+\.pyzunit(?:2|test2?/)cCshd}t|d}x"||kr2|||r2|d7}qWx"||krV|||rV|d8}q6W|||dS)atChop extraneous lines off beginning and end of a traceback. :param tb: a list of traceback lines as returned by ``traceback.format_stack()`` :param exclude_prefix: a regular expression object matching lines to skip at beginning of ``tb`` :param exclude_suffix: a regular expression object matching lines to skip at end of ``tb`` rr)rsearch)tbZexclude_prefixZexclude_suffixrDendrrrchop_tracebacks    rvcCs$d|}t}t|||dS)Nz&def set(obj, value): obj.%s = valuer&)rcopyrx)Zattrnamermrirrr attrsetters  rxcs(eZdZdZfddZddZZS)EnsureKWArgTypezYApply translation of functions to accept \**kw arguments if they don't already. c sv|j}|r^xR|D]J}t||}|r||}t|}|js||||<} t||| qWtt | |||dS)N) Z ensure_kwargr;rgrrar _wrap_w_kwrrBryr) r+ZclsnamerSZclsdictZfn_regrr rVrhwrapped)r?rrrs   zEnsureKWArgType.__init__csfdd}t|S)Ncs|S)Nr)rvr)rVrrwrapsz(EnsureKWArgType._wrap_w_kw..wrap)r)rrVr|r)rVrrzs zEnsureKWArgType._wrap_w_kw)r!r"r#r$rrzrCrr)r?rrys rycCsjt|drt||S|}|jj|_t|dr4|j|_t|jdrT|jjrT|jj|_n|jrb|j|_|SdS)zAugment functools.update_wrapper() to work with objects with a ``__call__()`` method. :param fn: object with __call__ method r!r"r$N)rGrr?r!r"rr$)wrapperrVZ_frrr wrap_callables     r~cCsd|kr|dSd}gg}d}t|}x||kr||}|dkr|dkr~||dkr~||ddkr~|dd|d7}q|dN}n*|dkr|dkr|gn|d||d7}q*Wdd|DS)aParse a dotted identifier with accommodation for quoted names. Includes support for SQL-style double quotes as a literal character. E.g.:: >>> quoted_token_parser("name") ["name"] >>> quoted_token_parser("schema.name") ["schema", "name"] >>> quoted_token_parser('"Schema"."Name"') ['Schema', 'Name'] >>> quoted_token_parser('"Schema"."Name""Foo"') ['Schema', 'Name""Foo'] "ryrrrzcSsg|]}d|qS)r)r:)r7rrrrr'sz'quoted_token_parser..)r~rrH)rrridxZlvcharrrrquoted_token_parsers$  $    rcstfdd}|S)Ncs:|jdk r|jpd}|r0t|fddD}||_|S)Nrcsi|] }|qSrr)r7param)r#rr 0sz8add_parameter_text..decorate..)r$inject_param_text)rVr)paramsr#rrro-s z$add_parameter_text..decorate)rr)rr#ror)rr#radd_parameter_text*s rcCsN|dd}t|dkr|S|\}}|ds@|dt|St|SdS)N rr5)r~rrtextwrapdedent)r#Z split_text firstlineZ remainingrrr_dedent_docstring7s   rcCst|pd}|d}t|dkr,|dt|d}|drP|ddddt|D}|dd|t|t|d}|d||||d}d |S)NrrrrcSsg|]\}}|s|qSr)r )r7r\linerrrrLsz)inject_docstring_text..) rr~rrHrrrnrminr:)doctextZ injecttextposlinesZ injectlinesZblanksZ inject_posrrrrCs      rz(\s+):param (.+?):c Cst|}g}d}x|r|}t|}|dkr|r|dd}||krdt|dd}|rt d|d} | rdt| d}|||}nV|r| d|dgd}n<| s| ||dgd}n| dr| ||gq| |qWd|S) Nr*r5rz(\s+)\Srrz::) collectionsdeque splitlinespopleft _param_regrgrlstriprr;r)rstriprrHr:) rZ inject_paramsZdoclinesrZ to_injectrr rindentZm2rrrrXs6  rcCst|dkrdSt|dk}|r,|ddn|dd|dd}dd|D}|r`d|Sd d|dd|dfSdS) zTrims a list of strings from the middle and return a string of up to four elements. Strings greater than 11 characters will be truncatedrNrrYrzcSs,g|]$}t|dkr$d|ddn|qS) z%s..N)r)r7r\rrrrsz$repr_tuple_names..z, z %s, ..., %s)rr:)rjflagZresrrrrepr_tuple_namess  ( rcCsBy(ddlm}ddlm}ddlm}dStk r<dSXdS)Nr)cimmutabledict) cprocessors) cresultproxyTF)r}rrrr)rrrrrrhas_compiled_exts   r)N)N)FF)T)T)rrr)rNr)NNrN)NNN)TN)N)rX)N)Nr)ar$r functoolsrr r^rOrr;rrrrjrrrrrrrr.r4r=rBrJrUrXrprbrerrrrrrrdrrrrrrrrrrrrrrrr"r%r'r)r+r-r/r7r9rpropertyrArDrHr&rIr!r{rUrVrWrYZ text_typerZrrdr`rrcompileZ_SQLA_REZ _UNITTEST_RErvr>ZNoneTyperxryr~rrrrrrrrrrrr s    1  # W& + 6 p % n H3 9 V<)    !D      ,   +