ó |£*^c@sWddlmZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZejjZd„Zd„Zded„Zd„Zd dd „ƒYZd dd „ƒYZd dd„ƒYZddd„ƒYZddd„ƒYZdd d„ƒYZdd!d„ƒYZdd"d„ƒYZdd#d„ƒYZ dS($iÿÿÿÿ(tunicode_literalsN(tpeektconsume(tto_php_identifiert PHPStringtPHPArraytPHPDictt PHPLiteralcCsL|dkrdS|j}|ddkrD|ddkrD|dd!S|SdS(u1 unescape an SQL name, e.g. convert `abc` to abc iu`iÿÿÿÿiN(tNonetvalue(ttoktv((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytget_names     cCsdj|jddƒƒS(Nu'{}'u'u''(tformattreplace(ts((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytsql_build_stringscCs"|r&ttjdƒr&tƒtƒS|dk rAt|ƒ}n tƒ}|jtjjj krut t |j ƒƒS|jtjj krštt|ƒƒS|jtjkrÅ|j dkrÅtdƒS|jtjkrð|j dkrðtdƒStjjƒdj|j|ƒGHt|j ƒSdS(NuNULLuCURRENT_TIMESTAMPu CURRENT_DATEu"Unrecognized value of type {}: {}.(RtTtKeywordRt NullValueRtttypetLiteraltNumbertIntegert IntegerValuetintR tStringt StringValuetsql_parse_stringt DateTimeValuetradtconsoletwarnR t LiteralValue(t type_hintt allow_nullR ((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytparse_sql_values$  ! !  cCs||jdd!}|jtjjjkr8|jddƒS|jtjjjkr`|jddƒStdj |jƒƒ‚dS(Niiÿÿÿÿu''u'u\"u"uUnknown string token type {}( R RRRRtSingleRtSymbolt ValueErrorR (ttokentval((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR4s tTablecBszeZd d„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z d „Z e d „Zd „ZRS( cCsF||_tjƒ|_d|_tƒ|_tƒ|_||_ dS(N( tnamet collectionst OrderedDicttcolumnsRt primary_keytsett unique_keyst foreign_keyst source_file(tselfR+R3((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyt__init__As     cCsG|j|jkr3tdj|j|jƒƒ‚n||j|j|D]6}|j|ƒstdj|||jƒƒ‚qqWdS(Nu8Unknown column '{}' encountered while {} for table '{}'.(R8R'R R+(R4R.t descriptiontcol((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyt check_columnsRs  cCs¦|jdk r*tdj|jƒƒ‚n|j|dƒx\|D]T}|j|jtj @r|tdj||jƒƒ‚n|j|jtj O_qAW||_dS(Nu+Primary key specified twice for table '{}'.uadding a primary keyu;Primary key cannot contain NULL column '{}' for table '{}'.( R/RR'R R+R;R.tflagstColumnt FLAG_NULLt FLAG_NOTNULL(R4tpkR:((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytset_primary_keyYs  cCs$|j|dƒ|jj|ƒdS(Nuadding a unique key(R;R1tadd(R4tuk((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytadd_unique_keydscCs-|j|jjƒdƒ|jj|ƒdS(Nuadding a foreign key(R;R.tkeysR2RB(R4tfk((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytadd_foreign_keyhscCst|jdd„ƒS(NtkeycSs|jS(N(R.(RF((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytms(tsortedR2(R4((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pytforeign_keys_sortedlscCsSt|ƒdkst‚|j|kr+tSx!|jD]}||kr5tSq5WtS(Ni(tlentAssertionErrorR/tTrueR1tFalse(R4R.RC((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyt is_uniqueos cCsdt|jƒjƒS(NuTable_(RR+t capitalize(R4((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyt get_php_classxscCs.g}x*|jjƒD]}|j|jƒƒqW|jdk r{t|jƒdkr{|jddj|jƒdƒnx/|jD]$}|jddj|ƒdƒq…Wx'|j ƒD]}|j|jƒƒqºW|ròdj |j ƒ}nd}|d|j d 7}|d j|ƒ7}|d 7}|S( NiuPRIMARY KEY (`u`, `u`)u UNIQUE KEY (`uDROP TABLE IF EXISTS `{}`; uuCREATE TABLE `u` ( u, u& ) ENGINE=InnoDB DEFAULT CHARSET=utf8;( R.tvaluestappendtto_sqlR/RRLtjoinR1RKR R+(R4tadd_droptlinesR:RCRFtsql((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyRU{s $$" cCsS|jƒ}g}|jdj|ƒƒ|jdƒ|jdƒ|jdƒ|jdj|ƒƒ|jdƒ|jdƒ|jdƒ|jd ƒ|jd ƒ|jd jt|jƒtg|jjƒD]}|jƒ^qÑd t ƒƒƒ|jd jtg|j ƒD]}|j|ƒ^qƒƒƒ|jdƒ|jdƒ|jdƒ|jdƒ|jdƒtgt |j ƒD]}t|ƒ^qˆƒ}|jdj|ƒƒ|jdƒx@|jjƒD])}|j tj@rÖt|jƒ}PqÖqÖWd}|jdƒ|jdj|ƒƒ|jdƒ|jdƒdj|ƒS(Nuclass {} extends R\Table {{u$ private static $instance = null;u* public static function getInstance() {u' if (self::$instance === null) {u' self::$instance = new {}();u }u return self::$instance;u }u private $foreignKeys;u& protected function __construct() {u# parent::__construct({}, {});t multilineu $this->foreignKeys = {};u& public function getForeignKeys() {u" return $this->foreignKeys;u% public function getPrimaryKey() {u return {};unullu% public function getAutoColumn() {u}u (RRRTR RR+RR.RStto_phpRNRKRJR/R<R=t FLAG_AUTORRV(R4tschema_classestcls_nameRXR:RFtpk_phpt auto_column((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR[”sH           +  2     .    N(t__name__t __module__RR5R7R8R;RARDRGRKRPRRRORUR[(((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR*@s         R=cBs5eZdZdZdZd„Zd„Zd„ZRS(iiicCs(||_||_d|_d|_dS(Ni(R+ttypeR<Rt default_value(R4R+tctype((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR5Äs   cCsÖg}|jd|jdƒ|j|jjƒƒ|jtj@rT|jdƒn|jtj@rt|jdƒn|jdk r©|jdƒ|j|jjƒƒn|jtj @rÉ|jdƒndj |ƒS(Nu`uNOT NULLuNULLuDEFAULTuAUTO_INCREMENTu ( RTR+RcRUR<R=R?R>RdRR\RV(R4RY((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyRUÉs cCs¶|jdk r!|jjƒ}nd}g}|jtj@rM|jdƒn|jtj@rm|jdƒndjt |j ƒ|j jƒ|t |ƒdkr¯dj |ƒndƒS(NunulluR\Column::FLAG_AUTOuR\Column::FLAG_NULLABLEunew R\Column({}, {}, {}, {})iu|u0(RdRR[R<R=R\RTR>R RR+RcRLRV(R4t default_phpt flags_php((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR[×s(RaRbR>R?R\R5RUR[(((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR=¿s   t ForeignKeycBs,eZd„Zd„Zd„Zd„ZRS(cCs(||_||_||_||_dS(N(ttableR.t on_updatet on_delete(R4RiR.RjRk((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyR5ès   cCs"t|j|j|j|jfƒS(N(treprRiR.RjRk(R4((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyt__repr__íscCs«g}t|jjƒŒ\}}|jdjdj|ƒ|jdj|ƒƒƒ|jdk rx|jd|jƒn|j dk rž|jd|j ƒndj|ƒS(Nu4CONSTRAINT FOREIGN KEY (`{}`) REFERENCES `{}` (`{}`)u`, `u ON UPDATE u ON DELETE u ( tzipR.titemsRTR RVRiRjRRk(R4RYt cols_fromtcols_to((s[/home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/rad/sql.pyRUïs %cCsbtƒ}x-|jjƒD]\}}t|ƒ||s&   (   (