Package com.querydsl.mongodb

Class AbstractMongodbQuery<K,Q extends AbstractMongodbQuery<K,Q>>

java.lang.Object

com.querydsl.mongodb.AbstractMongodbQuery<K,Q>

Type Parameters:

K - result type

Q - concrete subtype

All Implemented Interfaces:

Fetchable<K>, FilteredClause<Q>, SimpleQuery<Q>

Direct Known Subclasses:

MorphiaQuery

public abstract class AbstractMongodbQuery<K,Q extends AbstractMongodbQuery<K,Q>>
extends java.lang.Object
implements SimpleQuery<Q>, Fetchable<K>

AbstractMongodbQuery provides a base class for general Querydsl query implementation with a pluggable DBObject to Bean transformation

Author:

laimw

Constructor Summary

Constructors

Constructor	Description
AbstractMongodbQuery(com.mongodb.DBCollection collection, java.util.function.Function<com.mongodb.DBObject,K> transformer, MongodbSerializer serializer)	Create a new MongodbQuery instance

Method Summary

Modifier and Type	Method	Description
<T> AnyEmbeddedBuilder<Q,K>	anyEmbedded(Path<? extends java.util.Collection<T>> collection, Path<T> target)	Define a constraint for an embedded object
com.mongodb.DBObject	asDBObject()	Get the where definition as a DBObject instance
protected com.mongodb.DBCursor	createCursor()
protected com.mongodb.DBCursor	createCursor(com.mongodb.DBCollection collection, @Nullable Predicate where, Expression<?> projection, QueryModifiers modifiers, java.util.List<OrderSpecifier<?>> orderBy)
protected @Nullable Predicate	createFilter(QueryMetadata metadata)
protected @Nullable Predicate	createJoinFilter(QueryMetadata metadata)
Q	distinct()
java.util.List<K>	fetch()
java.util.List<K>	fetch(Path<?>... paths)	Fetch with the specific fields
long	fetchCount()
K	fetchFirst()
K	fetchFirst(Path<?>... paths)	Fetch first with the specific fields
K	fetchOne()
K	fetchOne(Path<?>... paths)	Fetch one with the specific fields
QueryResults<K>	fetchResults()
QueryResults<K>	fetchResults(Path<?>... paths)	Fetch results with the specific fields
protected abstract com.mongodb.DBCollection	getCollection(java.lang.Class<?> type)
protected java.util.List<java.lang.Object>	getIds(java.lang.Class<?> targetType, Predicate condition)
com.mysema.commons.lang.CloseableIterator<K>	iterate()
com.mysema.commons.lang.CloseableIterator<K>	iterate(Path<?>... paths)	Iterate with the specific fields
<T> JoinBuilder<Q,K,T>	join(CollectionPathBase<?,T,?> ref, Path<T> target)	Define a join
<T> JoinBuilder<Q,K,T>	join(Path<T> ref, Path<T> target)	Define a join
Q	limit(long limit)
Q	offset(long offset)
Q	orderBy(OrderSpecifier<?> o)
Q	orderBy(OrderSpecifier<?>... o)
Q	restrict(QueryModifiers modifiers)
<T> Q	set(ParamExpression<T> param, T value)
void	setReadPreference(com.mongodb.ReadPreference readPreference)	Sets the read preference for this query
java.lang.String	toString()
Q	where(Predicate e)
Q	where(Predicate... e)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.querydsl.core.Fetchable

stream

Constructor Detail

AbstractMongodbQuery

public AbstractMongodbQuery(com.mongodb.DBCollection collection,
                            java.util.function.Function<com.mongodb.DBObject,K> transformer,
                            MongodbSerializer serializer)

Create a new MongodbQuery instance

Parameters:

collection - collection

transformer - result transformer

serializer - serializer

Method Detail

join

public <T> JoinBuilder<Q,K,T> join(Path<T> ref,
                                               Path<T> target)

Define a join

Parameters:

ref - reference

