o
    y¬´\¡|  ã                   @   s�  d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddl	m
Z
 ddl	mZ dd	lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z  ddlm!Z! ddlm"Z" ddlm#Z# e$g d¢ƒZ%G d d!„ d!e&ƒZ'G d"d#„ d#e'ej!ƒZ(G d$d%„ d%e'ej!ƒZ)G d&d'„ d'e'ej*ƒZ+G d(d)„ d)ej,ƒZ-G d*d+„ d+ej.ƒZ/G d,d-„ d-ej.ƒZ0G d.d/„ d/ej.ƒZ1G d0d1„ d1ej.ƒZ2G d2d3„ d3ej3ƒZ4G d4d5„ d5ej5ƒZ6i d6e“d7e“d8e“d9e“d:e-“d;e“d<e“d=e“d>e“d?e“d@e“dAe“dBe“dCe“dDe“dEe1“dFe0“i dGe“dHe“dIe“dJe“dKe“dLe“dMe#“dNe#“dOe#“dPe(“dQe)“dRe“dSe“dTe“dUe“dVe“dWe“¥eee+ee"e4e/ee e2dXœ
¥Z7G dYdZ„ dZej8ƒZ9G d[d\„ d\e
j:ƒZ;G d]d^„ d^ej<ƒZ=G d_d`„ d`ej>ƒZ?G dadb„ dbej@ƒZAG dcdd„ dde
jBƒZCdS )ezÖ

.. 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.

