Package org.graylog2.database

Class PersistedServiceImpl

java.lang.Object

org.graylog2.database.PersistedServiceImpl

All Implemented Interfaces:

PersistedService

Direct Known Subclasses:

AbstractNodeService, AccessTokenServiceImpl, IndexFailureServiceImpl, InputServiceImpl, MongoDBSessionServiceImpl, NotificationServiceImpl, StreamRuleServiceImpl, StreamServiceImpl, SystemMessageServiceImpl, UserServiceImpl

public class PersistedServiceImpl
extends Object
implements PersistedService

Field Summary

Fields

Modifier and Type	Field	Description
final MongoConnection	mongoConnection

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PersistedServiceImpl(MongoConnection mongoConnection)

Method Summary

Modifier and Type	Method	Description
protected <T extends Persisted> com.mongodb.DBCollection	collection(Class<T> modelClass)
protected <T extends Persisted> com.mongodb.DBCollection	collection(T model)
protected <T extends Persisted> String	collectionName(Class<T> modelClass)
protected long	count(com.mongodb.DBObject query, String collectionName)
protected <T extends Persisted> long	count(Class<T> modelClass, com.mongodb.DBObject query)
protected List<com.mongodb.DBObject>	cursorToList(com.mongodb.DBCursor cursor)
protected int	destroy(com.mongodb.DBObject query, String collectionName)
<T extends Persisted> int	destroy(T model)
<T extends Persisted> int	destroyAll(Class<T> modelClass)
protected <T extends Persisted> int	destroyAll(Class<T> modelClass, com.mongodb.DBObject query)
protected int	destroyAll(String collectionName)
protected <T extends Persisted> void	embed(T model, String key, EmbeddedPersistable o)
protected void	fieldTransformations(Map<String,Object> doc)
protected com.mongodb.DBObject	findOne(com.mongodb.DBObject query, com.mongodb.DBObject sort, String collectioName)
protected com.mongodb.DBObject	findOne(com.mongodb.DBObject query, String collectionName)
protected <T extends Persisted> com.mongodb.DBObject	findOne(Class<T> model, com.mongodb.DBObject query)
protected <T extends Persisted> com.mongodb.DBObject	findOne(Class<T> model, com.mongodb.DBObject query, com.mongodb.DBObject sort)
protected <T extends Persisted> com.mongodb.DBObject	get(Class<T> modelClass, String id)
protected <T extends Persisted> com.mongodb.DBObject	get(Class<T> modelClass, org.bson.types.ObjectId id)
protected com.mongodb.DBObject	get(org.bson.types.ObjectId id, String collectionName)
protected <T extends Persisted> com.mongodb.client.MongoCollection<org.bson.Document>	mongoCollection(Class<T> modelClass)
protected List<com.mongodb.DBObject>	query(com.mongodb.DBObject query, com.mongodb.DBCollection collection)
protected List<com.mongodb.DBObject>	query(com.mongodb.DBObject query, String collectionName)
protected <T extends Persisted> List<com.mongodb.DBObject>	query(Class<T> modelClass, com.mongodb.DBObject query)
protected <T extends Persisted> List<com.mongodb.DBObject>	query(Class<T> modelClass, com.mongodb.DBObject query, com.mongodb.DBObject sort)
protected <T extends Persisted> List<com.mongodb.DBObject>	query(Class<T> modelClass, com.mongodb.DBObject query, com.mongodb.DBObject sort, int limit, int offset)
protected <T extends Persisted> void	removeEmbedded(T model, String key, String searchId)
protected <T extends Persisted> void	removeEmbedded(T model, String arrayKey, String key, String searchId)
<T extends Persisted> String	save(T model)
<T extends Persisted> String	saveWithoutValidation(T model)
protected <T extends Persisted> long	totalCount(Class<T> modelClass)
protected long	totalCount(String collectionName)
Map<String,List<ValidationResult>>	validate(Map<String,Validator> validators, Map<String,Object> fields)
<T extends Persisted> Map<String,List<ValidationResult>>	validate(T model)
<T extends Persisted> Map<String,List<ValidationResult>>	validate(T model, Map<String,Object> fields)

Methods inherited from class java.lang.Object

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

Field Details

mongoConnection

public final MongoConnection mongoConnection

Constructor Details

PersistedServiceImpl

