!j@kddlZddlZddlZddlZddlTddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZdZdZeejdddkrdndZndZdZGddeZGddeZGddeZGddeZGdd eZ Gd!d"eZ!Gd#d$e!Z"Gd%d&e#Z$Gd'd(e$Z%Gd)d*e&Z'Gd+d,e(Z)Gd-d.e*Z+Gd/d0e+Z,Gd1d2e,Z-d3Z.e/d4e/e.ze/e.0ze/e1d5fzZ2e/d6e3d7DZ4[.[2ej5d8Z6Gd9d:e,Z7d;e _8d<Z9dS)=N)*) ColumnBase)EnclosedNodeList)Entity) Expression)Insert)Node)NodeList)OP) VirtualField) merge_dict)sqlite3)JSON)RANK)register_udf_groupspcxpcnalx)rr)r rc.eZdZdZdxZxZZfdZxZS) RowIDFieldTrowidc||jkr'tt|d|jdtt|j||g|RdS)Nz must be named "z".) required_name ValueErrortypesuperrbind)selfmodelnameargs __class__s P/var/www/html/bolsaweb/venv/lib/python3.11/site-packages/playhouse/sqlite_ext.pyr zRowIDField.bind&sm 4% % %"4jjjj$*<*<*<>?? ?$j$$UD84888888) __name__ __module__ __qualname__auto_increment column_namer#rr __classcell__r%s@r&rr"sLN)00K0$999999999r'rceZdZdxZxZZdS) DocIDFielddocidN)r(r)r*r,r#rr'r&r0r0-s)00K0$r'r0ceZdZfdZxZS)AutoIncrementFieldctt||}t|t dfS)N AUTOINCREMENT)rr4ddlr SQL)r!ctx node_listr%s r&r7zAutoIncrementField.ddl2s<,d3377<< C$8$89:::r')r(r)r*r7r-r.s@r&r4r41s8;;;;;;;;;r'r4ceZdZdZdZdS) TDecimalFieldTEXTcdSNr2r!s r& get_modifierszTDecimalField.get_modifiers9sr'N)r(r)r* field_typerAr2r'r&r<r<7sJ!!!!!r'r<ceZdZgdZdZdS)ISODateTimeField)z%Y-%m-%dT%H:%M:%S.%f%zz%Y-%m-%dT%H:%M:%S%zz%Y-%m-%dT%H:%M:%S.%fz%Y-%m-%dT%H:%M:%Sz%Y-%m-%dc2|r|SdSr?) isoformatr!values r&db_valuezISODateTimeField.db_valueEs$  %??$$ $ % %r'N)r(r)r*formatsrIr2r'r&rDrD<s4G%%%%%r'rDceZdZdfd ZdZedZdZddZddZ ddZ dd Z dd Z d Z d Zd ZdZdZdZdZxZS)JSONPathNcvtt|||_|pd|_dSNr2)rrL__init___field_path)r!fieldpathr%s r&rOzJSONPath.__init__Ks5 h&&((( ZR r'c6|j|Sr?)rP python_valuerGs r& _converterzJSONPath._converterPs{''...r'cVtdd|jzS)Nz$%s)ValuejoinrQr@s r&rSz JSONPath.pathSs#URWWTZ000111r'ct|ts|dkrd|z}nd|z}t||j|j|fzS)N#z[%s]z.%s) isinstanceintrrPrQ)r!idxitems r& __getitem__zJSONPath.__getitem__WsS c3   3#::C>>r'c|st|ttfr2t|j|}||j|j|Sr?)r]rdrerfrgrPrhrSr!funcrHrks r&_json_operationzJSONPath._json_operationcsX  ww*6rt{DI>>>*.+77 7r'r?)r(r)r*rOrVpropertyrSrarlrprsrurxr|rrrrrrr-r.s@r&rLrLJsR      ///22X2===???? 3333 DDDDAAAAEEEEMMM666444<<<4444447777777r'rLcHeZdZd dZd dZd dZd dZd dZdZdZ d Z dS) JSONBPathNc|st|ttfr2t|j|}t|j|dj|Src) r]rdrerfjsonbrPrh jsonb_setrSrjs r&rlzJSONBPath.appends^  =jt 55 =HHT[44U;;<.inners<#d|,, /3 ..dB,, ,r'r2)rrs` r&_ez JSONField._es# - - - - - r'c8|||Sr?)Path)r!r`s r&razJSONField.__getitem__syyt$$r'c>d|D}tj|g|RS)Nc0g|]}t|dSF converterrY.0ps r& z%JSONField.extract..%:::qqE***:::r')rfrr!pathss r&extractzJSONField.extracts-::E:::t,e,,,,r'cBt|dt|dS)Nz->FrrrYr!rSs r& extract_jsonzJSONField.extract_jsons!$eDE&B&B&BCCCr'cBt|dt|dS)Nz->>Frrrs r& extract_textzJSONField.extract_texts!$uTU'C'C'CDDDr'cT||||Sr?)rrlrjs r&rlzJSONField.append"yy%%eW555r'cT||||Sr?)rrsrjs r&rszJSONField.insertrr'cT||||Sr?)rrurjs r&ruz JSONField.sets"yy""5'222r'cT||||Sr?)rrxrjs r&rxzJSONField.replaces"yy&&ug666r'cR|||Sr?)rr|)r!datas r&r|zJSONField.updates yy%%d+++r'cx|s'||Stj|g|RSr?)rrrfr~rs r&rzJSONField.removes> ,99T??))++ +~d+U++++r'c6t|Sr?)rfrr@s r&rzJSONField.json_type||D!!!r'c0|r||fn|f}tj|Sr?)rfr)r!rSr$s r&rzJSONField.lengths$#0d||$#T**r'c6t|S)a? Schema of `json_each` and `json_tree`: key, value, type TEXT (object, array, string, etc), atom (value for primitive/scalar types, NULL for array and object) id INTEGER (unique identifier for element) parent INTEGER (unique identifier of parent element or NULL) fullkey TEXT (full path describing element) path TEXT (path to the container of the current element) json JSON hidden (1st input parameter to function) root TEXT hidden (2nd input parameter, path at which to start) )rfrr@s r&rzJSONField.childrens||D!!!r'c6t|Sr?)rfrr@s r&rzJSONField.treerr')NNr?))r(r)r*rBunpackrLrrOrUrIrr EQ__eq__NE__ne__GT__gt__GTE__ge__LT__lt__LTE__le__Field__hash__rarrrrlrsrurxr|rrrrrr-r.s@r&rrsJ F D222222   RYYF RYYF RYYF RZZF RYYF RZZF~H%%%---DDDEEE6666666633337777,,,,,, """++++"""""""""""r'rc.eZdZdZeZdZdZdZdZ dS) JSONBFieldJSONBc|Dt|ts-t||}|SdSr?)r]r rfrrhrGs r&rIzJSONBField.db_value sF  eT** :!1!1%!8!899L  r'c6t|Sr?)rfrgr@s r&rgzJSONBField.jsonswwt}}r'c>d|D}tj|g|RS)Nc0g|]}t|dSrrrs r&rz&JSONBField.extract..rr')rfrrs r&rzJSONBField.extracts.::E:::-u----r'cx|s'||Stj|g|RSr?)rrrfrrs r&rzJSONBField.removes> ,99T??))++ +t,e,,,,r'N) r(r)r*rBrrrIrgrrr2r'r&rrsZJ D ...-----r'rcJeZdZd fd ZdZedZdZd d ZxZ S) SearchFieldFNc |rtdt|ztt|||ddS)Nz8SearchField does not accept these keyword arguments: %s.T) unindexedr,null)rsortedrrrO)r!rr,kr%s r&rOzSearchField.__init__sm  ;.06q :;; ; k4  ))I6A * N N N N Nr'c"t||Sr?)match)r!terms r&rzSearchField.match%sT4   r'ct|ds:d|jjjD}||j|_|jS)N_fts_column_indexcFg|]}t|t|jSr2)r]rr#)rfs r&rz0SearchField.fts_column_index..+s8<<< *1k : :.VsDDDc!ffDDDr' UNINDEXEDc,g|]}t|Sr2rrs r&rzCVirtualTableSchemaManager._create_virtual_table..bs===c!ff===r')r" clean_optionsr roptions_create_contextliteralrextension_moduler]r r8prefix_argumentsextendrr_hiddenrr,rrlr arguments_create_table_option_sqlr) r!saferr9 ext_moduler#metarR field_defs r&_create_virtual_tablez/VirtualTableSchemaManager._create_virtual_table=s&*** tz'/ 9 9;;""$$ +,,,  * KK( ) ) ) #dj// ')   Z%6 j$ ' ' '77:&& & J  ((--- z   F   DDd.CDDD E E E' 2 2E%*.. %-  1223I 3  [!1!1222   Xi00 1 1 1 1 > ?   ==dn=== > > >  E   T::7CC D D Dww' 22333r'c t|jtr|j|fi|St t |j|fi|Sr?) issubclassr" VirtualModelr)rr _create_table)r!r%rr%s r&r-z'VirtualTableSchemaManager._create_tablehsd dj, / / ?-4-d>>g>> >Cu.55C  r'T)r(r)r*r)r-r-r.s@r&rr<sR)4)4)4)4Vr'rc>eZdZGddZedZdS)r,c"eZdZdZdZdZdZeZdS)VirtualModel.MetaNF) r(r)r*r#rr  primary_keyrschema_manager_classr2r'r&Metar1qs,  8r'r4c|Sr?r2)clsrs r&rzVirtualModel.clean_optionsxsr'N)r(r)r*r4 classmethodrr2r'r&r,r,psW99999999[r'r,c$eZdZedZdS) BaseFTSModelc~|d}|d}|d}|d}t|tr |dkrd|d<n.s":":":a3q66":":":r'z'%s'z' fts5z"%s")getr]rArrr"r table_namer,rdtuplerZstriprlower)r6rr;r<r=r>s r&rzBaseFTSModel.clean_options~sG++i((X&&;;z** O44 gs # # =2 !%GI    ' ' =!' (;(F(/(;"="=GI   $'4GO $  <&4-00 <":":6":":":;; &d);); ;GH   4 288::fDD#)8"3GJ r'N)r(r)r*r7rr2r'r&r9r9}s-[r'r9ceZdZdZeZGddZedZedZ edZ edZ edd Z edd Z ed ZedZedZedZedZedZe ddZe ddZe ddZe ddZdS)FTSModelz VirtualModel class for creating tables that use either the FTS3 or FTS4 search extensions. Peewee automatically determines which version of the FTS extension is supported and will use FTS4 if possible. ceZdZdezZdS) FTSModel.MetazFTS%sN)r(r)r* FTS_VERSIONrr2r'r&r4rLs"[0r'r4c |jj}|jjd|d|d|d}|S)Nz INSERT INTO (z ) VALUES('z');)rrEdatabase execute_sqlfetchone)r6cmdtblress r&_fts_cmdzFTSModel._fts_cmdsOi"i ,,,25##sssCCC @BB||~~r'c,|dSNoptimizerVr6s r&rYzFTSModel.optimize||J'''r'c,|dSNrebuildrZr[s r&r_zFTSModel.rebuild||I&&&r'c,|dS)Nintegrity-checkrZr[s r&integrity_checkzFTSModel.integrity_checks||-...r'c8|d|d|S)Nzmerge=r?rZ)r6blockssegmentss r&mergezFTSModel.merges!|||VVVXX>???r'Tc:|d|rdpdzS)Nz automerge=%s10rZ)r6states r& automergezFTSModel.automerges"||Nem.BsCDDDr'c6t|jj|SzU Generate a `MATCH` expression appropriate for searching this table. rrrr6rs r&rzFTSModel.match SY%t,,,r'czt|jjt}tj|g|RSr?)rf matchinforrFTS3_MATCHINFOfts_rank)r6weightsrus r&rankz FTSModel.ranks2LL!1>BB {9/w////r'czt|jjt}tj|g|RSr?)rfrurrFTS4_MATCHINFOfts_bm25r6rx match_infos r&bm25z FTSModel.bm25s2\\#)"2NCC {:00000r'czt|jjt}tj|g|RSr?)rfrurrr{ fts_bm25fr}s r&bm25fzFTSModel.bm25fs2\\#)"2NCC |J11111r'czt|jjt}tj|g|RSr?)rfrurrr{ fts_lucener}s r&lucenezFTSModel.lucenes2\\#)"2NCC }Z2'2222r'c|s |}nut|tr[g}|jjD]F} || || jd} || G||}n||}d} |} |r|||f} |r|st|} |j | | | | S)N?r2) r]rerrrDr#rlaliasr8selectwhererorder_by) r6rrx with_score score_aliasscore_fnexplicit_orderingry weight_argsrR field_weight selectionrs r&_searchzFTSModel._searchs &8::DD  & & &K0 1 1 '{{5'++ej#2N2NOO ""<00008[)DD8W%D   7djj556I  (/ (;''H$syy''(## %r'NFscorec@||||||j|S'Full-text search using selected `term`.)rryr6rrxrrrs r&searchzFTSModel.search.{{     H   r'c@||||||j|Sz:Full-text search for selected `term` using BM25 algorithm.)rrrs r& search_bm25zFTSModel.search_bm25rr'c@||||||j|Sr)rrrs r& search_bm25fzFTSModel.search_bm25fs.{{     I   r'c@||||||j|Sr)rrrs r& search_lucenezFTSModel.search_lucenes.{{     J   r')rdrer.NFrF)r(r)r*__doc__r0r1r4r7rVrYr_rcrirnrryrrrrrrrrr2r'r&rJrJsA JLLE11111111[ (([(''['//[/@@@[@EEE[E--[- 00[011[122[233[3%%[%6FM!&   [ 8=;@   [ 9>r1s8KK3q663J3JSVV3J3J3J3JKKr'z [^\s"]+|"[^"\\]*(?:\\.[^"\\]*)*"c*eZdZdZeZGddZddddZedZ ed Z e d Z e e d fd Zed ZedZedZe d"dZe d"dZedZedZedZedZedZedZedZedZedZed#dZed$d!ZdS)% FTS5Modelan Requires SQLite >= 3.9.0. Table options: content: table name of external content, or empty string for "contentless" content_rowid: column name of external content primary key prefix: integer(s). Ex: '2' or '2 3 4' tokenize: porter, unicode61, ascii. Ex: 'porter unicode61' The unicode tokenizer supports the following parameters: * remove_diacritics (1 or 0, default is 1) * tokenchars (string of characters, e.g. '-_' * separators (string of characters) Parameters are passed as alternating parameter name and value, so: {'tokenize': "unicode61 remove_diacritics 0 tokenchars '-_'"} Content-less tables: If you don't need the full-text content in it's original form, you can specify a content-less table. Searches and auxiliary functions will work as usual, but the only values returned when SELECT-ing can be rowid. Also content-less tables do not support UPDATE or DELETE. External content tables: You can set up triggers to sync these, e.g. -- Create a table. And an external content fts5 table to index it. CREATE TABLE tbl(a INTEGER PRIMARY KEY, b); CREATE VIRTUAL TABLE ft USING fts5(b, content='tbl', content_rowid='a'); -- Triggers to keep the FTS index up to date. CREATE TRIGGER tbl_ai AFTER INSERT ON tbl BEGIN INSERT INTO ft(rowid, b) VALUES (new.a, new.b); END; CREATE TRIGGER tbl_ad AFTER DELETE ON tbl BEGIN INSERT INTO ft(fts_idx, rowid, b) VALUES('delete', old.a, old.b); END; CREATE TRIGGER tbl_au AFTER UPDATE ON tbl BEGIN INSERT INTO ft(fts_idx, rowid, b) VALUES('delete', old.a, old.b); INSERT INTO ft(rowid, b) VALUES (new.a, new.b); END; Built-in auxiliary functions: * bm25(tbl[, weight_0, ... weight_n]) * highlight(tbl, col_idx, prefix, suffix) * snippet(tbl, col_idx, prefix, suffix, ?, max_tokens) ceZdZdZdS)FTS5Model.MetarCN)r(r)r*rr2r'r&r4rqs!r'r4zQBesides the implicit `rowid` column, all columns must be instances of SearchFieldz3Secondary indexes are not supported for FTS5 modelsz4FTS5 models must use the default `rowid` primary key)rBrpkc^|jjjdkrt|jd|jjD]8}t|ttfst|jd9|jj rt|jddS)NrrrBr) rr2r#ImproperlyConfigured_error_messagesfieldsvaluesr]rrindexes)r6rRs r&validate_modelzFTS5Model.validate_model{s 9 % 0 0&s':4'@AA AY%,,.. N NEek:%>?? N*3+>|+LMMM N 9  E&s':7'CDD D E Er'ctjddtkrdStjd} |dno# |d|d|jjdn#YY| dSxYwYnxYw| n#| wxYwdS)NrFz:memory:z0CREATE VIRTUAL TABLE fts5test USING fts5 (data);TrC) rsqlite_version_infoFTS5_MIN_SQLITE_VERSIONconnectexecuteenable_load_extensionload_extensionrrPclose)r6tmp_dbs r&fts5_installedzFTS5Model.fts5_installeds  &rr *-D D D5,,  NNM N N N N : :,,T222%%f--- "11&9999 u LLNNNNN:9 LLNNNNFLLNNNNtsAA C B7*B8 B7B2B7C2B75CC%ct|}|D]G}|dr|dr-t |t zrdSHdS)z Simple helper function to indicate whether a search query is a valid FTS5 query. Note: this simply looks at the characters being used, and is not guaranteed to catch all problematic queries. "FT) _quote_refindall startswithendswithru_invalid_ascii)querytokenstokens r&validate_queryzFTS5Model.validate_querysv""5))  E$$ )<)< 5zzN* uu tr'rcg}d}t|}|D]}|dr+|dr||Bt |}|t z}|rd}|D]}|||}|||rd|S|S)z2 Clean a query of invalid tokens. FrTr) rrrrrlrurrxrZ) rrxaccum any_invalidrr token_setinvalid_for_tokencs r& clean_queryzFTS5Model.clean_querys  ""5)) E$$ )<)<  U###E I )N :   6" *66A!MM!W55EE LL      #88E?? " r'c6t|jj|Srprqrrs r&rzFTS5Model.matchrsr'c8|r |j|ntdS)Nry)rr8)r6r$s r&ryzFTS5Model.ranks"&7xsxCKK7r'c:tj|jjg|RSr?)rfrrr)r6rxs r&rzFTS5Model.bm25swsy'2'2222r'NFrcd|t|||||Sr)rrrrs r&rzFTS5Model.searchs7  ! !$ ' '      r'c |std}nt|trg}|jjD]`}t|t rI|jsB|||||j datj |jj g|R}ntj |jj g|R}d} |} |r|| |f} |r|st|} |j| |t"|| S)rryrr2)r8r]rerrrrrlrDr#rfrrrrrrrrr) r6rrxrrrryrrRrrs r&rzFTS5Model.search_bm25si 7v;;DD  & & 7K0 J Je[11J%/J&& E7;;uz3+G+GHHJJJ739+:k:::DD739+6g666D   7djj556I  (/ (;''H$syy!6!6t!>(## %r'c l|jj}|g}|g}|D]<\}}|t |||=t t d|jjt|t dt|fS)Nz INSERT INTOVALUES)rritemsrlrr r8r)r6rS extra_paramsrTcolumnsrkeyrHs r& _fts_cmd_sqlzFTS5Model._fts_cmd_sqlsi%&,,.. ! !JC NN6#;; ' ' ' MM%     I  W % % MM V $ $ &'' 'r'c \|j|fi|}|jj|Sr?)rrrPr)r6rSrrs r&rVzFTS5Model._fts_cmd s5  55 55y!))%000r'cld|cxkrdksntd|d|S)Nrr zlevel must be between 0 and 16rnry)rrV)r6levels r&rnzFTS5Model.automergesFU    b    =>> >||Ke|444r'c0|d|S)NrirrZ)r6npagess r&rizFTS5Model.merges||G&|111r'c,|dSrXrZr[s r&rYzFTS5Model.optimizer\r'c,|dSr^rZr[s r&r_zFTS5Model.rebuildr`r'c0|d|S)NpgszrrZ)r6rs r&set_pgszzFTS5Model.set_pgsz s||F|...r'c0|d|S)NryrrZ)r6rank_expressions r&set_rankzFTS5Model.set_rank$s||F|999r'c,|dS)Nz delete-allrZr[s r& delete_allzFTS5Model.delete_all(s||L)))r'rc0|d|S)NrbrrZ)r6rys r&rczFTS5Model.integrity_check,s||-D|999r'rowc dvrtddz}t|sGfdd}ttt t t |d}dkrtt|d<ndkrtt|d <d jz}t|t|tf|t|S) N)rcolinstancez5table_type must be either "row", "col" or "instance".z_vocab_model_%sceZdZjjZpjjdzZejje Z dS)"FTS5Model.VocabModel..Meta_vN) r(r)r*rrPrErf fts5vocabrr8r)r6table table_typesr&r4r9sV9-"Aci&:T&A #%<<I$C OO$%$%   r'r4)rdoccntrr4rroffsetz%sVocab) rrr TextField IntegerFieldrr(setattrrr,getattr)r6rrattrr4attrs class_names``` r& VocabModelzFTS5Model.VocabModel0s, 7 7 7+,, ,!:-sD!! I % % % % % % % % % % % %%Y//#~~#~~# EU""+I66e z))".|"<"<h"S\1J CtJGG H H HsD!!!r'r)r)rN)r(r)r*rrrr4rr7rr staticmethodrrrrryrrrrrVrnrirYr_rrrrcrr2r'r&rr7s44n JLLE""""""""5FD OEE[E[*  \ #&3r77\.--[- 88[833[3FM!&[8=;@%%%[%6 ' '[ '11[155[5 22[2(([(''['//[/::[:**[*:::[:"""["""r'rMATCHc8t|tj|Sr?)rr r)lhsrs r&rrTs c28S ) ))r'):rgresyswarningspeeweerrrrrr r r r r rplayhouse.sqlite_udfrrrrvr{rrMr AutoFieldrr0r4 DecimalFieldr< DateTimeFieldrDrLrrrrrr SchemaManagerrModelr,r9rJ _alphabetruupperrrrangercompilerrrrr2r'r&rs ######%%%%%%%%%%%%444444 22A26)CC!!KKK#9999999911111111;;;;;;;; """""L""" % % % % %} % % %;7;7;7;7;7z;7;7;7z77777777>]"]"]"]"]" ]"]"]"@--------.33333%333>11111 111h     5   <@LLLLL|LLL^ ) S* + + S^^ S"" # #$S##b''__ KKUU3ZZKKKKK  BJ: ; ; X"X"X"X"X" X"X"X"v *****r'