ó
‹EYc@s
dZd
dl
mZmZmZ
d
dlmZ
ddl
mZmZmZ	m
Z
mZmZm
Z

ddlmZ
eje
jjddƒ
d	e
jf
d
„ƒYƒ
ƒ
Zdejf
d„ƒYZd
ef
d„ƒYZdeefd„ƒYZd„Zdef
d„ƒYZdS(s‚Dynamic collection API.

Dynamic collections act like Query() objects for read operations and support
basic add/delete mutation.

i(tlogtutiltexc(
t	operatorsi
(t
attributestobject_sessionR
t
strategiest
object_mapperRt
properties(
tQuerytlazytdynamict
DynaLoaderc
BseZ
d„ZRS(
cCst|_
|js+tjd
|jƒ
‚
ntj||
dtdtdtd|jj	d|jj
d|jjd|jjƒ
dS(	NstOn relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False.t	useobjecttuselistt
impl_classt
target_mappertorder_bytquery_classtbackref(
tTruetis_class_levelRRtInvalidRequestErrortparent_propertyRt_register_attributetDynamicAttributeImpltmapperRRtback_populates(tselfR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytinit_class_attributes
	
	











(t__name__t
__module__R(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRsRcBs
eZ
eZeZeZeZdd„
Z	e
jd
„
Zde
j
d„Zejd„ƒ
Zejd„ƒ
Zdd„
Zdd„
Zd„Ze
jded„Zdd	„
Zd
„Zd„Ze
jd„
Ze
j
d
„
Ze
jd„
Ze
jd„
Ze
jd„
Ze
jd„
ZRS(c	Kswtt
|ƒj|
||||
||_||_|sFt|_n-t|jƒkrd||_nt	|ƒ
|_dS(
N(
tsuperRt__init__RRt
AppenderQueryRt
AppenderMixintmrotmixin_user_query(	Rtclass_tkeyttypecallabletdispatchRRRtkw((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR!5s

	
	



cCs7|tj
@s#|j|
tjƒjS|j||
ƒSdS(
N(RtSQL_OKt_get_collection_historytPASSIVE_NO_INITIALIZEtadded_itemsR(Rtstatetdict_tpassive((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytgetCs



cCs=|tj
@s |j|
|ƒjS|j|
|ƒ}|jSdS(
N(RR+R,R.tadded_plus_unchanged(RR/R0t	user_dataR1thistory((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytget_collectionJs


	


c

Cstj
|tjƒS(
N(RtEventt	OP_APPEND(
R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt
_append_tokenSsc

Cstj
|tjƒS(
N(RR7t	OP_REMOVE(
R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt
_remove_tokenWscCs˜|dkr!|j
|
|ƒ}n|j|ƒ

x/|jjD]!}||
||pV|jƒ}q;W|jr”|dk	r”|jtj	|ƒ
|
t
ƒ
ndS(
N(tNonet_modified_eventt	add_addedR)tappendR9ttrackparenttsethasparentRtinstance_stateR(RR/R0tvaluet	initiatortcollection_historytfn((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytfire_append_event[s



cCs–|dkr!|j
|
|ƒ}n|j|ƒ

|jrb|dk	rb|jtj|ƒ
|
tƒ
nx-|jj	D]}||
||pŠ|j
ƒ
qoWdS(
N(R<R=tadd_removedR@RARRBtFalseR)tremoveR;(RR/R0RCRDRERF((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytfire_remove_evenths



cCs_|j|
j
kr.t||
ƒ|
j
|j<n|
j||tjƒ
t||j<|
j
|jS(
N(R'tcommitted_statetCollectionHistoryR=Rt	NEVER_SETR(RR/R0((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR=us
	




cCsI|r|j|jkrdS|r2|dkr2dS|j|
||ƒ
dS(
N(tparent_tokenR<t
_set_iterable(RR/R0RCRDR1t	check_oldtpop((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytsetƒs



c
Cs
t|ƒ
}|
j
r3tj|j|
|ƒƒ
}n|j|
|ƒ}|
j
sZ|j}n|j|jƒ
}tj}|j|ƒ
}	||ƒ
j	|	ƒ
}
|j	|	ƒ
}x9|D]1}||
kr¯|j
|
||dd
|ƒ

q¯q¯Wx*|D]"}|j|
||dd
|ƒ

qëWdS(NRE(
tlistthas_identityR
tIdentitySetR2R=R.tuniontintersectiont
differenceRGR<RK(
RR/R0titerabletadaptert
new_valuestold_collectionREtidsett	constantst	additionstremovalstmember((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRPs&

	

	

	









c

Os
tƒ‚
dS(
N(
tNotImplementedError(Rtargstkwargs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytdelete§s
cCstd
ƒ
‚
dS(Ns7Dynamic attributes don't support collection population.(
Rc(RR/R0RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytset_committed_valueªs
cCs|j|
|ƒ}|j
ƒS(
N(R,t
as_history(RR/R0R1t
c((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytget_history®s

cCs;|j|
|ƒ}g|j
D]}tj|ƒ
|f^qS(
N(R,t	all_itemsRRB(RR/R0R1Rit
x((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytget_all_pending²s
cCse|j|
j
kr%|
j
|j}nt||
ƒ}|
jr]|tj@r]t||
d
|ƒ
S|SdS(Ntapply_to(R'RLRMRURtINIT_OK(RR/R1Ri((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR,¼s


cCs)||k	r%|j|
|||ƒ
ndS(
N(
RG(RR/R0RCRDR1((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR?Çs
cCs)||k	r%|j|
|||ƒ
ndS(
N(
RK(RR/R0RCRDR1((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRJÌs
cCs |j|
|||d
|ƒ

dS(NR1(
RJ(RR/R0RCRDR1((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRRÑsN( RRRtuses_objectsRItaccepts_scalar_loadertsupports_populationt
collectionR<R!RtPASSIVE_OFFR2R-R6R
tmemoized_propertyR9R;RGRKR=RSRPRfRgRjRmR,R?RJRR(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR/s0





	
			R#cBsteZ
d
Zd„Zd
„Zeed„ƒZd„Zd„Zd„Z	d
d„
Z
d„Zd„Zd	„Z
RS(cCs‘tt
|ƒj|
jdƒ
|jƒ|_}|
|_t|ƒ
}|j	|jj
}|j|d
tƒ

|_
|jjr|jj|_ndS(Ntalias_secondary(R R#R!RR<tobjtinstancetattrRt_propsR't_with_parentRIt
_criterionRt	_order_by(RRyR/RxRtprop((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR!Ùs


	




c
Csgt|j
ƒ
}
|
dk	rI|jrI|
jrI|j
|
krI|
jƒ
ntj|j
ƒ
s_dS|
SdS(
N(RRxR<t	autoflushtflushtorm_utilRU(Rtsess((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytsessionçs






c
CsdS(
N(
R<(t
sRl((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt<lambda>ðsc
CsW|j}
|
dkr@t|jjtj|jƒ
tjƒj	ƒ
St|j
|
ƒ
ƒ
SdS(
N(RƒR<titerRyR,RRBRxR-R.t_clone(RR‚((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt__iter__òs
	



cCsZ|j}|dkr@|jjtj|jƒ
tjƒj|
ƒ
S|j	|ƒ
j
|
ƒ
SdS(
N(RƒR<RyR,RRBRxR-tindexedR‡t__getitem__(RtindexR‚((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRŠûs
	

	

c
CsW|j}
|
dkr@t|jjtj|jƒ
tjƒj	ƒ
S|j
|
ƒ
jƒSdS(
N(RƒR<tlenRyR,RRBRxR-R.R‡tcount(RR‚((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR
s
	



cCs³|j}|
dkr[t|ƒ
}
|
dkr[tjd
tj|ƒ
|jjfƒ
‚
q[n|j	r‚|j	|jj
d|
ƒ

}n|
j|jj
ƒ
}|j|_|j
|_
|S(NsŒParent instance %s is not bound to a Session, and no contextual session is established; lazy load operation of attribute '%s' cannot proceedRƒ(RxR<Rtorm_exctDetachedInstanceErrorRtinstance_strRyR'RRtqueryR|R}(RR‚RxR‘((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR‡

s	




%	

cCsFx?|
D]7}|jj
tj|jƒ
tj|jƒ
|dƒ
qWdS(
N(RyR?RRBRxt
instance_dictR<(Rtiteratortitem((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytextend%
s


	

cCs5|jj
tj|jƒ
tj|jƒ
|
dƒ
dS(
N(RyR?RRBRxR’R<(RR”((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR?+
s
	

cCs5|jj
tj|jƒ
tj|jƒ
|
dƒ
dS(
N(RyRJRRBRxR’R<(RR”((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRJ0
s
	

N(RRR<RR!RƒtpropertyRˆRŠRR‡R•R?RJ(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR#Ös
											R"c
BseZ
dZRS(
sBA dynamic query that supports basic collection storage operations.(RRt__doc__(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR"6
s
c
Cs*d
|j}
t
|
t|fi
|d6ƒS(sAReturn a new class with AppenderQuery functionality layered over.tAppenderR(RttypeR#(tclstname((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR%:
s

RMcBs\eZ
dZdd
„
Zed„ƒ
Zed„ƒ
Zd„Zd„Z	d„Z
d„ZRS(	sDOverrides AttributeHistory to receive append/remove events directly.cCsŽ|rTt|
|ƒj
tƒ
}tj|ƒ
|_|j|_|j|_t|_	n6tjƒ|_tjƒ|_tjƒ|_t|_	dS(
N(
R"RRIR
tOrderedIdentitySettunchanged_itemsR.t
deleted_itemsRt_reconcile_collection(RRyR/Rntcoll((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR!C
s








c

Cst|j
j|jƒ
ƒ
S(
N(RTR.RWR(
R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR3P
sc

Cs%t|j
j|jƒ
j|jƒ
ƒ
S(
N(RTR.RWRRž(
R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRkT
s
c
CsŠ|jrH|j
j|jƒ
}
|jj|jƒ
}|jj|ƒ
}n|j
|j|j}
}}tjt|
ƒ
t|ƒ
t|ƒ
ƒS(
N(	RŸR.RYRRžRXRtHistoryRT(Rtaddedtdeletedt	unchanged((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRhY
s
	






	
	
cCst|j
ƒ
|
S(
N(RTR.(RR‹((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR‰h
s
cCs|jj
|
ƒ

dS(
N(R.tadd(RRC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR>k
s
cCs6|
|jkr"|jj
|
ƒ

n|jj|
ƒ

dS(
N(R.RJRžR¥(RRC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRHn
s

N(RRR—R<R!R–R3RkRhR‰R>RH(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRM@
s

			N(R—tRR
RtsqlRRRRRRRŽRR‘R	tclass_loggertRelationshipPropertytstrategy_fortAbstractRelationshipLoaderRt
AttributeImplRtobjectR#R"R%RM(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt<module>
s

4

§`