diff --git a/ckanext/datastore/db.py b/ckanext/datastore/db.py
index e388bd3694e..c8c119cf69f 100644
--- a/ckanext/datastore/db.py
+++ b/ckanext/datastore/db.py
@@ -158,6 +158,7 @@ def create(context, data_dict):
         else:
             alter_table(context, data_dict)
         insert_data(context, data_dict)
+        trans.commit()
         return data_dict
     except:
         trans.rollback()