é    N)Úexc)Úschema)Útypes)Úutil)Údefault)Ú
reflection)Úcompiler)Útext)ÚBIGINT)ÚBINARY)ÚCHAR)ÚDATE)ÚDATETIME)ÚDECIMAL)ÚFLOAT)ÚINT)ÚINTEGER)ÚNCHAR)ÚNUMERIC)ÚNVARCHAR)ÚREAL)ÚSMALLINT)ÚTEXT)ÚTIME)Ú	TIMESTAMP)ÚUnicode)Ú	VARBINARY)ÚVARCHAR)ßÚaddÚallÚalterÚandÚanyÚasÚascÚbackupÚbeginÚbetweenÚbigintÚbinaryÚbitÚbottomÚbreakÚbyÚcallÚ
capabilityÚcascadeÚcaseÚcastÚcharÚchar_convertÚ	characterÚcheckÚ
checkpointÚcloseÚcommentÚcommitÚconnectÚ
constraintÚcontainsÚcontinueÚconvertÚcreateÚcrossÚcubeÚcurrentÚcurrent_timestampÚcurrent_userÚcursorÚdateÚdbspaceÚ
deallocateÚdecÚdecimalÚdeclarer   ÚdeleteÚdeletingÚdescÚdistinctÚdoÚdoubleÚdropÚdynamicÚelseÚelseifÚ	encryptedÚendÚendifÚescapeÚexceptÚ	exceptionÚexecÚexecuteÚexistingÚexistsÚexternloginÚfetchÚfirstÚfloatÚforÚforceÚforeignÚforwardÚfromÚfullÚgotoÚgrantÚgroupÚhavingÚholdlockÚ
identifiedÚifÚinÚindexÚindex_lparenÚinnerÚinoutÚinsensitiveÚinsertÚ	insertingÚinstallÚinsteadÚintÚintegerÚ
integratedÚ	intersectÚintoÚiqÚisÚ	isolationÚjoinÚkeyÚlateralÚleftÚlikeÚlockÚloginÚlongÚmatchÚ
membershipÚmessageÚmodeÚmodifyÚnaturalÚnewÚnoÚ
noholdlockÚnotÚnotifyÚnullÚnumericÚofÚoffÚonÚopenÚoptionÚoptionsÚorÚorderÚothersÚoutÚouterÚoverÚpassthroughÚ	precisionÚprepareÚprimaryÚprintÚ
privilegesÚprocÚ	procedureÚpublicationÚ	raiserrorÚreadtextÚrealÚ	referenceÚ
referencesÚreleaseÚremoteÚremoveÚrenameÚ
reorganizeÚresourceÚrestoreÚrestrictÚreturnÚrevokeÚrightÚrollbackÚrollupÚsaveÚ	savepointÚscrollÚselectÚ	sensitiveÚsessionÚsetÚsetuserÚshareÚsmallintÚsomeÚsqlcodeÚsqlstateÚstartÚstopÚsubtransÚsubtransactionÚsynchronizeÚsyntax_errorÚtableÚ	temporaryÚthenÚtimeÚ	timestampÚtinyintÚtoÚtopÚtranÚtriggerÚtruncateÚtsequalÚ	unboundedÚunionÚuniqueÚunknownÚunsignedÚupdateÚupdatingÚuserÚusingÚvalidateÚvaluesÚ	varbinaryÚvarcharÚvariableÚvaryingÚviewÚwaitÚwaitforÚwhenÚwhereÚwhileÚwindowÚwithÚ	with_cubeÚwith_lparenÚwith_rollupÚwithinÚworkÚ	writetextc                   @   s   e Zd ZdZdd„ ZdS )Ú_SybaseUnitypeMixinz-these types appear to return a buffer object.c                 C   s   dd„ }|S )Nc                 S   s   | d urt | ƒS d S ©N)Ústr)Úvalue© r   úQ/var/www/html/env/lib/python3.10/site-packages/sqlalchemy/dialects/sybase/base.pyÚprocess!  s   z5_SybaseUnitypeMixin.result_processor.<locals>.processr   )ÚselfÚdialectÚcoltyper  r   r   r  Úresult_processor   s   z$_SybaseUnitypeMixin.result_processorN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r  r   r   r   r  rü     s    rü   c                   @   ó   e Zd Zd ZdS )ÚUNICHARN©r  r  r	  Ú__visit_name__r   r   r   r  r  *  ó    r  c                   @   r  )Ú
UNIVARCHARNr  r   r   r   r  r  .  r  r  c                   @   r  )ÚUNITEXTNr  r   r   r   r  r  2  r  r  c                   @   r  )ÚTINYINTNr  r   r   r   r  r  6  r  r  c                   @   r  )ÚBITNr  r   r   r   r  r  :  r  r  c                   @   r  )ÚMONEYNr  r   r   r   r  r  >  r  r  c                   @   r  )Ú
SMALLMONEYNr  r   r   r   r  r  B  r  r  c                   @   r  )ÚUNIQUEIDENTIFIERNr  r   r   r   r  r  F  r  r  c                   @   r  )ÚIMAGENr  r   r   r   r  r  J  r  r  c                   @   sl   e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd	d
„ Zdd„ Zdd„ Z	dd„ Z
dd„ Zdd„ Zdd„ Zdd„ ZdS )ÚSybaseTypeCompilerc                 K   ó
   |   |¡S rý   )Úvisit_IMAGE©r  Útype_Úkwr   r   r  Úvisit_large_binaryO  ó   
