Hopiu/django-cachalot
1
0
Fork 0
mirror of https://github.com/Hopiu/django-cachalot.git synced 2026-05-19 18:01:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Invalidates executemany.

Browse source
This commit is contained in:
Bertrand Bordage 2014-12-07 02:44:50 +01:00
parent 3293c2c644
commit 984b3f2530
1 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
cachalot/monkey_patch.py
View file

@ -109,17 +109,13 @@ def _patch_orm():
def _patch_cursor():
def _patch_cursor_execute(original):
@wraps(original)
def inner(cursor, sql, params=None):
out = original(cursor, sql, params)
def inner(cursor, sql, *args, **kwargs):
out = original(cursor, sql, *args, **kwargs)
if getattr(cursor.db, 'raw', True) \
and cachalot_settings.CACHALOT_INVALIDATE_RAW:
full_sql = sql
if params:
full_sql %= tuple(params)
full_sql = full_sql.lower()
if 'update' in full_sql or 'insert' in full_sql \
or 'delete' in full_sql:
tables = _get_tables_from_sql(cursor.db, full_sql)
sql = sql.lower()
if 'update' in sql or 'insert' in sql or 'delete' in sql:
tables = _get_tables_from_sql(cursor.db, sql)
invalidate_tables(tables, db_alias=cursor.db.alias)
return out
@ -127,6 +123,7 @@ def _patch_cursor():
return inner
CursorWrapper.execute = _patch_cursor_execute(CursorWrapper.execute)
CursorWrapper.executemany = _patch_cursor_execute(CursorWrapper.executemany)
def _patch_atomic():