iddvdZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd l m Z dd l m Z dd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZegdZGddejZGddeejZGddeejZGddej Z!ej e!iZ"eeeeeeeeeeeeed Z#Gd d!e j$Z%Gd"d#ej j&Z'Gd$d%ej j(Z)Gd&d'ej j*Z+Gd(d)e j,Z-Gd*d+e j.Z/dS),aQ .. dialect:: firebird :name: Firebird .. note:: The Firebird 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. Firebird Dialects ----------------- Firebird offers two distinct dialects_ (not to be confused with a SQLAlchemy ``Dialect``): dialect 1 This is the old syntax and behaviour, inherited from Interbase pre-6.0. dialect 3 This is the newer and supported syntax, introduced in Interbase 6.0. The SQLAlchemy Firebird dialect detects these versions and adjusts its representation of SQL accordingly. However, support for dialect 1 is not well tested and probably has incompatibilities. Locking Behavior ---------------- Firebird locks tables aggressively. For this reason, a DROP TABLE may hang until other transactions are released. SQLAlchemy does its best to release transactions as quickly as possible. The most common cause of hanging transactions is a non-fully consumed result set, i.e.:: result = engine.execute("select * from table") row = result.fetchone() return Where above, the ``ResultProxy`` has not been fully consumed. The connection will be returned to the pool and the transactional state rolled back once the Python garbage collector reclaims the objects which hold onto the connection, which often occurs asynchronously. The above use case can be alleviated by calling ``first()`` on the ``ResultProxy`` which will fetch the first row and immediately close all remaining cursor/connection resources. RETURNING support ----------------- Firebird 2.0 supports returning a result set from inserts, and 2.1 extends that to deletes and updates. This is generically exposed by the SQLAlchemy ``returning()`` method, such as:: # INSERT..RETURNING result = table.insert().returning(table.c.col1, table.c.col2).\ values(name='foo') print(result.fetchall()) # UPDATE..RETURNING raises = empl.update().returning(empl.c.id, empl.c.salary).\ where(empl.c.sales>100).\ values(dict(salary=empl.c.salary * 1.1)) print(raises.fetchall()) .. _dialects: http://mc-computing.com/Databases/Firebird/SQL_Dialect.html N)exc)sql)types)util)default) reflection)compiler) expression)BIGINT)BLOB)DATE)FLOAT)INTEGER)Integer)NUMERIC)SMALLINT)TEXT)TIME) TIMESTAMP)activeaddadminafterallalterandanyasasc ascendingatautoavgbeforebeginbetweenbigint bit_lengthblobbothbycasecastchar charactercharacter_length char_lengthcheckclosecollatecolumncommit committedcomputed conditionalconnect constraint containingcountcreatecrosscstringcurrentcurrent_connection current_date current_role current_timecurrent_timestampcurrent_transaction current_usercursordatabasedatedaydecdecimaldeclarerdeletedesc descending disconnectdistinctdodomaindoubledropelseend entry_pointescape exceptionexecuteexistsexitexternalextractfetchfilefilterfloatforforeignfromfullfunctiongdscode generatorgen_idglobalgrantgrouphavinghourifininactiveindexinner input_type insensitiveinsertintintegerintois isolationjoinkeyleadingleftlengthlevellikelonglowermanualmaxmaximum_segmentmergeminminute module_namemonthnamesnationalnaturalncharnonotnullnumeric octet_lengthofononlyopenoptionororderouter output_typeoverflowpagepages page_size parameterpasswordplanposition post_event precisionprimary privileges procedure protectedz rdb$db_keyreadrealrecord_versionrecreate recursive referencesreleasereserv reservingretainreturning_valuesreturnsrevokerightrollbackrows row_count savepointschemasecondsegmentselect sensitivesetshadowsharedsingularsizesmallintsnapshotsomesortsqlcode stabilitystartstartingstarts statisticssub_typesumsuspendtablethentime timestamptotrailing transactiontriggertrim uncommittedunionuniqueupdateupperuserusingvaluevaluesvarcharvariablevaryingviewwaitwhenwherewhilewithworkwriteyearc$eZdZdZdfd ZxZS) _StringTypezBase for Firebird string types.Nc V||_tt|jdi|dS)N)charsetsuperr__init__)selfrkw __class__s V/opt/cloudlinux/venv/lib/python3.11/site-packages/sqlalchemy/dialects/firebird/base.pyrz_StringType.__init__Us3 )k4  )//B/////N)__name__ __module__ __qualname____doc__r __classcell__rs@rrrRsC))0000000000rrc(eZdZdZdZdfd ZxZS)VARCHARzFirebird VARCHAR typeNc Ltt|jdd|i|dSNrr)rr rrrkwargsrs rrzVARCHAR.__init___s1%gt%>>V>v>>>>>rrrrrr __visit_name__rr r s@rr r ZsHN??????????rr c(eZdZdZdZdfd ZxZS)CHARzFirebird CHAR typeNc Ltt|jdd|i|dSr)rrrrs rrz CHAR.__init__hs1"dD";;&;F;;;;;rrrr s@rrrcsHN<<<<<<<<<.processns5E{{hm++(U[%)LLL rr)rdialectrs rbind_processorz_FBDateTime.bind_processorms    rN)rrrrrrrrrls#rr) SHORTLONGQUADrr rrINT64DOUBLErVARYINGCSTRINGr cFeZdZdZdZdZdZdZfdZfdZ xZ S)FBTypeCompilerc |j|fi|Sr)visit_SMALLINTrtype_rs r visit_booleanzFBTypeCompiler.visit_booleans"t"5//B///rc |j|fi|Sr)visit_TIMESTAMPr+s rvisit_datetimezFBTypeCompiler.visit_datetimes#t#E00R000rc dS)NzBLOB SUB_TYPE 1rr+s r visit_TEXTzFBTypeCompiler.visit_TEXT  rc dS)NzBLOB SUB_TYPE 0rr+s r visit_BLOBzFBTypeCompiler.visit_BLOBr3rc:t|dd}||S|d|S)Nrz CHARACTER SET )getattr)rr,basicrs r_extend_stringzFBTypeCompiler._extend_strings.%D11 ?L,1EE77; ;rc rtt|j|fi|}|||Sr)rr( visit_CHARr9rr,rr8rs rr;zFBTypeCompiler.visit_CHARs=6nd++6uCCCC""5%000rc |js!tjd|jjzt t |j|fi|}|||S)Nz'VARCHAR requires a length on dialect %s) rr CompileErrorrnamerr( visit_VARCHARr9r<s rr@zFBTypeCompiler.visit_VARCHARsk| "9DL65T**6$(.   >uz:+FGGH227EJGG"z!DLIII&IIm00 CCD $t|EN==f===rc D||jjd}||jjd}t|jjdkr1||jjd}d|d|d|dSd|d|dS)Nrz SUBSTRING(z FROM z FOR rS)rclauseslen)rfuncrsrrs rvisit_substring_funczFBCompiler.visit_substring_funcs LL-a0 1 1 T\1!455 t|# $ $q ( (\\$,"6q"9::FF56QQvvvF F )/0aa7 7rc z|jjrd||zSd||zS)Nr1strlen)rrYfunction_argspec)rrkrs rvisit_length_funczFBCompiler.visit_length_funcsA < $ > 4#8#8#B#BB Bd33H=== =rc b|j't|jr|j|jfi|SdS)N)rerfr clause_expr)rrgrs rrlzFBCompiler.function_argspecs= < #DL(9(9 #4< 077B77 72rcdS)Nz FROM rdb$databaser)rs r default_fromzFBCompiler.default_froms##rc <d|j|zS)Nz gen_id(%s, 1))r_format_sequence)rseqrs rvisit_sequencezFBCompiler.visit_sequences!>!>s!C!CCCrc d}|j|d|j|jfi|zz }|j|d|j|jfi|zz }|jr|dz }|S)zCalled when building a ``SELECT`` statement, position is just before column list Firebird puts the limit and offset right after the ``SELECT``... roNz FIRST %s zSKIP %s z DISTINCT ) _limit_clauser_offset_clause _distinct)rrrresults rget_select_precolumnsz FBCompiler.get_select_precolumnss    + kLDL1E$L$L$L$LL LF  , j<4<0E#L#L#L#LL LF   " k !F rc dS)zz/FBCompiler.returning_clause..s?     % %dAtUB ? ?   rz RETURNING rR)r _select_iterablesr)rstmtreturning_colscolumnss` rreturning_clausezFBCompiler.returning_clausesO    1.AA    dii0000r)F)rrrr ansi_bind_rulesrFrMrPrTrZrirmvisit_char_length_funcrlrrrvr|r~rr r s@rrBrBs**O###         >>>>>>,888>>> /$$$DDD    1111111rrBc$eZdZdZdZdZdZdS) FBDDLCompilerz!Firebird syntactic idiosyncrasiesc|jjtd|jjtd|jjr"d|j|jzSd|j|jzS)z;Generate a ``CREATE GENERATOR`` statement for the sequence.Nz,Firebird SEQUENCE doesn't support START WITHz.Firebird SEQUENCE doesn't support INCREMENT BYzCREATE SEQUENCE %szCREATE GENERATOR %s)elementrNotImplementedError incrementrrYr_rt)rr>s rvisit_create_sequencez#FBDDLCompiler.visit_create_sequence&s >  +%>  > # /%@  < $ '$-*G*G++ )4=+H+H,, rc|jjr"d|j|jzSd|j|jzS)z9Generate a ``DROP GENERATOR`` statement for the sequence.zDROP SEQUENCE %szDROP GENERATOR %s)rrYr_rtr)rrXs rvisit_drop_sequencez!FBDDLCompiler.visit_drop_sequence=s_ < $ % (E(E )) ')F)F ** rc|jtjdd|j|jddzS)Nz}Firebird computed columns do not support a persistence method setting; set the 'persisted' flag to None for Firebird support.zGENERATED ALWAYS AS (%s)FT) include_table literal_binds) persistedrr> sql_compilerrsqltext)r generateds rvisit_computed_columnz#FBDDLCompiler.visit_computed_columnIsY   *"$  *D,=,E,E  U$-F- -   rN)rrrr rrrrrrrr#sG++.         rrc\eZdZdZeZejdgZ fdZ xZ S)FBIdentifierPreparerz)Install Firebird specific reserved words._c\tt||ddS)NT) omit_schema)rrr)rrrs rrzFBIdentifierPreparer.__init__]s- "D))2272MMMMMr) rrrr RESERVED_WORDSreserved_wordsr ILLEGAL_INITIAL_CHARACTERSrillegal_initial_charactersrr r s@rrrUsj33#N!)!D!J!J ""NNNNNNNNNrrceZdZdZdS)FBExecutionContextcd|d|j|z|S)z8Get the next value from the sequence using ``gen_id()``.z&SELECT gen_id(%s, 1) FROM rdb$database)_execute_scalaridentifier_preparerrt)rrur,s r fire_sequencez FBExecutionContext.fire_sequencebs;## 4&66s;; <    rN)rrrrrrrrras#     rrceZdZdZdZdZdZdZdZdZ dZ dZ dZ e ZeZeZeZeZeZeZgZdZfdZddZdd Zejdd Z ejdd Z!ejdd Z"ejdd Z#ej ddZ$ejddZ%ejddZ&ejddZ'xZ(S) FBDialectzFirebird dialectfirebirdTFctt||d|jvo |jdkpd|jvo |jdk|_|jsOt |_tj|jd<tj tji|_ |jo|j dd|_ dS)Nr)rd interbase)rimplicit_returningT)rr initializeserver_version_inforY ischema_namescopysqltypesr DateTimecolspecs__dict__getr)r connectionrs rrzFBDialect.initializes i))*555 $2 2 1(D0  43 3 1(D0   ?!.!3!3!5!5D .6mD { +%. >DM"&"3#  8I8I $9 9 rNcd}||||g}|duS)zIReturn ``True`` if the given table exists, ignoring the `schema`.z SELECT 1 AS has_table FROM rdb$database WHERE EXISTS (SELECT rdb$relation_name FROM rdb$relations WHERE rdb$relation_name=?) Nr^denormalize_namefirst)rr table_namertblqryrs r has_tablezFBDialect.has_tablesD    v(=(=j(I(I'J K Kwwyy$$rcd}||||g}|duS)z9Return ``True`` if the given sequence (generator) exists.z SELECT 1 AS has_sequence FROM rdb$database WHERE EXISTS (SELECT rdb$generator_name FROM rdb$generators WHERE rdb$generator_name=?) Nr)rr sequence_namergenqryrs r has_sequencezFBDialect.has_sequencesD    v(=(=m(L(L'M N Nwwyy$$rc Jd}fd||DS)Nz select rdb$relation_name from rdb$relations where rdb$view_blr is null and (rdb$system_flag is null or rdb$system_flag = 0); cFg|]}|dSrnormalize_namerrowrs rrz-FBDialect.get_table_names..+MMM##CF++MMMrr^rrrrrhs` rget_table_nameszFBDialect.get_table_namess5  NMMMz7I7I!7L7LMMMMrc Jd}fd||DS)Nz select rdb$relation_name from rdb$relations where rdb$view_blr is not null and (rdb$system_flag is null or rdb$system_flag = 0); cFg|]}|dSrrrs rrz,FBDialect.get_view_names..rrrrs` rget_view_nameszFBDialect.get_view_namess5  NMMMz7I7I!7L7LMMMMrc d}||||g}|}|r|dSdS)Nzt SELECT rdb$view_source AS view_source FROM rdb$relations WHERE rdb$relation_name=? view_sourcer)rr view_namerrqryrprs rget_view_definitionzFBDialect.get_view_definitionsV    d&;&;I&F&F%G H Hhhjj  }% %4rc d}|}||d|g}fd|D}|ddS)Nz SELECT se.rdb$field_name AS fname FROM rdb$relation_constraints rc JOIN rdb$index_segments se ON rc.rdb$index_name=se.rdb$index_name WHERE rc.rdb$constraint_type=? AND rc.rdb$relation_name=? z PRIMARY KEYcFg|]}|dS)fnamer)rrrs rrz/FBDialect.get_pk_constraint..s+JJJD''' 33JJJr)constrained_columnsr?)rr^fetchall) rrrrrkeyqry tablenamerpkfieldss ` rget_pk_constraintzFBDialect.get_pk_constraintsh  ))*55   v y'A B BJJJJQZZ\\JJJ'/>>>rc ||}||}d}||||g} | )t|| dSdS)Na SELECT trigdep.rdb$depended_on_name AS fgenerator FROM rdb$dependencies tabdep JOIN rdb$dependencies trigdep ON tabdep.rdb$dependent_name=trigdep.rdb$dependent_name AND trigdep.rdb$depended_on_type=14 AND trigdep.rdb$dependent_type=2 JOIN rdb$triggers trig ON trig.rdb$trigger_name=tabdep.rdb$dependent_name WHERE tabdep.rdb$depended_on_name=? AND tabdep.rdb$depended_on_type=0 AND trig.rdb$trigger_type=1 AND tabdep.rdb$field_name=? AND (SELECT count(*) FROM rdb$dependencies trigdep2 WHERE trigdep2.rdb$dependent_name = trigdep.rdb$dependent_name) = 2 fgenerator)r?)rr^rdictr) rrr column_namerrrcolnamergenrs rget_column_sequencezFBDialect.get_column_sequences))*55 '' 44 "!!&9g*>??EEGG  T00l1CDDEEE E  rc Zd}|||}|d}||}|||g} g} | } | nC|| d} | d} | d}|j|}|(tj d|d| dtj }nt|tr-| d d kr!t| d | d d z }nl|dvr|| d}nV|dkrt| d}n:|dkr*| ddkrt}nt!}n |}d}| d}| d}|dddks Jd|z|dd}|dkrd}| |t)| d |dd}| | krd|d<t-|dkr*| |d kr|||| }|||d<| |[| S)Na SELECT r.rdb$field_name AS fname, r.rdb$null_flag AS null_flag, t.rdb$type_name AS ftype, f.rdb$field_sub_type AS stype, f.rdb$field_length/ COALESCE(cs.rdb$bytes_per_character,1) AS flen, f.rdb$field_precision AS fprec, f.rdb$field_scale AS fscale, COALESCE(r.rdb$default_source, f.rdb$default_source) AS fdefault FROM rdb$relation_fields r JOIN rdb$fields f ON r.rdb$field_source=f.rdb$field_name JOIN rdb$types t ON t.rdb$type=f.rdb$field_type AND t.rdb$field_name='RDB$FIELD_TYPE' LEFT JOIN rdb$character_sets cs ON f.rdb$character_set_id=cs.rdb$character_set_id WHERE f.rdb$system_flag=0 AND r.rdb$relation_name=? ORDER BY r.rdb$field_position rTrftypezDid not recognize type 'z ' of column ''fprecrfscale)rscale)r%r&flenrr stypercfdefaultDEFAULTzUnrecognized default value: %sNULL null_flagr")r?rnullabler autoincrementquotesequence)rrr^fetchonerrstriprrrwarnrNULLTYPE issubclassrrrr lstriprstripboolrrfrappend)rrrrrr pk_constraint pkey_colsrrcolsrr? orig_colnamecolspeccoltypedefvaluedefexprcol_dseq_ds r get_columnszFBDialect.get_columnss  ,..z:FF !"78 ))*55   v { 3 3A **,,C{&&s7|44DwA@@#122;,,..v%%#H $S%5 6 66#!' E!!##|33!%g9~~""ty|';';00YMM$(-E*% KK   CA D rc Bd}||}||d|g}tjd}|D]} || d} || } | ds#| | d<|| d| d<| d|| d | d || d t |S) Na SELECT rc.rdb$constraint_name AS cname, cse.rdb$field_name AS fname, ix2.rdb$relation_name AS targetrname, se.rdb$field_name AS targetfname FROM rdb$relation_constraints rc JOIN rdb$indices ix1 ON ix1.rdb$index_name=rc.rdb$index_name JOIN rdb$indices ix2 ON ix2.rdb$index_name=ix1.rdb$foreign_key JOIN rdb$index_segments cse ON cse.rdb$index_name=ix1.rdb$index_name JOIN rdb$index_segments se ON se.rdb$index_name=ix2.rdb$index_name AND se.rdb$field_position=cse.rdb$field_position WHERE rc.rdb$constraint_type=? AND rc.rdb$relation_name=? ORDER BY se.rdb$index_name, se.rdb$field_position z FOREIGN KEYcdgddgdS)N)r?rreferred_schemareferred_tablereferred_columnsrrrrz,FBDialect.get_foreign_keys..s')#'"&$& rcnamer? targetrnamerrrr targetfname)rr^r defaultdictrrlistr) rrrrrfkqryrrfksrrfks rget_foreign_keyszFBDialect.get_foreign_keysxs6  ))*55   u}i&@ A A      C''G 55EUBf: O"6 '+':':3};M'N'N#$ $ % , ,T-@-@W-N-N O O O ! " ) )##C $677    CJJLL!!!rc d}||||g}tjt}|D]}||d} d| vr;||d| d<g| d<t |d| d<| d||dt| S)Nap SELECT ix.rdb$index_name AS index_name, ix.rdb$unique_flag AS unique_flag, ic.rdb$field_name AS field_name FROM rdb$indices ix JOIN rdb$index_segments ic ON ix.rdb$index_name=ic.rdb$index_name LEFT OUTER JOIN rdb$relation_constraints ON rdb$relation_constraints.rdb$index_name = ic.rdb$index_name WHERE ix.rdb$relation_name=? AND ix.rdb$foreign_key IS NULL AND rdb$relation_constraints.rdb$constraint_type IS NULL ORDER BY index_name, ic.rdb$field_position index_namer? column_names unique_flagr field_name) r^rrrrrrrrr) rrrrrrrindexesrindexrecs r get_indexeszFBDialect.get_indexess     sT%:%::%F%F$G H H"4((  Cs<01HX%%#'#6#6s<7H#I#I +-(%)#m*<%=%=" ^ $ + +##C $566    GNN$$%%%rr))rrrr r?max_identifier_lengthsupports_sequencessequences_optionalsupports_default_valuespostfetch_lastrowidsupports_native_booleanrequires_name_normalizesupports_empty_insertrBstatement_compilerr ddl_compilerrr_r( type_compilerrexecution_ctx_clsrrconstruct_argumentsrYrrrrcacherrrrrrr"r*r r s@rrrls D"#"!# L#H"M*H!M L     ( % % % % % % % %NNNN*NNNN     ? ? ? ?:>FFFF6aaaaF)")")")"V&&&&&&&&rr)0r r sqlalchemyrrrrrsqlalchemy.enginerrsqlalchemy.sqlr r sqlalchemy.typesr r r rrrrrrrrrrStringrr rrrrrGenericTypeCompilerr( SQLCompilerrB DDLCompilerrIdentifierPreparerrDefaultExecutionContextrDefaultDialectrrrrrDsFFP((((((%%%%%%((((((######%%%%%%######!!!!!!!!!!!!""""""$$$$$$$$$$$$$$$$$$%%%%%%!!!!!!!!!!!!&&&&&&fffhhV00000(/000?????k8+???<<<<<; <<<(#  { +         *11111X1111Bq1q1q1q1q1)q1q1q1h/ / / / / CL,/ / / d N N N N N3<: N N N     8   V&V&V&V&V&&V&V&V&V&V&r