H`Tc@sPddlZddlmZddlmZddlmZddlmZmZm Z ddl m Z ddl m Z mZddlmZmZdd l mZmZdd lmZd d lmZddlZdd lmZmZddlmZeef\ZZdejfdYZ dejfdYZ!ddfZ"dS(iN(texc(ttypes(tinspect(tMetaDatatIntegertString(t Inspector(tenginestfixtures(tTabletColumn(teq_tassert_raises_message(ttestingi(tconfig(tDDLtIndex(teventt HasTableTestcBs&eZeZedZdZRS(cCs5td|tdtdttdtddS(Nt test_tabletidt primary_keytdatai2(R R RtTrueR(tclstmetadata((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt define_tabless cCsYtjjD}tjjj|ds0ttjjj|d sOtWdQXdS(NRtnonexistent_table(Rtdbtbegintdialectt has_tabletAssertionError(tselftconn((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_has_tables(t__name__t __module__Rt __backend__t classmethodRR#(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyRstComponentReflectionTestcBs5eZd.ZZeZedZedZ edZ edZ e j jdZe j jdZe j jdZe jd.dd.dZe j jd Ze j je j jd Ze j je j jd Ze j jd Ze j je j jd Ze j je j jdZd.ddZe j jdZe jdZ e j jdZ!e j jdZ"e j je jdZ#e j je j jdZ$e j jdZ%e j je j jdZ&e jd.dZ'e j j(dZ)e j je j j(e j jdZ*e j je jdZ+e jd.dZ,e j jdZ-e j je j jdZ.e jd.dZ/e j j0d Z1e j j0e j jd!Z2e j j3d"Z4e j j3e j jd#Z5e jd.d$Z6e jd.d%Z7e j j8d&Z9e j j8e j jd'Z:e j;d(d)e jd.d*Z<d+Z=e j jd,Z>e j je jd-Z?RS(/cCs6|j|dtjjjr2|j|dndS(Nt test_schema(tdefine_reflected_tablestNoneR trequirestschemastenabled(RR((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyR*sc Cs0|r|d}nd}tjjjrtd|tdtjdttdtj ddt td tj ddt td tj tj d |d |d t}nftd|tdtjdttdtj ddt td tj ddt d |d t}td|tdtj dttdtj tj d|tdtjdd |d ttd|tdtj tdtj tj |jjtdtjdtjdddd |d ttjjjr |j||ntjjjr,|j||ndS(Nt.ttuserstuser_idRttest1itnullablettest2tparent_user_ids%susers.user_idtschemat test_needs_fkt dingalingst dingaling_idt address_ids%semail_addresses.address_idRitemail_addressestremote_user_idt email_addressitnamet email_ad_pk(R R,tself_referential_foreign_keysR.R R tsatINTRtCHARtFalsetFloatRt ForeignKeyRtcR2tPrimaryKeyConstrainttindex_reflectiont define_indextview_column_reflectiont define_views(RRR7t schema_prefixR1((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyR*0sN              cCsEtd|jj|jjtd|jj|jj|jjdS(Nt users_t_idxt users_all_idx(RRHR3R5R2(RRR1((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyRKcscCsx}d D]u}|}|r,d||f}n|d}d||f}tj|dt|tj|dtd|qWdS( NR1R<s%s.%st_vs"CREATE VIEW %s AS SELECT * FROM %st after_createt before_drops DROP VIEW %s(suserssemail_addresses(RtlistenR(RRR7t table_nametfullnamet view_nametquery((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyRMhs    cCs,ttj}|jd|jkdS(NR)(RR Rtassert_tget_schema_names(R!tinsp((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_schema_names}scCsKtj}t|jd s%tt|t|jdsGtdS(Ntdefault_schema_name(Rttesting_enginethasattrRR R(R!tengine((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_dialect_initializes  cCs,ttj}t|jtjjjdS(N(RR RR R]R(R!R[((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_default_schema_namesttablec Cs|j}|jj|jj|jj}}}t|j}|dkr|j|} | jddg} t t | | nb|j |d|} |dkrdddg} t | | n"dddg} t t | | dS( Ntviewtemail_addresses_vtusers_vtorder_byt foreign_keyR1R<R9( RttablesR1R<R9Rtbindtget_view_namestsortR tsortedtget_table_names( R!R7t table_typeRgtmetaR1t addressesR9R[t table_namestanswer((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_table_namess         cCs|jdS(N(Rt(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_table_namesscCs|jdddS(NRgRh(Rt(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_table_names_fksscCs|jddS(NR)(Rt(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt test_get_table_names_with_schemascCs|jdddS(NRoRd(Rt(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_view_namesscCs|jddddS(NR)RoRd(Rt(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_view_names_with_schemascCs|j|jdddS(NRoRd(Rt(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_tables_and_viewss c Cs ttj}|jj|jj|jj}}}ddg}|dkr\ddg}nt|j}xt |||fD]\} } |} |j | d| } |j t | dkt | xKt | jD]:\} }t|j| | d| | d j}|j}t|tjjr9|j}ntjd rl|tjtjfkrltj}n|j t t|jj|jjtjtjtjtjtj tj!tj"gdkd |j|j| | d|f|j#s| | d dkst%qqWqWdS( NR1R<RdRfReR7iR?ttypetoracles%s(%s), %s(%s)tdefault(&RR RRiR1R<R9RRjtzipt get_columnsRYtlent enumeratetcolumnsR R?t __class__R{t isinstanceRBRt TypeEnginetagainstt sql_typestDatetDateTimetsett__mro__t intersectionRtNumerictTimeRt_BinaryRR+R (R!R7RoRpR1RqR9RrR[RURct schema_nametcolstitcoltctypet ctype_def((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_columnssD    "     " cCs|jdS(N(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_columnsscGs{td|jgt|D]\}}td||^q}|jgt|jjjdD]}|d^qgS(Nttst%dR{(R RRR tcreateRRjR(R!RRttype_RRH((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_type_round_trips  2 cCsbx[|jtjddD]>}t|tjs:tt|jdt|jdqWdS(Nii(RRRRR R t precisiontscale(R!ttyp((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_numeric_reflections  cCsH|jtjdd}t|tjs4tt|jddS(Ni4i(RRRRR R tlength(R!R((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_varchar_reflectionsc Cstd|jtdtdttdtdt}|jttdt |jj j dDitd6td6dS(NRtaR4tbcss#|]}|d|dfVqdS(R?R4N((t.0R((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pys s( R RR RRRERR tdictRRjR(R!R((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_nullable_reflections  cCs|jdddS(NR7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_columns_with_schema#scCs|jdddS(NRoRd(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_view_columns(scCs|jdddddS(NR7R)RoRd(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt!test_get_view_columns_with_schema,sc Cs|j}|jj|jj}}t|j}|j|jd|}|d}t|dg|j|jd|}|d} t| dgt j j j t|ddWdQXdS(NR7tconstrained_columnsR2R;R?R@( RRiR1R<RRjtget_pk_constraintR?R R R,treflects_pk_namestfail_if( R!R7RpR1RqR[t users_const users_pkeyst addr_const addr_pkeys((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_pk_constraint1s   cCs|jdS(N(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_pk_constraintBscCs|jdddS(NR7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt"test_get_pk_constraint_with_schemaFscCsD|j}|jj}t|j}ttjd|j|j dS(NsKCall to deprecated method get_primary_keys. Use get_pk_constraint instead.( RRiR1RRjR tsa_exctSADeprecationWarningtget_primary_keysR?(R!RpR1R[((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt test_deprecated_get_primary_keysLs  c Cs|j}|jj|jj|jj}}}t|j}|}tjj j r|j |j d|}|d} tjj j|j| ddk WdQXt| d|t| d|j t| ddgtjj j rt| dd gqn|j |j d|} | d} tjj j|j| ddk WdQXt| d|t| d|j t| ddgt| dd gdS( NR7iR?treferred_schematreferred_tabletreferred_columnsR2RR6R=(RRiR1R<R9RRjR R,RAR.tget_foreign_keysR?tnamed_constraintsRRYR+R ( R!R7RpR1RqR9R[texpected_schemat users_fkeystfkey1t addr_fkeys((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_foreign_keysYs2      cCs|jdS(N(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_foreign_keys}scCs|jdddS(NR7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt!test_get_foreign_keys_with_schemascCs|j}|jj|jj|jj}}}t|j}|jdd|}itd6ddgd6dd6itd6d ddgd6d d6g}g|D]} | d^q} xa|D]Y} | d| kst || j | d} x#| D]} t | | | | qWqWdS( NR1R7tuniqueR3R5t column_namesROR?R2RP( RRiR1R<R9RRjt get_indexesRER tindexR (R!R7RpR1RqR9R[tindexestexpected_indexestdt index_nameste_indexRtkey((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_indexess"        cCs|jdS(N(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_indexesscCs|jdddS(NR7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_indexes_with_schemascCs|jdS(N(t_test_get_unique_constraints(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_unique_constraintsscCs|jdddS(NR7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt'test_get_unique_constraints_with_schemasc Cstidd6dgd6idd6dddgd6idd6dddgd6id d6d d gd6gd tjd}|j}td |tdtjd tdtjdtdtjtd tjdtd tjdd|}x2|D]*}|j tj d|d|dqW|j t |j }t|jd d|d tjd}x*t||D]\}} t|| qWdS(Ntunique_aR?RRt unique_a_b_cRRHt unique_c_a_btunique_asc_keytascRttesttbliiR7(Rmtoperatort itemgetterRR R RBRRtappend_constrainttUniqueConstraintt create_allRRjtget_unique_constraintsR~R ( R!R7tuniquest orig_metaRctuct inspectort reflectedtorigtrefl((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyRs2   " c Cs|j}|jj|jj|jj}}}d}d}t|j}|j|d|} |j| |j|d|} |j| dS(NRfReR7( RRiR1R<R9RRjtget_view_definitionRY( R!R7RpR1RqR9t view_name1t view_name2R[tv1tv2((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_view_definitions   cCs|jdS(N(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_view_definitionscCs|jdddS(NR7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt$test_get_view_definition_with_schemast postgresqlsPG specific featurec Csj|j}|jj|jj|jj}}}t|j}|j||}|jt |t dS(N( RRiR1R<R9RRjt get_table_oidRYRtint( R!RUR7RpR1RqR9R[toid((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyt_test_get_table_oids   cCs|jddS(NR1(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_table_oidscCs|jddddS(NR1R7R)(R(R!((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_get_table_oid_with_schemascCs}|j}t|j}x^d d d gD]M\}}|j|}td|D|}|jdts(tq(Wd S( stest that 'autoincrement' is reflected according to sqla's policy. Don't mark this test as unsupported for any backend ! (technically it fails with MySQL InnoDB since "id" comes before "id2") A backend is better off not returning "autoincrement" at all, instead of potentially returning "False" for an auto-incrementing primary key column. R1R2R<R;R9R:css|]}|d|fVqdS(R?N((RRH((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pys st autoincrementN(suserssuser_id(semail_addressess address_id(s dingalingss dingaling_id(RRRjRRtgetRR (R!RpR[ttnametcnameRtid_((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyttest_autoincrement_cols N(@R$R%R+t run_insertst run_deletesRR&R'RR*RKRMR R,tschema_reflectionR\RaRbtprovide_metadataRtttable_reflectionRut!foreign_key_constraint_reflectionRvR-RwRLRxRyRzRRRRRRRRRRt!primary_key_constraint_reflectionRRRRRRRRJRRtunique_constraint_reflectionRRRRtview_reflectionRRtonly_onRRRR(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyR(%s 3    0        #   $    (#t sqlalchemyRBRRRRRRRRtsqlalchemy.engine.reflectionRtsqlalchemy.testingRRtsqlalchemy.testing.schemaR R R R R R0RRtsqlalchemy.schemaRRRR+RR1t TablesTestRR(t__all__(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/suite/test_reflection.pyts$