H`Tc@sdZddlZddlZddlmZmZmZmZddlm Z m Z m Z ddl m ZddlmZddl mZddl mZmZmZdd lmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+e,d d d d ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpdqdrdsdtdudvdwdxdydzd{d|d}d~ddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddgZ-de.fdYZ/de/ej)fdYZ0de/ej)fdYZ1de/ej*fdYZ2dej3fdYZ4dej5fdYZ6dej5fdYZ7dej5fdYZ8dej5fdYZ9dej:fdYZ;dej<fdYZ=i,e!d6e#di6e#dj6e$d6e4d6e!d6e#d6e$d6e d6e'd76e'd66edQ6e d?6e d6e+d6e8d6e7d6ed6ed6ed36ed6ed6ed!6ed6ed6ed6e0d 6e1d 6ed 6ed 6ed 6ed6ed6ed6ed6ed6e2d6e%d6e&d6e;d6e6d6ed6e(d6e9d6Z>de j?fdYZ@de jAfdYZBdejCfdYZDdejEfdYZFdejGfd YZHd!e jIfd"YZJdS(#s .. dialect:: sybase :name: Sybase .. note:: The Sybase dialect functions on current SQLAlchemy versions but is not regularly tested, and may have many issues and caveats not currently handled. iN(tcompilert expressionttextt bindparam(tdefaulttbaset reflection(ttypes(t operators(tschema(tutiltsqltexc(tCHARtVARCHARtTIMEtNCHARtNVARCHARtTEXTtDATEtDATETIMEtFLOATtNUMERICtBIGINTtINTtINTEGERtSMALLINTtBINARYt VARBINARYtDECIMALt TIMESTAMPtUnicodet UnicodeTexttREALtaddtalltaltertandtanytastasctbackuptbegintbetweentbiginttbinarytbittbottomtbreaktbytcallt capabilitytcascadetcasetcasttchart char_convertt charactertcheckt checkpointtclosetcommenttcommittconnectt constrainttcontainstcontinuetconverttcreatetcrosstcubetcurrenttcurrent_timestampt current_usertcursortdatetdbspacet deallocatetdectdecimaltdeclareRtdeletetdeletingtdesctdistincttdotdoubletdroptdynamictelsetelseift encryptedtendtendiftescapetexceptt exceptiontexectexecutetexistingtexistst externlogintfetchtfirsttfloattfortforcetforeigntforwardtfromtfulltgototgranttgroupthavingtholdlockt identifiedtiftintindext index_lparentinnertinoutt insensitivetinsertt insertingtinstalltinsteadtinttintegert integratedt intersecttintotiqtist isolationtjointkeytlateraltlefttliketlocktlogintlongtmatcht membershiptmessagetmodetmodifytnaturaltnewtnot noholdlocktnottnotifytnulltnumerictoftofftontopentoptiontoptionstortordertotherstouttoutertovert passthrought precisiontpreparetprimarytprintt privilegestproct proceduret publicationt raiserrortreadtexttrealt referencet referencestreleasetremotetremovetrenamet reorganizetresourcetrestoretrestricttreturntrevoketrighttrollbacktrolluptsavet savepointtscrolltselectt sensitivetsessiontsettsetusertsharetsmallinttsometsqlcodetsqlstatetstarttstoptsubtranstsubtransactiont synchronizet syntax_errorttablet temporarytthenttimet timestampttinyintttottopttranttriggerttruncatettsequalt unboundedtuniontuniquetunknowntunsignedtupdatetupdatingtusertusingtvalidatetvaluest varbinarytvarchartvariabletvaryingtviewtwaittwaitfortwhentwheretwhiletwindowtwitht with_cubet with_lparent with_rolluptwithintworkt writetextt_SybaseUnitypeMixincBseZdZdZRS(s-these types appear to return a buffer object.cCs d}|S(NcSs|dk rt|SdSdS(N(tNonetstr(tvalue((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytprocessis  ((tselftdialecttcoltypeR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytresult_processorhs (t__name__t __module__t__doc__R(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRdstUNICHARcBseZdZRS(R (R R t__visit_name__(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR qst UNIVARCHARcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRustUNITEXTcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRystTINYINTcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR}stBITcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRstMONEYcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRst SMALLMONEYcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRstUNIQUEIDENTIFIERcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRstIMAGEcBseZdZRS(R(R R R (((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRstSybaseTypeCompilercBsteZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z RS( cCs |j|S(N(t visit_IMAGE(Rttype_((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytvisit_large_binaryscCs |j|S(N(t visit_BIT(RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_booleanscCs |j|S(N(tvisit_NVARCHAR(RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_unicodescCs d|jS(Ns UNICHAR(%d)(tlength(RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_UNICHARscCs d|jS(NsUNIVARCHAR(%d)(R(RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytvisit_UNIVARCHARscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_UNITEXTscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_TINYINTscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_MONEYscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytvisit_SMALLMONEYscCsdS(NR((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytvisit_UNIQUEIDENTIFIERs(R R RRRRR R!R"RRR#R$R%(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRs           sunsigned bigints unsigned intsunsigned smallintsdouble precisiont smallmoneytmoneyt smalldatetimetdatetimescharacter varyings char varyingtunicharsunicode charactertnchars national charsnational charactertnvarchars nchar varyingsnational char varyingsnational character varyingRtunitexttimages long varchartuniqueidentifiertSybaseInspectorcBseZdZddZRS(cCstjj||dS(N(Rt Inspectort__init__(Rtconn((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR2scCs"|jj|j||d|jS(s3Return the table id from `table_name` and `schema`.t info_cache(Rt get_table_idtbindR4(Rt table_nameR ((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR5sN(R R R2RR5(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR0s tSybaseExecutionContextcBs2eZeZdZdZdZdZRS(cCs tdS(sMust be implemented by subclasses to accommodate DDL executions. "connection" is the raw unwrapped DBAPI connection. "value" is True or False. when True, the connection should be configured such that a DDL can take place subsequently. when False, a DDL has taken place and the connection should be resumed into non-autocommit mode. N(tNotImplementedError(Rt connectionR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytset_ddl_autocommits cCs|jr|jjj}|j}|dk }|rO|j|jdk|_n t |_|jr|j j d|j j j|qn|jr|jstjdn|jjjjd|j|jjjtndS(NisSET IDENTITY_INSERT %s ONsGThe Sybase dialect only supports DDL in 'autocommit' mode at this time.s-AUTOCOMMIT (Assuming no Sybase 'ddl in tran')(tisinserttcompiledt statementRt_autoincrement_columnRRtcompiled_parameterst_enable_identity_inserttFalseRJRbRtidentifier_preparert format_tabletisddltshould_autocommitR tInvalidRequestErrortroot_connectiontenginetloggertinfoR;R:tTrue(Rttblt seq_columntinsert_has_sequence((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytpre_exec s(          cCs[|jr|j|jtn|jrW|jjd|jjj |j j j ndS(NsSET IDENTITY_INSERT %s OFF( RER;RHRBRARJRbRRCRDR=R>R(R((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt post_exec*s    cCs7|j}|jd|jd}|j|S(NsSELECT @@identity AS lastrowidi(t create_cursorRbtfetchoneR<(RRJt lastrowid((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt get_lastrowid5s    (R R RBRAR;RPRQRU(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR8s  ! tSybaseSQLCompilercBszeZeZejejjidd6dd6dd6ZdZ dZ dZ d Z d Z d Zd ZRS( t dayofyeartdoytweekdaytdowt millisecondt millisecondscCss|jrdpd}|jr5|d|jf7}n|jro|jsT|d7}n|d|jdf7}n|S(Ns DISTINCT tsTOP %s s TOP 1000000 s START AT %s i(t _distinctt_limitt_offset(RRts((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytget_select_precolumnsHs    cCs|S(N((RRR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytget_from_hint_textZscCsdS(NR]((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt limit_clause]scKs8|jj|j|j}d||j|j|fS(NsDATEPART("%s", %s)(t extract_maptgettfieldRtexpr(RtextracttkwRg((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt visit_extractascKsdS(Ns GETDATE()((RtfnRj((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytvisit_now_funcfscCsdS(NR]((RR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytfor_update_clauseiscKsKt|d<|j|j|}|rC|j s;|jrCd|SdSdS(Nt literal_bindss ORDER BY R](RLRt_order_by_clauset is_subqueryR_(RRRjtorder_by((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytorder_by_clausens  (R R RLtansi_bind_rulesR t update_copyRt SQLCompilerReRbRcRdRkRmRnRs(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRV=s        tSybaseDDLCompilercBseZdZdZRS(c KsY|jj|d|jjj|j}|jdkrMtj dn|jj }||krt |j t jo|j }|r|jpd|jpd}}n d \}}||fd kr|d7}qU|d||f7}nh|j|}|dk r|d|7}n|jdk rU|j s;|jrH|d7}qU|d7}n|S( Nt sHThe Sybase dialect requires Table-bound columns in order to generate DDLis IDENTITYs IDENTITY(%s,%s)s DEFAULT s NOT NULLs NULL(ii(ii(tpreparert format_columnRt type_compilerRttypeRRR t CompileErrorR?t isinstanceRt sa_schematSequenceRt incrementtget_column_default_stringtnullablet primary_key( Rtcolumntkwargstcolspectseq_coltsequenceRRR((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytget_column_specification{s0          cCs;|j}d|jj|jj|j|jdtfS(Ns DROP INDEX %s.%stinclude_schema(telementRytquote_identifierRtnamet_prepared_index_nameRB(RRWRw((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pytvisit_drop_indexs  (R R RR(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRwys %tSybaseIdentifierPreparercBseZeZRS((R R tRESERVED_WORDStreserved_words(((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRst SybaseDialectcBs:eZdZeZeZeZeZeZe Z iZ e Z e ZeZeZeZeZgZdZdZddZejddZdZejddZ ejddZ!ejddZ"ejd Z#ejdd Z$ejdd Z%ejdd Z&dd Z'RS(tsybasecCs |jtdditd6S(NsSELECT user_name() as user_namettypemapt user_name(tscalarRR(RR:((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt_get_default_schema_names cCsMtt|j||jdk r@|jdkr@d|_n d|_dS(Niii(i(tsuperRt initializetserver_version_infoRtmax_identifier_length(RR:((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRs  cKsd}|dkr|j}ntd}tjrxt|trT|jd}nt|trx|jd}qxn|j|d|d|}|j }|dkrt j |n|S(sFetch the id for schema.table_name. Several reflection methods require the table id. The idea for using this method is that it can be fetched one time and cached for subsequent calls. s SELECT o.id AS id FROM sysobjects o JOIN sysusers u ON o.uid=u.uid WHERE u.name = :schema_name AND o.name = :table_name AND o.type in ('U', 'V') tasciit schema_nameR7N( Rtdefault_schema_nameRR tpy2kR~tunicodetencodeRbRR tNoSuchTableError(RR:R7R Rjttable_idt TABLEID_SQLtresult((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyR5s"         c Ks|j|||d|jd}td}|j|d|}g}xc|D][\} } } } } }}}|j| | t| t| | |||}|j|qRW|S(NR4s* SELECT col.name AS name, t.name AS type, (col.status & 8) AS nullable, (col.status & 128) AS autoincrement, com.text AS 'default', col.prec AS precision, col.scale AS scale, col.length AS length FROM systypes t, syscolumns col LEFT OUTER JOIN syscomments com ON col.cdefault = com.id WHERE col.usertype = t.usertype AND col.id = :table_id ORDER BY col.colid R(R5RfRRbt_get_column_infotbooltappend(RR:R7R RjRt COLUMN_SQLtresultstcolumnsRRRt autoincrementRRtscaleRtcol_info((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt get_columnss "   c Cs)|jj|d} i} | ttfkr<||f} nH| tkrT|f} n0| tttt t t fkr~|f} nd } | r| | | } n t j d||ftj} |rtjdd|j}tjdd|}nd}td|d| d|d |d |} | S( Ns*Did not recognize type '%s' of column '%s'tDEFAULTR]s^'(.*)'$cSs |jdS(Ni(Rq(tm((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyt0sRR|RRR((t ischema_namesRfRRRRR RR RRRR twarntsqltypestNULLTYPEtretsubtstriptdict( RRRRRRRRRRRtargst column_info((se/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/sybase/base.pyRs*     cKsx|j|||d|jd}i}i}g}i|d6|d6||s  "                                                        &  C<0