ambidextrous/gemp-lotr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improving collection DAO.

Browse Source
This commit is contained in:
marcins78@gmail.com
2012-12-16 18:54:16 +00:00
parent 70978820bf
commit b5d6741e4d
1 changed files with 15 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
gemp-lotr/gemp-lotr-server/src/main/java/com/gempukku/lotro/db/DbCollectionDAO.java
View File

@@ -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);