z%SybaseTypeCompiler.visit_large_binaryc                 K   r  rý   )Ú	visit_BITr  r   r   r  Úvisit_booleanR  r  z SybaseTypeCompiler.visit_booleanc                 K   r  rý   )Úvisit_NVARCHARr  r   r   r  Úvisit_unicodeU  r  z SybaseTypeCompiler.visit_unicodec                 K   ó
   d|j  S )NzUNICHAR(%d)©Úlengthr  r   r   r  Úvisit_UNICHARX  r  z SybaseTypeCompiler.visit_UNICHARc                 K   r$  )NzUNIVARCHAR(%d)r%  r  r   r   r  Úvisit_UNIVARCHAR[  r  z#SybaseTypeCompiler.visit_UNIVARCHARc                 K   ó   dS )Nr  r   r  r   r   r  Úvisit_UNITEXT^  ó   z SybaseTypeCompiler.visit_UNITEXTc                 K   r)  )Nr  r   r  r   r   r  Úvisit_TINYINTa  r+  z SybaseTypeCompiler.visit_TINYINTc                 K   r)  )Nr  r   r  r   r   r  r  d  r+  zSybaseTypeCompiler.visit_IMAGEc                 K   r)  )Nr  r   r  r   r   r  r   g  r+  zSybaseTypeCompiler.visit_BITc                 K   r)  )Nr  r   r  r   r   r  Úvisit_MONEYj  r+  zSybaseTypeCompiler.visit_MONEYc                 K   r)  )Nr  r   r  r   r   r  Úvisit_SMALLMONEYm  r+  z#SybaseTypeCompiler.visit_SMALLMONEYc                 K   r)  )Nr  r   r  r   r   r  Úvisit_UNIQUEIDENTIFIERp  r+  z)SybaseTypeCompiler.visit_UNIQUEIDENTIFIERN)r  r  r	  r  r!  r#  r'  r(  r*  r,  r  r   r-  r.  r/  r   r   r   r  r  N  s    r  r(   r|   r}   rÉ   rØ   zunsigned bigintzunsigned intzunsigned smallintr˜   rK   rJ   rd   rR   zdouble precisionr°   Ú
smallmoneyÚmoneyÚsmalldatetimeÚdatetimerG   rÖ   r3   r5   rë   zcharacter varyingzchar varyingÚunicharzunicode characterÚncharznational charznational characterÚnvarcharznchar varyingznational char varying)
znational character varyingr	   Úunitextr)   rê   Úimager*   zlong varcharr×   Úuniqueidentifierc                   @   s   e Zd Zdd„ Zddd„ZdS )ÚSybaseInspectorc                 C   s   t j | |¡ d S rý   )r   Ú	InspectorÚ__init__)r  Úconnr   r   r  r<  ¦  s   zSybaseInspector.__init__Nc                 C   s   | j j| j||| jd�S )z3Return the table id from `table_name` and `schema`.©Ú
info_cache)r  Úget_table_idÚbindr?  )r  Ú
table_namer   r   r   r  r@  ©  s   ÿzSybaseInspector.get_table_idrý   )r  r  r	  r<  r@  r   r   r   r  r:  ¥  s    r:  c                   @   s0   e Zd ZdZdd„ Zdd„ Zdd„ Zdd	„ Zd
S )ÚSybaseExecutionContextFc                 C   s   t ƒ ‚)a‚  Must 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.

        )ÚNotImplementedError)r  Ú
connectionrÿ   r   r   r  Úset_ddl_autocommit´  s   
z)SybaseExecutionContext.set_ddl_autocommitc                 C   sœ   | j r.| jjj}|j}|d u}|r|j| jd v | _nd| _| jr.| j 	d| j
j |¡ ¡ | jrL| js9t d¡‚| jjj d¡ |  | jjjd¡ d S d S )Nr   FzSET IDENTITY_INSERT %s ONzGThe Sybase dialect only supports DDL in 'autocommit' mode at this time.z-AUTOCOMMIT (Assuming no Sybase 'ddl in tran')T)ÚisinsertÚcompiledÚ	statementrÓ   Ú_autoincrement_columnr…   Úcompiled_parametersÚ_enable_identity_insertrF   r^   r  Úidentifier_preparerÚformat_tableÚisddlÚshould_autocommitr   ÚInvalidRequestErrorÚroot_connectionÚengineÚloggerÚinforF  rE  )r  ÚtblÚ
seq_columnÚinsert_has_sequencer   r   r  Úpre_execÀ  s4   
ÿÿÿÿ
ÿ
ÿòzSybaseExecutionContext.pre_execc                 C   sB   | j r
|  | jd¡ | jr| j d| jj | j	j
j¡ ¡ d S d S )NFzSET IDENTITY_INSERT %s OFF)rO  rF  rR  rL  rF   r^   r  rM  rN  rH  rI  rÓ   )r  r   r   r  Ú	post_execå  s   ÿÿÿÿz SybaseExecutionContext.post_execc                 C   s*   |   ¡ }| d¡ | ¡ d }| ¡  |S )NzSELECT @@identity AS lastrowidr   )Úcreate_cursorr^   Úfetchoner8   )r  rF   Ú	lastrowidr   r   r  Úget_lastrowidñ  s
   
