h#ddlZddlZddlZddlTddlmZddlmZddlmZddlmZddlmZddlm Z dd lm Z dd lm Z dd l m Z  dd lmZdd lmZddlmZeZn#e$r dxZxZxZZYnwxYwejddkreZdZdZGddeZGddeZGddeZGddeZ GddeZ! ddZ"Gdde e Z#dS) N)*)_atomic)_manual)ColumnMetadata)EnclosedNodeList)Entity)ForeignKeyMetadata) IndexMetadata)NodeList)_PooledPostgresqlDatabase) ArrayField)BinaryJSONField) IntervalFieldi aCockroachDB does not support nested transactions. You may alternatively use the @transaction context-manager/decorator, which only wraps the outer-most block in transactional logic. To run a transaction with automatic retries, use the run_transaction() helper.ceZdZdS)ExceededMaxAttemptsN__name__ __module__ __qualname__S/var/www/html/marketdash/venv/lib/python3.11/site-packages/playhouse/cockroachdb.pyrr#srrc"eZdZdZfdZxZS) UUIDKeyFieldTc|drtdt|ztdg|d<|ddt t |j|i|dS)N constraints%s cannot specify constraints.zDEFAULT gen_random_uuid() primary_keyT)get ValueErrortypeSQL setdefaultsuperr__init__selfargskwargs __class__s rr&zUUIDKeyField.__init__)s ::m $ $ L=T JKK K!$%@!A!A B}-...*lD!!*D;F;;;;;r)rrrauto_incrementr& __classcell__r+s@rrr&s=N<<<<<<<<!> ?}(j$($9&99999r)rrr field_typer&r-r.s@rr0r01s=J:::::::::rr0ceZdZejZeddidZfdZfdZ ddZ dfd Z d Z fd Z d Zd Zdfd Zdfd ZfdZ ddZ ddZxZS)CockroachDatabaseBLOBBYTESTcd|vrC|rA|ds,|dd|ddtt|j|g|Ri|dS)Ndsnz postgresql://userrootportif) startswithr$r%r5r&)r(databaser)r*r+s rr&zCockroachDatabase.__init__Cs   H (0(;(;O(L(L    ff - - -   fe , , ,/&&/J4JJJ6JJJJJrc|}|d|\}tjd|}|Ddt d|Dz}t||_dStt| |dS)Nzselect version()z#^CockroachDB.+?v(\d+)\.(\d+)\.(\d+)z %d%02d%02dc34K|]}t|VdSN)int).0is r z8CockroachDatabase._set_server_version..Rs((L(LAQ(L(L(L(L(L(Lr) cursorexecutefetchonerematchtuplegroupsrBserver_versionr%r5_set_server_version)r(conncursraw match_objcleanr+s rrNz%CockroachDatabase._set_server_versionLs{{}} '(((}}HCSII   5(L(L9I9I9K9K(L(L(L#L#LLE"%e**D    #T * * > >t D D D D DrNc|d}||||pddf}|}|r|dpdS)NzSELECT constraint_name FROM information_schema.table_constraints WHERE table_name = %s AND table_schema = %s AND constraint_type = %spublicz PRIMARY KEYr) execute_sqlrH)r(tableschemaqueryrFrows r_get_pk_constraintz$CockroachDatabase._get_pk_constraintXsU,!!%%1C8*7*9::oo~s1v%%rctt|||}|||fd|DS)Nc.g|]}r |jk|Sr)name)rCidxpkcs r z1CockroachDatabase.get_indexes..gs%IIIsICr)r%r5 get_indexesr[)r(rWrXindexesr`r+s @rrbzCockroachDatabase.get_indexesbsU)400<.ysA/4/4/4$.c:#>#>GF3KKKC/4/4/4rz DO NOTHINGrezWCockroachDB does not support the usage of a constraint name. Use the column(s) instead.) rlrmr#_conflict_targetappendrr _conflict_constraintr!r%r5conflict_update)r(ocrYropartsr+s rrzz!CockroachDatabase.conflict_updatets')z9!!###r * * *''(E" 6 -/4/4!2/4/4/455666 LL\** + + +E?? " , , , F  $ LKLL L&--==b%HHHrc8t||SrA)fnextract)r( date_part date_fields r extract_datezCockroachDatabase.extract_dateszz)Z000rcR|ddS)NrB timestamptz)cast)r(rs rfrom_timestampz CockroachDatabase.from_timestamps$u%%**=999rcVtt||)|d|f|S|}|dvrt d|d|zdSdS)Nz$SET TRANSACTION AS OF SYSTEM TIME %s)lownormalhighz$priority must be low, normal or highzSET TRANSACTION PRIORITY %s)r%r5beginrFrGrmr!r( system_timepriorityr+s rrzCockroachDatabase.begins &&,,...  " KKMM ! !"H#.. 2 2 2  ~~''H888 !GHHH KKMM ! !"?("J K K K K K rc|r||jtkrt |||St t |||SrA) is_closedconnectrMNESTED_TX_MIN_VERSION _crdb_atomicr%r5atomicrs rrzCockroachDatabase.atomicsa >>  +T\\^^^  !6 6 6k8<< <&--44[(KKKrc|r||jtkrt t t t|SrA) rrrMrNotImplementedError TXN_ERR_MSGr%r5 savepointr(r+s rrzCockroachDatabase.savepointsY >>  +T\\^^^  !6 6 6%k22 2&--77999rcfd}|S)NcPtjfd}|S)Nc*tSrArun_transaction)cb max_attemptsrr(rsrnew_fnzACockroachDatabase.retry_transaction..deco..new_fns &tR{'/111r) functoolswraps)rrrrr(rs` rdecoz1CockroachDatabase.retry_transaction..decosM _R  1 1 1 1 1 1 1 1!  1Mrr)r(rrrrs```` rretry_transactionz#CockroachDatabase.retry_transactions5          rc(t|||||SrAr)r(rrrrs rrz!CockroachDatabase.run_transactionstR{HMMMrrA)NNNNN)rrrPostgresqlDatabase field_typescopyrkrelease_after_rollbackr&rNr[rbrprzrrrrrrrr-r.s@rr5r5;s$05577K"KKKKK E E E E E&&&&JJJJJJ , , ,IIIII(111::: L L L L L LLLLLLL ::::: @D#'BF!%NNNNNNNNrr5ceZdZfdZxZS)rc |jdkr@t|jtst t tt| S)Nr) dbtransaction_depthrttop_transactionrrrr%r __enter__rs rrz_crdb_atomic.__enter__sf 7 $ $ & & * *dg5577AA 7)+666\4((22444r)rrrrr-r.s@rrrs8555555555rrc|pd}|||5}|d|dkrq ||}|d|cdddS#t$r5}|jjdkr|dz}|d Yd}~nd}~wwxYw dddn #1swxYwYt dd ) a Run transactional SQL in a transaction with automatic retries. User-provided `callback`: * Must accept one parameter, the `db` instance representing the connection the transaction is running under. * Must not attempt to commit, rollback or otherwise manage transactions. * May be called more than once. * Should ideally only contain SQL operations. Additionally, the database must not have any open transaction at the time this function is called, as CRDB does not support nested transactions. )rrzSAVEPOINT cockroach_restartrz#RELEASE SAVEPOINT cockroach_restartN40001z'ROLLBACK TO SAVEPOINT cockroach_restartzunable to commit transaction)rrVOperationalErrororigpgcoder)rcallbackrrrtxnresultexcs rrrsW %2L {X > > # 4555a !"DEEE        $   8?g-- A%LNN#LMMMHHHH                    d$B C CCs:B6!A'' B&1*B!B6 B!!B&&B66B:=B:ceZdZdS)PooledCockroachDatabaseNrrrrrrsDrrr)$rrIsyspeeweerrrrrr r r playhouse.poolr playhouse.postgres_extr rr JSONField ImportError version_infostrrurrrr UUIDFieldr AutoFieldr0rr5rrrrrrrs !!!!!!######%%%%%% 444444D111111666666444444IIDDD?CCJCC=999DAJ+ 21111*111<<<<<9<<<::::::::xNxNxNxNxN*xNxNxNv555557555BF!DDDD@     79J     sA A-,A-