diff --git a/ckanext/datastore/backend/postgres.py b/ckanext/datastore/backend/postgres.py
index 57de29d0c99..186dda97563 100644
--- a/ckanext/datastore/backend/postgres.py
+++ b/ckanext/datastore/backend/postgres.py
@@ -1504,11 +1504,10 @@ def _remove_explain(msg):
                        .replace('EXPLAIN ', ''))
 
         raise ValidationError({
-            'query': [_remove_explain(str(e))],
+            'sql': [_remove_explain(str(e.orig))],
             'info': {
                 'statement': [_remove_explain(e.statement)],
                 'params': [e.params],
-                'orig': [_remove_explain(str(e.orig))]
             }
         })
     except DBAPIError, e:
diff --git a/ckanext/datastore/logic/action.py b/ckanext/datastore/logic/action.py
index a831805057d..06725c6a0db 100644
--- a/ckanext/datastore/logic/action.py
+++ b/ckanext/datastore/logic/action.py
@@ -111,10 +111,10 @@ def datastore_create(context, data_dict):
                 {'sql': materialized_view_sql, 'dry_run': True})
         except p.toolkit.ValidationError as e:
             raise p.toolkit.ValidationError(
-                {'datastore_search_sql': e.error_dict['sql']})
+                {'materialized_view_sql': e.error_dict['sql']})
         except p.toolkit.NotAuthorized as e:
             raise p.toolkit.ValidationError(
-                {'datastore_search_sql': e.message})
+                {'materialized_view_sql': e.message})
 
     if 'resource' in data_dict and 'resource_id' in data_dict:
         raise p.toolkit.ValidationError({
diff --git a/ckanext/datastore/plugin.py b/ckanext/datastore/plugin.py
index 488320cedab..4a2c79f033c 100644
--- a/ckanext/datastore/plugin.py
+++ b/ckanext/datastore/plugin.py
@@ -278,7 +278,7 @@ def datastore_resource_query(value):
             None,
             {'sql': value, 'dry_run': True})
     except p.toolkit.ValidationError as e:
-        raise p.toolkit.Invalid(e['sql'])
+        raise p.toolkit.Invalid(e.error_dict['sql'])
     except p.toolkit.NotAuthorized as e:
         raise p.toolkit.Invalid(e.message)
     return value