andreacavalli/CavalliumDBEngine-Server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Update API

Browse Source
This commit is contained in:
Andrea Cavalli 2022-03-20 16:15:47 +01:00
parent 3e358c4bc9
commit 99d94ad275
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/it/cavallium/dbengine/database/remote/QuicRPCServer.java
View File

@ -43,6 +43,7 @@ import java.util.concurrent.atomic.AtomicReference;
import java.util.logging.Level; import java.util.logging.Level;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.jetbrains.annotations.Nullable;
import org.reactivestreams.Publisher; import org.reactivestreams.Publisher;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
@ -213,11 +214,20 @@ public class QuicRPCServer {
private Mono<LLSingleton> obtainSingleton(DatabasePartName id, GetSingleton getSingleton) { private Mono<LLSingleton> obtainSingleton(DatabasePartName id, GetSingleton getSingleton) {
Mono<LLKeyValueDatabase> dbMono = dbs.getResource(id.dbRef()); Mono<LLKeyValueDatabase> dbMono = dbs.getResource(id.dbRef());
return dbMono.flatMap(db -> db.getSingleton( return dbMono.flatMap(db -> {
QuicUtils.toArrayNoCopy(getSingleton.singletonListColumnName()), var defaultValueOpt = getSingleton.defaultValue();
QuicUtils.toArrayNoCopy(getSingleton.name()), byte[] defaultValue;
QuicUtils.toArrayNoCopy(getSingleton.defaultValue()) if (defaultValueOpt.isPresent()) {
)); defaultValue = QuicUtils.toArrayNoCopy(defaultValueOpt.get());
} else {
defaultValue = null;
}
return db.getSingleton(
QuicUtils.toArrayNoCopy(getSingleton.singletonListColumnName()),
QuicUtils.toArrayNoCopy(getSingleton.name()),
defaultValue
);
});
} }
private Mono<GeneratedEntityId> handleGetDatabase(GetDatabase getDatabase) { private Mono<GeneratedEntityId> handleGetDatabase(GetDatabase getDatabase) {