org.apache.usergrid.persistence.Query.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(12.4k)|赞(0)|评价(0)|浏览(294)

本文整理了Java中org.apache.usergrid.persistence.Query.<init>方法的一些代码示例，展示了Query.<init>的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Query.<init>方法的具体详情如下：
包路径：org.apache.usergrid.persistence.Query
类名称：Query
方法名：<init>

Query.<init>介绍

[英]Creates a deep copy of a query from another query
[中]

代码示例

代码示例来源：origin: apache/usergrid

  1. private static Query newQueryIfNull( Query query ) {
  2.   if ( query == null ) {
  3.     query = new Query();
  4.   }
  5.   return query;
  6. }

代码示例来源：origin: apache/usergrid

  1. /**
  2.  * Create a query instance from the QL.  If the string is null, return an empty query
  3.  * @param ql
  4.  * @return
  5.  */
  6. public static Query fromQLNullSafe(final String ql){
  7.   final Query query = fromQL(ql);
  8.   if(query != null){
  9.     return query;
  10.   }
  11.   return new Query();
  12. }

代码示例来源：origin: apache/usergrid

  1. public static Query fromQL( String ql ) throws QueryParseException {
  2.   if ( StringUtils.isEmpty(ql) ) {
  3.     return null;
  4.   }
  5.   Query query = new Query(  );
  6.   query.setQl( ql );
  7.   return query;
  8. }
  9. public static Query all( ){

代码示例来源：origin: apache/usergrid

  1. public static List<ServiceParameter> addParameter( List<ServiceParameter> parameters, String name ) {
  2.   if ( parameters == null ) {
  3.     parameters = new ArrayList<ServiceParameter>();
  4.   }
  5.   if ( name == null ) {
  6.     return parameters;
  7.   }
  8.   if ( "all".equals( name ) ) {
  9.     Query query = new Query();
  10.     ServiceParameter p = new QueryParameter( query );
  11.     parameters.add( p );
  12.     return parameters;
  13.   }
  14.   ServiceParameter p = new NameParameter( name );
  15.   parameters.add( p );
  16.   return parameters;
  17. }

代码示例来源：origin: apache/usergrid

  1. public static Query fromUUID( UUID uuid ) {
  2.   Query q = new Query();
  3.   q.addIdentifier( Identifier.fromUUID( uuid ) );
  4.   return q;
  5. }

代码示例来源：origin: apache/usergrid

  1. public static Query fromIdentifier( Object id ) {
  2.   if (id == null) {
  3.     throw new IllegalArgumentException("null identifier passed in");
  4.   }
  5.   Identifier objectIdentifier = Identifier.from(id);
  6.   if (objectIdentifier == null) {
  7.     throw new IllegalArgumentException("Supplied id results in null Identifier");
  8.   }
  9.   Query q = new Query();
  10.   q.addIdentifier( Identifier.from(id) );
  11.   return q;
  12. }

代码示例来源：origin: apache/usergrid

  1. @Override
  2. public Results getTargetEntities( String connectionType, String connectedEntityType, Level level )
  3.   throws Exception {
  4.   //until this is refactored properly, we will delegate to a search by query
  5.   Results raw = null;
  6.   Preconditions.checkNotNull( connectionType, "connectionType cannot be null" );
  7.   Query query = new Query();
  8.   query.setConnectionType( connectionType );
  9.   query.setEntityType( connectedEntityType );
  10.   query.setResultsLevel( level );
  11.   return searchTargetEntities( query );
  12. }

代码示例来源：origin: apache/usergrid

  1. @Override
  2. public ServiceResults getCollection( ServiceContext context ) throws Exception {
  3.   checkPermissionsForCollection( context );
  4.   if ( getCollectionSort( context ) != null ) {
  5.     return getItemsByQuery( context, new Query() );
  6.   }
  7.   if (logger.isTraceEnabled()) {
  8.     logger.trace("Limiting collection to {}", Query.DEFAULT_LIMIT);
  9.   }
  10.   int count = Query.DEFAULT_LIMIT;
  11.   Results r = em.getCollection( context.getOwner(), context.getCollectionName(),
  12.     null, count, Level.ALL_PROPERTIES, isCollectionReversed( context ) );
  13.   importEntities( context, r );
  14. /*
  15.  * if (r.isEmpty()) { throw new ServiceResourceNotFoundException(request); }
  16.  */
  17.   return new ServiceResults( this, context, Type.COLLECTION, r, null, null );
  18. }

代码示例来源：origin: apache/usergrid

  1. @Override
  2. public Results queryJobData( Query query ) throws Exception {
  3.   if ( query == null ) {
  4.     query = new Query();
  5.   }
  6.   String jobDataType = Schema.getDefaultSchema().getEntityType(JobData.class);
  7.   return getEm().searchCollection( getEm().getApplicationRef(),
  8.       Schema.defaultCollectionName(jobDataType), query );
  9. }

代码示例来源：origin: apache/usergrid

  1. protected List<EntityRef> getNotificationReceipts(EntityRef notification)
  2.     throws Exception {
  3.   Query query = new Query();
  4.   query.setCollection("receipts");
  5.   query.setLimit(100);
  6.   PathQuery<Receipt> pathQuery = new PathQuery<Receipt>(
  7.       new SimpleEntityRef(app.getEntityManager().getApplicationRef()),
  8.       query
  9.   );
  10.   Iterator<Receipt> it = pathQuery.iterator(app.getEntityManager());
  11.   List<EntityRef> list =new ArrayList<EntityRef>();//get all
  12.   while(it.hasNext()){
  13.     Receipt receipt =it.next();
  14.     if(receipt.getNotificationUUID().equals(notification.getUuid())) {
  15.       list.add(receipt);
  16.     }
  17.   }
  18.   return list;
  19. }

代码示例来源：origin: apache/usergrid

  1. @Test
  2. public void emptyQuery() throws Exception {
  3.   logger.debug( "emptyQuery" );
  4.   EntityManager em = app.getEntityManager();
  5.   assertNotNull( em );
  6.   String firstName = "firstName" + UUIDUtils.newTimeUUID();
  7.   Map<String, Object> properties = new LinkedHashMap<String, Object>();
  8.   properties.put( "username", "edanuff" );
  9.   properties.put( "email", "ed@anuff.com" );
  10.   properties.put( "firstname", firstName );
  11.   Entity user = em.create( "user", properties );
  12.   assertNotNull( user );
  13.   properties = new LinkedHashMap<String, Object>();
  14.   properties.put( "username", "djacobs" );
  15.   properties.put( "email", "djacobs@gmail.com" );
  16.   Entity user2 = em.create( "user", properties );
  17.   assertNotNull( user2 );
  18.   app.waitForQueueDrainAndRefreshIndex();
  19.   // EntityRef
  20.   Query query = new Query();
  21.   Results r = em.searchCollection( em.getApplicationRef(), "users", query );
  22.   assertEquals( 2, r.size() );
  23.   Entity returned = r.getEntities().get( 0 );
  24.   assertEquals( user2.getUuid(), returned.getUuid() );
  25.   returned = r.getEntities().get( 1 );
  26.   assertEquals( user.getUuid(), returned.getUuid() );
  27. }

代码示例来源：origin: apache/usergrid

  1. @Test
  2. public void emptyQueryReverse() throws Exception {
  3.   logger.debug( "emptyQueryReverse" );
  4.   EntityManager em = app.getEntityManager();
  5.   assertNotNull( em );
  6.   String firstName = "firstName" + UUIDUtils.newTimeUUID();
  7.   Map<String, Object> properties = new LinkedHashMap<String, Object>();
  8.   properties.put( "username", "edanuff" );
  9.   properties.put( "email", "ed@anuff.com" );
  10.   properties.put( "firstname", firstName );
  11.   Entity user = em.create( "user", properties );
  12.   assertNotNull( user );
  13.   properties = new LinkedHashMap<String, Object>();
  14.   properties.put( "username", "djacobs" );
  15.   properties.put( "email", "djacobs@gmail.com" );
  16.   Entity user2 = em.create( "user", properties );
  17.   assertNotNull( user2 );
  18.   app.waitForQueueDrainAndRefreshIndex();
  19.   // EntityRef
  20.   Query query = new Query();
  21.   query.setReversed( true );
  22.   Results r = em.searchCollection( em.getApplicationRef(), "users", query );
  23.   assertEquals( 2, r.size() );
  24.   Entity returned = r.getEntities().get( 0 );
  25.   assertEquals( user2.getUuid(), returned.getUuid() );
  26.   returned = r.getEntities().get( 1 );
  27.   assertEquals( user.getUuid(), returned.getUuid() );
  28. }

代码示例来源：origin: apache/usergrid

  1. protected Iterator refIterator(EntityManager em, boolean useGraph) throws Exception {
  2.   if ( query.getQl() == null && query.getSingleNameOrEmailIdentifier() != null){
  3.     return new PagingResultsIterator( getHeadResults( em ), Level.REFS, null);
  4.   }
  5.   if ( type != null  && uuid != null) {
  6.     return new PagingResultsIterator( getHeadResults( em ), Level.REFS, null);
  7.   }
  8.   else {
  9.     Query q = query;
  10.     if ( query.getResultsLevel() != Level.REFS ) { // ensure REFS level
  11.       q = new Query( q );
  12.       q.setResultsLevel( Level.REFS );
  13.     }
  14.     if( useGraph){
  15.       return new NotificationGraphIterator( em, source.refIterator( em, true), q );
  16.     }else{
  17.       return new MultiQueryIterator( em, source.refIterator( em, false ), q );
  18.     }
  19.   }
  20. }

代码示例来源：origin: apache/usergrid

  1. @Test
  2. public void nameIdentifierTest() throws Exception {
  3.   logger.debug( "nameIdentifierTest" );
  4.   EntityManager em = app.getEntityManager();
  5.   assertNotNull( em );
  6.   Map<String, Object> properties = new LinkedHashMap<String, Object>();
  7.   properties.put( "keywords", "blah,test,game" );
  8.   properties.put( "title", "Solitaire" );
  9.   properties.put( "name", "test" );
  10.   Entity game1 = em.create( "games", properties );
  11.   assertNotNull( game1 );
  12.   //we create 2 entities, otherwise this test will pass when it shouldn't
  13.   properties.put( "name", "test2" );
  14.   Entity game2 = em.create( "game", properties );
  15.   assertNotNull( game2 );
  16.   app.waitForQueueDrainAndRefreshIndex();
  17.   // overlap
  18.   Query query = new Query();
  19.   query.addIdentifier( Identifier.fromName( "test" ) );
  20.   Results r = em.searchCollection( em.getApplicationRef(), "games", query );
  21.   assertEquals( "We should only get 1 result", 1, r.size() );
  22.   assertNull( "No cursor should be present", r.getCursor() );
  23.   assertEquals( "Saved entity returned", game1, r.getEntity() );
  24. }

代码示例来源：origin: apache/usergrid

  1. /**
  2.  * Validate loaded entities for geo queries
  3.  * 1. load test entities
  4.  * 2. validate the size of the result
  5.  * 3. verify each entity has geo data
  6.  */
  7. @Test
  8. public void testGeolocationEntities() throws Exception {
  9.   //1. load test entities
  10.   EntityManager em = app.getEntityManager();
  11.   assertNotNull(em);
  12.   //2. load test entities
  13.   for (Map<String, Object> location : LOCATION_PROPERTIES) {
  14.     Entity entity = em.create("store", location);
  15.     assertNotNull(entity);
  16.     logger.debug("Entity {} created", entity.getProperty("name"));
  17.   }
  18.   app.waitForQueueDrainAndRefreshIndex();
  19.   //2. validate the size of the result
  20.   Query query = new Query();
  21.   Results listResults = em.searchCollection(em.getApplicationRef(), "stores", query);
  22.   assertEquals("total number of 'stores'", LOCATION_PROPERTIES.size(), listResults.size());
  23.   //3. verify each entity has geo data
  24.   for (Entity entity : listResults.entities) {
  25.     Map location =  (Map)entity.getProperty("location");
  26.     assertNotNull(location);
  27.     assertNotNull(location.get("longitude"));
  28.     assertNotNull(location.get("latitude"));
  29.   }
  30. }

代码示例来源：origin: apache/usergrid

  1. @Override
  2. public ServiceResults putItemsByQuery( ServiceContext context, Query query ) throws Exception {
  3.   checkPermissionsForCollection( context );
  4.   if ( context.moreParameters() ) {
  5.     return getItemsByQuery( context, query );
  6.   }
  7.   query = new Query( query );
  8.   query.setResultsLevel( Level.ALL_PROPERTIES );
  9.   query.setLimit( 1000 );
  10.   if ( !query.isReversedSet() ) {
  11.     query.setReversed( isCollectionReversed( context ) );
  12.   }
  13.   Results r = em.searchCollection( context.getOwner(), context.getCollectionName(), query );
  14.   if ( r.isEmpty() ) {
  15.     throw new ServiceResourceNotFoundException( context );
  16.   }
  17.   updateEntities( context, r );
  18.   return new ServiceResults( this, context, Type.COLLECTION, r, null, null );
  19. }

代码示例来源：origin: apache/usergrid

  1. @Test
  2. public void uuidIdentifierTest() throws Exception {
  3.   logger.debug( "uuidIdentifierTest" );
  4.   EntityManager em = app.getEntityManager();
  5.   assertNotNull( em );
  6.   Map<String, Object> properties = new LinkedHashMap<String, Object>();
  7.   properties.put( "keywords", "blah,test,game" );
  8.   properties.put( "title", "Solitaire" );
  9.   Entity game1 = em.create( "game", properties );
  10.   assertNotNull( game1 );
  11.   //we create 2 entities, otherwise this test will pass when it shouldn't
  12.   Entity game2 = em.create( "game", properties );
  13.   assertNotNull( game2 );
  14.   app.waitForQueueDrainAndRefreshIndex();
  15.   // overlap
  16.   Query query = new Query();
  17.   query.addIdentifier( Identifier.fromUUID( game1.getUuid() ) );
  18.   Results r = em.searchCollection( em.getApplicationRef(), "games", query );
  19.   assertEquals( "We should only get 1 result", 1, r.size() );
  20.   assertNull( "No cursor should be present", r.getCursor() );
  21.   assertEquals( "Saved entity returned", game1, r.getEntity() );
  22. }

代码示例来源：origin: apache/usergrid

  1. @Override
  2. public ServiceResults deleteItemsByQuery( ServiceContext context, Query query ) throws Exception {
  3.   checkPermissionsForCollection( context );
  4.   if ( context.moreParameters() ) {
  5.     return getItemsByQuery( context, query );
  6.   }
  7.   query = new Query( query );
  8.   query.setResultsLevel( Level.ALL_PROPERTIES );
  9.   query.setLimit( query.getLimit() );
  10.   if ( !query.isReversedSet() ) {
  11.     query.setReversed( isCollectionReversed( context ) );
  12.   }
  13.   Results r = em.searchCollection( context.getOwner(), context.getCollectionName(), query );
  14.   importEntities( context, r );
  15.   for ( Entity entity : r ) {
  16.     prepareToDelete( context, entity );
  17.   }
  18.   for ( Entity entity : r ) {
  19.     em.removeFromCollection( context.getOwner(), context.getCollectionName(), entity );
  20.   }
  21.   return new ServiceResults( this, context, Type.COLLECTION, r, null, null );
  22. }

代码示例来源：origin: apache/usergrid

  1. query = new Query( query );
  2. query.setResultsLevel( level );
  3. query.setLimit( query.getLimit( count ) );

代码示例来源：origin: apache/usergrid

  1. @Test
  2. public void emailIdentifierTest() throws Exception {
  3.   logger.debug( "emailIdentifierTest" );
  4.   EntityManager em = app.getEntityManager();
  5.   assertNotNull( em );
  6.   User user = new User();
  7.   user.setUsername( "foobar" );
  8.   user.setEmail( "foobar@usergrid.org" );
  9.   Entity createUser = em.create( user );
  10.   assertNotNull( createUser );
  11.   //we create 2 entities, otherwise this test will pass when it shouldn't
  12.   User user2 = new User();
  13.   user2.setUsername( "foobar2" );
  14.   user2.setEmail( "foobar2@usergrid.org" );
  15.   Entity createUser2 = em.create( user2 );
  16.   assertNotNull( createUser2 );
  17.   app.waitForQueueDrainAndRefreshIndex();
  18.   // overlap
  19.   Query query = new Query();
  20.   query.addIdentifier( Identifier.fromEmail( "foobar@usergrid.org" ) );
  21.   Results r = em.searchCollection( em.getApplicationRef(), "users", query );
  22.   assertEquals( "We should only get 1 result", 1, r.size() );
  23.   assertNull( "No cursor should be present", r.getCursor() );
  24.   assertEquals( "Saved entity returned", createUser, r.getEntity() );
  25. }

内容来源于网络，如有侵权，请联系作者删除！

query

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com