Package org.bitcoinj.store

Class MySQLFullPrunedBlockStore

java.lang.Object

org.bitcoinj.store.DatabaseFullPrunedBlockStore

org.bitcoinj.store.MySQLFullPrunedBlockStore

All Implemented Interfaces:

UTXOProvider, BlockStore, FullPrunedBlockStore

public class MySQLFullPrunedBlockStore
extends DatabaseFullPrunedBlockStore

A full pruned block store using the MySQL 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
MySQLFullPrunedBlockStore(NetworkParameters params, int fullStoreDepth, String hostname, String dbName, String username, String password)	Creates a new MySQLFullPrunedBlockStore.

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	getDeleteOpenoutputsSQL()	Get the SQL to delete a openoutputs record.
protected String	getDuplicateKeyErrorCode()	Get the database specific error code that indicated a duplicate key error when inserting a record.
protected String	getInsertOpenoutputsSQL()	Get the SQL to insert a openoutputs record.
protected String	getSelectOpenoutputsSQL()	Get the SQL to select a openoutputs record.
protected String	getTransactionOutputSelectSQL()	Get the SQL to select the transaction outputs for a given address.

Methods inherited from class org.bitcoinj.store.DatabaseFullPrunedBlockStore

abortDatabaseBatchWrite, addUnspentTransactionOutput, beginDatabaseBatchWrite, calculateBalanceForAddress, close, commitDatabaseBatchWrite, deleteStore, dumpSizes, get, get, getBalanceSelectSQL, getChainHead, getChainHeadHeight, getCompatibilitySQL, getDeleteUndoableBlocksSQL, getDropTablesSQL, getInsertHeadersSQL, getInsertSettingsSQL, getInsertUndoableBlocksSQL, getOnceUndoableStoredBlock, getOpenTransactionOutputs, getParams, getSelectHeadersDumpSQL, getSelectHeadersSQL, getSelectOpenoutputsCountSQL, getSelectopenoutputsDumpSQL, getSelectSettingsDumpSQL, getSelectSettingsSQL, getSelectUndoableblocksDumpSQL, getSelectUndoableBlocksSQL, getTablesExistSQL, getTransactionOutput, getUndoBlock, getUpdateHeadersSQL, getUpdateSettingsSLQ, getUpdateUndoableBlocksSQL, getVerifiedChainHead, hasUnspentOutputs, maybeConnect, put, 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

MySQLFullPrunedBlockStore

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

Creates a new MySQLFullPrunedBlockStore.

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

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.

getSelectOpenoutputsSQL

protected String getSelectOpenoutputsSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL to select a openoutputs record.

Overrides:

getSelectOpenoutputsSQL in class DatabaseFullPrunedBlockStore

Returns:

The SQL select statement.

getInsertOpenoutputsSQL

protected String getInsertOpenoutputsSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL to insert a openoutputs record.

Overrides:

getInsertOpenoutputsSQL in class DatabaseFullPrunedBlockStore

Returns:

The SQL insert statement.

getDeleteOpenoutputsSQL

protected String getDeleteOpenoutputsSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL to delete a openoutputs record.

Overrides:

getDeleteOpenoutputsSQL in class DatabaseFullPrunedBlockStore

Returns:

The SQL delete statement.

getTransactionOutputSelectSQL

protected String getTransactionOutputSelectSQL()

Description copied from class: DatabaseFullPrunedBlockStore

Get the SQL to select the transaction outputs for a given address.

Overrides:

getTransactionOutputSelectSQL in class DatabaseFullPrunedBlockStore

Returns:

The SQL prepared statement.

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.