JSQL-Driver

Description

A simple Java SQL driver for connecting to a SQL databases.

Supported Databases

• MariaDB
• MySQL
• PostgreSQL
• SQLite

Usage

Maven

Make sure you have my Sonatype Nexus OSS repository added to your pom.xml file:

<repositories>
    <repository>
        <id>Nexus</id>
        <name>Sonatype Nexus</name>
        <url>https://mcmodersd.de/nexus/repository/maven-releases/</url>
    </repository>
</repositories>

Add the dependency to your pom.xml file:

<dependency>
    <groupId>de.MCmoderSD</groupId>
    <artifactId>JSQL-Driver</artifactId>
    <version>3.1.2</version>
</dependency>

Usage Example

MySQL/MariaDB/PostgreSQL

import de.MCmoderSD.sql.Driver.Builder;
import de.MCmoderSD.sql.Driver;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.ResultSet;

import static de.MCmoderSD.sql.Driver.DatabaseType.MARIADB;

void main() {

    // Build Database Configuration
    Builder builder = Database.builder()    // Create Builder
            .withType(MARIADB)              // Database Type
            .withHost("localhost")          // Host
            .withPort(3306)                 // Port
            .withDatabase("database")       // Database
            .withUsername("username")       // Username
            .withPassword("password");      // Password

    // Initialize Database Connection
    Database database = new Database(builder);
    database.setAutoReconnectSettings(5, 10000);    // Auto Reconnect Settings (5 Attempts, 10s Delay)
    database.setAutoReconnect(true);                // Enable Auto Reconnect
    database.connect();                             // Connect to Database

    // Test Database
    IO.println("Connected: " + database.isConnected());
    IO.println("Row Count: " + database.getRowCount());
}

// Database Driver Implementation
private static class Database extends Driver {

    // Constructor
    public Database(Builder builder) {
        super(builder); // Initialize Driver
    }

    // Get Row Count Method
    public Integer getRowCount() {

        // Initialize SQL Query
        String query = "SELECT COUNT(*) FROM `table`";

        // Initialize Statement
        try (PreparedStatement statement = connection.prepareStatement(query)) {

            // Execute Query
            ResultSet resultSet = statement.executeQuery();

            // Return Result
            if (resultSet.next()) return resultSet.getInt(1);

        } catch (SQLException e) {
            System.err.println(e.getMessage());
        }

        return null;
    }
}

SQLite

import de.MCmoderSD.sql.Driver.Builder;
import de.MCmoderSD.sql.Driver;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.ResultSet;

import static de.MCmoderSD.sql.Driver.DatabaseType.SQLITE;

void main() {

    // Build SQLite Configuration
    Builder builder = SQLite.builder()
            .withType(SQLITE)               // Database Type
            .withDatabase("Database.db");   // Database File

    // Initialize Database Connection
    SQLite database = new SQLite(builder);
    database.connect();

    // Test Database
    IO.println("Connected: " + database.isConnected());
    IO.println("Row Count: " + database.getRowCount());
}

// SQLite Driver Implementation
private static class SQLite extends Driver {

    // Constructor
    public SQLite(Builder builder) {
        super(builder); // Initialize Driver
    }

    // Get Row Count Method
    public Integer getRowCount() {

        // Initialize SQL Query
        String query = "SELECT COUNT(*) FROM `table`";

        // Initialize Statement
        try (PreparedStatement statement = connection.prepareStatement(query)) {

            // Execute Query
            ResultSet resultSet = statement.executeQuery();

            // Return Result
            if (resultSet.next()) return resultSet.getInt(1);

        } catch (SQLException e) {
            System.err.println(e.getMessage());
        }

        return null;
    }
}