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

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

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

Query.setConnectionType介绍

[英]Set the connection type
[中]设置连接类型

代码示例

代码示例来源：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 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.setConnectionType(IMPORT_FILE_INCLUDES_CONNECTION);
  2. 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.setConnectionType( connection );

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

  1. + ((LinkedHashMap<String, Object>) userProperties.get("location")).get("latitude")
  2.     + ", " + ((LinkedHashMap<String, Object>)
  3.     userProperties.get("location")).get("longitude")).setConnectionType("likes"));
  4. assertEquals(1, emSearchResults.size());
  5.     + ((LinkedHashMap<String, Object>) userProperties.get("location")).get("latitude")
  6.     + ", " + ((LinkedHashMap<String, Object>)
  7.     userProperties.get("location")).get("longitude")).setConnectionType("likes"));
  8. assertEquals(0, emSearchResults.size());

代码示例来源：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.setConnectionType( "testconnection" );
  2. query.setEntityType( "user" );

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

  1. query = new Query();
  2. query.setConnectionType( cType );
  3. query.setEntityType( eType );
  4. if ( id != null ) {

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

  1. private int readData( EntityManager em, String collectionName, int expectedEntities, int expectedConnections )
  2.   throws Exception {
  3.   app.waitForQueueDrainAndRefreshIndex();
  4.   Query q = Query.fromQL( "select * where key1=1000" ).withLimit( 1000 );
  5.   Results results = em.searchCollectionConsistent( em.getApplicationRef(), collectionName, q, expectedEntities );
  6.   int count = 0;
  7.   while ( true ) {
  8.     for ( Entity e : results.getEntities() ) {
  9.       assertEquals( 2000, e.getProperty( "key2" ) );
  10.       Results catResults =
  11.         em.searchTargetEntities( e, Query.fromQL( "select *" ).setConnectionType( "herds" ) );
  12.       assertEquals( expectedConnections, catResults.size() );
  13.       if ( count % 100 == 0 ) {
  14.         logger.info( "read {} entities", count );
  15.       }
  16.       count++;
  17.     }
  18.     if ( results.hasCursor() ) {
  19.       logger.info( "Counted {} : query again with cursor", count );
  20.       q.setCursor( results.getCursor() );
  21.       results = em.searchCollection( em.getApplicationRef(), collectionName, q );
  22.     }
  23.     else {
  24.       break;
  25.     }
  26.   }
  27.   return count;
  28. }

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

  1. query.setConnectionType( "likes" );

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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