Java Client SDK

<dependency>
    <groupId>io.github.oxia-db</groupId>
    <artifactId>oxia-client</artifactId>
    <version>${VERSION}</version>
</dependency>

implementation("io.github.oxia-db:oxia-client:${VERSION}")

SyncOxiaClient client = OxiaClientBuilder.create("localhost:6648")
        .namespace("my-namespace")
        .syncClient();

AsyncOxiaClient client = OxiaClientBuilder.create("localhost:6648")
        .namespace("my-namespace")
        .asyncClient()
        .get();

// Write a record to Oxia with the specified key and value, and with the expectation
// that the record does not already exist.
PutResult res = client.put("my-key", "my-value".getBytes(), Set.of(IfRecordDoesNotExist));
 
// Write a record with the expectation that it has not changed since the previous write.
// If there was any change, the operation will fail
client.put("my-key", "my-value-2".getBytes(),
            Set.of(IfVersionIdEquals(res.version().versionId())));

// Write a record to Oxia with the specified key and value, and with the expectation
// that the record does not already exist.
client.put("my-string", "my-value".getBytes(), Set.of(IfRecordDoesNotExist))
        .thenAccept(res -> {
            log.info("Put result: {}", res);
        }).exceptionally(ex -> {
            log.warn("Put failed", ex);
            return null;
        });
 
// Write a record with the expectation that it has not changed since the previous write.
// If there was any change, the operation will fail
client.put("my-key", "my-value-2".getBytes(),
            Set.of(IfVersionIdEquals(res.version().versionId())))
        .thenAccept(res -> {
            log.info("Put result: {}", res);
        }).exceptionally(ex -> {
            log.warn("Put failed", ex);
            return null;
        });

GetResult res = client.get("my-key");
log.info("Got key: {} - value: {} - version: {}",
            res.getKey(), res.getValue(), res.getVersion());

aclient.get("my-key")
        .thenAccept(res -> {
            log.info("Got key: {} - value: {} - version: {}",
                    res.getKey(), res.getValue(), res.getVersion());
        }).exceptionally(ex -> {
            log.warn("Get failed", ex);
            return null;
        });