org.mongodb.morphia

Class DatastoreImpl

java.lang.Object

org.mongodb.morphia.DatastoreImpl

All Implemented Interfaces:

AdvancedDatastore, Datastore

public class DatastoreImpl
extends Object
implements AdvancedDatastore

A generic (type-safe) wrapper around mongodb collections

Constructor Summary

Constructors

Constructor and Description
DatastoreImpl(Mapper mapper, com.mongodb.Mongo mongo, String dbName)
DatastoreImpl(Morphia morphia, com.mongodb.Mongo mongo)
DatastoreImpl(Morphia morphia, com.mongodb.Mongo mongo, String dbName)
DatastoreImpl(Morphia morphia, com.mongodb.Mongo mongo, String dbName, String username, char[] password) Deprecated. Authentication is already handled by the Mongo instance

Method Summary

Modifier and Type	Method and Description
DatastoreImpl	copy(String database)
<T> Query<T>	createQuery(Class<T> type) Returns a new query bound to the kind (a specific DBCollection)
<T> Query<T>	createQuery(Class<T> type, com.mongodb.DBObject q)
<T> Query<T>	createQuery(String kind, Class<T> type)
<T> Query<T>	createQuery(String kind, Class<T> type, com.mongodb.DBObject q)
<T,V> com.mongodb.DBRef	createRef(Class<T> clazz, V id) Creates a reference to the entity (using the current DB -can be null-, the collectionName, and id)
<T> com.mongodb.DBRef	createRef(T entity) Creates a reference to the entity (using the current DB -can be null-, the collectionName, and id)
<T> UpdateOperations<T>	createUpdateOperations(Class<T> clazz) The builder for all update operations
<T> UpdateOperations<T>	createUpdateOperations(Class<T> kind, com.mongodb.DBObject ops)
<T,V> com.mongodb.WriteResult	delete(Class<T> clazz, Iterable<V> ids) Deletes the given entities (by id)
<T,V> com.mongodb.WriteResult	delete(Class<T> clazz, V id) Deletes the given entity (by id)
<T,V> com.mongodb.WriteResult	delete(Class<T> clazz, V id, com.mongodb.WriteConcern wc)
<T> com.mongodb.WriteResult	delete(Query<T> query) Deletes the given entities based on the query
<T> com.mongodb.WriteResult	delete(Query<T> query, com.mongodb.WriteConcern wc) Deletes the given entities based on the query, with the WriteConcern
<T,V> com.mongodb.WriteResult	delete(String kind, Class<T> clazz, V id)
<T,V> com.mongodb.WriteResult	delete(String kind, Class<T> clazz, V id, com.mongodb.WriteConcern wc)
<T> com.mongodb.WriteResult	delete(String kind, T id) No validation or conversion is done to the id
<T> com.mongodb.WriteResult	delete(T entity) Deletes the given entity (by @Id)
<T> com.mongodb.WriteResult	delete(T entity, com.mongodb.WriteConcern wc) Deletes the given entity (by @Id), with the WriteConcern
void	ensureCaps() ensure capped DBCollections for Entity(s)
<T> void	ensureIndex(Class<T> type, boolean background, IndexFieldDef... fields)
<T> void	ensureIndex(Class<T> type, IndexFieldDef... fields) Ensures (creating if necessary) the index including the field(s) + directions
<T> void	ensureIndex(Class<T> type, String fields) Ensures (creating if necessary) the index including the field(s) + directions; eg fields = "field1, -field2" ({field1:1, field2:-1})
<T> void	ensureIndex(Class<T> type, String name, IndexDirection dir) Ensures (creating if necessary) the index and direction
<T> void	ensureIndex(Class<T> clazz, String name, IndexFieldDef[] definitions, boolean unique, boolean dropDupsOnCreate) Deprecated. IndexFieldDef is deprecated
<T> void	ensureIndex(Class<T> clazz, String name, String fields, boolean unique, boolean dropDupsOnCreate) Ensures (creating if necessary) the index including the field(s) + directions; eg fields = "field1, -field2" ({field1:1, field2:-1})
<T> void	ensureIndex(Class<T> clazz, String name, String fields, boolean unique, boolean dropDupsOnCreate, boolean background)
void	ensureIndex(Class clazz, String name, IndexFieldDef[] definitions, boolean unique, boolean dropDupsOnCreate, boolean background) Deprecated. IndexFieldDef is deprecated
void	ensureIndexes() Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes)
void	ensureIndexes(boolean background) Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes), possibly in the background
<T> void	ensureIndexes(Class<T> clazz) Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes)
<T> void	ensureIndexes(Class<T> clazz, boolean background) Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes), possibly in the background
Key<?>	exists(Object entityOrKey) Does a query to check if the keyOrEntity exists in mongodb
Key<?>	exists(Object entityOrKey, com.mongodb.ReadPreference readPreference)
<T> Query<T>	find(Class<T> clazz) Find all instances by type
<T,V> Query<T>	find(Class<T> clazz, String property, V value) Find all instances by collectionName, and filter property.
<T,V> Query<T>	find(Class<T> clazz, String property, V value, int offset, int size) Find all instances by collectionName, and filter property.
<T> Query<T>	find(String kind, Class<T> clazz)
<T,V> Query<T>	find(String kind, Class<T> clazz, String property, V value, int offset, int size)
<T,V> Query<T>	find(String kind, Class<T> clazz, String property, V value, int offset, int size, boolean validate)
<T> T	findAndDelete(Query<T> qi) Deletes the given entities based on the query (first item only).
<T> T	findAndModify(Query<T> q, UpdateOperations<T> ops) Find the first Entity from the Query, and modify it.
<T> T	findAndModify(Query<T> query, UpdateOperations<T> ops, boolean oldVersion) Find the first Entity from the Query, and modify it.
<T> T	findAndModify(Query<T> qi, UpdateOperations<T> ops, boolean oldVersion, boolean createIfMissing) Find the first Entity from the Query, and modify it.
<T> T	get(Class<T> clazz, com.mongodb.DBRef ref) Find the given entity (by collectionName/id);
<T,V> Query<T>	get(Class<T> clazz, Iterable<V> ids) Find the given entities (by id); shorthand for find("_id in", ids)
<T,V> T	get(Class<T> clazz, V id) Find the given entity (by id); shorthand for find("_id ", id)
<T,V> T	get(String kind, Class<T> clazz, V id)
<T> T	get(T entity) Find the given entity (by collectionName/id); think of this as refresh
<T> T	getByKey(Class<T> clazz, Key<T> key) Find the given entity (by collectionName/id);
<T> List<T>	getByKeys(Class<T> clazz, Iterable<Key<T>> keys) Find the given entities (by id), verifying they are of the correct type; shorthand for find("_id in", ids)
<T> List<T>	getByKeys(Iterable<Key<T>> keys) Find the given entities (by id); shorthand for find("_id in", ids)
com.mongodb.DBCollection	getCollection(Class clazz)
com.mongodb.DBCollection	getCollection(Object obj)
<T> long	getCount(Class<T> clazz) Gets the count this kind (DBCollection)
<T> long	getCount(Query<T> query) Gets the count of items returned by this query; same as query.countAll()
long	getCount(String kind) Gets the count this kind
<T> long	getCount(T entity) Gets the count this kind (DBCollection)
com.mongodb.DB	getDB()
com.mongodb.DBDecoderFactory	getDecoderFact()
com.mongodb.WriteConcern	getDefaultWriteConcern()
<T> Key<T>	getKey(T entity) Deprecated.
<T> List<Key<T>>	getKeysByRefs(List<com.mongodb.DBRef> refs) Queries the server to check for each DBRef
Mapper	getMapper()
com.mongodb.Mongo	getMongo()
QueryFactory	getQueryFactory() Returns the current QueryFactory.
com.mongodb.WriteConcern	getWriteConcern(Object clazzOrEntity) Gets the write concern for entity or returns the default write concern for this datastore
<T> Iterable<Key<T>>	insert(Iterable<T> entities)
<T> Iterable<Key<T>>	insert(Iterable<T> entities, com.mongodb.WriteConcern wc)
<T> Iterable<Key<T>>	insert(String kind, Iterable<T> entities)
<T> Iterable<Key<T>>	insert(String kind, Iterable<T> entities, com.mongodb.WriteConcern wc)
<T> Key<T>	insert(String kind, T entity)
<T> Key<T>	insert(String kind, T entity, com.mongodb.WriteConcern wc)
<T> Iterable<Key<T>>	insert(T... entities)
<T> Key<T>	insert(T entity)
<T> Key<T>	insert(T entity, com.mongodb.WriteConcern wc)
static <T> List<com.mongodb.DBRef>	keysAsRefs(List<Key<T>> keys, Mapper mapper) Converts a list of keys to refs
<T> MapreduceResults<T>	mapReduce(MapreduceType type, Query query, Class<T> outputType, com.mongodb.MapReduceCommand baseCommand) Runs a map/reduce job at the server; this should be used with a server version 1.7.4 or higher
<T> MapreduceResults<T>	mapReduce(MapreduceType type, Query query, String map, String reduce, String finalize, Map<String,Object> scopeFields, Class<T> outputType) Runs a map/reduce job at the server; this should be used with a server version 1.7.4 or higher
<T> Key<T>	merge(T entity) Work as if you did an update with each field in the entity doing a $set; Only at the top level of the entity.
<T> Key<T>	merge(T entity, com.mongodb.WriteConcern wc) Work as if you did an update with each field in the entity doing a $set; Only at the top level of the entity.
<T> Query<T>	queryByExample(String kind, T ex) Returns a new query based on the example object
<T> Query<T>	queryByExample(T ex) Returns a new query based on the example object
static <T> List<Key<T>>	refsToKeys(Mapper mapper, List<com.mongodb.DBRef> refs, Class<T> c) Converts a list of refs to keys
<T> Iterable<Key<T>>	save(Iterable<T> entities) Saves the entities (Objects) and updates the @Id field
<T> Iterable<Key<T>>	save(Iterable<T> entities, com.mongodb.WriteConcern wc) Saves the entities (Objects) and updates the @Id field, with the WriteConcern
<T> Key<T>	save(String kind, T entity)
<T> Key<T>	save(String kind, T entity, com.mongodb.WriteConcern wc)
<T> Iterable<Key<T>>	save(T... entities) Saves the entities (Objects) and updates the @Id field
<T> Key<T>	save(T entity) Saves the entity (Object) and updates the @Id field
<T> Key<T>	save(T entity, com.mongodb.WriteConcern wc) Saves the entity (Object) and updates the @Id field, with the WriteConcern
com.mongodb.DBDecoderFactory	setDecoderFact(com.mongodb.DBDecoderFactory fact)
void	setDefaultWriteConcern(com.mongodb.WriteConcern wc)
void	setQueryFactory(QueryFactory queryFactory) Replaces the current QueryFactory with the given value.
<T> UpdateResults<T>	update(Key<T> key, UpdateOperations<T> ops) updates the entity with the operations; this is an atomic operation
<T> UpdateResults<T>	update(Query<T> query, UpdateOperations<T> ops) updates all entities found with the operations; this is an atomic operation per entity
<T> UpdateResults<T>	update(Query<T> query, UpdateOperations<T> ops, boolean createIfMissing) updates all entities found with the operations, if nothing is found insert the update as an entity if "createIfMissing" is true; this is an atomic operation per entity
<T> UpdateResults<T>	update(Query<T> query, UpdateOperations<T> ops, boolean createIfMissing, com.mongodb.WriteConcern wc)
<T> UpdateResults<T>	update(T ent, UpdateOperations<T> ops) updates the entity with the operations; this is an atomic operation
<T> UpdateResults<T>	updateFirst(Query<T> query, T entity, boolean createIfMissing) updates the first entity found with the operations, if nothing is found insert the update as an entity if "createIfMissing" is true; this is an atomic operation per entity
<T> UpdateResults<T>	updateFirst(Query<T> query, UpdateOperations<T> ops) updates the first entity found with the operations; this is an atomic operation
<T> UpdateResults<T>	updateFirst(Query<T> query, UpdateOperations<T> ops, boolean createIfMissing) updates the first entity found with the operations, if nothing is found insert the update as an entity if "createIfMissing" is true; this is an atomic operation per entity
<T> UpdateResults<T>	updateFirst(Query<T> query, UpdateOperations<T> ops, boolean createIfMissing, com.mongodb.WriteConcern wc)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatastoreImpl

public DatastoreImpl(Mapper mapper,
                     com.mongodb.Mongo mongo,
                     String dbName)

DatastoreImpl

public DatastoreImpl(Morphia morphia,
                     com.mongodb.Mongo mongo)

DatastoreImpl

public DatastoreImpl(Morphia morphia,
                     com.mongodb.Mongo mongo,
                     String dbName,
                     String username,
                     char[] password)

Deprecated. Authentication is already handled by the Mongo instance

DatastoreImpl

public DatastoreImpl(Morphia morphia,
                     com.mongodb.Mongo mongo,
                     String dbName)

Method Detail

copy

public DatastoreImpl copy(String database)

createRef

public <T,V> com.mongodb.DBRef createRef(Class<T> clazz,
                                         V id)

Description copied from interface: AdvancedDatastore

Creates a reference to the entity (using the current DB -can be null-, the collectionName, and id)

Specified by:

createRef in interface AdvancedDatastore

createRef

public <T> com.mongodb.DBRef createRef(T entity)

Description copied from interface: AdvancedDatastore

Creates a reference to the entity (using the current DB -can be null-, the collectionName, and id)

Specified by:

createRef in interface AdvancedDatastore

getKey

@Deprecated
public <T> Key<T> getKey(T entity)

Deprecated.

Description copied from interface: Datastore