protected PersistedServiceImpl(MongoConnection mongoConnection)

Method Details

get

protected com.mongodb.DBObject get(org.bson.types.ObjectId id,
 String collectionName)

get

protected <T extends Persisted>
com.mongodb.DBObject get(Class<T> modelClass,
 org.bson.types.ObjectId id)

get

protected <T extends Persisted>
com.mongodb.DBObject get(Class<T> modelClass,
 String id)

query

protected List<com.mongodb.DBObject> query(com.mongodb.DBObject query,
 String collectionName)

query

protected List<com.mongodb.DBObject> query(com.mongodb.DBObject query,
 com.mongodb.DBCollection collection)

query

protected <T extends Persisted>
List<com.mongodb.DBObject> query(Class<T> modelClass,
 com.mongodb.DBObject query)

query

protected <T extends Persisted>
List<com.mongodb.DBObject> query(Class<T> modelClass,
 com.mongodb.DBObject query,
 com.mongodb.DBObject sort)

query

protected <T extends Persisted>
List<com.mongodb.DBObject> query(Class<T> modelClass,
 com.mongodb.DBObject query,
 com.mongodb.DBObject sort,
 int limit,
 int offset)

count

protected long count(com.mongodb.DBObject query,
 String collectionName)

count

protected <T extends Persisted> long count(Class<T> modelClass,
 com.mongodb.DBObject query)

collection

protected <T extends Persisted>
com.mongodb.DBCollection collection(Class<T> modelClass)

collectionName

protected <T extends Persisted> String collectionName(Class<T> modelClass)

collection

protected <T extends Persisted>
com.mongodb.DBCollection collection(T model)

mongoCollection

protected <T extends Persisted>
com.mongodb.client.MongoCollection<org.bson.Document> mongoCollection(Class<T> modelClass)

cursorToList

protected List<com.mongodb.DBObject> cursorToList(com.mongodb.DBCursor cursor)

findOne

protected <T extends Persisted>
com.mongodb.DBObject findOne(Class<T> model,
 com.mongodb.DBObject query)

findOne

protected <T extends Persisted>
com.mongodb.DBObject findOne(Class<T> model,
 com.mongodb.DBObject query,
 com.mongodb.DBObject sort)

findOne

protected com.mongodb.DBObject findOne(com.mongodb.DBObject query,
 String collectionName)

findOne

protected com.mongodb.DBObject findOne(com.mongodb.DBObject query,
 com.mongodb.DBObject sort,
 String collectioName)

totalCount

protected long totalCount(String collectionName)

totalCount

protected <T extends Persisted> long totalCount(Class<T> modelClass)

destroy

public <T extends Persisted> int destroy(T model)

Specified by:

destroy in interface PersistedService

destroyAll

public <T extends Persisted> int destroyAll(Class<T> modelClass)

Specified by:

destroyAll in interface PersistedService

destroyAll

protected int destroyAll(String collectionName)

destroy

protected int destroy(com.mongodb.DBObject query,
 String collectionName)

destroyAll

protected <T extends Persisted> int destroyAll(Class<T> modelClass,
 com.mongodb.DBObject query)

save

public <T extends Persisted> String save(T model)
                                  throws ValidationException

Specified by:

save in interface PersistedService

Throws:

ValidationException

saveWithoutValidation

public <T extends Persisted> String saveWithoutValidation(T model)

Specified by:

saveWithoutValidation in interface PersistedService

validate

public <T extends Persisted>
Map<String,List<ValidationResult>> validate(T model,
 Map<String,Object> fields)

Specified by:

validate in interface PersistedService

validate

public Map<String,List<ValidationResult>> validate(Map<String,Validator> validators,
 Map<String,Object> fields)

Specified by:

validate in interface PersistedService

validate

public <T extends Persisted>
Map<String,List<ValidationResult>> validate(T model)

Specified by:

validate in interface PersistedService

embed

protected <T extends Persisted> void embed(T model,
 String key,
 EmbeddedPersistable o)
                                    throws ValidationException

Throws:

ValidationException

removeEmbedded

protected <T extends Persisted> void removeEmbedded(T model,
 String key,
 String searchId)

removeEmbedded

protected <T extends Persisted> void removeEmbedded(T model,
 String arrayKey,
 String key,
 String searchId)

fieldTransformations

protected void fieldTransformations(Map<String,Object> doc)