Package io.semla.datasource

Class MongoDBDatasource<T>

java.lang.Object

io.semla.datasource.Datasource<T>

io.semla.datasource.MongoDBDatasource<T>

public class MongoDBDatasource<T>
extends Datasource<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MongoDBDatasource.Configuration
static class	MongoDBDatasource.Sequence

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_SEQUENCE_TABLE

Fields inherited from class io.semla.datasource.Datasource

logger

Constructor Summary

Constructors

Constructor	Description
MongoDBDatasource(EntityModel<T> model, com.mongodb.client.MongoDatabase mongoDatabase)

Method Summary

Modifier and Type	Method	Description
static MongoDBDatasource.Configuration	configure()
long	count(Predicates<T> predicates)
void	create(Collection<T> entities)
void	create(T entity)
long	delete(Predicates<T> predicates, Pagination<T> pagination)
boolean	delete(Object key)
long	delete(Collection<?> keys)
Optional<T>	first(Predicates<T> predicates, Pagination<T> pagination)
Optional<T>	get(Object key)
<K> Map<K,T>	get(Collection<K> keys)
List<T>	list(Predicates<T> predicates, Pagination<T> pagination)
long	patch(Values<T> values, Predicates<T> predicates, Pagination<T> pagination)
io.semla.util.Pair<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCollection<MongoDBDatasource.Sequence>>	raw()
void	update(Collection<T> entities)
void	update(T entity)

Methods inherited from class io.semla.datasource.Datasource

alreadyExists, count, delete, deleteAll, first, first, first, list, list, list, model, notFound, patch

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SEQUENCE_TABLE

public static String DEFAULT_SEQUENCE_TABLE

Constructor Details

MongoDBDatasource

public MongoDBDatasource(EntityModel<T> model,
 com.mongodb.client.MongoDatabase mongoDatabase)

Method Details

raw

public io.semla.util.Pair<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCollection<MongoDBDatasource.Sequence>> raw()

Specified by:

raw in class Datasource<T>

get

public Optional<T> get(Object key)

Specified by:

get in class Datasource<T>

get

public <K> Map<K,T> get(Collection<K> keys)

Specified by:

get in class Datasource<T>

create

public void create(T entity)

Specified by:

create in class Datasource<T>

create

public void create(Collection<T> entities)

Specified by:

create in class Datasource<T>

update

public void update(T entity)

Specified by:

update in class Datasource<T>

update

public void update(Collection<T> entities)

Specified by:

update in class Datasource<T>

delete

public boolean delete(Object key)

Specified by:

delete in class Datasource<T>

delete

public long delete(Collection<?> keys)

Specified by:

delete in class Datasource<T>

first

public Optional<T> first(Predicates<T> predicates,
 Pagination<T> pagination)

Specified by:

first in class Datasource<T>

list

public List<T> list(Predicates<T> predicates,
 Pagination<T> pagination)

Specified by:

list in class Datasource<T>

patch

public long patch(Values<T> values,
 Predicates<T> predicates,
 Pagination<T> pagination)

Specified by:

patch in class Datasource<T>

delete

public long delete(Predicates<T> predicates,
 Pagination<T> pagination)

Specified by:

delete in class Datasource<T>

count

public long count(Predicates<T> predicates)

Specified by:

count in class Datasource<T>

configure

public static MongoDBDatasource.Configuration configure()