本文整理了Java中com.impetus.kundera.query.QueryImpl
类的一些代码示例,展示了QueryImpl
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryImpl
类的具体详情如下:
包路径:com.impetus.kundera.query.QueryImpl
类名称:QueryImpl
[英]The Class QueryImpl.
[中]这个班的学生问。
代码示例来源:origin: Impetus/Kundera
log.info("On getResultList() executing query: " + getJPAQuery());
if (getEntityMetadata() == null)
executeUpdate();
results = populateEntities(null, client);
handlePostEvent();
executeUpdate();
results = fetch();
assignReferenceToProxy(results);
代码示例来源:origin: Impetus/Kundera
@Override
public Query setMaxResults(int maxResult)
{
return super.setMaxResults(maxResult);
}
代码示例来源:origin: Impetus/Kundera
/**
* *********************** Methods from {@link Query} interface
* ******************************.
*
* @return the single result
*/
/* @see javax.persistence.Query#getSingleResult() */
/*
* (non-Javadoc)
*
* @see javax.persistence.Query#getSingleResult()
*/
@Override
public Object getSingleResult()
{
// to fetch a single result form database.
isSingleResult = true;
List results = getResultList();
isSingleResult = false;
return onReturnResults(results);
}
代码示例来源:origin: Impetus/Kundera
log.debug("Populating entities for Cassandra query {}.", ((QueryImpl) query).getJPAQuery());
m.getPersistenceUnit());
String queryString = appMetadata.getQuery(((QueryImpl) query).getJPAQuery());
MetadataUtils.useSecondryIndex(((ClientBase) client).getClientMetadata()));
Map<Boolean, List<IndexClause>> ixClause = query.prepareIndexClause(m, useInvertedIndex);
if (useInvertedIndex && !((QueryImpl) query).getKunderaQuery().getFilterClauseQueue().isEmpty())
query.getColumnList(m, metaModel, ((QueryImpl) query).getKunderaQuery().getResult(), null),
expressions, maxResult);
代码示例来源:origin: Impetus/Kundera
/**
* Validates if expected result class is matching with supplied one, else
* throws {@link IllegalArgumentException}
*
* @param <T>
* object type
* @param paramClass
* expected result class
* @param q
* query
* @return typed query instance.
*/
private <T> TypedQuery<T> onTypedQuery(Class<T> paramClass, Query q)
{
if (paramClass.equals(((QueryImpl) q).getKunderaQuery().getEntityClass()) || paramClass.equals(Object.class))
{
return new KunderaTypedQuery<T>(q);
}
throw new IllegalArgumentException("Mismatch in expected return type. Expected:" + paramClass
+ " But actual class is:" + ((QueryImpl) q).getKunderaQuery().getEntityClass());
}
代码示例来源:origin: Impetus/Kundera
/**
* Method to handle get/set Parameter supplied for native query.
*/
private void onNativeCondition()
{
ApplicationMetadata appMetadata = kunderaMetadata.getApplicationMetadata();
if (appMetadata.isNative(getJPAQuery()))
{
throw new IllegalStateException(
"invoked on a native query when the implementation does not support this use");
}
}
代码示例来源:origin: Impetus/Kundera
@Override
public int executeUpdate()
{
return super.executeUpdate();
}
代码示例来源:origin: Impetus/Kundera
String columnName = ((AbstractAttribute) entityType.getAttribute(idField)).getJPAColumnName();
List<Object> result = new ArrayList<Object>();
Queue queue = getKunderaQuery().getFilterClauseQueue();
KunderaQuery kunderaQuery = getKunderaQuery();
queue.clear();
queue.add(filterClause);
List<Object> object = findUsingLucene(m, client);
if (object != null && !object.isEmpty())
result.add(object.get(0));
代码示例来源:origin: Impetus/Kundera
@Override
public Query setFirstResult(int firstResult)
{
return super.setFirstResult(firstResult);
}
代码示例来源:origin: Impetus/Kundera
/**
* Sets the relational entities.
*
* @param enhanceEntities
* the enhance entities
* @param client
* the client
* @param m
* the m
*/
public void setRelationalEntities(List enhanceEntities, Client client, EntityMetadata m) {
super.setRelationEntities(enhanceEntities, client, m);
}
代码示例来源:origin: Impetus/Kundera
public List getResutList()
{
return super.getResultList();
}
代码示例来源:origin: com.impetus.client/kundera-cassandra
log.debug("Populating entities for Cassandra query {}.", ((QueryImpl) query).getJPAQuery());
m.getPersistenceUnit());
String queryString = appMetadata.getQuery(((QueryImpl) query).getJPAQuery());
: ((QueryImpl) query).getJPAQuery());
results = nativeQuery != null ? ((CassandraClientBase) client).executeQuery(m.getEntityClazz(), null,isNative,
nativeQuery) : null;
MetadataUtils.useSecondryIndex(((ClientBase) client).getClientMetadata()));
Map<Boolean, List<IndexClause>> ixClause = query.prepareIndexClause(m, useInvertedIndex);
if (useInvertedIndex && !((QueryImpl) query).getKunderaQuery().getFilterClauseQueue().isEmpty())
query.getColumnList(m, ((QueryImpl) query).getKunderaQuery().getResult(), null),
expressions, maxResult);
代码示例来源:origin: Impetus/Kundera
element.substring(element.indexOf("=") + 1, element.length()));
KunderaQuery kq = ((QueryImpl) q).getKunderaQuery();
Set<Parameter<?>> parameters = kq.getParameters();
for (String paramName : paramsMap.keySet()) {
代码示例来源:origin: Impetus/Kundera
/**
* Test create native query.
*/
@Test
public void testCreateNativeQuery()
{
EntityManager em = emf.createEntityManager();
String nativeSql = "Select * from Cassandra c";
QueryImpl q = (QueryImpl) em.createNativeQuery(nativeSql, CassandraEntitySample.class);
Assert.assertEquals(nativeSql, q.getJPAQuery());
}
代码示例来源:origin: Impetus/Kundera
@Override
public int executeUpdate()
{
return super.executeUpdate();
}
代码示例来源:origin: Impetus/Kundera
@Override
public Query setFirstResult(int firstResult)
{
return super.setFirstResult(firstResult);
}
代码示例来源:origin: com.impetus.client/kundera-cassandra
void setRelationalEntities(List enhanceEntities, Client client, EntityMetadata m)
{
super.setRelationEntities(enhanceEntities, client, m);
}
代码示例来源:origin: Impetus/Kundera
@Override
public Query setMaxResults(int maxResult)
{
return super.setMaxResults(maxResult);
}
代码示例来源:origin: Impetus/Kundera
boolean isDeleteOrUpdateQuery = ((QueryImpl) q).getKunderaQuery().isDeleteUpdate();
if (isDeleteOrUpdateQuery) {
log.error("Incorrect HTTP method GET for query:" + queryPart);
代码示例来源:origin: Impetus/Kundera
/**
* Test create native query.
*/
@Test
public void testCreateNativeQuery()
{
EntityManager em = emf.createEntityManager();
String nativeSql = "Select * from Cassandra c";
QueryImpl q = (QueryImpl) em.createNativeQuery(nativeSql, CassandraEntitySample.class);
Assert.assertEquals(nativeSql, q.getJPAQuery());
}
内容来源于网络,如有侵权,请联系作者删除!