Creates a (type-safe) reference to the entity; if stored this will become a DBRef

Specified by:

getKey in interface Datastore

delete

public <T> com.mongodb.WriteResult delete(String kind,
                                          T id)

Description copied from interface: AdvancedDatastore

No validation or conversion is done to the id

Specified by:

delete in interface AdvancedDatastore

delete

public <T,V> com.mongodb.WriteResult delete(String kind,
                                            Class<T> clazz,
                                            V id)

Specified by:

delete in interface AdvancedDatastore

delete

public <T,V> com.mongodb.WriteResult delete(String kind,
                                            Class<T> clazz,
                                            V id,
                                            com.mongodb.WriteConcern wc)

Specified by:

delete in interface AdvancedDatastore

delete

public <T,V> com.mongodb.WriteResult delete(Class<T> clazz,
                                            V id)

Description copied from interface: Datastore

Deletes the given entity (by id)

Specified by:

delete in interface Datastore

delete

public <T,V> com.mongodb.WriteResult delete(Class<T> clazz,
                                            V id,
                                            com.mongodb.WriteConcern wc)

delete

public <T,V> com.mongodb.WriteResult delete(Class<T> clazz,
                                            Iterable<V> ids)

Description copied from interface: Datastore

Deletes the given entities (by id)

Specified by:

