diff --git a/gemp-lotr/gemp-lotr-server/src/main/java/com/gempukku/lotro/db/DbCollectionDAO.java b/gemp-lotr/gemp-lotr-server/src/main/java/com/gempukku/lotro/db/DbCollectionDAO.java
index 306a95fa9..1779d1033 100644
--- a/gemp-lotr/gemp-lotr-server/src/main/java/com/gempukku/lotro/db/DbCollectionDAO.java
+++ b/gemp-lotr/gemp-lotr-server/src/main/java/com/gempukku/lotro/db/DbCollectionDAO.java
@@ -32,16 +32,7 @@ public class DbCollectionDAO implements CollectionDAO {
                     while (rs.next()) {
                         int playerId = rs.getInt(1);
                         Blob blob = rs.getBlob(2);
-                        try {
-                            InputStream inputStream = blob.getBinaryStream();
-                            try {
-                                playerCollections.put(playerId, _collectionSerializer.deserializeCollection(inputStream));
-                            } finally {
-                                inputStream.close();
-                            }
-                        } finally {
-                            blob.free();
-                        }
+                        playerCollections.put(playerId, extractCollectionAndClose(blob));
                     }
                     return playerCollections;
                 } finally {
@@ -66,16 +57,7 @@ public class DbCollectionDAO implements CollectionDAO {
                 try {
                     if (rs.next()) {
                         Blob blob = rs.getBlob(1);
-                        try {
-                            InputStream inputStream = blob.getBinaryStream();
-                            try {
-                                return _collectionSerializer.deserializeCollection(inputStream);
-                            } finally {
-                                inputStream.close();
-                            }
-                        } finally {
-                            blob.free();
-                        }
+                        return extractCollectionAndClose(blob);
                     } else {
                         return null;
                     }
@@ -90,6 +72,19 @@ public class DbCollectionDAO implements CollectionDAO {
         }
     }
 
+    private CardCollection extractCollectionAndClose(Blob blob) throws SQLException, IOException {
+        try {
+            InputStream inputStream = blob.getBinaryStream();
+            try {
+                return _collectionSerializer.deserializeCollection(inputStream);
+            } finally {
+                inputStream.close();
+            }
+        } finally {
+            blob.free();
+        }
+    }
+
     public void setPlayerCollection(int playerId, String type, CardCollection collection) throws SQLException, IOException {
         CardCollection oldCollection = getPlayerCollection(playerId, type);