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

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

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

Query.setEntityType介绍

暂无

代码示例

代码示例来源：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 Results getImports(final UUID applicationId, @Nullable final String ql, @Nullable final String cursor) {
  3.   Preconditions.checkNotNull(applicationId, "applicationId must be specified");
  4.   try {
  5.     final EntityManager rootEm = emf.getEntityManager(emf.getManagementAppId());
  6.     final Entity appInfo = getApplicationInfoEntity(rootEm, applicationId);
  7.     Query query = Query.fromQLNullSafe(ql);
  8.     query.setCursor(cursor);
  9.     //set our entity type
  10.     query.setEntityType(Schema.getDefaultSchema().getEntityType(Import.class));
  11.     return rootEm.searchCollection(appInfo, APP_IMPORT_CONNECTION, query);
  12.   } catch (Exception e) {
  13.     throw new RuntimeException("Unable to get import entity", e);
  14.   }
  15. }

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

  1. @Override
  2. public Results getFailedImportEntities(final UUID applicationId, final UUID importId, final UUID fileImportId,
  3.                     @Nullable final String ql, @Nullable final String cursor) {
  4.   Preconditions.checkNotNull(applicationId, "applicationId must be specified");
  5.   Preconditions.checkNotNull(importId, "importId must be specified");
  6.   Preconditions.checkNotNull(fileImportId, "fileImportId must be specified");
  7.   try {
  8.     final EntityManager rootEm = emf.getEntityManager(emf.getManagementAppId());
  9.     final FileImport importEntity = getFileImport(applicationId, importId, fileImportId);
  10.     Query query = Query.fromQLNullSafe(ql);
  11.     query.setCursor(cursor);
  12.     query.setConnectionType(FileImportTracker.ERRORS_CONNECTION_NAME);
  13.     query.setResultsLevel(Level.ALL_PROPERTIES);
  14.     //set our entity type
  15.     query.setEntityType(Schema.getDefaultSchema().getEntityType(FailedImportEntity.class));
  16.     return rootEm.searchTargetEntities(importEntity, query);
  17.   } catch (Exception e) {
  18.     throw new RuntimeException("Unable to get import entity", e);
  19.   }
  20. }

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

  1. @Override
  2. public Results getFileImports(final UUID applicationId, final UUID importId,
  3.                @Nullable final String ql, @Nullable final String cursor) {
  4.   Preconditions.checkNotNull(applicationId, "applicationId must be specified");
  5.   Preconditions.checkNotNull(importId, "importId must be specified");
  6.   try {
  7.     final EntityManager rootEm = emf.getEntityManager(emf.getManagementAppId());
  8.     final Import importEntity = getImport(applicationId, importId);
  9.     Query query = Query.fromQLNullSafe(ql);
  10.     query.setCursor(cursor);
  11.     query.setConnectionType(IMPORT_FILE_INCLUDES_CONNECTION);
  12.     query.setResultsLevel(Level.ALL_PROPERTIES);
  13.     //set our entity type
  14.     query.setEntityType(Schema.getDefaultSchema().getEntityType(FileImport.class));
  15.     return rootEm.searchTargetEntities(importEntity, query);
  16.   } catch (Exception e) {
  17.     throw new RuntimeException("Unable to get import entity", e);
  18.   }
  19. }

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

  1. private int getConnectionCount(final Import importRoot) {
  3.     try {
  5.       EntityManager rootEM = emf.getEntityManager(emf.getManagementAppId());
  6.       Query query = Query.fromQL("select *");
  7.       query.setEntityType("file_import");
  8.       query.setConnectionType(IMPORT_FILE_INCLUDES_CONNECTION);
  9.       query.setLimit(MAX_FILE_IMPORTS);
  11.       // TODO, this won't work with more than 100 files
  12.       Results entities = rootEM.searchTargetEntities(importRoot, query);
  13.       return entities.size();
  15.       // see ImportConnectsTest()
  16. //            Results entities = rootEM.getTargetEntities(
  17. //              importRoot, "includes", null, Level.ALL_PROPERTIES );
  18. //            PagingResultsIterator itr = new PagingResultsIterator( entities );
  19. //            int count = 0;
  20. //            while ( itr.hasNext() ) {
  21. //                itr.next();
  22. //                count++;
  23. //            }
  24. //            return count;
  25.     } catch (Exception e) {
  26.       logger.error("application doesn't exist within the current context");
  27.       throw new RuntimeException(e);
  28.     }
  29.   }

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

  1. /**
  2.    * (non-Javadoc) @see org.apache.usergrid.persistence.query.SingleOrderByMaxLimitCollection
  3.    * .ConnectionHelper#getResults
  4.    * (org.apache.usergrid.persistence.Query)
  5.    */
  6.   @Override
  7.   public Results getResults( Query query ) throws Exception {
  8.     query.setConnectionType( CONNECTION );
  9.     // don't set it on purpose
  10.     query.setEntityType( null );
  11.     return app.getEntityManager().searchTargetEntities(rootEntity, query);
  12.   }
  13. }

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

  1. query.setEntityType(Schema.getDefaultSchema().getEntityType(FileImport.class));
  2. query.setConnectionType(IMPORT_FILE_INCLUDES_CONNECTION);
  3. query.setLimit(MAX_FILE_IMPORTS);

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

  1. @Override
  2.   public Results getResults( Query query ) throws Exception {
  4.     app.waitForQueueDrainAndRefreshIndex();
  5.     query.setConnectionType( CONNECTION );
  6.     query.setEntityType( "test" );
  8.     return app.getEntityManager().searchTargetEntities(rootEntity, query);
  9.   }
  10. }

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

  1. q.setEntityType( type );

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

  1. private int getConnectionCountViaSearch( final Import importRoot ) {
  3.     try {
  4.       EntityManager emMgmtApp = setup.getEmf()
  5.         .getEntityManager(setup.getEmf().getManagementAppId() );
  7.       Query query = Query.fromQL("select *");
  8.       query.setEntityType("file_import");
  9.       query.setConnectionType("includes");
  10.       query.setLimit(10000);
  12.       Results entities = emMgmtApp.searchTargetEntities(importRoot, query);
  13.       return entities.size();
  15. //            PagingResultsIterator itr = new PagingResultsIterator( entities );
  16. //            int count = 0;
  17. //            while ( itr.hasNext() ) {
  18. //                itr.next();
  19. //                count++;
  20. //            }
  21. //            return count;
  22.     }
  23.     catch ( Exception e ) {
  24.       logger.error( "application doesn't exist within the current context" );
  25.       throw new RuntimeException( e );
  26.     }
  27.   }
  28. }

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

  1. query.setEntityType( collection.getType() );
  2. final Query toExecute = adjustQuery( query );
  3. final Optional<String> queryString = query.isGraphSearch()? Optional.<String>absent(): query.getQl();

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

  1. query.setEntityType( "user" );

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

  1. query.setEntityType( eType );
  2. if ( id != null ) {
  3.   query.addIdentifier( Identifier.fromUUID( id ) );

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

  1. query.setConnectionType( "likes" );
  2. query.setEntityType( "user" );

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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