delete in interface Datastore

delete

public <T> com.mongodb.WriteResult delete(T entity)

Description copied from interface: Datastore

Deletes the given entity (by @Id)

Specified by:

delete in interface Datastore

delete

public <T> com.mongodb.WriteResult delete(T entity,
                                          com.mongodb.WriteConcern wc)

Description copied from interface: Datastore

Deletes the given entity (by @Id), with the WriteConcern

Specified by:

delete in interface Datastore

delete

public <T> com.mongodb.WriteResult delete(Query<T> query)

Description copied from interface: Datastore

Deletes the given entities based on the query

Specified by:

delete in interface Datastore

delete

public <T> com.mongodb.WriteResult delete(Query<T> query,
                                          com.mongodb.WriteConcern wc)

Description copied from interface: Datastore

Deletes the given entities based on the query, with the WriteConcern

Specified by:

delete in interface Datastore

ensureIndex

public <T> void ensureIndex(Class<T> type,
                            String fields)

Description copied from interface: Datastore

Ensures (creating if necessary) the index including the field(s) + directions; eg fields = "field1, -field2" ({field1:1, field2:-1})

Specified by:

ensureIndex in interface Datastore

ensureIndex

public <T> void ensureIndex(Class<T> clazz,
                            String name,
                            IndexFieldDef[] definitions,
                            boolean unique,
                            boolean dropDupsOnCreate)

Deprecated. IndexFieldDef is deprecated

Description copied from interface: Datastore

Ensures (creating if necessary) the index including the field(s) + directions

Specified by:

ensureIndex in interface Datastore

ensureIndex

public <T> void ensureIndex(Class<T> clazz,
                            String name,
                            String fields,
                            boolean unique,
                            boolean dropDupsOnCreate)

Description copied from interface: Datastore

Ensures (creating if necessary) the index including the field(s) + directions; eg fields = "field1, -field2" ({field1:1, field2:-1})

Specified by:

ensureIndex in interface Datastore

ensureIndex

public <T> void ensureIndex(Class<T> clazz,
                            String name,
                            String fields,
                            boolean unique,
                            boolean dropDupsOnCreate,
                            boolean background)

ensureIndex

public void ensureIndex(Class clazz,
                        String name,
                        IndexFieldDef[] definitions,
                        boolean unique,
                        boolean dropDupsOnCreate,
                        boolean background)

