�
��4]c@sw
dZd
dl
Z
ddlmZ
ddlmZ
ddlmZ
ddlmZ
ejd	d
�Zejd�
Z	ejd�
Z
ejd
�
Zd�Zd�Z
eedd�Zd�Zd�Zd�Zd�Zd�Zedd�Zedd�Zdejf
d��YZd�Zd�Zd�Zd�Zd�Zd�Z d �Z!d!�Z"d"�Z#d#�Z$dS($siFunctions used by compiler.py to determine the parameters rendered
within INSERT and UPDATE statements.

i����Ni
(
tdml(
telementsi(
texc(
tutiltREQUIREDs1

Placeholder for the value within a :class:`.BindParameter`
which is required to be present when the statement is passed
to :meth:`.Connection.execute`.

This symbol is typically used when a :func:`.expression.insert`
or :func:`.expression.update` statement is compiled without parameter
values present.

tISINSERTtISUPDATEtISDELETEcKs�|j}|j
}|j}|p?|p?|p?t|j�
d
k}|tkrct|_
t|_nB|tkr�t|_
t|_n!|t	kr�|s�t|_q�nz&|ttfkr�t
||
|�SWd|r�||_||_
||_nXdS(Ni
(tisinserttisupdatetisdeletetlentstackRtFalsetTrueRRt_get_crud_params(tcompilertstmttlocal_stmt_typetkwtrestore_isinserttrestore_isupdatetrestore_isdeletetshould_restore((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyt_setup_crud_params's*
	
	
	

	


	






	
	
c

sCg|_g|_
g|_g|_|jdkrw|
jdkrwg|
jjD]$}|t	||dd
t
�
f^qOS|
jr�|
jd�
n	|
j�
t||
�\�}}|jdkr�i}n"t
��
fd�|jD�
�
}g}�
dk	r
t||�
�||�
ni}|jrY
|
jrY
�
rY
t||
�
|||||�
n|jr�
|
jr�
t||
||�||||�	
n"t||
||�||||�	
|r�
rt|�
j�f
d��
D�
�
j|�
}	|	rtjddjd�|	D�
�
�
�
qn|
jr?t||
||�}n|S(	sP
create a set of tuples representing column/string pairs for use
    in an INSERT or UPDATE statement.

    Also generates the Compiled object's postfetch, prefetch, and
    returning column collections, used for default handling and ultimately
    populating the ResultProxy's prefetch_cols() and postfetch_cols()
    collections.

    trequiredic
3s4|]*}
�
s|
�
kr�|
�
tfV
qdS(
N(
R(t.0tkey(t_column_as_keytstmt_parameters(sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pys	<genexpr>rs

c
3s|]}
�|
�
V
qdS(
N((Rt
k(
R(sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pys	<genexpr>�ssUnconsumed column names: %ss, c
ss|]}
d|
V
qd
S(s%sN((Rt
c((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pys	<genexpr>�sN(t	postfetchtinsert_prefetchtupdate_prefetcht	returningtcolumn_keystNonet
parametersttabletcolumnst_create_bind_paramRt_has_multi_parameterst_key_getters_for_crud_columntdictt_get_stmt_parameters_paramsR	t_extra_fromst_get_multitable_paramsRtselect_namest_scan_insert_from_select_colst
_scan_colstsettintersectiont
differenceRtCompileErrortjoint_extend_values_for_multiparams(
RRRRt_getattr_col_keyt_col_bind_nameR&tvaluest
check_columnstcheck((RRsF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRFs~	
	
	
	
2	
		
	



































	


#	
cKsa|dkr|
j
}ntj||d
|
jd|�}t|_|r]|j||�
}n|S(Nttype_R(R%RR
t
BindParameterttypeRt_is_crudt_compiler_dispatch(RtcoltvaluetprocessRtnameRt	bindparam((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR)�s


	


csz|jrQ|
j
rQt|
j
�
��f
d
�}�f
d�}�f
d�}ntj}tjd�
}}|||fS(Nc
sEtj
|�
}
t|d
�r=|j�kr=|jj|
fS|
SdS(NR'(R
RthasattrR'RF(Rtstr_key(
t_et(sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR�s


c

s-|j�kr"|jj
|jfS|jSdS(
N(R'RFR(
RC(
RJ(sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR9�s

c

s1|j�kr&d
|jj
|jfS|jSdS(Ns%s_%s(R'RFR(
RC(
RJ(sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR:�s

R(R	R.R3R
Rtoperatort
attrgetter(RRRR9R:((
RJsF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR+�s
	
c	Css
t||
�\}	}
}}g|
j
D]}
|
jj||
�
^q%}|
j|_g}|
jr�t|�
}x<|
jjD]+}||kr{|j	r{|j
|�

q{q{Wnxk|D]c}||�
}||kr

||kr

|j|�

|j
|df�

q�t
||
|||�
q�W|ro
|j|�

|jj�|_t|jj�
td
�|D�
�
|j_ndS(Nc
ss|]\}
}|V
qdS(
N((RRCtexpr((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pys	<genexpr>
s(t_get_returning_modifiersR0R'Rtselectt_insert_from_selectt#include_insert_from_select_defaultsR3R(tdefaulttappendtpopR%t&_append_param_insert_select_hasdefaulttextendt	_generatettuplet_raw_columns(RRR&R9RR:R<R;Rtneed_pkstimplicit_returningtimplicit_return_defaultstpostfetch_lastrowidRFtcolstadd_select_colstcol_setRCRtcol_key((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR1�s,,
	
















c	Cs}t||
�\}	}
}}|
j
r�g|
j
D]}
||
�
^q.}t|�
}g|D]}
|
jj|
^qYg|
jjD]}|j|kr|^q}n|
jj}x�
|D]�
}||�
}||kr	
||kr	
t||
|||||
|||�

