Fixed db inconsistency (#779)

* Fixed db creation inconsistency in taskdb, projectdb and resultdb * Fixed typo
binux · Apr 8, 2018 · 1e45731 · 1e45731
1 parent a203a77
commit 1e45731
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/pyspider/database/sqlalchemy/resultdb.py b/pyspider/database/sqlalchemy/resultdb.py
@@ -37,9 +37,10 @@ def __init__(self, url):
             database = self.url.database
             self.url.database = None
             try:
-                engine = create_engine(self.url, convert_unicode=True,
-                                       pool_recycle=3600)
-                engine.execute("CREATE DATABASE IF NOT EXISTS %s" % database)
+                engine = create_engine(self.url, convert_unicode=True, pool_recycle=3600)
+                conn = engine.connect()
+                conn.execute("commit")
+                conn.execute("CREATE DATABASE %s" % database)
             except sqlalchemy.exc.SQLAlchemyError:
                 pass
             self.url.database = database