Deprecated. IndexFieldDef is deprecated

ensureIndex

public <T> void ensureIndex(Class<T> type,
                            String name,
                            IndexDirection dir)

Description copied from interface: Datastore

Ensures (creating if necessary) the index and direction

Specified by:

ensureIndex in interface Datastore

ensureIndex

public <T> void ensureIndex(Class<T> type,
                            IndexFieldDef... fields)

Description copied from interface: Datastore

Ensures (creating if necessary) the index including the field(s) + directions

Specified by:

ensureIndex in interface Datastore

ensureIndex

public <T> void ensureIndex(Class<T> type,
                            boolean background,
                            IndexFieldDef... fields)

ensureIndexes

public <T> void ensureIndexes(Class<T> clazz)

Description copied from interface: Datastore

Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes)

Specified by:

ensureIndexes in interface Datastore

ensureIndexes

public <T> void ensureIndexes(Class<T> clazz,
                              boolean background)

Description copied from interface: Datastore

Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes), possibly in the background

Specified by:

ensureIndexes in interface Datastore

ensureIndexes

public void ensureIndexes()

Description copied from interface: Datastore

Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes)

Specified by:

ensureIndexes in interface Datastore

ensureIndexes

public void ensureIndexes(boolean background)

Description copied from interface: Datastore

Ensures (creating if necessary) the indexes found during class mapping (using @Indexed, @Indexes), possibly in the background

Specified by:

ensureIndexes in interface Datastore

ensureCaps

public void ensureCaps()

Description copied from interface: Datastore

ensure capped DBCollections for Entity(s)

Specified by:

ensureCaps in interface Datastore

queryByExample

public <T> Query<T> queryByExample(T ex)

Description copied from interface: Datastore

Returns a new query based on the example object

Specified by:

queryByExample in interface Datastore

queryByExample

public <T> Query<T> queryByExample(String kind,
                                   T ex)

Description copied from interface: AdvancedDatastore

Returns a new query based on the example object

Specified by:

queryByExample in interface AdvancedDatastore

createQuery

public <T> Query<T> createQuery(Class<T> type)

Description copied from interface: Datastore

Returns a new query bound to the kind (a specific DBCollection)

Specified by:

createQuery in interface Datastore

createQuery

public <T> Query<T> createQuery(String kind,
                                Class<T> type)

Specified by:

createQuery in interface AdvancedDatastore

createQuery

public <T> Query<T> createQuery(Class<T> type,
                                com.mongodb.DBObject q)

Specified by:

createQuery in interface AdvancedDatastore

createQuery

public <T> Query<T> createQuery(String kind,
                                Class<T> type,
                                com.mongodb.DBObject q)

Specified by:

createQuery in interface AdvancedDatastore

find

public <T> Query<T> find(String kind,
                         Class<T> clazz)

Specified by:

find in interface AdvancedDatastore

find

public <T> Query<T> find(Class<T> clazz)

Description copied from interface: Datastore

Find all instances by type

Specified by:

find in interface Datastore

find

public <T,V> Query<T> find(Class<T> clazz,
                           String property,
                           V value)

Description copied from interface: Datastore

Find all instances by collectionName, and filter property.

This is the same as: find(clazzOrEntity).filter(property, value);

Specified by:

find in interface Datastore

find

public <T,V> Query<T> find(String kind,
                           Class<T> clazz,
                           String property,
                           V value,
                           int offset,
                           int size)

Specified by:

find in interface AdvancedDatastore

find

public <T,V> Query<T> find(String kind,
                           Class<T> clazz,
                           String property,
                           V value,
                           int offset,
                           int size,
                           boolean validate)

find

public <T,V> Query<T> find(Class<T> clazz,
                           String property,
                           V value,
                           int offset,
                           int size)

Description copied from interface: Datastore

Find all instances by collectionName, and filter property.

This is the same as: find(clazzOrEntity).filter(property, value).offset(offset).limit(size);

Specified by:

find in interface Datastore

get

public <T> T get(Class<T> clazz,
                 com.mongodb.DBRef ref)

Description copied from interface: AdvancedDatastore

Find the given entity (by collectionName/id);

Specified by:

get in interface AdvancedDatastore

get

public <T,V> Query<T> get(Class<T> clazz,
                          Iterable<V> ids)

Description copied from interface: Datastore

Find the given entities (by id); shorthand for find("_id in", ids)

Specified by:

get in interface Datastore

