summary refs log tree commit diff
path: root/synapse
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2016-01-29 14:41:16 +0000
committerErik Johnston <erik@matrix.org>2016-01-29 14:41:16 +0000
commitf67d60496a8a9b2c95fcacb6d4c539a1d4b6a105 (patch)
tree70ccf422cebff962c099b774517b10988e475e4a /synapse
parentPrefill stream change caches (diff)
downloadsynapse-f67d60496a8a9b2c95fcacb6d4c539a1d4b6a105.tar.xz
Convert param style
Diffstat (limited to 'synapse')
-rw-r--r--synapse/storage/__init__.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/storage/__init__.py b/synapse/storage/__init__.py
index 95ae97d507..2ed505cb1e 100644
--- a/synapse/storage/__init__.py
+++ b/synapse/storage/__init__.py
@@ -85,6 +85,7 @@ class DataStore(RoomMemberStore, RoomStore,
 
     def __init__(self, db_conn, hs):
         self.hs = hs
+        self.database_engine = hs.database_engine
 
         cur = db_conn.cursor()
         try:
@@ -157,6 +158,8 @@ class DataStore(RoomMemberStore, RoomStore,
             "stream": stream_column,
         }
 
+        sql = self.database_engine.convert_param_style(sql)
+
         txn = db_conn.cursor()
         txn.execute(sql, (int(max_value),))
         rows = txn.fetchall()