Cómo establecer declaraciones SQLite PRAGMA con SQLAlchemy

Question

Me gustaría que SQLAlchemy ponga el archivo SQLite .journal en la memoria para acelerar el rendimiento. He intentado esto:

sqlite_db_engine = create_engine('sqlite:///%s' % str(dbname), connect_args = {'PRAGMA  journal_mode':'MEMORY', 'PRAGMA synchronous':'OFF', 'PRAGMA temp_store':'MEMORY', 'PRAGMA cache_size':'5000000'}) 

db = sqlite_db_engine.connect() 

y esto:

sqlite_db_engine = create_engine('sqlite:///%s' % str(dbname)) 

db = sqlite_db_engine.connect() 
db.execute("PRAGMA journal_mode = MEMORY") 
db.execute("PRAGMA synchronous = OFF") 
db.execute("PRAGMA temp_store = MEMORY") 
db.execute("PRAGMA cache_size = 500000") 

sin suerte. Para transacciones largas, aún puedo ver el archivo .journal que se está creando en el disco. ¿Hay alguna otra manera de establecer esto?

* Nota tengo ningún problema en hacer con el módulo Python SQLite incorporados

Answer 1

Básicamente, usted debería ser capaz de reescribir los ejemplos sobre ForeignKey para lograr lo que quiere. Echar un vistazo a https://stackoverflow.com/a/7831210/1890086

engine = create_engine(database_url) 

def _fk_pragma_on_connect(dbapi_con, con_record): 
    dbapi_con.execute('PRAGMA journal_mode = MEMORY') 
    # ... 

from sqlalchemy import event 
event.listen(engine, 'connect', _fk_pragma_on_connect) 

Answer 2

¿Cómo sobre el uso de eventos:

from sqlalchemy.engine import Engine 
from sqlalchemy import event 

@event.listens_for(Engine, "connect") 
def set_sqlite_pragma(dbapi_connection, connection_record): 
    cursor = dbapi_connection.cursor() 
    cursor.execute("PRAGMA journal_mode=WAL") 
    cursor.close() 

Ver http://docs.sqlalchemy.org/en/rel_0_9/dialects/sqlite.html#foreign-key-support

Answer 3

dos soluciones anteriores no funcionan, por lo que he encontrado the another one.

from sqlalchemy.interfaces import PoolListener 
class MyListener(PoolListener): 
    def connect(self, dbapi_con, con_record): 
     dbapi_con.execute('pragma journal_mode=OFF') 
     dbapi_con.execute('PRAGMA synchronous=OFF') 
     dbapi_con.execute('PRAGMA cache_size=100000') 

engine = create_engine('sqlite:///' + basefile,echo=False, listeners= [MyListener()])