com.djrapitops.plan.db

Class SQLDB

java.lang.Object

com.djrapitops.plan.db.AbstractDatabase

com.djrapitops.plan.db.SQLDB

All Implemented Interfaces:

Database

Direct Known Subclasses:

H2DB, MySQLDB, SQLiteDB

public abstract class SQLDB
extends AbstractDatabase

Class containing main logic for different data related save and load functionality.

Nested Class Summary

Nested classes/interfaces inherited from interface com.djrapitops.plan.db.Database

Database.State

Field Summary

Fields

Modifier and Type	Field and Description
protected PlanConfig	config
protected com.djrapitops.plugin.logging.error.ErrorHandler	errorHandler
protected Locale	locale
protected com.djrapitops.plugin.logging.console.PluginLogger	logger
protected NetworkContainer.Factory	networkContainerFactory
protected com.djrapitops.plugin.task.RunnableFactory	runnableFactory

Fields inherited from class com.djrapitops.plan.db.AbstractDatabase

accessLock

Constructor Summary

Constructors

Constructor and Description
SQLDB(java.util.function.Supplier<java.util.UUID> serverUUIDSupplier, Locale locale, PlanConfig config, NetworkContainer.Factory networkContainerFactory, com.djrapitops.plugin.task.RunnableFactory runnableFactory, com.djrapitops.plugin.logging.console.PluginLogger logger, com.djrapitops.plugin.logging.error.ErrorHandler errorHandler)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	equals(java.lang.Object o)
java.util.concurrent.Future<?>	executeTransaction(Transaction transaction) Execute an SQL Transaction.
abstract java.sql.Connection	getConnection()
NetworkContainer.Factory	getNetworkContainerFactory()
java.util.function.Supplier<java.util.UUID>	getServerUUIDSupplier()
int	hashCode()
void	init() Initializes the Database.
<T> T	query(Query<T> query) Execute an SQL Query statement to get a result.
abstract void	returnToPool(java.sql.Connection connection)
void	setTransactionExecutorServiceProvider(java.util.function.Supplier<java.util.concurrent.ExecutorService> transactionExecutorServiceProvider)
abstract void	setupDataSource() Set up the source for connections.

Methods inherited from class com.djrapitops.plan.db.AbstractDatabase

getState, setState

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.djrapitops.plan.db.Database

getType

Field Detail

locale

protected final Locale locale

config

protected final PlanConfig config

networkContainerFactory

protected final NetworkContainer.Factory networkContainerFactory

runnableFactory

protected final com.djrapitops.plugin.task.RunnableFactory runnableFactory

logger

protected final com.djrapitops.plugin.logging.console.PluginLogger logger

errorHandler

protected final com.djrapitops.plugin.logging.error.ErrorHandler errorHandler

Constructor Detail

SQLDB

public SQLDB(java.util.function.Supplier<java.util.UUID> serverUUIDSupplier,
             Locale locale,
             PlanConfig config,
             NetworkContainer.Factory networkContainerFactory,
             com.djrapitops.plugin.task.RunnableFactory runnableFactory,
             com.djrapitops.plugin.logging.console.PluginLogger logger,
             com.djrapitops.plugin.logging.error.ErrorHandler errorHandler)

Method Detail

init

public void init()

Description copied from interface: Database

Initializes the Database.

Queries can be performed after this request has completed all required transactions for the database operations.

setupDataSource

public abstract void setupDataSource()

Set up the source for connections.

Throws:

DBInitException - If the DataSource fails to be initialized.

close

public void close()

getConnection

public abstract java.sql.Connection getConnection()
                                           throws java.sql.SQLException

Throws:

java.sql.SQLException

returnToPool

public abstract void returnToPool(java.sql.Connection connection)

query

public <T> T query(Query<T> query)

Description copied from interface: Database

Execute an SQL Query statement to get a result.

This method should only be called from an asynchronous thread.

Type Parameters:

T - Type of the object to be returned.

Parameters:

query - QueryStatement to execute.

Returns:

Result of the query.

executeTransaction

public java.util.concurrent.Future<?> executeTransaction(Transaction transaction)

Description copied from interface: Database

Execute an SQL Transaction.

Parameters:

transaction - Transaction to execute.

Returns:

Future that is finished when the transaction has been executed.

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

getServerUUIDSupplier

public java.util.function.Supplier<java.util.UUID> getServerUUIDSupplier()

getNetworkContainerFactory

public NetworkContainer.Factory getNetworkContainerFactory()

setTransactionExecutorServiceProvider

public void setTransactionExecutorServiceProvider(java.util.function.Supplier<java.util.concurrent.ExecutorService> transactionExecutorServiceProvider)