Upstream/SongodaCore
1
0
Fork 0
mirror of https://github.com/songoda/SongodaCore.git synced 2024-10-22 20:30:41 +02:00
Code Issues Projects Releases Wiki Activity

New delete methods, start auto increment from one for databases

Browse Source
This commit is contained in:
ceze88 2023-07-25 19:54:05 +02:00
parent 54ef2c0b29
commit fdf79eeee3
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
Core/src/main/java/com/craftaro/core/database/DataManager.java
View File

@ -233,10 +233,10 @@ public class DataManager {
//recreate upper method using java 8 syntax
try {
Optional<Integer> max = context.select(DSL.max(DSL.field("id"))).from(prefixedTable).fetchOptional().map(record -> record.get(0, Integer.class));
this.autoIncrementCache.put(prefixedTable, new AtomicInteger(max.orElse(1)));
this.autoIncrementCache.put(prefixedTable, new AtomicInteger(max.orElse(0)));
} catch (Exception e) {
//Table is empty
this.autoIncrementCache.put(prefixedTable, new AtomicInteger(1));
this.autoIncrementCache.put(prefixedTable, new AtomicInteger(0));
}
});
}
@ -338,6 +338,20 @@ public class DataManager {
});
}
public void delete(Data data, String idField, Object idValue) {
asyncPool.execute(() -> {
deleteSync(data, idField, idValue);
});
}
public void deleteSync(Data data, String idField, Object idValue) {
databaseConnector.connectDSL(context -> {
context.delete(DSL.table(getTablePrefix() + data.getTableName()))
.where(DSL.field(idField).eq(idValue))
.execute();
});
}
/**
* Deletes the data from the database
*/