Class XodusDatabase

java.lang.Object

eu.cloudnetservice.node.impl.database.AbstractDatabase

eu.cloudnetservice.node.impl.database.xodus.XodusDatabase

All Implemented Interfaces:

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

public class XodusDatabase
extends AbstractDatabase

Field Summary

Fields

Modifier and Type	Field	Description
protected final jetbrains.exodus.env.Environment	environment
protected final AtomicReference<jetbrains.exodus.env.Store>	store

Fields inherited from class AbstractDatabase

databaseProvider, name

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	XodusDatabase(@NonNull String name, @NonNull jetbrains.exodus.env.Store store, @NonNull XodusDatabaseProvider provider)

Method Summary

Modifier and Type	Method	Description
protected void	acceptWithCursor(@NonNull BiConsumer<String, eu.cloudnetservice.driver.document.Document> handler)
void	clear()
void	close()
boolean	contains(@NonNull String key)
boolean	delete(@NonNull String key)
long	documentCount()
@NonNull Collection<eu.cloudnetservice.driver.document.Document>	documents()
@NonNull Map<String, eu.cloudnetservice.driver.document.Document>	entries()
@NonNull List<eu.cloudnetservice.driver.document.Document>	find(@NonNull String fieldName, @Nullable String fieldValue)
@NonNull List<eu.cloudnetservice.driver.document.Document>	find(@NonNull Map<String,String> filters)
@Nullable eu.cloudnetservice.driver.document.Document	get(@NonNull String key)
protected <T> @NonNull List<T>	handleWithCursor(@NonNull BiFunction<String, eu.cloudnetservice.driver.document.Document, T> mapper)
boolean	insert(@NonNull String key, @NonNull eu.cloudnetservice.driver.document.Document document)
void	iterate(@NonNull BiConsumer<String, eu.cloudnetservice.driver.document.Document> consumer)
@NonNull Collection<String>	keys()
@Nullable Map<String, eu.cloudnetservice.driver.document.Document>	readChunk(long beginIndex, int chunkSize)
protected @NonNull jetbrains.exodus.env.Store	store()
boolean	synced()

Methods inherited from class AbstractDatabase

clearAsync, containsAsync, deleteAsync, documentCountAsync, documentsAsync, entriesAsync, findAsync, findAsync, getAsync, insertAsync, iterate, keysAsync, name, serializeDocumentToJsonString

Methods inherited from class Object

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

Field Details

environment

protected final jetbrains.exodus.env.Environment environment

store

protected final AtomicReference<jetbrains.exodus.env.Store> store

Constructor Details

XodusDatabase

protected XodusDatabase(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull jetbrains.exodus.env.Store store,
 @NonNull
 @NonNull XodusDatabaseProvider provider)

Method Details

insert

public boolean insert(@NonNull
 @NonNull String key,
 @NonNull
 @NonNull eu.cloudnetservice.driver.document.Document document)

contains

public boolean contains(@NonNull
 @NonNull String key)

delete

public boolean delete(@NonNull
 @NonNull String key)

get

@Nullable
public @Nullable eu.cloudnetservice.driver.document.Document get(@NonNull
 @NonNull String key)

find

@NonNull
public @NonNull List<eu.cloudnetservice.driver.document.Document> find(@NonNull
 @NonNull String fieldName,
 @Nullable
 @Nullable String fieldValue)

find

@NonNull
public @NonNull List<eu.cloudnetservice.driver.document.Document> find(@NonNull
 @NonNull Map<String,String> filters)

keys

@NonNull
public @NonNull Collection<String> keys()

documents

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

entries

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

iterate

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

clear

public void clear()

documentCount

public long documentCount()

synced

public boolean synced()

close

public void close()

handleWithCursor

@NonNull
protected <T> @NonNull List<T> handleWithCursor(@NonNull
 @NonNull BiFunction<String, eu.cloudnetservice.driver.document.Document, T> mapper)

acceptWithCursor

protected void acceptWithCursor(@NonNull
 @NonNull BiConsumer<String, eu.cloudnetservice.driver.document.Document> handler)

readChunk

@Nullable
public @Nullable Map<String, eu.cloudnetservice.driver.document.Document> readChunk(long beginIndex,
 int chunkSize)

store

@NonNull
protected @NonNull jetbrains.exodus.env.Store store()