Catch database errors also on schema initialization

In case any database error occurs on opening the connection and
initializing the schema, catch the error and throw it properly.
For instance, this can happen if the database is locked on opening.

Author: eht16

logstash_async/database.py

@@ -55,8 +55,13 @@ def _close(self):
     # ----------------------------------------------------------------------
     def _initialize_schema(self):
         cursor = self._connection.cursor()
-        for statement in DATABASE_SCHEMA_STATEMENTS:
-            cursor.execute(statement)
+        try:
+            for statement in DATABASE_SCHEMA_STATEMENTS:
+                cursor.execute(statement)
+        except sqlite3.OperationalError:
+            self._close()
+            self._handle_sqlite_error()
+            raise
 
     # ----------------------------------------------------------------------
     def add_event(self, event):