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 and Description
static class	MongoDBDatasource.Sequence

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_SEQUENCE_TABLE

Fields inherited from class io.semla.datasource.Datasource

logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static MongoDBDatasourceConfiguration	configure()
long	count(Predicates<T> predicates)
void	create(Collection<T> entities)
void	create(T entity)
long	delete(Collection<?> keys)
boolean	delete(Object key)
long	delete(Predicates<T> predicates, Pagination<T> pagination)
Optional<T>	first(Predicates<T> predicates, Pagination<T> pagination)
<K> Map<K,T>	get(Collection<K> keys)
Optional<T>	get(Object key)
List<T>	list(Predicates<T> predicates, Pagination<T> pagination)
long	patch(Values<T> values, Predicates<T> predicates, Pagination<T> pagination)
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 Detail

DEFAULT_SEQUENCE_TABLE

public static String DEFAULT_SEQUENCE_TABLE

Constructor Detail

MongoDBDatasource

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

Method Detail

raw

public 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 MongoDBDatasourceConfiguration configure()