Module cloud.quinimbus.persistence.storage.mongo

Package cloud.quinimbus.persistence.storage.mongo

Class MongoSchemaStorage

java.lang.Object

cloud.quinimbus.persistence.storage.mongo.MongoSchemaStorage

All Implemented Interfaces:

PersistenceSchemaStorage

public class MongoSchemaStorage
extends Object
implements PersistenceSchemaStorage

Constructor Summary

Constructors

Constructor	Description
MongoSchemaStorage(com.mongodb.client.MongoClient client, Schema schema, PersistenceContext context)

Method Summary

Modifier and Type	Method	Description
<K> Optional<Entity<K>>	find(EntityType type, K id)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException>	findAll(EntityType type)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException>	findAllIDs(EntityType type)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException>	findFiltered(EntityType type, Set<? extends PropertyFilter> propertyFilters)
<K> name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException>	findIDsFiltered(EntityType type, Set<? extends PropertyFilter> propertyFilters)
PersistenceSchemaStorageMigrator	getMigrator()
Metadata	getSchemaMetadata()
void	increaseSchemaVersion(Long version)
void	logMigrationRun(String identifier, String entityType, Long schemaVersion, Instant runAt)
<K> void	remove(EntityType type, K id)
<K> void	save(Entity<K> entity)

Methods inherited from class java.lang.Object

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

Constructor Details

MongoSchemaStorage

public MongoSchemaStorage(com.mongodb.client.MongoClient client,
 Schema schema,
 PersistenceContext context)
                   throws PersistenceException

Throws:

PersistenceException

Method Details

getSchemaMetadata

public Metadata getSchemaMetadata()
                           throws PersistenceException

Specified by:

getSchemaMetadata in interface PersistenceSchemaStorage

Throws:

PersistenceException

increaseSchemaVersion

public void increaseSchemaVersion(Long version)
                           throws PersistenceException

Specified by:

increaseSchemaVersion in interface PersistenceSchemaStorage

Throws:

PersistenceException

getMigrator

public PersistenceSchemaStorageMigrator getMigrator()

Specified by:

getMigrator in interface PersistenceSchemaStorage

logMigrationRun

public void logMigrationRun(String identifier,
 String entityType,
 Long schemaVersion,
 Instant runAt)

Specified by:

logMigrationRun in interface PersistenceSchemaStorage

find

public <K> Optional<Entity<K>> find(EntityType type,
 K id)
                             throws PersistenceException

Specified by:

find in interface PersistenceSchemaStorage

Throws:

PersistenceException

findFiltered

public <K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException> findFiltered(EntityType type,
 Set<? extends PropertyFilter> propertyFilters)

Specified by:

findFiltered in interface PersistenceSchemaStorage

findIDsFiltered

public <K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException> findIDsFiltered(EntityType type,
 Set<? extends PropertyFilter> propertyFilters)

Specified by:

findIDsFiltered in interface PersistenceSchemaStorage

save

public <K> void save(Entity<K> entity)
              throws PersistenceException

Specified by:

save in interface PersistenceSchemaStorage

Throws:

PersistenceException

findAll

public <K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<Entity<K>,PersistenceException> findAll(EntityType type)
                                                                                     throws PersistenceException

Specified by:

findAll in interface PersistenceSchemaStorage

Throws:

PersistenceException

findAllIDs

public <K>
name.falgout.jeffrey.throwing.stream.ThrowingStream<K,PersistenceException> findAllIDs(EntityType type)
                                                                                throws PersistenceException

Specified by:

findAllIDs in interface PersistenceSchemaStorage

Throws:

PersistenceException

remove

public <K> void remove(EntityType type,
 K id)
                throws PersistenceException

Specified by:

remove in interface PersistenceSchemaStorage

Throws:

PersistenceException