Begin work on MariaDB

pom.xml

@@ -196,5 +196,17 @@
             <version>6.3.0.RELEASE</version>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>4.0.3</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mariadb.jdbc</groupId>
+            <artifactId>mariadb-java-client</artifactId>
+            <version>3.3.1</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 </project>

src/main/java/me/braydon/feather/database/IDatabase.java

@@ -29,6 +29,7 @@ public interface IDatabase<B, C> extends Closeable {
      *
      * @param credentials the optional credentials to use
      * @throws IllegalStateException if already connected
+     * @see C for credentials
      */
     void connect(C credentials) throws IllegalStateException;
     

src/main/java/me/braydon/feather/database/impl/mariadb/MariaDB.java

@@ -0,0 +1,110 @@
+/*
+ * Copyright (c) 2023 Braydon (Rainnny). All rights reserved.
+ *
+ * For inquiries, please contact braydonrainnny@gmail.com
+ */
+package me.braydon.feather.database.impl.mariadb;
+
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import lombok.NonNull;
+import me.braydon.feather.database.IDatabase;
+
+/**
+ * The {@link IDatabase} implementation for MariaDB (& other MySQL servers).
+ *
+ * @author Braydon
+ * @see HikariDataSource for the bootstrap class
+ * @see MariaDBAuthorization for the credentials class
+ * @see <a href="https://github.com/brettwooldridge/HikariCP">HikariCP Official GitHub</a>
+ */
+public class MariaDB implements IDatabase<HikariDataSource, MariaDBAuthorization> {
+    /**
+     * The current {@link HikariDataSource} instance.
+     */
+    private HikariDataSource dataSource;
+    
+    /**
+     * Get the name of this database.
+     *
+     * @return the database name
+     */
+    @Override @NonNull
+    public String getName() {
+        return "MariaDB";
+    }
+    
+    /**
+     * Initialize a connection to this database.
+     *
+     * @param credentials the optional credentials to use
+     * @throws IllegalArgumentException if no credentials are provided
+     * @throws IllegalStateException if already connected
+     * @see MariaDBAuthorization for credentials
+     */
+    @Override
+    public void connect(MariaDBAuthorization credentials) throws IllegalArgumentException, IllegalStateException {
+        if (credentials == null) { // We need valid credentials
+            throw new IllegalArgumentException("No credentials defined");
+        }
+        if (isConnected()) { // Already connected
+            throw new IllegalStateException("Already connected");
+        }
+        if (dataSource != null) { // We have a data source, close it first
+            dataSource.close();
+        }
+        HikariConfig config = credentials.getHikariConfig(); // Get the custom config
+        if (config == null) { // No custom config, make a new one
+            config = new HikariConfig();
+        }
+        config.setJdbcUrl(credentials.getJdbcUrl()); // Set the JDBC connection URL
+        config.setUsername(credentials.getUsername()); // Set the username
+        config.setPassword(credentials.getPassword()); // Set the password
+        dataSource = new HikariDataSource(config); // Create a new data source
+    }
+    
+    /**
+     * Check if this database is connected.
+     *
+     * @return the database connection state
+     */
+    @Override
+    public boolean isConnected() {
+        return dataSource != null && (dataSource.isRunning() && !dataSource.isClosed());
+    }
+    
+    /**
+     * Get the latency to this database.
+     *
+     * @return the latency, -1 if not connected
+     */
+    @Override
+    public long getLatency() {
+        return 0;
+    }
+    
+    /**
+     * Get the bootstrap class
+     * instance for this database.
+     *
+     * @return the bootstrap class instance, null if none
+     * @see HikariDataSource for bootstrap class
+     */
+    @Override
+    public HikariDataSource getBootstrap() {
+        return dataSource;
+    }
+    
+    /**
+     * Closes this stream and releases any system resources associated
+     * with it. If the stream is already closed then invoking this
+     * method has no effect.
+     */
+    @Override
+    public void close() {
+        if (dataSource != null) {
+            dataSource.close();
+        }
+        dataSource = null;
+    }
+}

src/main/java/me/braydon/feather/database/impl/mariadb/MariaDBAuthorization.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright (c) 2023 Braydon (Rainnny). All rights reserved.
+ *
+ * For inquiries, please contact braydonrainnny@gmail.com
+ */
+package me.braydon.feather.database.impl.mariadb;
+
+import com.zaxxer.hikari.HikariConfig;
+import lombok.*;
+
+/**
+ * Authorization for a {@link MariaDB} database.
+ *
+ * @author Braydon
+ */
+@RequiredArgsConstructor @AllArgsConstructor @Getter @ToString
+public final class MariaDBAuthorization {
+    /**
+     * The JDBC connection URL for the database.
+     */
+    @NonNull private final String jdbcUrl;
+    
+    /**
+     * The username to use for authenticating with the database.
+     */
+    @NonNull private final String username;
+    
+    /**
+     * The password to use for authenticating with the database.
+     */
+    @NonNull private final String password;
+    
+    /**
+     * The optional {@link HikariConfig} to use.
+     */
+    private HikariConfig hikariConfig;
+}

src/main/java/me/braydon/feather/database/impl/mariadb/MariaDBRepository.java

@@ -0,0 +1,93 @@
+/*
+ * Copyright (c) 2023 Braydon (Rainnny). All rights reserved.
+ *
+ * For inquiries, please contact braydonrainnny@gmail.com
+ */
+package me.braydon.feather.database.impl.mariadb;
+
+import lombok.NonNull;
+import me.braydon.feather.database.Repository;
+
+import java.util.List;
+
+/**
+ * The {@link MariaDB} {@link Repository} implementation.
+ *
+ * @author Braydon
+ * @param <ID> the identifier for type for entities
+ * @param <E> the entity type this repository stores
+ */
+public class MariaDBRepository<ID, E> extends Repository<MariaDB, ID, E> {
+    public MariaDBRepository(@NonNull MariaDB database, @NonNull Class<? extends E> entityClass) {
+        super(database, entityClass);
+    }
+    
+    /**
+     * Get the entity with the given id.
+     *
+     * @param id the entity id
+     * @return the entity with the id, null if none
+     * @see ID for id
+     * @see E for entity
+     */
+    @Override
+    public E find(@NonNull ID id) {
+        throw new UnsupportedOperationException();
+    }
+    
+    /**
+     * Get all entities within this repository.
+     *
+     * @return the entities
+     * @see E for entity
+     */
+    @Override
+    public List<E> findAll() {
+        throw new UnsupportedOperationException();
+    }
+    
+    /**
+     * Save the given entities.
+     *
+     * @param entities the entities to save
+     * @see E for entity
+     */
+    @Override
+    public void saveAll(@NonNull E... entities) {
+        throw new UnsupportedOperationException();
+    }
+    
+    /**
+     * Get the amount of stored entities.
+     *
+     * @return the amount of stored entities
+     * @see E for entity
+     */
+    @Override
+    public long count() {
+        throw new UnsupportedOperationException();
+    }
+    
+    /**
+     * Drop the entity with the given id.
+     *
+     * @param id the entity id to drop
+     * @see ID for id
+     * @see E for entity
+     */
+    @Override
+    public void dropById(@NonNull ID id) {
+        throw new UnsupportedOperationException();
+    }
+    
+    /**
+     * Drop the given entity.
+     *
+     * @param entity the entity to drop
+     * @see E for entity
+     */
+    @Override
+    public void drop(@NonNull E entity) {
+        throw new UnsupportedOperationException();
+    }
+}

src/main/java/me/braydon/feather/database/impl/mariadb/queries/UpdateQuery.java

@@ -0,0 +1,80 @@
+/*
+ * Copyright (c) 2023 Braydon (Rainnny). All rights reserved.
+ *
+ * For inquiries, please contact braydonrainnny@gmail.com
+ */
+package me.braydon.feather.database.impl.mariadb.queries;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NonNull;
+import lombok.Singular;
+import me.braydon.feather.database.impl.mariadb.MariaDB;
+
+import java.util.Map;
+
+/**
+ * A builder for {@link MariaDB} update queries.
+ *
+ * @author Braydon
+ */
+@Builder @Getter
+public class UpdateQuery {
+    /**
+     * The table to execute the update in.
+     */
+    @NonNull private String table;
+    
+    /**
+     * The mapped values (by column) for this query.
+     */
+    @NonNull @Singular private Map<String, Object> values;
+    
+    /**
+     * The where clause for this query.
+     */
+    @NonNull private WhereClause whereClause;
+    
+    /**
+     * Build this query.
+     *
+     * @return the built query
+     */
+    @Override @NonNull
+    public String toString() {
+        // Build the values
+        StringBuilder valuesBuilder = new StringBuilder();
+        for (Map.Entry<String, Object> entry : values.entrySet()) {
+            valuesBuilder.append("`").append(entry.getKey()).append("`")
+                .append("='").append(entry.getValue()).append("', ");
+        }
+        String values = valuesBuilder.toString(); // The built values string
+        values = values.substring(0, values.length() - 2); // Remove the trailing comma
+        
+        // Build the query
+        return String.format("UPDATE `%s` SET %s WHERE %s;",
+            table, values, whereClause
+        );
+    }
+    
+    /**
+     * The where clause for this query.
+     */
+    @Builder @Getter
+    public static class WhereClause {
+        /**
+         * The column to target.
+         */
+        @NonNull private String column;
+        
+        /**
+         * The value of the column to target.
+         */
+        @NonNull private Object value;
+        
+        @Override @NonNull
+        public String toString() {
+            return column + "='" + value + "'";
+        }
+    }
+}

src/main/java/me/braydon/feather/database/impl/mongodb/MongoDB.java

@@ -49,6 +49,7 @@ public class MongoDB implements IDatabase<MongoClient, ConnectionString> {
      * @param credentials the optional credentials to use
      * @throws IllegalArgumentException if no credentials or database name is provided
      * @throws IllegalStateException if already connected
+     * @see ConnectionString for credentials
      */
     @Override
     public void connect(ConnectionString credentials) throws IllegalArgumentException, IllegalStateException {
@@ -91,8 +92,8 @@ public class MongoDB implements IDatabase<MongoClient, ConnectionString> {
         }
         // Return ping
         long before = System.currentTimeMillis();
-        database.runCommand(new BasicDBObject("ping", "1"));
+        database.runCommand(new BasicDBObject("ping", "1")); // Send a ping command
-        return System.currentTimeMillis() - before;
+        return System.currentTimeMillis() - before; // Return time difference
     }
     
     /**

src/main/java/me/braydon/feather/database/impl/redis/Redis.java

@@ -46,6 +46,7 @@ public class Redis implements IDatabase<StatefulRedisConnection<String, String>,
      * @param credentials the optional credentials to use
      * @throws IllegalArgumentException if no credentials are provided
      * @throws IllegalStateException if already connected
+     * @see RedisURI for credentials
      */
     @Override
     public void connect(RedisURI credentials) throws IllegalArgumentException, IllegalStateException {
@@ -82,7 +83,13 @@ public class Redis implements IDatabase<StatefulRedisConnection<String, String>,
      */
     @Override
     public long getLatency() {
-        return 0;
+        if (!isConnected()) { // Not connected
+            return -1L;
+        }
+        // Return ping
+        long before = System.currentTimeMillis();
+        connection.sync().ping(); // Send a ping command
+        return System.currentTimeMillis() - before; // Return time difference
     }
     
     /**