Added database tables
This commit is contained in:
parent
c6bd15f141
commit
42601a11c2
56
src/main/java/com/alttd/database/DatabaseTables.java
Normal file
56
src/main/java/com/alttd/database/DatabaseTables.java
Normal file
|
|
@ -0,0 +1,56 @@
|
||||||
|
package com.alttd.database;
|
||||||
|
|
||||||
|
import com.alttd.util.Logger;
|
||||||
|
|
||||||
|
import java.lang.reflect.InvocationTargetException;
|
||||||
|
import java.lang.reflect.Method;
|
||||||
|
import java.lang.reflect.Modifier;
|
||||||
|
import java.sql.Connection;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
|
||||||
|
public class DatabaseTables {
|
||||||
|
|
||||||
|
private Connection connection;
|
||||||
|
|
||||||
|
protected DatabaseTables (Connection connection) {
|
||||||
|
this.connection = connection;
|
||||||
|
init(DatabaseTables.class, this);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void init(Class<?> clazz, Object instance) {
|
||||||
|
for (Method method : clazz.getDeclaredMethods()) {
|
||||||
|
if (Modifier.isPrivate(method.getModifiers())) {
|
||||||
|
if (method.getParameterTypes().length == 0 && method.getReturnType() == Void.TYPE && method.getName().contains("Table")) {
|
||||||
|
try {
|
||||||
|
method.setAccessible(true);
|
||||||
|
method.invoke(instance);
|
||||||
|
} catch (InvocationTargetException ex) {
|
||||||
|
throw new RuntimeException(ex.getCause());
|
||||||
|
} catch (Exception ex) {
|
||||||
|
Logger.severe("Error invoking %.", method.toString());
|
||||||
|
ex.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void createPollsTable() {
|
||||||
|
try {
|
||||||
|
String sql = "CREATE TABLE IF NOT EXISTS polls(" +
|
||||||
|
"poll_id BIGINT NOT NULL, " +
|
||||||
|
"channel_id BIGINT NOT NULL, " +
|
||||||
|
"guild_id BIGINT NOT NULL, " +
|
||||||
|
"active BIT DEFAULT b'0', " +
|
||||||
|
"poll_title VARCHAR(256) NOT NULL, " +
|
||||||
|
"embed_type VARCHAR(32) DEFAULT 'ABSTRACT_EMBED', " +
|
||||||
|
"PRIMARY KEY (UUID, villager_type)" +
|
||||||
|
")";
|
||||||
|
connection.prepareStatement(sql).executeUpdate();
|
||||||
|
} catch (SQLException e) {
|
||||||
|
Logger.sql(e);
|
||||||
|
Logger.severe("Unable to create polls table, shutting down...");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue
Block a user