z$SybaseExecutionContext.get_lastrowidN)r  r  r	  rL  rF  rY  rZ  r^  r   r   r   r  rC  ±  s    %rC  c                   @   sp   e Zd ZdZe ejjddddœ¡Zdd„ Z	dd	„ Z
d
d„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ ZdS )ÚSybaseSQLCompilerTÚ	dayofyearÚweekdayÚmillisecond)ÚdoyÚdowÚmillisecondsc                 K   s<   |j rdpd}|j}|r|d|f 7 }|j}|rtdƒ‚|S )Nz	DISTINCT Ú zTOP %s z"Sybase ASE does not support OFFSET)Ú	_distinctÚ_limitÚ_offsetrD  )r  rÃ   r  ÚsÚlimitÚoffsetr   r   r  Úget_select_precolumns  s   z'SybaseSQLCompiler.get_select_precolumnsc                 C   s   |S rý   r   )r  rÓ   r	   r   r   r  Úget_from_hint_text  r+  z$SybaseSQLCompiler.get_from_hint_textc                 K   r)  ©Nrf  r   )r  rÃ   r  r   r   r  Úlimit_clause  s   zSybaseSQLCompiler.limit_clausec                 K   s.   | j  |j|j¡}d|| j|jfi |¤Žf S )NzDATEPART("%s", %s))Úextract_mapÚgetÚfieldr  Úexpr)r  Úextractr  rs  r   r   r  Úvisit_extract  s   zSybaseSQLCompiler.visit_extractc                 K   r)  )Nz	GETDATE()r   )r  Úfnr  r   r   r  Úvisit_now_func  r+  z SybaseSQLCompiler.visit_now_funcc                 C   r)  ro  r   )r  rÃ   r   r   r  Úfor_update_clause  s   z#SybaseSQLCompiler.for_update_clausec                 K   s:   d|d< | j |jfi |¤Ž}|r|  ¡ r|jrd| S dS )NTÚliteral_bindsz
 ORDER BY rf  )r  Ú_order_by_clauseÚis_subqueryrh  )r  rÃ   r  Úorder_byr   r   r  Úorder_by_clause$  s
   z!SybaseSQLCompiler.order_by_clausec                 C   s   d}|rd}|j | dd|d�S )z=If we have extra froms make sure we render any alias as hint.FT)ÚasfromÚiscrudÚashint©Ú_compiler_dispatch)r  Údelete_stmtÚ
from_tableÚextra_fromsr�  r   r   r  Údelete_table_clause.  s   ÿz%SybaseSQLCompiler.delete_table_clausec                    s&   dd  ‡ ‡‡fdd„|g| D ƒ¡ S )z4Render the DELETE .. FROM clause specific to Sybase.zFROM z, c                 3   s(   � | ]}|j ˆfd ˆ dœˆ¤ŽV  qdS )T)r  Ú	fromhintsNr‚  ©Ú.0Út©Ú
from_hintsr  r  r   r  Ú	<genexpr>;  s
   € ÿ
ÿz=SybaseSQLCompiler.delete_extra_from_clause.<locals>.<genexpr>)r„   )r  r„  r…  r†  r�  r  r   rŒ  r  Údelete_extra_from_clause7  s   
þz*SybaseSQLCompiler.delete_extra_from_clauseN)r  r  r	  Úansi_bind_rulesr   Úupdate_copyr   ÚSQLCompilerrq  rm  rn  rp  rv  rx  ry  r~  r‡  r�  r   r   r   r  r_  ù  s    
þ
	r_  c                   @   s   e Zd Zdd„ Zdd„ ZdS )ÚSybaseDDLCompilerc           	      K   sø   | j  |¡d | jjj|j|d� }|jd u rt d¡‚|jj	}||u rVt