getKeysByRefs

public <T> List<Key<T>> getKeysByRefs(List<com.mongodb.DBRef> refs)

Queries the server to check for each DBRef

getByKeys

public <T> List<T> getByKeys(Iterable<Key<T>> keys)

Description copied from interface: Datastore

Find the given entities (by id); shorthand for find("_id in", ids)

Specified by:

getByKeys in interface Datastore

getByKeys

public <T> List<T> getByKeys(Class<T> clazz,
                             Iterable<Key<T>> keys)

Description copied from interface: Datastore

Find the given entities (by id), verifying they are of the correct type; shorthand for find("_id in", ids)

Specified by:

getByKeys in interface Datastore

get

public <T,V> T get(String kind,
                   Class<T> clazz,
                   V id)

Specified by:

get in interface AdvancedDatastore

get

public <T,V> T get(Class<T> clazz,
                   V id)

Description copied from interface: Datastore

Find the given entity (by id); shorthand for find("_id ", id)

Specified by:

get in interface Datastore

getByKey

public <T> T getByKey(Class<T> clazz,
                      Key<T> key)

Description copied from interface: Datastore

Find the given entity (by collectionName/id);

Specified by:

getByKey in interface Datastore

get

public <T> T get(T entity)

Description copied from interface: Datastore

Find the given entity (by collectionName/id); think of this as refresh

Specified by:

get in interface Datastore

exists

public Key<?> exists(Object entityOrKey)

Description copied from interface: Datastore

Does a query to check if the keyOrEntity exists in mongodb

Specified by:

exists in interface Datastore

exists

public Key<?> exists(Object entityOrKey,
                     com.mongodb.ReadPreference readPreference)

Specified by:

exists in interface AdvancedDatastore

readPreference - Uses the supplied ReadPreference for the check. If readPreference is null the preference is taken from the annotation or uses the default preference.

See Also:

Datastore.exists(Object)

getCollection

public com.mongodb.DBCollection getCollection(Class clazz)

Specified by:

getCollection in interface Datastore

getCollection

public com.mongodb.DBCollection getCollection(Object obj)

getCount

public <T> long getCount(T entity)

Description copied from interface: Datastore

Gets the count this kind (DBCollection)

Specified by:

getCount in interface Datastore

getCount

public <T> long getCount(Class<T> clazz)

Description copied from interface: Datastore

Gets the count this kind (DBCollection)

Specified by:

getCount in interface Datastore

getCount

public long getCount(String kind)

Description copied from interface: AdvancedDatastore

Gets the count this kind

Specified by:

getCount in interface AdvancedDatastore

getCount

public <T> long getCount(Query<T> query)

Description copied from interface: Datastore

Gets the count of items returned by this query; same as query.countAll()

Specified by:

getCount in interface Datastore

getMongo

public com.mongodb.Mongo getMongo()

Specified by:

getMongo in interface Datastore

getDB

public com.mongodb.DB getDB()

Specified by:

getDB in interface Datastore

getMapper

public Mapper getMapper()

insert

public <T> Iterable<Key<T>> insert(Iterable<T> entities)

insert

public <T> Iterable<Key<T>> insert(String kind,
                                   Iterable<T> entities,
                                   com.mongodb.WriteConcern wc)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Iterable<Key<T>> insert(String kind,
                                   Iterable<T> entities)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Iterable<Key<T>> insert(Iterable<T> entities,
                                   com.mongodb.WriteConcern wc)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Iterable<Key<T>> insert(T... entities)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Key<T> insert(T entity)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Key<T> insert(T entity,
                         com.mongodb.WriteConcern wc)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Key<T> insert(String kind,
                         T entity)

Specified by:

insert in interface AdvancedDatastore

insert

public <T> Key<T> insert(String kind,
                         T entity,
                         com.mongodb.WriteConcern wc)

save

public <T> Iterable<Key<T>> save(Iterable<T> entities)

Description copied from interface: Datastore

Saves the entities (Objects) and updates the @Id field

Specified by:

save in interface Datastore

save

public <T> Iterable<Key<T>> save(Iterable<T> entities,
                                 com.mongodb.WriteConcern wc)

Description copied from interface: Datastore

Saves the entities (Objects) and updates the @Id field, with the WriteConcern

Specified by:

save in interface Datastore

save

public <T> Iterable<Key<T>> save(T... entities)

Description copied from interface: Datastore

