diff --git a/synapse/storage/__init__.py b/synapse/storage/__init__.py
index cd9acdc447e9cd86715aaad6235c32f1234fcf7b..75d93f7111cb0fd1656c52bf3d70b111ef5ddccf 100644
--- a/synapse/storage/__init__.py
+++ b/synapse/storage/__init__.py
@@ -119,7 +119,7 @@ class DataStore(RoomDataStore, RoomMemberStore, MessageStore, RoomStore,
         else:
             args = (room_id, )
 
-        results = yield self._execute_query(sql, *args)
+        results = yield self._execute_and_decode(sql, *args)
 
         defer.returnValue(
 
diff --git a/synapse/storage/_base.py b/synapse/storage/_base.py
index befeb55b25d93951b829e37df98a781f651b70bc..7fef8601e726001228063e66570569eae92bdda9 100644
--- a/synapse/storage/_base.py
+++ b/synapse/storage/_base.py
@@ -71,7 +71,7 @@ class SQLBaseStore(object):
 
         return self._db_pool.runInteraction(interaction)
 
-    def _execut_query(self, query, *args):
+    def _execute_and_decode(self, query, *args):
         return self._execute(self.cursor_to_dict, *args)
 
     # "Simple" SQL API methods that operate on a single table with no JOINs,
diff --git a/synapse/storage/feedback.py b/synapse/storage/feedback.py
index b9e792c1205b387366059f2c2822e9baec8f76e5..dd5f3fbc1053dcd1378eaaa507688a91bee89684 100644
--- a/synapse/storage/feedback.py
+++ b/synapse/storage/feedback.py
@@ -39,7 +39,7 @@ class FeedbackStore(SQLBaseStore):
             "WHERE feedback.target_event_id = ? "
         )
 
-        rows = yield self._execute_query(sql, event_id)
+        rows = yield self._execute_and_decode(sql, event_id)
 
         defer.returnValue(
             [
diff --git a/synapse/storage/roommember.py b/synapse/storage/roommember.py
index 60296380e668d6f04b86ad11df70361351edcaec..c99cefbcfc81c0faa0fa706822e56425cd20b29e 100644
--- a/synapse/storage/roommember.py
+++ b/synapse/storage/roommember.py
@@ -141,6 +141,6 @@ class RoomMemberStore(SQLBaseStore):
             "WHERE %s "
         ) % (where_clause,)
 
-        rows = yield self._execute_query(sql, where_values)
+        rows = yield self._execute_and_decode(sql, where_values)
         results = [self._parse_event_from_row(r) for r in rows]
         defer.returnValue(results)