|jtjƒo-|j}|r<|jp4d|jp8d}}nd\}}||fdkrL|d7 }|S |d||f 7 }|S |  |¡}|d ure|d| 7 }|jd urz|jrp|jrv|d	7 }|S |d
7 }|S )Nú )Útype_expressionzHThe Sybase dialect requires Table-bound columns in order to generate DDLé   )r–  r–  z	 IDENTITYz IDENTITY(%s,%s)z	 DEFAULT z	 NOT NULLz NULL)ÚpreparerÚformat_columnr  Útype_compilerr  ÚtyperÓ   r   ÚCompileErrorrJ  Ú
isinstancer   Ú	sa_schemaÚSequencerÍ   Ú	incrementÚget_column_default_stringÚnullableÚprimary_key)	r  ÚcolumnÚkwargsÚcolspecÚseq_colÚsequencerÍ   rŸ  r   r   r   r  Úget_column_specificationB  sD   
ÿÿþÿ
ÿþô
ö
þz*SybaseDDLCompiler.get_column_specificationc                 C   s*   |j }d| j |jj¡| j|j dd�f S )Nz
DROP INDEX %s.%sF)Úinclude_schema)Úelementr—  Úquote_identifierrÓ   ÚnameÚ_prepared_index_name)r  rS   rs   r   r   r  Úvisit_drop_indexn  s
   þz"SybaseDDLCompiler.visit_drop_indexN)r  r  r	  r¨  r®  r   r   r   r  r“  A  s    ,r“  c                   @   s   e Zd ZeZdS )ÚSybaseIdentifierPreparerN)r  r  r	  ÚRESERVED_WORDSÚreserved_wordsr   r   r   r  r¯  v  r  r¯  c                       sú   e Zd ZdZdZdZdZdZdZdZ	i Z
eZeZeZeZeZeZg Zdd„ Z‡ fdd„Zdd	d
„Zejddd„ƒZdd„ Zejddd„ƒZejddd„ƒZejddd„ƒZ ejdd„ ƒZ!ejddd„ƒZ"ejddd„ƒZ#ejddd„ƒZ$ddd„Z%‡  Z&S ) ÚSybaseDialectÚsybaseFTc                 C   s   |  tdƒjtd�¡S )NzSELECT user_name() as user_name)Úusername)Úscalarr	   Úcolumnsr   ©r  rE  r   r   r  Ú_get_default_schema_name�  s   ÿz&SybaseDialect._get_default_schema_namec                    s8   t t| ƒ |¡ | jd ur| jdk rd| _d S d| _d S )N)é   é   éÿ   )Úsuperr²  Ú
initializeÚserver_version_infoÚmax_identifier_lengthr·  ©Ú	__class__r   r  r½  ”  s
   



zSybaseDialect.initializeNc                 K   sv   d}|du r	| j }tdƒ}tjr$t|tƒr| d¡}t|tƒr$| d¡}|j|||d�}| ¡ }|du r9t	 
|¡‚|S )zÛFetch 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.

        NzÔ
          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')
        Úascii)Úschema_namerB  )Údefault_schema_namer	   r   Úpy2krœ  ÚunicodeÚencoder^   rµ  r   ÚNoSuchTableError)r  rE  rB  r   r  Útable_idÚTABLEID_SQLÚresultr   r   r  r@  ž  s$   	ÿ




ÿ
zSybaseDialect.get_table_idc                 K   sz   | j |||| d¡d�}tdƒ}|j||d�}g }|D ]\}	}
}}}}}}|  |	|
t|ƒt|ƒ||||¡}| |¡ q|S )Nr?  r>  a*  
          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É  )r@  rr  r	   r^   Ú_get_column_infoÚboolÚappend)r  rE  rB  r   r  rÉ  Ú
COLUMN_SQLÚresultsr¶  r¬  r  r¡  ÚautoincrementÚdefault_r¦   Úscaler&  Úcol_infor   r   r  Úget_columnsÂ  s<   ÿÿ
÷ø
zSybaseDialect.get_columnsc	                 C   sÆ   | j  |d ¡}	i }
|	ttfv r||f}n|	tkr|f}n|	ttttt	t
fv r*|f}nd}|	r6|	|i |
¤Ž}	nt d||f ¡ tj}	|rV| dd¡ ¡ }t ddd„ |¡}nd }t||	|||d�}|S )	Nr   z*Did not recognize type '%s' of column '%s'ÚDEFAULTrf  z^'(.*)'$c                 S   s
   |   d¡S )Nr–  )rm   )Úmr   r   r  Ú<lambda>  s   
 z0SybaseDialect._get_column_info.<locals>.<lambda>)r¬  rš  r¡  r   rÒ  )Úischema_namesrr  r   r   r   r   r   r  r  r   r   r   ÚwarnÚsqltypesÚNULLTYPEÚreplaceÚstripÚreÚsubÚdict)r  r¬  r  r¡  rÒ  r   r¦   rÔ  r&  r  r¤  ÚargsÚcolumn_infor   r   r  rÍ  õ  s6   

