Package org.bitcoinj.store

Class PostgresFullPrunedBlockStore

java.lang.Object

org.bitcoinj.store.DatabaseFullPrunedBlockStore

org.bitcoinj.store.PostgresFullPrunedBlockStore

All Implemented Interfaces:

UTXOProvider, BlockStore, FullPrunedBlockStore

public class PostgresFullPrunedBlockStore
extends DatabaseFullPrunedBlockStore

A full pruned block store using the Postgres database engine. As an added bonus an address index is calculated, so you can use DatabaseFullPrunedBlockStore.calculateBalanceForAddress(Address) to quickly look up the quantity of bitcoins controlled by that address.

Field Summary

Fields inherited from class org.bitcoinj.store.DatabaseFullPrunedBlockStore

allConnections, chainHeadBlock, chainHeadHash, conn, connectionURL, fullStoreDepth, params, password, schemaName, username, verifiedChainHeadBlock, verifiedChainHeadHash

Constructor Summary

Constructors

Constructor	Description
PostgresFullPrunedBlockStore(NetworkParameters params, int fullStoreDepth, String hostname, String dbName, String username, String password)	Creates a new PostgresFullPrunedBlockStore.
PostgresFullPrunedBlockStore(NetworkParameters params, int fullStoreDepth, String hostname, String dbName, String username, String password, String schemaName)	Create a new PostgresFullPrunedBlockStore, storing the tables in the schema specified.

Method Summary

Modifier and Type	Method	Description
protected List<String>	getCreateIndexesSQL()	Get the SQL statements that create the indexes (DDL).
protected List<String>	getCreateSchemeSQL()	Get the SQL statements that create the schema (DDL).
protected List<String>	getCreateTablesSQL()	Get the SQL statements that create the tables (DDL).
protected String	getDatabaseDriverClass()	Get the database driver class,
protected String	getDuplicateKeyErrorCode()	Get the database specific error code that indicated a duplicate key error when inserting a record.
void	put(StoredBlock storedBlock, StoredUndoableBlock undoableBlock)	Saves the given StoredUndoableBlock and StoredBlock.

Methods inherited from class org.bitcoinj.store.DatabaseFullPrunedBlockStore

abortDatabaseBatchWrite, addUnspentTransactionOutput, beginDatabaseBatchWrite, calculateBalanceForAddress, close, commitDatabaseBatchWrite, deleteStore, dumpSizes, get, get, getBalanceSelectSQL, getChainHead, getChainHeadHeight, getCompatibilitySQL, getDeleteOpenoutputsSQL, getDeleteUndoableBlocksSQL, getDropTablesSQL, getInsertHeadersSQL, getInsertOpenoutputsSQL, getInsertSettingsSQL, getInsertUndoableBlocksSQL, getOnceUndoableStoredBlock, getOpenTransactionOutputs, getParams, getSelectHeadersDumpSQL, getSelectHeadersSQL, getSelectOpenoutputsCountSQL, getSelectopenoutputsDumpSQL, getSelectOpenoutputsSQL, getSelectSettingsDumpSQL, getSelectSettingsSQL, getSelectUndoableblocksDumpSQL, getSelectUndoableBlocksSQL, getTablesExistSQL, getTransactionOutput, getTransactionOutputSelectSQL, getUndoBlock, getUpdateHeadersSQL, getUpdateSettingsSLQ, getUpdateUndoableBlocksSQL, getVerifiedChainHead, hasUnspentOutputs, maybeConnect, put, putUpdateStoredBlock, removeUnspentTransactionOutput, resetStore, setChainHead, setVerifiedChainHead

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PostgresFullPrunedBlockStore

public PostgresFullPrunedBlockStore(NetworkParameters params,
 int fullStoreDepth,
 String hostname,
 String dbName,
 String username,
 String password)
                             throws BlockStoreException

Creates a new PostgresFullPrunedBlockStore.

Parameters:

params - A copy of the NetworkParameters used

fullStoreDepth - The number of blocks of history stored in full (something like 1000 is pretty safe)

hostname - The hostname of the database to connect to

dbName - The database to connect to

username - The database username

password - The password to the database

Throws:

BlockStoreException - if the database fails to open for any reason

PostgresFullPrunedBlockStore

public PostgresFullPrunedBlockStore(NetworkParameters params,
 int fullStoreDepth,
 String hostname,
 String dbName,
 String username,
 String password,
 @Nullable
 String schemaName)
                             throws BlockStoreException

Create a new PostgresFullPrunedBlockStore, storing the tables in the schema specified. You may want to specify a schema to avoid name collisions, or just to keep the database better organized. The schema is not required, and if one is not provided than the default schema for the username will be used. See the postgres schema docs for more on schemas.

Parameters:

params - A copy of the NetworkParameters used.

fullStoreDepth - The number of blocks of history stored in full (something like 1000 is pretty safe).

hostname - The hostname of the database to connect to.

dbName - The database to connect to.

username - The database username.

password - The password to the database.

schemaName - The name of the schema to put the tables in. May be null if no schema is being used.

Throws:

BlockStoreException - If the database fails to open for any reason.

Method Details

getDuplicateKeyErrorCode

protected String getDuplicateKeyErrorCode()

Description copied from class: DatabaseFullPrunedBlockStore

Get the database specific error code that indicated a duplicate key error when inserting a record.

This is the code returned by SQLException.getSQLState()

Specified by:

getDuplicateKeyErrorCode in class DatabaseFullPrunedBlockStore

Returns:

The database duplicate error code.

getCreateTablesSQL

protected List<String> getCreateTablesSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL statements that create the tables (DDL).

Specified by:

getCreateTablesSQL in class DatabaseFullPrunedBlockStore

Returns:

The list of SQL statements.

getCreateIndexesSQL

protected List<String> getCreateIndexesSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL statements that create the indexes (DDL).

Specified by:

getCreateIndexesSQL in class DatabaseFullPrunedBlockStore

Returns:

The list of SQL statements.

getCreateSchemeSQL

protected List<String> getCreateSchemeSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL statements that create the schema (DDL).

Specified by:

getCreateSchemeSQL in class DatabaseFullPrunedBlockStore

Returns:

The list of SQL statements.

getDatabaseDriverClass

protected String getDatabaseDriverClass()

Description copied from class: DatabaseFullPrunedBlockStore

Get the database driver class,

i.e org.postgresql.Driver.

Specified by:

getDatabaseDriverClass in class DatabaseFullPrunedBlockStore

Returns:

The fully qualified database driver class.

put

public void put(StoredBlock storedBlock,
 StoredUndoableBlock undoableBlock)
         throws BlockStoreException

Description copied from interface: FullPrunedBlockStore

Saves the given StoredUndoableBlock and StoredBlock. Calculates keys from the StoredBlock

Though not required for proper function of a FullPrunedBlockStore, any user of a FullPrunedBlockStore should ensure that a StoredUndoableBlock for each block up to the fully verified chain head has been added to this block store using this function (not put(StoredBlock)), so that the ability to perform reorgs is maintained.

Specified by:

put in interface FullPrunedBlockStore

Overrides:

put in class DatabaseFullPrunedBlockStore

Throws:

BlockStoreException - if there is a problem with the underlying storage layer, such as running out of disk space.