œO$# d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z dd l m
Z
dd
l mZ dd lmZ dd lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddlm Z dd lm!Z! dd lm"Z" dd lm#Z# e$g d Z% G d d!e& Z' G d" d#e'ej! Z( G d$ d%e'ej! Z) G d& d'e'ej* Z+ G d( d)ej, Z- G d* d+ej. Z/ G d, d-ej. Z0 G d. d/ej. Z1 G d0 d1ej. Z2 G d2 d3ej3 Z4 G d4 d5e
j5 Z6i d6ed7ed8ed9e d:e-d;eded?ed@edAedBedCedDe dEe1dFe0i dGedHedIedJe dKedLedMe#dNe#dOe#dPe(dQe)dRedSedTedUedVedWeee e+ee"e4e/e e e2dX
Z7 G dY dZe j8 Z9 G d[ d\e
j: Z; G d] d^e
j< Z= G d_ d`e
j> Z? G da dbe
j@ ZA G dc dde
jB ZCdS )eaf
.. dialect:: sybase
:name: Sybase
.. note::
The Sybase dialect within SQLAlchemy **is not currently supported**.
It is not tested within continuous integration and is likely to have
many issues and caveats not currently handled. Consider using the
`external dialect `_
instead.
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)addallalterandanyasascbackupbeginbetweenbigintbinarybitbottombreakbycall
capabilitycascadecasecastchar char_convert charactercheck
checkpointclosecommentcommitconnect
constraintcontainscontinueconvertcreatecrosscubecurrentcurrent_timestamp current_usercursordatedbspace
deallocatedecdecimaldeclarer deletedeletingdescdistinctdodoubledropdynamicelseelseif encryptedendendifescapeexcept exceptionexecexecuteexistingexists externloginfetchfirstfloatforforceforeignforwardfromfullgotograntgrouphavingholdlock
identifiedifinindex index_lpareninnerinout insensitiveinsert insertinginstallinsteadintinteger
integrated intersectintoiqis isolationjoinkeylateralleftlikelockloginlongmatch
membershipmessagemodemodifynaturalnewno
noholdlocknotnotifynullnumericofoffonopenoptionoptionsororderothersoutouterover passthrough precisionprepareprimaryprint
privilegesproc procedure publication raiserrorreadtextreal reference
referencesreleaseremoteremoverename
reorganizeresourcerestorerestrictreturnrevokerightrollbackrollupsave savepointscrollselect sensitivesessionsetsetusersharesmallintsomesqlcodesqlstatestartstopsubtranssubtransaction synchronize syntax_errortable temporarythentime timestamptinyinttotoptrantriggertruncatetsequal unboundedunionuniqueunknownunsignedupdateupdatinguserusingvalidatevalues varbinaryvarcharvariablevaryingviewwaitwaitforwhenwherewhilewindowwith with_cube with_lparen with_rollupwithinwork writetextc e Zd ZdZd ZdS )_SybaseUnitypeMixinz-these types appear to return a buffer object.c d }|S )Nc ( | t | S d S N)str)values s/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/dialects/sybase/base.pyprocessz5_SybaseUnitypeMixin.result_processor..process$ s 5zz!t )selfdialectcoltyper s r result_processorz$_SybaseUnitypeMixin.result_processor# s r N)__name__
__module__ __qualname____doc__r r r r r r s) 77 r r c e Zd Zd ZdS )UNICHARNr r
r __visit_name__r r r r r - NNNr r c e Zd Zd ZdS )
UNIVARCHARNr r r r r r 1 !NNNr r c e Zd Zd ZdS )UNITEXTNr r r r r r 5 r r r c e Zd Zd ZdS )TINYINTNr r r r r r 9 r r r c e Zd Zd ZdS )BITNr r r r r r = s NNNr r c e Zd Zd ZdS )MONEYNr r r r r r A NNNr r c e Zd Zd ZdS )
SMALLMONEYNr r r r r" r" E r r r" c e Zd Zd ZdS )UNIQUEIDENTIFIERNr r r r r$ r$ I s 'NNNr r$ c e Zd Zd ZdS )IMAGENr r r r r& r& M r r r& c V e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
S )SybaseTypeCompilerc , | | S r ) visit_IMAGEr type_kws r visit_large_binaryz%SybaseTypeCompiler.visit_large_binaryR s &&&r c , | | S r ) visit_BITr+ s r
visit_booleanz SybaseTypeCompiler.visit_booleanU s ~~e$$$r c , | | S r )visit_NVARCHARr+ s r
visit_unicodez SybaseTypeCompiler.visit_unicodeX s ""5)))r c d|j z S )Nz UNICHAR(%d)lengthr+ s r
visit_UNICHARz SybaseTypeCompiler.visit_UNICHAR[ s u|++r c d|j z S )NzUNIVARCHAR(%d)r6 r+ s r visit_UNIVARCHARz#SybaseTypeCompiler.visit_UNIVARCHAR^ s %,..r c dS )Nr r r+ s r
visit_UNITEXTz SybaseTypeCompiler.visit_UNITEXTa yr c dS )Nr r r+ s r
visit_TINYINTz SybaseTypeCompiler.visit_TINYINTd r= r c dS )Nr& r r+ s r r* z SybaseTypeCompiler.visit_IMAGEg wr c dS )Nr r r+ s r r0 z SybaseTypeCompiler.visit_BITj s ur c dS )Nr r r+ s r visit_MONEYz SybaseTypeCompiler.visit_MONEYm rA r c dS )Nr" r r+ s r visit_SMALLMONEYz#SybaseTypeCompiler.visit_SMALLMONEYp s |r c dS )Nr$ r r+ s r visit_UNIQUEIDENTIFIERz)SybaseTypeCompiler.visit_UNIQUEIDENTIFIERs s !!r N)r r
r r. r1 r4 r8 r: r< r? r* r0 rD rF rH r r r r( r( Q s ' ' '% % %* * *, , ,/ / / " " " " "r r( r) r} r~ r r zunsigned bigintz unsigned intzunsigned smallintr rL rK re rS zdouble precisionr
smallmoneymoney
smalldatetimedatetimerH r r4 r6 r zcharacter varyingz char varyingunicharzunicode characterncharz
national charznational characternvarcharz
nchar varyingznational char varying)
znational character varyingr
unitextr* r imager+ z long varcharr uniqueidentifierc e Zd Zd ZddZdS )SybaseInspectorc F t j | | d S r )r Inspector__init__)r conns r rW zSybaseInspector.__init__ s! %%dD11111r Nc R | j | j ||| j S )z3Return the table id from `table_name` and `schema`.
info_cache)r get_table_idbindr[ )r
table_namer s r r\ z SybaseInspector.get_table_id s0 |(( Iz6do )
r r )r r
r rW r\ r r r rT rT s7 2 2 2
r rT c * e Zd ZdZd Zd Zd Zd ZdS )SybaseExecutionContextFc 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 s r set_ddl_autocommitz)SybaseExecutionContext.set_ddl_autocommit s "###r c | j r| j j j }|j }|d u}|r|j | j d v | _ nd| _ | j r:| j d| j
j | z | j
rf| j st j d | j j j d | | j j j d d S d S )Nr FzSET IDENTITY_INSERT %s ONzGThe Sybase dialect only supports DDL in 'autocommit' mode at this time.z-AUTOCOMMIT (Assuming no Sybase 'ddl in tran')T)isinsertcompiled statementr _autoincrement_columnr compiled_parameters_enable_identity_insertrG r_ r identifier_preparer format_tableisddlshould_autocommitr InvalidRequestErrorroot_connectionengineloggerinford rc )r tbl
seq_columninsert_has_sequences r pre_execz SybaseExecutionContext.pre_exec s4 = -)/C 2J",D"8 "
5 Nd&>q&AA ,, 05,+
##/l6CCCHHI
: )
-=
' . 3 3?
# #$/:D
r c | j r| | j d | j rK| j d| j j | j j
j z d S d S )NFzSET IDENTITY_INSERT %s OFF) rn rd rq rk rG r_ r rl rm rg rh r )r s r post_execz SybaseExecutionContext.post_exec s : A # #D$8% @ @ @ ' K ,,2??M+1
r c | }| d | d }| |S )Nz SELECT @@identity AS lastrowidr )
create_cursorr_ fetchoner9 )r rG lastrowids r
get_lastrowidz$SybaseExecutionContext.get_lastrowid sM ##%%7888OO%%a( r N)r r
r rk rd rx rz r r r r r` r` sW #
$
$
$# # #J
r r` c e Zd ZdZ ej ej j dddd Zd Z d Z
d Z d Z d
Z
d Zd Zd
ZdS )SybaseSQLCompilerT dayofyearweekday millisecond)doydow millisecondsc |S r r )r r r
s r get_from_hint_textz$SybaseSQLCompiler.get_from_hint_text s r c d}|j |d | j |j fi |z z
}|j %|j |dz
}|d | j |j fi |z z
}|S )N z ROWS LIMIT z ROWSz OFFSET )
_limit_clauser _offset_clause)r r r- r
s r limit_clausez SybaseSQLCompiler.limit_clause s| + N\T\&2F%M%M"%M%MM MD ,#+ J f.C!J!Jr!J!JJ JD r c | j |j |j }d|d | j |j fi |dS )Nz
DATEPART("z", )) extract_mapgetfieldr expr)r extractr- r s r
visit_extractz SybaseSQLCompiler.visit_extract sK $$W]GMBB',uuldl7<.N.N2.N.N.N.NOOr c dS )Nz GETDATE()r )r fnr- s r visit_now_funcz SybaseSQLCompiler.visit_now_func s {r c dS )Nr r )r r s r for_update_clausez#SybaseSQLCompiler.for_update_clause s rr c z d|d< | j |j fi |}|r | r|j rd|z S dS )NT
literal_bindsz
ORDER BY r )r _order_by_clause is_subquery_limit)r r r- order_bys r order_by_clausez!SybaseSQLCompiler.order_by_clause s^ "? 4< 7>>2>> T - - / / 6= (* *2r c @ d}|rd}| | dd| S )z=If we have extra froms make sure we render any alias as hint.FT)asfromiscrudashint_compiler_dispatch)r delete_stmt
from_table extra_fromsr s r delete_table_clausez%SybaseSQLCompiler.delete_table_clause' s: F,, d6 -
r c \ dd fd|g|z D z S )z4Render the DELETE .. FROM clause specific to Sybase.zFROM z, c 3 : K | ]} |j fd dV dS )T)r fromhintsNr ).0t
from_hintsr- r s r z=SybaseSQLCompiler.delete_extra_from_clause..4 sS #
#
!A Odj O OB O O#
#
#
#
#
#
r )r )r r r r r r- s ` ``r delete_extra_from_clausez*SybaseSQLCompiler.delete_extra_from_clause0 s[ #
#
#
#
#
#
\K/#
#
#
r N)r r
r ansi_bind_rulesr update_copyr SQLCompilerr r r r r r r r r r r r r r s O"$" (I}MM K
P P P
r r c e Zd Zd Zd ZdS )SybaseDDLCompilerc | j | dz | j j |j | z }|j t j d |j j }||u r[t |j t j
o|j }|r|j pd|j pd}}nd\ }}||fdk r|dz
}nL|d|d|d z
}n?| | }||d
|z z
}|j |j r|j r|d z
}n|d z
}|S )
N )type_expressionzHThe Sybase dialect requires Table-bound columns in order to generate DDL )r r z IDENTITYz
IDENTITY(,r z DEFAULT z NOT NULLz NULL)preparer
format_columnr
type_compilerr typer r CompileErrorri
isinstancer sa_schemaSequencer incrementget_column_default_stringnullable primary_key) r columnkwargscolspecseq_colsequencer r r s r get_column_specificationz*SybaseDDLCompiler.get_column_specification; so M ' ' / /
l(00 V 1
< "3
,4 f 6>9+=>> #N
(#+>#6Q8J8Oay#' yy!V++;& BB44V<-F
9 8&'**
0 w//*g..
8 ' . .w 7 7
## V
$
==?? &z22 2r c ` | |||| d }t d }| || }g }|D ]V\ } }
} } }
}}}| | |
t | t | |
||| }| | W|S )Nr[ rZ 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\ r r
r_ _get_column_infoboolappend)r rc r^ r r- r
COLUMN_SQLresultsr r r, r
autoincrementdefault_r scaler7 col_infos r get_columnszSybaseDialect.get_columns s $$
Frvvl7K7K %
$ $$Z($CC % %
,,X]## H
NN8 $ $ $ $r c | j |d } i }
| t t fv r||f} n=| t k r|f} n.| t
t t t t t fv r|f} nd} | r | | i |
} n't j d|d|d t j } |r; |j dd }t# j dd | }nd }t' || ||| } | S )
Nr zDid not recognize type 'z
' of column ''DEFAULTr z^'(.*)'$c , | d S )Nr )rn )ms r z0SybaseDialect._get_column_info.. s 1771:: r )r r r r r )
ischema_namesr r r r r
r r r r r r warnsqltypesNULLTYPEreplacestripresubdict)
r r r, r r r r r r7 r
r args column_infos
r r z SybaseDialect._get_column_info s7 $((55 w( ( ( u%DD
>C25f+$SY//,< [)";/H +K 8 "$ ! 1aj1n--
M
M#**71Y]3C+DEEE ''(8:>9J(KLLLL (;#+H#5"*6"2$4& G
( ( ( (r c | |||| d }t d }| || }g }|D ]p} g }
t d| d D ]!} |
| d| fz "| d t
| d |
d
} | | q|S ) Nr[ rZ 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 zcol_%ir r )r r column_names)r\ r r
r_ r r r )
r rc r^ r r- r INDEX_SQLr indexesr' r0 r,
index_infos
r get_indexeszSybaseDialect.get_indexes s $$
Frvvl7K7K %
< $$Y$BB ' 'A L1aj))
8
8 ##Ah!o$67777& q{++ , J
NN: & & & &r c | |||| d }t d }| || }| }| g } |rFt
d|d dz D ]!}
| |d|
fz "| |d d S g d d S )
Nr[ rZ 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 zpk_%ir )r r )r\ r r
r_ r} r9 r r ) r rc r^ r r- r PK_SQLr pksr r, s r get_pk_constraintz SybaseDialect.get_pk_constraint s $$
Frvvl7K7K %
: $$Vh$??
=1c'lQ .//
@
@#**3w!~+>????':F
,.t<< z2SybaseDialect.get_schema_names.. s +++a& +++r )r
r_ )r rc r-
SCHEMA_SQLschemass r get_schema_namesz SybaseDialect.get_schema_names s9 ABB
$$Z00++7++++r c || j }t d }t j r*t |t
r| 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 g | ]
}|d S r; r )r r s r r= z1SybaseDialect.get_table_names.. s ***a& ***r r r
r r r r r r_ )r rc r r- TABLE_SQLtabless r get_table_namesz SybaseDialect.get_table_names s~ >-F
9 0&'**
0 w//##I6#BB**6****r c || j }t d }t j r*t |t
r| 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 rc rI r r- VIEW_DEF_SQLr s r get_view_definitionz!SybaseDialect.get_view_definition sz >-F
9 6)W--
6 % , ,W 5 5 !!,)!DD{{}} r c || j }t d }t j r*t |t
r| 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 = 'V'
r rB c g | ]
}|d S r; r )r vs r r= z0SybaseDialect.get_view_names..4 s )))a& )))r rD )r rc r r- VIEW_SQLviewss r get_view_namesz SybaseDialect.get_view_names! s~ >-F
9 0&'**
0 w//""8"@@))5))))r c b | ||| dS # t j $ r Y dS w xY w)NTF)r\ r r )r rc r^ r s r has_tablezSybaseDialect.has_table6 sM j*f = = = 4 # 55 s ..r )'r r
r r supports_unicode_statementssupports_sane_rowcount supports_sane_multi_rowcountsupports_native_booleansupports_unicode_bindspostfetch_lastrowidcolspecsr r( r r statement_compilerr ddl_compilerr r rT inspectorconstruct_argumentsr r r\ r cacher r r. r4 r8 r@ rG rK rQ rS
__classcell__)r s @r r r s s D"' "#( # " H!M&M*$L'H I
- - - - -" " " "H 0 0 0 0d1 1 1f c c c c J 0 0 0 0d /= /= /= /=b , , , + + + +* * * * * *( r 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 rV rT DefaultExecutionContextr` r r DDLCompilerr IdentifierPreparerr DefaultDialectr r r r ro s:
* * * * * * ( ( ( ( ( ( % % % % % % ( ( ( ( ( ( # # # # # # # # # # # # # # # # # # ! ! ! ! ! ! ! ! ! ! ! ! % % % % % % $ $ $ $ $ $ " " " " " " $ $ $ $ $ $ " " " " " " $ $ $ $ $ $ % % % % % % ! ! ! ! ! ! % % % % % % ! ! ! ! ! ! ! ! ! ! ! ! & & & & & & $ $ $ $ $ $ & & & & & & $ $ $ $ $ $ ` ` `b bJ
&
!8#3 " " " " "$h&6 " " " !8#7 h (
H " " " " "$ " " "( ( ( ( (x* ( ( ( H #" #" #" #" #"5 #" #" #"L. f. 7. w. .
w . v
. G. . w. w.
7. U.
g. . D . *!." U#. .$ X%.& '.( D).* D+., D-.. /.0 w1.2 3.4 G5.6 w7.8 9.: U;.< U=.> %?.@ A.B XC.D XE. .F #+
([. . .
b
j*
E E E E EW < E E EP;
;
;
;
;
, ;
;
;
|2
2
2
2
2
, 2
2
2
j$ $ $ $ $x : $ $ $I I I I IG* I I I I Ir