Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package nl.dusdavidgames.test;
- import com.zaxxer.hikari.HikariDataSource;
- import org.bukkit.Bukkit;
- import org.bukkit.configuration.file.YamlConfiguration;
- import java.io.File;
- import java.sql.Connection;
- import java.sql.PreparedStatement;
- import java.sql.SQLException;
- /**
- * Created by michi on 27/02/2017.
- */
- public class DatabaseManager {
- private static String USERNAME;
- private static String PASSWORD;
- private static String DB_URL;
- private static String DB_NAME;
- public static HikariDataSource datasource;
- public static HikariDataSource getDatasource() {
- return datasource;
- }
- public static DatabaseManager instance;
- public static DatabaseManager getInstance() {
- return instance;
- }
- public DatabaseManager() {
- try{
- openConnection();
- insertQuery("create table test (naam text)");
- } catch (Exception e){
- e.printStackTrace();
- }
- }
- public void openConnection() {
- /*
- database:
- username: root
- isolation: REPEATABLEREAD
- driver: com.mysql.jdbc.Driver
- password: Pidiboe002
- url: jdbc:mysql://localhost:3306/test
- name: test
- */
- YamlConfiguration bukkitYml = YamlConfiguration.loadConfiguration(new File(Bukkit.getWorldContainer().getAbsoluteFile(), "bukkit.yml"));
- USERNAME = bukkitYml.getString("database.username");
- PASSWORD = bukkitYml.getString("database.password");
- DB_URL = bukkitYml.getString("database.url");
- DB_NAME = bukkitYml.getString("database.name");
- datasource = new HikariDataSource();
- datasource.setMaximumPoolSize(10);
- datasource.setDataSourceClassName("com.mysql.jdbc.jdbc2.optional.MysqlDataSource");
- datasource.addDataSourceProperty("serverName", DB_URL);
- datasource.addDataSourceProperty("port", 3306);
- try {
- datasource.addDataSourceProperty("databaseName", DB_NAME);
- } catch (NullPointerException e) {
- }
- datasource.addDataSourceProperty("user", USERNAME);
- datasource.addDataSourceProperty("password", PASSWORD);
- }
- public void closeConnection() {
- if (datasource != null)
- datasource.close();
- if (datasource == null)
- Messages.getInstance().info("Datascoure was not closed!");
- }
- public void insertQuery(String query) {
- Connection connection = null;
- PreparedStatement pStatement = null;
- try {
- connection = datasource.getConnection();
- pStatement = connection.prepareStatement(query);
- pStatement.execute();
- } catch (SQLException e) {
- e.printStackTrace();
- Messages.getInstance().info("Something went wrong on inserting Query @ DatabaseManager:insertQuery");
- } finally {
- try {
- if (connection != null) {
- connection.close();
- }
- } catch (SQLException ex) {
- Messages.getInstance().info("Couldn't close DB Connection");
- }
- try {
- if (pStatement != null) {
- pStatement.close();
- }
- } catch (SQLException ex) {
- Messages.getInstance().info("Couldn't close DB PreparedStatement");
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement