Package org.nuxeo.ecm.core.mongodb.kv
Class MongoDBKeyValueStore
java.lang.Object
org.nuxeo.runtime.kv.AbstractKeyValueStoreProvider
org.nuxeo.ecm.core.mongodb.kv.MongoDBKeyValueStore
- All Implemented Interfaces:
KeyValueStore
,KeyValueStoreProvider
MongoDB implementation of a Key/Value Store Provider.
The following configuration properties are available:
- collection: the MongoDB collection prefix to use, the default is "kv". This will be followed by the Store name.
- Since:
- 9.3
-
Field Summary
Modifier and TypeFieldDescriptionprotected com.mongodb.client.MongoCollection<org.bson.Document>
static final String
static final String
static final String
static final String
static final Double
static final String
static final String
Fields inherited from class org.nuxeo.runtime.kv.AbstractKeyValueStoreProvider
name, UTF_8_DECODERS
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionlong
Atomically adds the delta to the value associated to the key, interpreted as a long represented as a string.protected long
addAndGetGeneric
(String key, long delta) protected void
addTTL
(org.bson.Document doc, long ttl) void
clear()
Clears the content of this Key/Value store provider.void
close()
Closes this Key/Value store provider.boolean
compareAndSet
(String key, byte[] expected, byte[] value, long ttl) Atomically sets the value associated to the key to the given value, with the given TTL, if the current value is the expected value.protected boolean
compareAndSet
(String key, Object expected, Object value, long ttl) boolean
compareAndSet
(String key, String expected, String value, long ttl) Atomically sets the value associated to the key to the given value, with the given TTL, if the current value is the expected value.protected void
findByKeys
(Collection<String> keys, Consumer<org.bson.Document> block) byte[]
Retrieves the value associated to the key.get
(Collection<String> keys) Retrieves the key/value map associated with the keys.protected Date
getDateFromTTL
(long ttl) Retrieves the value associated to the key.getLongs
(Collection<String> keys) Retrieves the key/value map associated with the keys.protected Object
Retrieves the value associated to the key.getStrings
(Collection<String> keys) Retrieves the key/value map associated with the keys.void
initialize
(KeyValueStoreDescriptor descriptor) Initializes this Key/Value store provider.Returns aStream
of the keys contained in this Key/Value store provider.Returns aStream
of the keys with the given prefix contained in this Key/Value store provider.void
Sets the value associated to the key, and a TTL.void
Sets the value associated to the key.void
Sets the value associated to the key.protected void
void
Sets the value associated to the key.void
Sets the value associated to the key, and a TTL.boolean
Sets the TTL for an existing key.protected byte[]
protected Long
protected static Object
toStorage
(byte[] bytes) protected String
Methods inherited from class org.nuxeo.runtime.kv.AbstractKeyValueStoreProvider
bytesToLong, bytesToString, compareAndSet, compareAndSet, longToBytes, put, stringToBytes, toString
-
Field Details
-
KEYVALUE_CONNECTION_ID
- See Also:
-
COLLECTION_PROP
- See Also:
-
COLLECTION_DEFAULT
- See Also:
-
ID_KEY
- See Also:
-
VALUE_KEY
- See Also:
-
TTL_KEY
- See Also:
-
ONE
-
coll
protected com.mongodb.client.MongoCollection<org.bson.Document> coll
-
-
Constructor Details
-
MongoDBKeyValueStore
public MongoDBKeyValueStore()
-
-
Method Details
-
initialize
Description copied from interface:KeyValueStoreProvider
Initializes this Key/Value store provider.- Specified by:
initialize
in interfaceKeyValueStoreProvider
- Overrides:
initialize
in classAbstractKeyValueStoreProvider
- Parameters:
descriptor
- the store provider descriptor
-
keyStream
Description copied from interface:KeyValueStoreProvider
Returns aStream
of the keys contained in this Key/Value store provider.This operation may be slow and should only be used for management or debug purposes.
- Returns:
- the stream of keys
-
keyStream
Description copied from interface:KeyValueStoreProvider
Returns aStream
of the keys with the given prefix contained in this Key/Value store provider.This operation may be slow and should only be used for management or debug purposes.
- Returns:
- the stream of keys
-
close
public void close()Description copied from interface:KeyValueStoreProvider
Closes this Key/Value store provider. -
clear
public void clear()Description copied from interface:KeyValueStoreProvider
Clears the content of this Key/Value store provider. -
toStorage
-
toBytes
-
toString
-
toLong
- Throws:
NumberFormatException
-
get
Description copied from interface:KeyValueStore
Retrieves the value associated to the key.- Parameters:
key
- the key- Returns:
- the value, or
null
if there is no value
-
getString
Description copied from interface:KeyValueStore
Retrieves the value associated to the key.- Specified by:
getString
in interfaceKeyValueStore
- Overrides:
getString
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the key- Returns:
- the value, or
null
if there is no value
-
getLong
Description copied from interface:KeyValueStore
Retrieves the value associated to the key.- Specified by:
getLong
in interfaceKeyValueStore
- Overrides:
getLong
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the key- Returns:
- the value, or
null
if there is no value - Throws:
NumberFormatException
- if the value cannot be returned as aLong
-
getObject
-
get
Description copied from interface:KeyValueStore
Retrieves the key/value map associated with the keys.- Specified by:
get
in interfaceKeyValueStore
- Overrides:
get
in classAbstractKeyValueStoreProvider
- Parameters:
keys
- the keys- Returns:
- the key/value map
-
getStrings
Description copied from interface:KeyValueStore
Retrieves the key/value map associated with the keys.- Specified by:
getStrings
in interfaceKeyValueStore
- Overrides:
getStrings
in classAbstractKeyValueStoreProvider
- Parameters:
keys
- the keys- Returns:
- the key/value map
-
getLongs
Description copied from interface:KeyValueStore
Retrieves the key/value map associated with the keys.- Specified by:
getLongs
in interfaceKeyValueStore
- Overrides:
getLongs
in classAbstractKeyValueStoreProvider
- Parameters:
keys
- the keys- Returns:
- the key/value map
- Throws:
NumberFormatException
- if one of the values cannot be returned as aLong
-
findByKeys
- Since:
- 9.10
-
getDateFromTTL
-
put
Description copied from interface:KeyValueStore
Sets the value associated to the key, and a TTL.- Parameters:
key
- the keybytes
- the value, which may benull
ttl
- the TTL, in seconds (0 for infinite)
-
put
Description copied from interface:KeyValueStore
Sets the value associated to the key.- Specified by:
put
in interfaceKeyValueStore
- Overrides:
put
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the keystring
- the value, which may benull
-
put
Description copied from interface:KeyValueStore
Sets the value associated to the key, and a TTL.- Specified by:
put
in interfaceKeyValueStore
- Overrides:
put
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the keystring
- the value, which may benull
ttl
- the TTL, in seconds (0 for infinite)
-
put
Description copied from interface:KeyValueStore
Sets the value associated to the key.- Specified by:
put
in interfaceKeyValueStore
- Overrides:
put
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the keyvalue
- the value, which may benull
-
put
Description copied from interface:KeyValueStore
Sets the value associated to the key.- Specified by:
put
in interfaceKeyValueStore
- Overrides:
put
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the keyvalue
- the value, which may benull
ttl
- the TTL, in seconds (0 for infinite)
-
put
-
addTTL
protected void addTTL(org.bson.Document doc, long ttl) -
setTTL
Description copied from interface:KeyValueStore
Sets the TTL for an existing key.- Parameters:
key
- the keyttl
- the TTL, in seconds (0 for infinite)- Returns:
true
if the TTL has been set, orfalse
if the key does not exist
-
compareAndSet
Description copied from interface:KeyValueStore
Atomically sets the value associated to the key to the given value, with the given TTL, if the current value is the expected value.Note value comparison is done by value and not by reference.
- Parameters:
key
- the keyexpected
- the expected value, which may benull
value
- the updated value, which may benull
ttl
- the TTL, in seconds (0 for infinite)- Returns:
true
if the value was updated, orfalse
if not (the expected value was not found)
-
compareAndSet
Description copied from interface:KeyValueStore
Atomically sets the value associated to the key to the given value, with the given TTL, if the current value is the expected value.Note value comparison is done by value and not by reference.
- Specified by:
compareAndSet
in interfaceKeyValueStore
- Overrides:
compareAndSet
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the keyexpected
- the expected value, which may benull
value
- the updated value, which may benull
ttl
- the TTL, in seconds (0 for infinite)- Returns:
true
if the value was updated, orfalse
if not (the expected value was not found)
-
compareAndSet
-
addAndGet
Description copied from interface:KeyValueStore
Atomically adds the delta to the value associated to the key, interpreted as a long represented as a string.If the value does not exist (if
KeyValueStore.get(java.lang.String)
would returnnull
), it is interpreted as0
.- Specified by:
addAndGet
in interfaceKeyValueStore
- Overrides:
addAndGet
in classAbstractKeyValueStoreProvider
- Parameters:
key
- the keydelta
- the delta to add- Returns:
- the new value
- Throws:
NumberFormatException
- if the existing value cannot be interpreted as along
-
addAndGetGeneric
- Throws:
NumberFormatException
-