ÿûzSybaseDialect._get_column_infoc                 K   sº  | j |||| d¡d�}i }i }g }||dœ||< tdƒ}	|j|	|d�}
i }|
D ]
}|d ||d < q(|||< tdƒ}|j||d� ¡ }td	ƒ}|D ]�}|d
 }||vr™|j||d�}| ¡ }| ¡  |d d dœ}|d usu|d | jkr{|d |d< |||< |j|	|d�}
i }|
D ]
}|d ||d < qŠ|||< || }|| }g }g }td|d d ƒD ]}| 	||d|   ¡ | 	||d|   ¡ q®||d |d ||d dœ}| 	|¡ qJ|S )Nr?  r>  )r¬  r   zu
          SELECT c.colid AS id, c.name AS name
          FROM syscolumns c
          WHERE c.id = :table_id
        rÌ  r¬  Úida(  
          SELECT o.name AS name, r.reftabid AS reftable_id,
            r.keycnt AS 'count',
            r.fokey1 AS fokey1, r.fokey2 AS fokey2, r.fokey3 AS fokey3,
            r.fokey4 AS fokey4, r.fokey5 AS fokey5, r.fokey6 AS fokey6,
            r.fokey7 AS fokey7, r.fokey1 AS fokey8, r.fokey9 AS fokey9,
            r.fokey10 AS fokey10, r.fokey11 AS fokey11, r.fokey12 AS fokey12,
            r.fokey13 AS fokey13, r.fokey14 AS fokey14, r.fokey15 AS fokey15,
            r.fokey16 AS fokey16,
            r.refkey1 AS refkey1, r.refkey2 AS refkey2, r.refkey3 AS refkey3,
            r.refkey4 AS refkey4, r.refkey5 AS refkey5, r.refkey6 AS refkey6,
            r.refkey7 AS refkey7, r.refkey1 AS refkey8, r.refkey9 AS refkey9,
            r.refkey10 AS refkey10, r.refkey11 AS refkey11,
            r.refkey12 AS refkey12, r.refkey13 AS refkey13,
            r.refkey14 AS refkey14, r.refkey15 AS refkey15,
            r.refkey16 AS refkey16
          FROM sysreferences r JOIN sysobjects o on r.tableid = o.id
          WHERE r.tableid = :table_id
        z›
          SELECT o.name AS name, u.name AS 'schema'
          FROM sysobjects o JOIN sysusers u ON o.uid = u.uid
          WHERE o.id = :table_id
        Úreftable_idr   r–  Úcountzfokey%izrefkey%i)Úconstrained_columnsÚreferred_schemaÚreferred_tableÚreferred_columnsr¬  )
r@  rr  r	   r^   Úfetchallr\  r8   rÄ  ÚrangerÏ  )r  rE  rB  r   r  rÉ  Útable_cacheÚcolumn_cacheÚforeign_keysrÐ  rÑ  r¶  ÚcolÚREFCONSTRAINT_SQLÚreferential_constraintsÚREFTABLE_SQLÚrræ  ÚcÚreftableÚ
table_infoÚreftable_columnsrè  rë  ÚiÚfk_infor   r   r  Úget_foreign_keys(  sr   ÿÿÿÿþÿûzSybaseDialect.get_foreign_keysc                 K   sŽ   | j |||| d¡d�}tdƒ}|j||d�}g }|D ])}	g }
td|	d ƒD ]}|
 |	d|f  ¡ q&|	d t|	d	 ƒ|
