diff options
| author | Erik Johnston <erik@matrix.org> | 2016-01-29 14:41:16 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-01-29 14:41:16 +0000 |
| commit | f67d60496a8a9b2c95fcacb6d4c539a1d4b6a105 (patch) | |
| tree | 70ccf422cebff962c099b774517b10988e475e4a | |
| parent | Prefill stream change caches (diff) | |
| download | synapse-f67d60496a8a9b2c95fcacb6d4c539a1d4b6a105.tar.xz | |
Convert param style
| -rw-r--r-- | synapse/storage/__init__.py | 3 |
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() |