target - join target

Returns:

join builder

join

public <T> JoinBuilder<Q,K,T> join(CollectionPathBase<?,T,?> ref,
                                               Path<T> target)

Define a join

Parameters:

ref - reference

target - join target

Returns:

join builder

anyEmbedded

public <T> AnyEmbeddedBuilder<Q,K> anyEmbedded(Path<? extends java.util.Collection<T>> collection,
                                                     Path<T> target)

Define a constraint for an embedded object

Parameters:

collection - collection

target - target

Returns:

builder

getCollection

protected abstract com.mongodb.DBCollection getCollection(java.lang.Class<?> type)

createFilter

@Nullable
protected @Nullable Predicate createFilter(QueryMetadata metadata)

createJoinFilter

@Nullable
protected @Nullable Predicate createJoinFilter(QueryMetadata metadata)

getIds

protected java.util.List<java.lang.Object> getIds(java.lang.Class<?> targetType,
                                                  Predicate condition)

distinct

public Q distinct()

Specified by:

distinct in interface SimpleQuery<K>

where

public Q where(Predicate e)

where

public Q where(Predicate... e)

Specified by:

where in interface FilteredClause<K>

limit

public Q limit(long limit)

Specified by:

limit in interface SimpleQuery<K>

offset

public Q offset(long offset)

Specified by:

offset in interface SimpleQuery<K>

restrict

public Q restrict(QueryModifiers modifiers)

Specified by:

restrict in interface SimpleQuery<K>

orderBy

public Q orderBy(OrderSpecifier<?> o)

orderBy

public Q orderBy(OrderSpecifier<?>... o)

Specified by:

orderBy in interface SimpleQuery<K>

set

public <T> Q set(ParamExpression<T> param,
                 T value)

Specified by:

set in interface SimpleQuery<K>

iterate

public com.mysema.commons.lang.CloseableIterator<K> iterate(Path<?>... paths)

Iterate with the specific fields

Parameters:

paths - fields to return

Returns:

iterator

iterate

public com.mysema.commons.lang.CloseableIterator<K> iterate()

Specified by:

iterate in interface Fetchable<K>

fetch

public java.util.List<K> fetch(Path<?>... paths)

Fetch with the specific fields

Parameters:

paths - fields to return

Returns:

results

fetch

public java.util.List<K> fetch()

Specified by:

fetch in interface Fetchable<K>

createCursor

protected com.mongodb.DBCursor createCursor()

createCursor

protected com.mongodb.DBCursor createCursor(com.mongodb.DBCollection collection,
                                            @Nullable
                                            @Nullable Predicate where,
                                            Expression<?> projection,
                                            QueryModifiers modifiers,
                                            java.util.List<OrderSpecifier<?>> orderBy)

fetchFirst

public K fetchFirst(Path<?>... paths)

Fetch first with the specific fields

Parameters:

paths - fields to return

Returns:

first result

fetchFirst

public K fetchFirst()

Specified by:

fetchFirst in interface Fetchable<K>

fetchOne

public K fetchOne(Path<?>... paths)

Fetch one with the specific fields

Parameters:

paths - fields to return

Returns:

first result

fetchOne

public K fetchOne()
           throws NonUniqueResultException

Specified by:

fetchOne in interface Fetchable<K>

Throws:

NonUniqueResultException

fetchResults

public QueryResults<K> fetchResults(Path<?>... paths)

Fetch results with the specific fields

Parameters:

paths - fields to return

Returns:

results

fetchResults

public QueryResults<K> fetchResults()

Specified by:

fetchResults in interface Fetchable<K>

fetchCount

public long fetchCount()

Specified by:

fetchCount in interface Fetchable<K>

setReadPreference

public void setReadPreference(com.mongodb.ReadPreference readPreference)

Sets the read preference for this query

Parameters:

readPreference - read preference

asDBObject

public com.mongodb.DBObject asDBObject()

Get the where definition as a DBObject instance

Returns:

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object