diff --git a/SDMeta/Cache/SqliteDataSource.cs b/SDMeta/Cache/SqliteDataSource.cs
index 13ae550..0c52edf 100644
--- a/SDMeta/Cache/SqliteDataSource.cs
+++ b/SDMeta/Cache/SqliteDataSource.cs
@@ -75,15 +75,12 @@ private SqliteConnection GetConnection()
 
         private T ExecuteOnConnection<T>(Func<SqliteConnection, SqliteTransaction?, T> func)
         {
-            if (this.transaction?.Connection != null)
+            lock (transactionLock)
             {
-                lock (transactionLock)
+                var currentTransaction = this.transaction;
+                if (currentTransaction?.Connection != null)
                 {
-                    var currentTransaction = this.transaction;
-                    if (currentTransaction?.Connection != null)
-                    {
-                        return func(currentTransaction.Connection, currentTransaction);
-                    }
+                    return func(currentTransaction.Connection, currentTransaction);
                 }
             }