Saves the entities (Objects) and updates the @Id field

Specified by:

save in interface Datastore

save

public <T> Key<T> save(T entity)

Description copied from interface: Datastore

Saves the entity (Object) and updates the @Id field

Specified by:

save in interface Datastore

save

public <T> Key<T> save(String kind,
                       T entity)

Specified by:

save in interface AdvancedDatastore

save

public <T> Key<T> save(String kind,
                       T entity,
                       com.mongodb.WriteConcern wc)

Specified by:

save in interface AdvancedDatastore

save

public <T> Key<T> save(T entity,
                       com.mongodb.WriteConcern wc)

Description copied from interface: Datastore

Saves the entity (Object) and updates the @Id field, with the WriteConcern

Specified by:

save in interface Datastore

createUpdateOperations

public <T> UpdateOperations<T> createUpdateOperations(Class<T> clazz)

Description copied from interface: Datastore

The builder for all update operations

Specified by:

createUpdateOperations in interface Datastore

createUpdateOperations

public <T> UpdateOperations<T> createUpdateOperations(Class<T> kind,
                                                      com.mongodb.DBObject ops)

Specified by:

createUpdateOperations in interface AdvancedDatastore

update

public <T> UpdateResults<T> update(Query<T> query,
                                   UpdateOperations<T> ops,
                                   boolean createIfMissing)

Description copied from interface: Datastore

updates all entities found with the operations, if nothing is found insert the update as an entity if "createIfMissing" is true; this is an atomic operation per entity

Specified by:

update in interface Datastore

update

public <T> UpdateResults<T> update(Query<T> query,
                                   UpdateOperations<T> ops,
                                   boolean createIfMissing,
                                   com.mongodb.WriteConcern wc)

Specified by:

update in interface Datastore

update

public <T> UpdateResults<T> update(T ent,
                                   UpdateOperations<T> ops)

Description copied from interface: Datastore

updates the entity with the operations; this is an atomic operation

Specified by:

update in interface Datastore

update

public <T> UpdateResults<T> update(Key<T> key,
                                   UpdateOperations<T> ops)

Description copied from interface: Datastore

updates the entity with the operations; this is an atomic operation

Specified by:

update in interface Datastore

update

public <T> UpdateResults<T> update(Query<T> query,
                                   UpdateOperations<T> ops)

Description copied from interface: Datastore

updates all entities found with the operations; this is an atomic operation per entity

Specified by:

update in interface Datastore

updateFirst

public <T> UpdateResults<T> updateFirst(Query<T> query,
                                        UpdateOperations<T> ops)

Description copied from interface: Datastore

updates the first entity found with the operations; this is an atomic operation

Specified by:

updateFirst in interface Datastore

updateFirst

public <T> UpdateResults<T> updateFirst(Query<T> query,
                                        UpdateOperations<T> ops,
                                        boolean createIfMissing)

Description copied from interface: Datastore

updates the first entity found with the operations, if nothing is found insert the update as an entity if "createIfMissing" is true; this is an atomic operation per entity

Specified by:

updateFirst in interface Datastore

updateFirst

public <T> UpdateResults<T> updateFirst(Query<T> query,
                                        UpdateOperations<T> ops,
                                        boolean createIfMissing,
                                        com.mongodb.WriteConcern wc)

Specified by:

updateFirst in interface Datastore

updateFirst

public <T> UpdateResults<T> updateFirst(Query<T> query,
                                        T entity,
                                        boolean createIfMissing)

Description copied from interface: Datastore

updates the first entity found with the operations, if nothing is found insert the update as an entity if "createIfMissing" is true; this is an atomic operation per entity

Specified by:

updateFirst in interface Datastore

merge

public <T> Key<T> merge(T entity)

Description copied from interface: Datastore

Work as if you did an update with each field in the entity doing a $set; Only at the top level of the entity.

Specified by:

merge in interface Datastore

merge

public <T> Key<T> merge(T entity,
                        com.mongodb.WriteConcern wc)

Description copied from interface: Datastore

Work as if you did an update with each field in the entity doing a $set; Only at the top level of the entity.

Specified by:

merge in interface Datastore

findAndDelete

public <T> T findAndDelete(Query<T> qi)

Description copied from interface: Datastore

Deletes the given entities based on the query (first item only).

Specified by:

findAndDelete in interface Datastore

Returns:

the deleted Entity

findAndModify

public <T> T findAndModify(Query<T> q,
                           UpdateOperations<T> ops)

