Class AbstractDatabase

java.lang.Object

eu.cloudnetservice.node.impl.database.AbstractDatabase

All Implemented Interfaces:

eu.cloudnetservice.driver.base.Named, eu.cloudnetservice.driver.database.Database, eu.cloudnetservice.node.database.LocalDatabase, AutoCloseable

Direct Known Subclasses:

SQLDatabase, XodusDatabase

public abstract class AbstractDatabase
extends Object
implements eu.cloudnetservice.node.database.LocalDatabase, eu.cloudnetservice.driver.database.Database

Field Summary

Fields

Modifier and Type	Field	Description
protected final AbstractNodeDatabaseProvider	databaseProvider
protected final String	name

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractDatabase(@NonNull String name, @NonNull AbstractNodeDatabaseProvider databaseProvider)

Method Summary

Modifier and Type	Method	Description
@NonNull CompletableFuture<Void>	clearAsync()
@NonNull CompletableFuture<Boolean>	containsAsync(@NonNull String key)
@NonNull CompletableFuture<Boolean>	deleteAsync(@NonNull String key)
@NonNull CompletableFuture<Long>	documentCountAsync()
@NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.document.Document>>	documentsAsync()
@NonNull CompletableFuture<Map<String, eu.cloudnetservice.driver.document.Document>>	entriesAsync()
@NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.document.Document>>	findAsync(@NonNull String fieldName, @Nullable String fieldValue)
@NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.document.Document>>	findAsync(@NonNull Map<String,String> filters)
@NonNull CompletableFuture<eu.cloudnetservice.driver.document.Document>	getAsync(@NonNull String key)
@NonNull CompletableFuture<Boolean>	insertAsync(@NonNull String key, @NonNull eu.cloudnetservice.driver.document.Document document)
void	iterate(@NonNull BiConsumer<String, eu.cloudnetservice.driver.document.Document> consumer, int chunkSize)
@NonNull CompletableFuture<Collection<String>>	keysAsync()
@NonNull String	name()
protected @NonNull String	serializeDocumentToJsonString(@NonNull eu.cloudnetservice.driver.document.Document document)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface AutoCloseable

close

Methods inherited from interface eu.cloudnetservice.driver.database.Database

clear, contains, delete, documentCount, documents, entries, find, find, get, insert, keys, synced

Methods inherited from interface eu.cloudnetservice.node.database.LocalDatabase

iterate, readChunk

Field Details

name

protected final String name

databaseProvider

protected final AbstractNodeDatabaseProvider databaseProvider

Constructor Details

AbstractDatabase

protected AbstractDatabase(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull AbstractNodeDatabaseProvider databaseProvider)

Method Details

name

@NonNull
public @NonNull String name()

Specified by:

name in interface eu.cloudnetservice.driver.base.Named

iterate

public void iterate(@NonNull
 @NonNull BiConsumer<String, eu.cloudnetservice.driver.document.Document> consumer,
 int chunkSize)

Specified by:

iterate in interface eu.cloudnetservice.node.database.LocalDatabase

documentCountAsync

@NonNull
public @NonNull CompletableFuture<Long> documentCountAsync()

Specified by:

documentCountAsync in interface eu.cloudnetservice.driver.database.Database

clearAsync

@NonNull
public @NonNull CompletableFuture<Void> clearAsync()

Specified by:

clearAsync in interface eu.cloudnetservice.driver.database.Database

entriesAsync

@NonNull
public @NonNull CompletableFuture<Map<String, eu.cloudnetservice.driver.document.Document>> entriesAsync()

Specified by:

entriesAsync in interface eu.cloudnetservice.driver.database.Database

documentsAsync

@NonNull
public @NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.document.Document>> documentsAsync()

Specified by:

documentsAsync in interface eu.cloudnetservice.driver.database.Database

keysAsync

@NonNull
public @NonNull CompletableFuture<Collection<String>> keysAsync()

Specified by:

keysAsync in interface eu.cloudnetservice.driver.database.Database

findAsync

@NonNull
public @NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.document.Document>> findAsync(@NonNull
 @NonNull Map<String,String> filters)

Specified by:

findAsync in interface eu.cloudnetservice.driver.database.Database

findAsync

@NonNull
public @NonNull CompletableFuture<Collection<eu.cloudnetservice.driver.document.Document>> findAsync(@NonNull
 @NonNull String fieldName,
 @Nullable
 @Nullable String fieldValue)

Specified by:

findAsync in interface eu.cloudnetservice.driver.database.Database

deleteAsync

@NonNull
public @NonNull CompletableFuture<Boolean> deleteAsync(@NonNull
 @NonNull String key)

Specified by:

deleteAsync in interface eu.cloudnetservice.driver.database.Database

getAsync

@NonNull
public @NonNull CompletableFuture<eu.cloudnetservice.driver.document.Document> getAsync(@NonNull
 @NonNull String key)

Specified by:

getAsync in interface eu.cloudnetservice.driver.database.Database

containsAsync

@NonNull
public @NonNull CompletableFuture<Boolean> containsAsync(@NonNull
 @NonNull String key)

Specified by:

containsAsync in interface eu.cloudnetservice.driver.database.Database

insertAsync

@NonNull
public @NonNull CompletableFuture<Boolean> insertAsync(@NonNull
 @NonNull String key,
 @NonNull
 @NonNull eu.cloudnetservice.driver.document.Document document)

Specified by:

insertAsync in interface eu.cloudnetservice.driver.database.Database

serializeDocumentToJsonString

@NonNull
protected @NonNull String serializeDocumentToJsonString(@NonNull
 @NonNull eu.cloudnetservice.driver.document.Document document)