diff --git a/Plan/common/src/main/java/com/djrapitops/plan/db/SQLDB.java b/Plan/common/src/main/java/com/djrapitops/plan/db/SQLDB.java index 26264e40c..e76624722 100644 --- a/Plan/common/src/main/java/com/djrapitops/plan/db/SQLDB.java +++ b/Plan/common/src/main/java/com/djrapitops/plan/db/SQLDB.java @@ -20,6 +20,7 @@ import com.djrapitops.plan.api.exceptions.database.DBInitException; import com.djrapitops.plan.api.exceptions.database.DBOpException; import com.djrapitops.plan.data.store.containers.NetworkContainer; import com.djrapitops.plan.db.access.ExecStatement; +import com.djrapitops.plan.db.access.Query; import com.djrapitops.plan.db.access.QueryStatement; import com.djrapitops.plan.db.patches.*; import com.djrapitops.plan.db.sql.tables.*; @@ -317,6 +318,7 @@ public abstract class SQLDB extends AbstractDatabase { public abstract void returnToPool(Connection connection); + @Deprecated public boolean execute(ExecStatement statement) { if (!isOpen()) { throw new DBOpException("SQL Statement tried to execute while connection closed"); @@ -335,6 +337,7 @@ public abstract class SQLDB extends AbstractDatabase { } } + @Deprecated public boolean execute(String sql) { return execute(new ExecStatement(sql) { @Override @@ -344,6 +347,7 @@ public abstract class SQLDB extends AbstractDatabase { }); } + @Deprecated public void executeUnsafe(String... statements) { Verify.nullCheck(statements); for (String statement : statements) { @@ -357,6 +361,7 @@ public abstract class SQLDB extends AbstractDatabase { } } + @Deprecated public void executeBatch(ExecStatement statement) { if (!isOpen()) { throw new DBOpException("SQL Batch tried to execute while connection closed"); @@ -375,6 +380,7 @@ public abstract class SQLDB extends AbstractDatabase { } } + @Deprecated public T query(QueryStatement statement) { if (!isOpen()) { throw new DBOpException("SQL Query tried to execute while connection closed"); @@ -393,6 +399,11 @@ public abstract class SQLDB extends AbstractDatabase { } } + @Override + public T query(Query query) { + return query.executeQuery(this); + } + public UsersTable getUsersTable() { return usersTable; } diff --git a/Plan/common/src/main/java/com/djrapitops/plan/db/access/Query.java b/Plan/common/src/main/java/com/djrapitops/plan/db/access/Query.java index 8509204a4..b6f6f7338 100644 --- a/Plan/common/src/main/java/com/djrapitops/plan/db/access/Query.java +++ b/Plan/common/src/main/java/com/djrapitops/plan/db/access/Query.java @@ -10,6 +10,6 @@ import com.djrapitops.plan.db.SQLDB; */ public interface Query { - T query(SQLDB db); + T executeQuery(SQLDB db); } diff --git a/Plan/common/src/main/java/com/djrapitops/plan/db/access/QueryStatement.java b/Plan/common/src/main/java/com/djrapitops/plan/db/access/QueryStatement.java index fbb573193..24082935e 100644 --- a/Plan/common/src/main/java/com/djrapitops/plan/db/access/QueryStatement.java +++ b/Plan/common/src/main/java/com/djrapitops/plan/db/access/QueryStatement.java @@ -44,7 +44,7 @@ public abstract class QueryStatement implements Query { } @Override - public T query(SQLDB db) { + public T executeQuery(SQLDB db) { Connection connection = null; try { connection = db.getConnection();