d
œ}| |¡ q|S )Nr?  r>  aµ  
          SELECT object_name(i.id) AS table_name,
                 i.keycnt AS 'count',
                 i.name AS name,
                 (i.status & 0x2) AS 'unique',
                 index_col(object_name(i.id), i.indid, 1) AS col_1,
                 index_col(object_name(i.id), i.indid, 2) AS col_2,
                 index_col(object_name(i.id), i.indid, 3) AS col_3,
                 index_col(object_name(i.id), i.indid, 4) AS col_4,
                 index_col(object_name(i.id), i.indid, 5) AS col_5,
                 index_col(object_name(i.id), i.indid, 6) AS col_6,
                 index_col(object_name(i.id), i.indid, 7) AS col_7,
                 index_col(object_name(i.id), i.indid, 8) AS col_8,
                 index_col(object_name(i.id), i.indid, 9) AS col_9,
                 index_col(object_name(i.id), i.indid, 10) AS col_10,
                 index_col(object_name(i.id), i.indid, 11) AS col_11,
                 index_col(object_name(i.id), i.indid, 12) AS col_12,
                 index_col(object_name(i.id), i.indid, 13) AS col_13,
                 index_col(object_name(i.id), i.indid, 14) AS col_14,
                 index_col(object_name(i.id), i.indid, 15) AS col_15,
                 index_col(object_name(i.id), i.indid, 16) AS col_16
          FROM sysindexes i, sysobjects o
          WHERE o.id = i.id
            AND o.id = :table_id
            AND (i.status & 2048) = 0
            AND i.indid BETWEEN 1 AND 254
        rÌ  r–  rç  zcol_%ir¬  rá   )r¬  rá   Úcolumn_names)r@  rr  r	   r^   rí  rÏ  rÎ  )r  rE  rB  r   r  rÉ  Ú	INDEX_SQLrÑ  Úindexesrõ  rý  rú  Ú
index_infor   r   r  Úget_indexesŽ  s$   ÿÿ
ýzSybaseDialect.get_indexesc                 K   sŠ   | j |||| d¡d�}tdƒ}|j||d�}| ¡ }| ¡  g }	|r@td|d d ƒD ]}
|	 |d|
f  ¡ q,|	|d d	œS g d d	œS )
Nr?  r>  ay  
          SELECT object_name(i.id) AS table_name,
                 i.keycnt AS 'count',
                 i.name AS name,
                 index_col(object_name(i.id), i.indid, 1) AS pk_1,
                 index_col(object_name(i.id), i.indid, 2) AS pk_2,
                 index_col(object_name(i.id), i.indid, 3) AS pk_3,
                 index_col(object_name(i.id), i.indid, 4) AS pk_4,
                 index_col(object_name(i.id), i.indid, 5) AS pk_5,
                 index_col(object_name(i.id), i.indid, 6) AS pk_6,
                 index_col(object_name(i.id), i.indid, 7) AS pk_7,
                 index_col(object_name(i.id), i.indid, 8) AS pk_8,
                 index_col(object_name(i.id), i.indid, 9) AS pk_9,
                 index_col(object_name(i.id), i.indid, 10) AS pk_10,
                 index_col(object_name(i.id), i.indid, 11) AS pk_11,
                 index_col(object_name(i.id), i.indid, 12) AS pk_12,
                 index_col(object_name(i.id), i.indid, 13) AS pk_13,
                 index_col(object_name(i.id), i.indid, 14) AS pk_14,
                 index_col(object_name(i.id), i.indid, 15) AS pk_15,
                 index_col(object_name(i.id), i.indid, 16) AS pk_16
          FROM sysindexes i, sysobjects o
          WHERE o.id = i.id
            AND o.id = :table_id
            AND (i.status & 2048) = 2048
            AND i.indid BETWEEN 1 AND 254
        rÌ  r–  rç  zpk_%ir¬  )rè  r¬  )r@  rr  r	   r^   r\  r8   rí  rÏ  )r  rE  rB  r   r  rÉ  ÚPK_SQLrÑ  Úpksrè  rú  r   r   r  Úget_pk_constraintÁ  s"   ÿÿþ
