Qortal/altcoinj
3
0
Fork 0
mirror of https://github.com/Qortal/altcoinj.git synced 2025-02-12 18:25:51 +00:00
Code Issues Projects Releases Wiki Activity

Add ctor that takes a connectionUrl instead of hostname and database name.

Browse Source 
Avoid exception in close() - only rollback when autocommit is false.
This commit is contained in:
Erik Tierney 2014-02-05 11:26:11 -05:00 committed by Mike Hearn
parent 417c81f54d
commit c95a864831
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
core/src/main/java/com/google/bitcoin/store/PostgresFullPrunedBlockStore.java
View File

@ -107,9 +107,24 @@ public class PostgresFullPrunedBlockStore implements FullPrunedBlockStore {
*/
public PostgresFullPrunedBlockStore(NetworkParameters params, int fullStoreDepth, String hostname, String dbName,
String username, String password) throws BlockStoreException {
this(params, fullStoreDepth, "jdbc:postgresql://" + hostname + "/" + dbName, username, password);
}
/**
* Creates a new PostgresFullPrunedBlockStore.
*
* @param params A copy of the NetworkParameters used
* @param fullStoreDepth The number of blocks of history stored in full (something like 1000 is pretty safe)
* @param connectionURL The jdbc url to connect to the database.
* @param username The database username
* @param password The password to the database
* @throws BlockStoreException if the database fails to open for any reason
*/
public PostgresFullPrunedBlockStore(NetworkParameters params, int fullStoreDepth, String connectionURL,
String username, String password) throws BlockStoreException {
this.params = params;
this.fullStoreDepth = fullStoreDepth;
connectionURL = "jdbc:postgresql://" + hostname + "/" + dbName;
this.connectionURL = connectionURL;
this.username = username;
this.password = password;
@ -160,7 +175,9 @@ public class PostgresFullPrunedBlockStore implements FullPrunedBlockStore {
public synchronized void close() {
for (Connection conn : allConnections) {
try {
if(!conn.getAutoCommit()) {
conn.rollback();
}
} catch (SQLException ex) {
throw new RuntimeException(ex);
}