io.picodata.driver.core.space

Class ProxyTarantoolSpace<T extends Packable,R extends Collection<T>>

java.lang.Object

io.picodata.driver.core.space.ProxyTarantoolSpace<T,R>

All Implemented Interfaces:

TarantoolSpaceOperations<T,R>

Direct Known Subclasses:

ProxyTarantoolTupleSpace

public abstract class ProxyTarantoolSpace<T extends Packable,R extends Collection<T>>
extends Object
implements TarantoolSpaceOperations<T,R>

Basic proxy TarantoolSpaceOperations implementation, which uses calls to API functions defined in Tarantool instance for performing CRUD operations on a space

Constructor Summary

Constructors

Constructor and Description
ProxyTarantoolSpace(TarantoolClientConfig config, TarantoolCallOperations client, ProxyOperationsMappingConfig operationsMapping, TarantoolMetadataOperations metadata, TarantoolSpaceMetadata spaceMetadata)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<R>	delete(Conditions conditions) Delete a tuple.
CompletableFuture<R>	delete(Conditions conditions, DeleteOptions options) Delete a tuple.
TarantoolSpaceMetadata	getMetadata() Get metadata associated with this space
CompletableFuture<R>	insert(T tuple) Inserts tuple into the space, if no tuple with same unique keys exists.
CompletableFuture<R>	insert(T tuple, InsertOptions options) Inserts tuple into the space, if no tuple with same unique keys exists.
CompletableFuture<R>	insertMany(Collection<T> tuples) Inserts several tuples into the space at once.
CompletableFuture<R>	insertMany(Collection<T> tuples, InsertManyOptions options) Inserts several tuples into the space at once.
protected abstract TupleOperations	makeOperationsFromTuple(T tuple) Create a TupleOperations instance from the given tuple of type T
CompletableFuture<R>	replace(T tuple) Insert a tuple into the space or replace an existing one.
CompletableFuture<R>	replace(T tuple, ReplaceOptions options) Insert a tuple into the space or replace an existing one.
CompletableFuture<R>	replaceMany(Collection<T> tuples) Insert or replace several tuples into the space at once.
CompletableFuture<R>	replaceMany(Collection<T> tuples, ReplaceManyOptions options) Insert or replace several tuples into the space at once.
protected abstract CallResultMapper<R,SingleValueCallResult<R>>	rowsMetadataTupleResultMapper() MessagePack value mapper configured with an ArrayValue to tuple converter corresponding to the selected tuple type
CompletableFuture<R>	select(Conditions conditions) Select tuples matching the specified query with options.
CompletableFuture<R>	select(Conditions conditions, SelectOptions options) Select tuples matching the specified query with specified conditions and options.
String	toString()
CompletableFuture<Void>	truncate() Truncate space if space would be found.
CompletableFuture<R>	update(Conditions conditions, T tuple) Update a tuple.
CompletableFuture<R>	update(Conditions conditions, T tuple, UpdateOptions options) Update a tuple.
CompletableFuture<R>	update(Conditions conditions, TupleOperations operations) Update a tuple.
CompletableFuture<R>	update(Conditions conditions, TupleOperations operations, UpdateOptions options) Update a tuple.
CompletableFuture<R>	upsert(Conditions conditions, T tuple, TupleOperations operations) Update tuple if it would be found elsewhere try to insert tuple.
CompletableFuture<R>	upsert(Conditions conditions, T tuple, TupleOperations operations, UpsertOptions options) Update tuple if it would be found elsewhere try to insert tuple.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.picodata.driver.api.space.TarantoolSpaceOperations

cursor, cursor

Constructor Detail

ProxyTarantoolSpace

public ProxyTarantoolSpace(TarantoolClientConfig config,
                           TarantoolCallOperations client,
                           ProxyOperationsMappingConfig operationsMapping,
                           TarantoolMetadataOperations metadata,
                           TarantoolSpaceMetadata spaceMetadata)

Method Detail

delete

public CompletableFuture<R> delete(Conditions conditions)
                            throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Delete a tuple. Only a single primary index value condition is supported.

Specified by:

delete in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

Returns:

a future that will contain removed tuple once completed

Throws:

TarantoolClientException - in case if the request failed

delete

public CompletableFuture<R> delete(Conditions conditions,
                                   DeleteOptions options)
                            throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Delete a tuple. Only a single primary index value condition is supported.

Specified by:

delete in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

options - operation options

Returns:

a future that will contain removed tuple once completed

Throws:

TarantoolClientException - in case if the request failed

insert

public CompletableFuture<R> insert(T tuple)
                            throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Inserts tuple into the space, if no tuple with same unique keys exists. Otherwise throw duplicate key error.

Specified by:

insert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuple - new data

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if request failed

insert

public CompletableFuture<R> insert(T tuple,
                                   InsertOptions options)
                            throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Inserts tuple into the space, if no tuple with same unique keys exists. Otherwise throw duplicate key error.

Specified by:

insert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuple - new data

options - operation options

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if request failed

insertMany

public CompletableFuture<R> insertMany(Collection<T> tuples)

Description copied from interface: TarantoolSpaceOperations