zSybaseDialect.get_pk_constraintc                 K   s    t dƒ}| |¡}dd„ |D ƒS )Nz%SELECT u.name AS name FROM sysusers uc                 S   ó   g | ]}|d  ‘qS ©r¬  r   )rŠ  rj  r   r   r  Ú
<listcomp>ú  ó    z2SybaseDialect.get_schema_names.<locals>.<listcomp>)r	   r^   )r  rE  r  Ú
SCHEMA_SQLÚschemasr   r   r  Úget_schema_namesó  s   
zSybaseDialect.get_schema_namesc                 K   óL   |d u r| j }tdƒ}tjrt|tƒr| d¡}|j||d�}dd„ |D ƒS )Nz©
          SELECT o.name AS name
          FROM sysobjects o JOIN sysusers u ON o.uid = u.uid
          WHERE u.name = :schema_name
            AND o.type = 'U'
        rÂ  ©rÃ  c                 S   r  r  r   r‰  r   r   r  r    r  z1SybaseDialect.get_table_names.<locals>.<listcomp>©rÄ  r	   r   rÅ  rœ  rÆ  rÇ  r^   )r  rE  r   r  Ú	TABLE_SQLÚtablesr   r   r  Úget_table_namesü  s   ÿ	

zSybaseDialect.get_table_namesc                 K   sF   |d u r| j }tdƒ}tjrt|tƒr| d¡}|j||d�}| ¡ S )Nz 
          SELECT c.text
          FROM syscomments c JOIN sysobjects o ON c.id = o.id
          WHERE o.name = :view_name
            AND o.type = 'V'
        rÂ  )Ú	view_name)	rÄ  r	   r   rÅ  rœ  rÆ  rÇ  r^   rµ  )r  rE  r  r   r  ÚVIEW_DEF_SQLrî   r   r   r  Úget_view_definition  s   ÿ	

z!SybaseDialect.get_view_definitionc                 K   r  )Nz©
          SELECT o.name AS name
          FROM sysobjects o JOIN sysusers u ON o.uid = u.uid
          WHERE u.name = :schema_name
            AND o.type = 'V'
        rÂ  r  c                 S   r  r  r   )rŠ  Úvr   r   r  r  ;  r  z0SybaseDialect.get_view_names.<locals>.<listcomp>r  )r  rE  r   r  ÚVIEW_SQLÚviewsr   r   r  Úget_view_names(  s   ÿ	

zSybaseDialect.get_view_namesc                 C   s,   z
|   |||¡ W dS  tjy   Y dS w )NFT)r@  r   rÈ  )r  rE  rB  r   r   r   r  Ú	has_table=  s   ýÿzSybaseDialect.has_tablerý   )'r  r  r	  r¬  Úsupports_unicode_statementsÚsupports_sane_rowcountÚsupports_sane_multi_rowcountÚsupports_native_booleanÚsupports_unicode_bindsÚpostfetch_lastrowidÚcolspecsrÚ  r  r™  r_  Ústatement_compilerr“  Úddl_compilerr¯  r—  r:  Ú	inspectorÚconstruct_argumentsr¸  r½  r@  r   ÚcacherÖ  rÍ  rü  r  r  r  r  r  r  r  Ú__classcell__r   r   rÀ  r  r²  z  sJ    

$23e21
r²  )Dr
  rà  Ú
sqlalchemyr   r   r�  r   rÜ  r   Úsqlalchemy.enginer   r   Úsqlalchemy.sqlr   r	   Úsqlalchemy.typesr
   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   rÆ   r°  Úobjectrü   r  r  ÚUnicodeTextr  ÚIntegerr  Ú
TypeEnginer  r  r  r  ÚLargeBinaryr  ÚGenericTypeCompilerr  rÚ  r;  r:  ÚDefaultExecutionContextrC  r’  r_  ÚDDLCompilerr“  ÚIdentifierPreparerr¯  ÚDefaultDialectr²  r   r   r   r  Ú<module>   s  ÿ f&ÿþýüûúùø	÷
öõôóòñðïîíìëêéèçæåäãâá à!ß"Þ#Ó1HH5