q�|jrP|j	rx
|	rx
|
s@
|s@
||
jj
k	rx
|
r_
t||
|||�
qMt||
|||�
qu|j
dk	r�
t||
||||�
qu|jdk	r�
|r�
||kr�
|jj|�

qM|j	sM|jj|�

qMqu|r||kr|jj|�

qu|j	ru||
jj
k	ru|jrut|�

quq�|jr�t||
||||�
q�q�WdS(
N(RNt_parameter_orderingR3R'RRR(t_append_param_parameterRtprimary_keyt_autoincrement_columnt!_append_param_insert_pk_returningt_append_param_insert_pkRRR%t_append_param_insert_hasdefaulttserver_defaultR#RSR tnullablet"_warn_pk_with_no_anticipated_valueR	t_append_param_update(RRR&R9RR:R<R;RRZR[R\R]Rtparameter_orderingtordered_keysRR^Ra((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR2
s`	"
 
2












		








	


	


	

c

Csb
|j|�
}
t
j|
�
rgt|||
d
|
tkd|
jsN||�
n
d||�
|	�}
n�t|
t
j�r�|
jj	r�|
j
�}
|j|
_n|jr�|r�|jj
|�

|j|
j�|	�
}
nq|r
||kr
|jj
|�

|j|
j�|	�
}
n4|js3
|jj
|�

n|j|
j�|	�
}
|j
||
f�

dS(NRRFs%s_m0(RTR
t_is_literalR)RR*t
isinstanceR?R@t_isnullt_cloneRdR#RSREt
self_groupR (RRRRaR&R:R[R\R;RRD((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRcx
s.















	


cCs6
|jd
k	r�|jjr|jjrl|jjsA|jjrl|j|j|�
}|j||f�

n|j	j|�

q2
|jj
r�|j||j|jjj�|�
f�

|j	j|�

q2
|j|t
||�f�

nJ||
jjks	
|jd
k	r
|j	j|�

n|js2
t|�

nd
S(s�Create a primary key expression in the INSERT statement and
    possibly a RETURNING clause for it.

    If the column has a Python-side default, we will create a bound
    parameter for it and "pre-execute" the Python function.  If
    the column has a SQL expression default, or is a sequence,
    we will add it directly into the INSERT statement and add a
    RETURNING element to get the new value.  If the column has a
    server side default or is marked as the "autoincrement" column,
    we will add a RETRUNING element to get at the value.

    If all the above tests fail, that indicates a primary key column with no
    noted default generation capabilities that has no parameter passed;
    raise an exception.

    N(RRR%tis_sequencetdialecttsupports_sequencestoptionaltsequences_optionalRERSR#tis_clause_elementtargRst"_create_insert_prefetch_bind_paramR'ReRiRjRk(RRRR;Rtproc((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRf�
s"










%
!

	cCs2t||
dd
|d|�}|jj|
�

|S(NRERF(R)R%R!RS(RRRERFtparam((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR{�
s


cCs2t||
dd
|d|�}|jj|
�

|S(NRERF(R)R%R"RS(RRRERFR}((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyt"_create_update_prefetch_bind_param�
s


t_multiparam_columnc
Bs eZ
eZd�Zd
�ZRS(cCsH||_d
|
j
|df|_
|
|_|
j|_|
j|_dS(Ns%s_m%di
(tindexRtoriginalRRR@(tselfR�R�((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyt__init__�
s

	

	

cCs1t|
t
�o0|
j|jko0|
j|jkS(
N(RpRRR�(R�tother((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyt__eq__�
s

(t__name__t
__module__Rt_is_multiparam_columnR�R�(((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR�
s
	cCs�|jst
jd
|�
�
nc|jjrG|j|jjj�|�
St||�}t|
t	j
�rut||�St||�SdS(Ns�INSERT value for column %s is explicitly rendered as a boundparameter in the VALUES clause; a Python-side value or SQL expression is required(
RRRR6RyRERzRsRRpRtInsertR{R~(RRRR�RRC((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyt _process_multiparam_default_bind�
s	






cCs�|jd
k	r(|jjsR|jjsR||
jjkrq|jjsR|jjrq|j|t	||�f�

n5|jd
kr�|j
d
kr�|jr�t|�

nd
S(s�
Create a bound parameter in the INSERT statement to receive a
    'prefetched' default value.

    The 'prefetched' value indicates that we are to invoke a Python-side
    default function or expliclt SQL expression before the INSERT statement
    proceeds, so that we have a primary key value available.

    if the column has no noted default generation capabilities, it has
    no value passed in either; raise an exception.

    N(
RRR%RtRuRvR'Ret"preexecute_autoincrement_sequencesRSR{RiRjRk(RRRR;R((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRg�
s



(cCsB
|jj
r�|jjr>
|jjs2|jjr>
|j|j|�
}|j||f�

|r||kr|jj|�

q�|j	s�|j
j|�

q�q>
n�|jjr"
|j|jjj
�|�
}|j||f�

|r
||kr
|jj|�

q>
|j	s>
|j
j|�

q>
n|j|t||�f�

dS(
N(RRRtRuRvRwRxRERSR#RdR RyRzRsR{(RRRR\R;RR|((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRh$s"





	





	cCs�|jj
rZ|jjr�|jjs2|jjr�|j}|j||j�f�

q�nV|jjr�|jj	j
�}|j||f�

n"|j|t||d
t�
f�

dS(NRE(
RRRtRuRvRwRxRSt
next_valueRyRzRsR{R
(RRRR;RR|((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRU?s

	




cCs)
|jdk	r�|jjr�|jjr�|j||j|jjj�|�
f�

|rx||krx|jj|�

q�|j	j|�

q%
|j|t
||�f�

n{|jdk	r�|r�||kr�|jj|�

q%
|j	j|�

n4|r%
|
jt
k	r%
||kr%
|jj|�

ndS(
N(tonupdateR%RtRyRSRERzRsR#R R~tserver_onupdatet_return_defaultsR(RRRR\R;R((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRlPs 


%





c
Cs�
td
�|j
�D�
�
}t�}	x�|
jD]�}
x�|
jD]�}||kr?|	j|
�

||||�
<||}tj|�
r�t|||d|t	kd||�
�}n(|j
j|�

|j|j
�|�
}|j||f�

q?q?Wq/Wx�|	D]�}
x�|
jD]�}||kr)
q
q
|jdk	r�
|jjr�
|jjr�
|j||j|jjj
�|�
f�

|j
j|�

q�
|j|t||d||�
�
f�

q
|jdk	r
|j
j|�

q
q
Wq

WdS(Nc
ss*|] \}
}tj
|
�
|fV
qdS(
N(R
t_clause_element_as_expr(RRR}((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pys	<genexpr>xs
RRF(R,titemsR3R.RtaddR
RoR)RR RSRERsR�R%RtRyRzR~R�(
RRRR<R:R9R;Rtnormalized_paramstaffected_tablest
tRRD((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR/lsJ

	




























cCs'
|}|g
}x
t|
j
d
�
D]�\}}g}x�|D]�\}}	||ksc|j|kr�||kru|n|j}
tj||
�
r�t||||
dd|j|d
f|�
}q�|j||
j�|�
}nt||
|||�}|j	||f�

q<W|j	|�

q#W|S(Ni
RFs%s_m%d(
t	enumerateR&RR
RoR)RERsR�RS(RRR;Rtvalues_0t
itrowt	extensionRCR}Rt	new_param((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR8�s(

	 











c	Cs�x�|j�D]�\}}||�
}|dk	rD|
j||�
q
tj|�
r}|jtjd|d
|j�
|�
}n|j|j�|�
}|j	||f�

q
WdS(NR>(
R�R%t
setdefaultR
RoRER?R@RsRS(	RR&RRR;RRt
vtcolkey((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyR-�s




$cCs�|jo$|j
o$|
jo$|
j}|oB|jjoB|
jj}|jr`|oZ|
j}n3|jr�|jjo�|
jjo�|
j}nt	}|r�|
jt
kr�t|
jj�
}q�t|
j�
}n|o�|jj
}||||fS(
N(Rtinlinet
_returningR*RuR[R'R�R	R
RR3RR](RRRZR[R\R]((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRN�s.	







	

	






c
CsXd
|jj
|j|jj
f}
t|jj�
dkrG|
d7}
ntj|
�

dS(Ns
Column '%s.%s' is marked as a member of the primary key for table '%s', but has no Python-side or server-side default generator indicated, nor does it indicate 'autoincrement=True' or 'nullable=True', and no explicit value is passed.  Primary key columns typically may not store NULL.i
s0
 Note that as of SQLAlchemy 1.1, 'autoincrement=True' must be indicated explicitly for composite (e.g. multicolumn) primary keys if AUTO_INCREMENT/SERIAL/IDENTITY behavior is expected for one of the columns in the primary key. CREATE TABLE statements are impacted by this change as well on most backends.(R'tfullnameRFRRdRtwarn(Rtmsg((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyRks


(%t__doc__RKtRR
RRtsymbolRRRRRRRR
R%R)R+R1R2RcRfR{R~t
ColumnElementRR�RgRhRURlR/R8R-RNRk(((sF/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/crud.pyt<module>s@





	

		u
	$	0	\	.	)		%				@	 		+