diff --git a/ckanext/datastore/db.py b/ckanext/datastore/db.py
index 76d7c2c2758..10434a6e8dd 100644
--- a/ckanext/datastore/db.py
+++ b/ckanext/datastore/db.py
@@ -851,6 +851,7 @@ def create(context, data_dict):
         else:
             raise
     except Exception, e:
+        trans.rollback()
         if 'due to statement timeout' in str(e):
             raise ValidationError({
                 'query': ['Query took too long']