···

       
1
       
 
       
import logging

     

       
2
       
-
       
import os

     

       
3
       
 
       


     

       
4
       
 
       
import apsw

     

       
5
       
 
       
import apsw.ext

     
···

       
14
       
 
       
    def __init__(self):

     

       
15
       
 
       
        super().__init__()

     

       
16
       
 
       


     

       
17
       
-
       
        db_fname = ''

     

       
18
       
-
       
        if os.path.isdir('/dev/shm/'):

     

       
19
       
-
       
            os.makedirs('/dev/shm/feedgens/', exist_ok=True)

     

       
20
       
-
       
            db_fname = '/dev/shm/feedgens/rapidfire.db'

     

       
21
       
-
       
        else:

     

       
22
       
-
       
            db_fname = 'db/rapidfire.db'

     

       
23
       
-
       


     

       
24
       
-
       
        self.db_cnx = apsw.Connection(db_fname)

     

       
25
       
 
       
        self.db_cnx.pragma('journal_mode', 'WAL')

     

       
26
       
-
       
        self.db_cnx.pragma('synchronous', 'OFF')

     

       
27
       
 
       
        self.db_cnx.pragma('wal_autocheckpoint', '0')

     

       
28
       
 
       


     

       
29
       
 
       
        with self.db_cnx:

     

···

       
1
       
 
       
import logging

     

       
0
       
 
       

     

       
2
       
 
       


     

       
3
       
 
       
import apsw

     

       
4
       
 
       
import apsw.ext

     
···

       
13
       
 
       
    def __init__(self):

     

       
14
       
 
       
        super().__init__()

     

       
15
       
 
       


     

       
16
       
+
       
        self.db_cnx = apsw.Connection('db/rapidfire.db')

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
17
       
 
       
        self.db_cnx.pragma('journal_mode', 'WAL')

     

       
0
       
 
       

     

       
18
       
 
       
        self.db_cnx.pragma('wal_autocheckpoint', '0')

     

       
19
       
 
       


     

       
20
       
 
       
        with self.db_cnx: