]j 4 d Z ddlZddlT ddlmZ ddlmZ ddlmZ ddlmZ ddlm
Z dd lm Z dd
lm
Z dd lmZ dd lmZ G d
de Zd Z G d de Z G d de Z G d de Z
G d de Z G d de Z
dS )an
Peewee integration with APSW, "another python sqlite wrapper".
Project page: https://rogerbinns.github.io/apsw/
APSW is a really neat library that provides a thin wrapper on top of SQLite's
C interface.
Here are just a few reasons to use APSW, taken from the documentation:
* APSW gives all functionality of SQLite, including virtual tables, virtual
file system, blob i/o, backups and file control.
* Connections can be shared across threads without any additional locking.
* Transactions are managed explicitly by your code.
* APSW can handle nested transactions.
* Unicode is handled correctly.
* APSW is faster.
N)*)__exception_wrapper__) BooleanField) DateField)
DateTimeField) DecimalField)Insert) TimeField)logger)SqliteExtDatabasec e Zd Z ed ej d D Z fdZd Z d Z
d Z fdZ d Z
d Zd
Zd Zd Zd
ZddZd ZddZd Zd ZddZ xZS ) APSWDatabasec # 4 K | ]}t | V d S N)int).0is r/builddir/build/BUILD/imunify360-venv-2.6.3/opt/imunify360/venv/lib/python3.11/site-packages/playhouse/apsw_ext.py <genexpr>zAPSWDatabase.<genexpr>" s( NNa3q66NNNNNN .c X i | _ t t | j |fi | d S r )_modulessuperr __init__)selfdatabasekwargs __class__s r r zAPSWDatabase.__init__$ s5
*lD!!*8>>v>>>>>r c || j |< | s*| || d S d S r )r is_closed
connection createmodule)r mod_namemod_insts r register_modulez APSWDatabase.register_module( sP "*
h ~~ ? OO * *8X > > > > > ? ?r c | j |= d S r )r )r r$ s r unregister_modulez APSWDatabase.unregister_module- s M( # # #r c t j | j fi | j }| j | | j dz | | n# | xY w|S )Ni )apsw
Connectionr connect_params_timeoutsetbusytimeout_add_conn_hooksclose)r conns r _connectzAPSWDatabase._connect0 s{ t}DD0CDD = $
4 5 5 5 & & & & JJLLL s A A/c t t | | | | d S r )r r r/
_load_modules)r r1 r s r r/ z APSWDatabase._add_conn_hooks; s;
lD!!11$777 4 r c p | j D ]\ }}| || |S r )r itemsr# )r r1 r$ r% s r r4 zAPSWDatabase._load_modules? sB "&-"5"5"7"7 2 2 Hh h 1 1 1 1 r c | j D ]#\ }\ }fd}| || $d S )Nc 2 j j fS r )stepfinalize)klasss r make_aggregatez5APSWDatabase._load_aggregates.<locals>.make_aggregateF s U^<<r ) _aggregatesr6 createaggregatefunction)r r1 name
num_paramsr< r; s @r _load_aggregatesz APSWDatabase._load_aggregatesD sg )-)9)?)?)A)A ? ? %D%5*
=
=
=
=
= ( (~ > > > > ? ?r c p | j D ]\ }}| || d S r ) _collationsr6 createcollation)r r1 r? fns r _load_collationsz APSWDatabase._load_collationsJ sG (..00 + +HD" r * * * * + +r c z | j D ] \ }\ }}}|r|fnd} |j |||g|R !d S N )
_functionsr6 createscalarfunction)r r1 r? rE r@
deterministicargss r _load_functionsz APSWDatabase._load_functionsN sm 59_5J5J5L5L C C 1D12z='4<M##"D %D %dB
BT B B B B B C Cr c n | d | j D ]}| | d S NT)enableloadextension _extensions
loadextension)r r1 extensions r _load_extensionsz APSWDatabase._load_extensionsS sI &&& ) * *I y ) ) ) ) * *r c | j | | s@| }| d | | d S d S rP )rR addr! r" rQ rS )r rT r1 s r load_extensionzAPSWDatabase.load_extensionX sr Y'''~~ *??$$D $ $T * * * y ) ) ) ) ) * *r Nc | j s&| S |t j k r, |d d S # t
t t f$ r Y nw xY w|S )Nr )returning_clause
getconnectionlast_insert_rowidr SIMPLEAttributeError
IndexError TypeError)r cursor
query_types r last_insert_idzAPSWDatabase.last_insert_id_ sw $ ''));;== =
6=
(
(
ay|#"J :
s
A
A'&A'c | S # t $ r. |j cY S w xY wr )r[ changesr^ ra )r ra s r
rows_affectedzAPSWDatabase.rows_affectedi sf ;''))1133 3 ; ; ;=..0088:: : : : ;s %( 5A A deferredc Z | d|z d S )Nz begin %s;)ra execute)r lock_types r beginzAPSWDatabase.begino s)
kI 566666r c t 5 | }| r d d d dS | d d d d n # 1 swxY w Y dS )NFzcommit;Tr ra r[
getautocommitri r curss r commitzAPSWDatabase.commitr s
" $ $;;==D!!##1133
$ $ $ $ $ $ $ $
LL # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $
t <A2A22A69A6c t 5 | }| r d d d dS | d d d d n # 1 swxY w Y dS )NFz rollback;Trm ro s r rollbackzAPSWDatabase.rollbackz s
" & &;;==D!!##1133
& & & & & & & &
LL % % % & & & & & & & & & & & & & & &
trr c t j ||f t 5 | }| ||pd d d d n # 1 swxY w Y |S rH )r debugr ra ri )r sqlparamsra s r execute_sqlzAPSWDatabase.execute_sql s c6]###
" . .[[]]F NN3 " - - - . . . . . . . . . . . . . . .
s -AA Ar )rg )__name__
__module__ __qualname__tupler* sqlitelibversionsplitserver_versionr r& r( r2 r/ r4 rA rF rN rU rX rc rf rk rq rt ry
__classcell__r s @r r r ! s| UNN+@4+@+B+B+H+H+M+MNNNNNN? ? ? ? ?? ? ?
% % % ! ! ! ! !
? ? ? + + +C C C
* * *
* * * ; ; ; 7 7 7 7 r r c ( |t | S d S r )str)svs r nhr s }1vv
}r c e Zd Z fdZ xZS )r c h t t | | }||rdpdS d S )N r )r r db_value)r r r s r r zBooleanField.db_value s: , % % . .q 1 1 =7<a =r )rz r{ r| r r r s @r r r s8 r r c e Zd ZeZdS )r Nrz r{ r| r r rI r r r r HHHr r c e Zd ZeZdS )r
Nr rI r r r
r
r r r
c e Zd ZeZdS )r Nr rI r r r r r r r c e Zd ZeZdS )r Nr rI r r r r r r r )__doc__r* peeweer r
_BooleanFieldr
_DateFieldr _DateTimeFieldr
_DecimalFieldr r
_TimeFieldr playhouse.sqlite_extr r r rI r r <module>r s $ ( ( ( ( ( ( 0 0 0 0 0 0 * * * * * * 2 2 2 2 2 2 0 0 0 0 0 0 * * * * * * 2 2 2 2 2 2f f f f f$ f f fR =
N = r