diff options
author | Erik Johnston <erik@matrix.org> | 2015-03-23 15:38:56 +0000 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2015-03-23 15:38:56 +0000 |
commit | 6e7131f02f33695b6423db9a377f130ffebbdb67 (patch) | |
tree | f869beee97728bb359b3d884c6224986fc18c6c8 /synapse/storage/_base.py | |
parent | Sanitize RoomMemberStore (diff) | |
download | synapse-6e7131f02f33695b6423db9a377f130ffebbdb67.tar.xz |
Remove uses of REPLACE and ON CONFLICT IGNORE to make the SQL more portable.
Diffstat (limited to 'synapse/storage/_base.py')
-rw-r--r-- | synapse/storage/_base.py | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/synapse/storage/_base.py b/synapse/storage/_base.py index d038c55092..9214e0c494 100644 --- a/synapse/storage/_base.py +++ b/synapse/storage/_base.py @@ -341,26 +341,21 @@ class SQLBaseStore(object): # "Simple" SQL API methods that operate on a single table with no JOINs, # no complex WHERE clauses, just a dict of values for columns. - def _simple_insert(self, table, values, or_replace=False, or_ignore=False, - desc="_simple_insert"): + def _simple_insert(self, table, values, desc="_simple_insert"): """Executes an INSERT query on the named table. Args: table : string giving the table name values : dict of new column names and values for them - or_replace : bool; if True performs an INSERT OR REPLACE """ return self.runInteraction( desc, - self._simple_insert_txn, table, values, or_replace=or_replace, - or_ignore=or_ignore, + self._simple_insert_txn, table, values, ) @log_function - def _simple_insert_txn(self, txn, table, values, or_replace=False, - or_ignore=False): - sql = "%s INTO %s (%s) VALUES(%s)" % ( - ("REPLACE" if or_replace else "INSERT"), + def _simple_insert_txn(self, txn, table, values): + sql = "INSERT INTO %s (%s) VALUES(%s)" % ( table, ", ".join(k for k in values), ", ".join("?" for k in values) |