Inserts several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved.

Specified by:

insertMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuples - new data

Returns:

a future that will contain all corresponding tuples once completed

insertMany

public CompletableFuture<R> insertMany(Collection<T> tuples,
                                       InsertManyOptions options)
                                throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Inserts several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved.

Specified by:

insertMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuples - new data

options - operation options

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if request failed

replace

public CompletableFuture<R> replace(T tuple)
                             throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Insert a tuple into the space or replace an existing one.

Specified by:

replace in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuple - new data

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if request failed

replace

public CompletableFuture<R> replace(T tuple,
                                    ReplaceOptions options)
                             throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Insert a tuple into the space or replace an existing one.

Specified by:

replace in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuple - new data

options - operation options

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if request failed

replaceMany

public CompletableFuture<R> replaceMany(Collection<T> tuples)
                                 throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Insert or replace several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved.

Specified by:

replaceMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuples - new data

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if request failed

replaceMany

public CompletableFuture<R> replaceMany(Collection<T> tuples,
                                        ReplaceManyOptions options)

Description copied from interface: TarantoolSpaceOperations

Insert or replace several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved, but this behavior can be changed with the options.

Specified by:

replaceMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

tuples - new data

options - operation options

Returns:

a future that will contain all corresponding tuples once completed

select

public CompletableFuture<R> select(Conditions conditions)
                            throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Select tuples matching the specified query with options.

Specified by:

select in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if the request failed

select

public CompletableFuture<R> select(Conditions conditions,
                                   SelectOptions options)
                            throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Select tuples matching the specified query with specified conditions and options.

Specified by:

select in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - specified conditions

options - operation options

Returns:

a future that will contain all corresponding tuples once completed

Throws:

TarantoolClientException - in case if the request failed

update

public CompletableFuture<R> update(Conditions conditions,
                                   T tuple)

Description copied from interface: TarantoolSpaceOperations

Update a tuple. Only a single primary index value condition is supported.

Specified by:

update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

tuple - tuple with new field values

Returns:

a future that will contain corresponding tuple once completed

update

public CompletableFuture<R> update(Conditions conditions,
                                   T tuple,
                                   UpdateOptions options)

Description copied from interface: TarantoolSpaceOperations

Update a tuple. Only a single primary index value condition is supported.

Specified by:

update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

tuple - tuple with new field values

options - operation options

Returns:

a future that will contain corresponding tuple once completed

makeOperationsFromTuple

protected abstract TupleOperations makeOperationsFromTuple(T tuple)

Create a TupleOperations instance from the given tuple of type T

Parameters:

tuple - tuple of the specified type

Returns:

new TupleOperations instance

update

public CompletableFuture<R> update(Conditions conditions,
                                   TupleOperations operations)

Description copied from interface: TarantoolSpaceOperations

Update a tuple. Only a single primary index value condition is supported.

Specified by:

update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

operations - the list update operations

Returns:

a future that will contain corresponding tuple once completed

update

public CompletableFuture<R> update(Conditions conditions,
                                   TupleOperations operations,
                                   UpdateOptions options)

Description copied from interface: TarantoolSpaceOperations

Update a tuple. Only a single primary index value condition is supported.

Specified by:

update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

operations - the list update operations

options - operation options

Returns:

a future that will contain corresponding tuple once completed

upsert

public CompletableFuture<R> upsert(Conditions conditions,
                                   T tuple,
                                   TupleOperations operations)

Description copied from interface: TarantoolSpaceOperations

Update tuple if it would be found elsewhere try to insert tuple. Only a single primary index value condition is supported.

Specified by:

upsert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

tuple - new data that will be insert if tuple will be not found

operations - the list of update operations to be performed if the tuple exists

Returns:

a future that will empty list

upsert

public CompletableFuture<R> upsert(Conditions conditions,
                                   T tuple,
                                   TupleOperations operations,
                                   UpsertOptions options)

Description copied from interface: TarantoolSpaceOperations

Update tuple if it would be found elsewhere try to insert tuple. Only a single primary index value condition is supported.

Specified by:

upsert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Parameters:

conditions - query with options

tuple - new data that will be insert if tuple will be not found

operations - the list of update operations to be performed if the tuple exists

options - operation options

Returns:

a future that will empty list

truncate

public CompletableFuture<Void> truncate()
                                 throws TarantoolClientException

Description copied from interface: TarantoolSpaceOperations

Truncate space if space would be found. Otherwise, throw space not found error.

Specified by:

truncate in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Returns:

a future that will contain void.

Throws:

TarantoolClientException - in case if request failed

rowsMetadataTupleResultMapper

protected abstract CallResultMapper<R,SingleValueCallResult<R>> rowsMetadataTupleResultMapper()

MessagePack value mapper configured with an ArrayValue to tuple converter corresponding to the selected tuple type

Returns:

configured mapper with ArrayValue to T converter

getMetadata

public TarantoolSpaceMetadata getMetadata()

Description copied from interface: TarantoolSpaceOperations

Get metadata associated with this space

Specified by:

getMetadata in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>

Returns:

space metadata

toString

public String toString()

Overrides:

toString in class Object