Package net.twilightmc.skReflectabase

Class DatabaseManager

java.lang.Object

net.twilightmc.skReflectabase.DatabaseManager

public class DatabaseManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DatabaseManager.QueryResult

Field Summary

Fields

Modifier and Type	Field	Description
private Connection	connection
private final String	password
private final org.bukkit.plugin.Plugin	plugin
private final String	url
private final String	username

Constructor Summary

Constructors

Constructor	Description
DatabaseManager(org.bukkit.plugin.Plugin plugin, String url, String username, String password)

Method Summary

Modifier and Type	Method	Description
void	closeConnection()
private void	connect()
DatabaseManager.QueryResult	executeQuery(String query)
DatabaseManager.QueryResult	executeQuery(String query, Object... params)
CompletableFuture<DatabaseManager.QueryResult>	executeQueryAsync(String query)
CompletableFuture<DatabaseManager.QueryResult>	executeQueryAsync(String query, Object... params)
void	executeQueryAsync(String query, Consumer<DatabaseManager.QueryResult> callback)
void	executeQueryAsync(String query, Consumer<DatabaseManager.QueryResult> callback, Object... params)
int	executeUpdate(String query)
int	executeUpdate(String query, Object... params)
CompletableFuture<Integer>	executeUpdateAsync(String query)
CompletableFuture<Integer>	executeUpdateAsync(String query, Object... params)
void	executeUpdateAsync(String query, Consumer<Integer> callback)
void	executeUpdateAsync(String query, Consumer<Integer> callback, Object... params)
Connection	getConnection()
List<String>	getTableColumns(String tableName)
CompletableFuture<List<String>>	getTableColumnsAsync(String tableName)
private PreparedStatement	prepareStatement(String query, Object... params)
boolean	tableExists(String tableName)
CompletableFuture<Boolean>	tableExistsAsync(String tableName)

Methods inherited from class java.lang.Object

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

Field Details

plugin

private final org.bukkit.plugin.Plugin plugin

connection

private Connection connection

url

private final String url

username

private final String username

password

private final String password

Constructor Details

DatabaseManager

public DatabaseManager(org.bukkit.plugin.Plugin plugin,
 String url,
 String username,
 String password)
                throws SQLException

Throws:

SQLException

Method Details

connect

private void connect()
              throws SQLException

Throws:

SQLException

closeConnection

public void closeConnection()

executeQuery

public DatabaseManager.QueryResult executeQuery(String query)
                                         throws SQLException

Throws:

SQLException

executeQuery

public DatabaseManager.QueryResult executeQuery(String query,
 Object... params)
                                         throws SQLException

Throws:

SQLException

executeUpdate

public int executeUpdate(String query)
                  throws SQLException

Throws:

SQLException

executeUpdate

public int executeUpdate(String query,
 Object... params)
                  throws SQLException

Throws:

SQLException

executeQueryAsync

public CompletableFuture<DatabaseManager.QueryResult> executeQueryAsync(String query)

executeQueryAsync

public CompletableFuture<DatabaseManager.QueryResult> executeQueryAsync(String query,
 Object... params)

executeUpdateAsync

public CompletableFuture<Integer> executeUpdateAsync(String query)

executeUpdateAsync

public CompletableFuture<Integer> executeUpdateAsync(String query,
 Object... params)

executeQueryAsync

public void executeQueryAsync(String query,
 Consumer<DatabaseManager.QueryResult> callback)

executeQueryAsync

public void executeQueryAsync(String query,
 Consumer<DatabaseManager.QueryResult> callback,
 Object... params)

executeUpdateAsync

public void executeUpdateAsync(String query,
 Consumer<Integer> callback)

executeUpdateAsync

public void executeUpdateAsync(String query,
 Consumer<Integer> callback,
 Object... params)

tableExists

public boolean tableExists(String tableName)
                    throws SQLException

Throws:

SQLException

tableExistsAsync

public CompletableFuture<Boolean> tableExistsAsync(String tableName)

getTableColumns

public List<String> getTableColumns(String tableName)
                             throws SQLException

Throws:

SQLException

getTableColumnsAsync

public CompletableFuture<List<String>> getTableColumnsAsync(String tableName)

prepareStatement

private PreparedStatement prepareStatement(String query,
 Object... params)
                                    throws SQLException

Throws:

SQLException

getConnection

public Connection getConnection()
                         throws SQLException

Throws:

SQLException