fix getConnection before acquire mainConnLock

Author: Librazy

src/main/java/cat/nyaa/nyaacore/database/provider/SQLiteDatabase.java

@@ -96,7 +96,13 @@ protected Object clone() throws CloneNotSupportedException {
     @Override
     @SuppressWarnings("rawtypes")
     public void createTable(Class<?> cls) {
-        mainConnLock.acquireUninterruptibly();
+        try {
+            if (!mainConnLock.tryAcquire(10, TimeUnit.SECONDS)) {
+                throw new IllegalStateException();
+            }
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
         try {
             Validate.notNull(cls);
             if (createdTableClasses.contains(cls)) return;
@@ -150,27 +156,27 @@ public void rollbackTransaction() {
     @Override
     public <T> SynchronizedQuery.TransactionalQuery<T> queryTransactional(Class<T> tableClass) {
         Connection conn;
-        try {
-            createTable(tableClass);
-            conn = getConnection();
-            conn.setAutoCommit(false);
-        } catch (Throwable ex) {
-            mainConnLock.release();
-            throw new RuntimeException(ex);
-        }
+        createTable(tableClass);
         try {
             if (!mainConnLock.tryAcquire(10, TimeUnit.SECONDS)) {
                 throw new IllegalStateException();
             }
         } catch (InterruptedException e) {
             throw new RuntimeException(e);
         }
+        try {
+            conn = getConnection();
+            conn.setAutoCommit(false);
+        } catch (Throwable ex) {
+            mainConnLock.release();
+            throw new RuntimeException(ex);
+        }
         SQLiteQuery<T> sqliteQuery = new SQLiteQuery<>(tableClass, conn, logger);
         FinalizablePhantomReference<SynchronizedQuery.TransactionalQuery<T>> reference = new FinalizablePhantomReference<SynchronizedQuery.TransactionalQuery<T>>(sqliteQuery, frq) {
             public void finalizeReferent() {
                 Semaphore lock = references.remove(this);
                 if (lock != null) {
-                    logger.severe("Unhandled TransactionalQuery found");
+                    logger.severe("Unhandled TransactionalQuery found: " + this);
                     try {
                         if (conn.isValid(1) && !conn.getAutoCommit()) {
                             conn.rollback();
@@ -180,7 +186,7 @@ public void finalizeReferent() {
                         logger.log(Level.SEVERE, "Bad connection!", e);
                     }
                     dbConn = null;
-                    dbConn = newConnection();
+                    dbConn = createConnection();
                     lock.release();
                 }
             }