Description copied from interface: Datastore

Find the first Entity from the Query, and modify it.

Specified by:

findAndModify in interface Datastore

Returns:

The modified Entity (the result of the update)

findAndModify

public <T> T findAndModify(Query<T> query,
                           UpdateOperations<T> ops,
                           boolean oldVersion)

Description copied from interface: Datastore

Find the first Entity from the Query, and modify it.

Specified by:

findAndModify in interface Datastore

Parameters:

query - the query to find the Entity with; You are not allowed to offset/skip in the query.

oldVersion - indicated the old version of the Entity should be returned

Returns:

The Entity (the result of the update if oldVersion is false)

findAndModify

public <T> T findAndModify(Query<T> qi,
                           UpdateOperations<T> ops,
                           boolean oldVersion,
                           boolean createIfMissing)

Description copied from interface: Datastore

Find the first Entity from the Query, and modify it.

Specified by:

findAndModify in interface Datastore

Parameters:

qi - the query to find the Entity with; You are not allowed to offset/skip in the query.

oldVersion - indicated the old version of the Entity should be returned

createIfMissing - if the query returns no results, then a new object will be created (sets upsert=true)

Returns:

The Entity (the result of the update if oldVersion is false)

mapReduce

public <T> MapreduceResults<T> mapReduce(MapreduceType type,
                                         Query query,
                                         Class<T> outputType,
                                         com.mongodb.MapReduceCommand baseCommand)

Description copied from interface: Datastore

Runs a map/reduce job at the server; this should be used with a server version 1.7.4 or higher

Specified by:

mapReduce in interface Datastore

Type Parameters:

T - The type of resulting data

Parameters:

type - MapreduceType

query - The query (only the criteria, limit and sort will be used)

outputType - The type of resulting data; inline is not working yet

baseCommand - The base command to fill in and send to the server

Returns:

counts and stuff

mapReduce

public <T> MapreduceResults<T> mapReduce(MapreduceType type,
                                         Query query,
                                         String map,
                                         String reduce,
                                         String finalize,
                                         Map<String,Object> scopeFields,
                                         Class<T> outputType)

Description copied from interface: Datastore

Runs a map/reduce job at the server; this should be used with a server version 1.7.4 or higher

Specified by:

mapReduce in interface Datastore

Type Parameters:

T - The type of resulting data

Parameters:

type - MapreduceType

query - The query (only the criteria, limit and sort will be used)

map - The map function, in javascript, as a string

reduce - The reduce function, in javascript, as a string

finalize - The finalize function, in javascript, as a string; can be null

scopeFields - Each map entry will be a global variable in all the functions; can be null

outputType - The type of resulting data; inline is not working yet

Returns:

counts and stuff

keysAsRefs

public static <T> List<com.mongodb.DBRef> keysAsRefs(List<Key<T>> keys,
                                                     Mapper mapper)

Converts a list of keys to refs

refsToKeys

public static <T> List<Key<T>> refsToKeys(Mapper mapper,
                                          List<com.mongodb.DBRef> refs,
                                          Class<T> c)

Converts a list of refs to keys

getWriteConcern

public com.mongodb.WriteConcern getWriteConcern(Object clazzOrEntity)

Gets the write concern for entity or returns the default write concern for this datastore

getDefaultWriteConcern

public com.mongodb.WriteConcern getDefaultWriteConcern()

Specified by:

getDefaultWriteConcern in interface Datastore

setDefaultWriteConcern

public void setDefaultWriteConcern(com.mongodb.WriteConcern wc)

Specified by:

setDefaultWriteConcern in interface Datastore

setDecoderFact

public com.mongodb.DBDecoderFactory setDecoderFact(com.mongodb.DBDecoderFactory fact)

Specified by:

setDecoderFact in interface AdvancedDatastore

getDecoderFact

public com.mongodb.DBDecoderFactory getDecoderFact()

Specified by:

getDecoderFact in interface AdvancedDatastore

setQueryFactory

public void setQueryFactory(QueryFactory queryFactory)

Description copied from interface: Datastore

Replaces the current QueryFactory with the given value.

Specified by:

setQueryFactory in interface Datastore

See Also:

QueryFactory

getQueryFactory

public QueryFactory getQueryFactory()

Description copied from interface: Datastore

Returns the current QueryFactory.

Specified by:

getQueryFactory in interface Datastore

See Also:

QueryFactory