nanopenguin/swen-mtcg
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Made custom sql statements possible

Browse Source 
~10 min work
This commit is contained in:
Benedikt Galbavy 2024-01-05 16:41:52 +01:00
parent 756d299e2c
commit 86d43f04ce
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/at/nanopenguin/mtcg/db/DbQuery.java
View File

@ -25,6 +25,9 @@ public final class DbQuery {
@Singular @Singular
private SortedMap<String, Object> conditions; private SortedMap<String, Object> conditions;
private String returnColumn; private String returnColumn;
private String customSql;
@Singular
private List<Object> values;
public static class DbQueryBuilder { public static class DbQueryBuilder {
@ -32,6 +35,7 @@ public final class DbQuery {
public List<Map<String, Object>> executeQuery() throws SQLException { public List<Map<String, Object>> executeQuery() throws SQLException {
DbQuery dbQuery = this.build(); DbQuery dbQuery = this.build();
if (dbQuery.command != SqlCommand.SELECT && dbQuery.returnColumn == null) throw new SQLException(); if (dbQuery.command != SqlCommand.SELECT && dbQuery.returnColumn == null) throw new SQLException();
if (dbQuery.customSql != null) return DbQuery.executeQuery(dbQuery.customSql, dbQuery.values);
return switch (dbQuery.command) { return switch (dbQuery.command) {
case INSERT -> dbQuery.create(true); case INSERT -> dbQuery.create(true);
case SELECT -> dbQuery.read(); case SELECT -> dbQuery.read();
@ -43,6 +47,7 @@ public final class DbQuery {
public int executeUpdate() throws SQLException { public int executeUpdate() throws SQLException {
if (this.returnColumn != null) throw new SQLException(); if (this.returnColumn != null) throw new SQLException();
DbQuery dbQuery = this.build(); DbQuery dbQuery = this.build();
if (dbQuery.customSql != null) return DbQuery.executeUpdate(dbQuery.customSql, dbQuery.values);
return switch (dbQuery.command) { return switch (dbQuery.command) {
case INSERT -> dbQuery.create(); case INSERT -> dbQuery.create();
case UPDATE -> dbQuery.update(); case UPDATE -> dbQuery.update();