com.marklogic.client.query.QueryManager.tuples()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(9.9k)|赞(0)|评价(0)|浏览(88)

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

QueryManager.tuples介绍

[英]Retrieves combinations of values for the same document from indexes based on query criteria and, potentially, previously saved query options.
[中]根据查询条件和以前保存的查询选项,从索引中检索同一文档的值组合。

代码示例

代码示例来源:origin: marklogic/java-client-api

@Test
public void testTuples() {
 String str = head + lexiconOptions + tail;
 RawCombinedQueryDefinition rawCombinedQueryDefinition;
 rawCombinedQueryDefinition = queryMgr
  .newRawCombinedQueryDefinition(new StringHandle(str).withMimetype("application/xml"));
 StringHandle stringResults = null;
 ValuesDefinition vdef = queryMgr.newValuesDefinition("n-way");
 vdef.setQueryDefinition(rawCombinedQueryDefinition);
 stringResults = queryMgr.tuples(vdef, new StringHandle());
 System.out.println(stringResults.get());
 TuplesHandle tuplesResults = queryMgr.tuples(vdef,
  new TuplesHandle());
 Tuple[] tuples = tuplesResults.getTuples();
 assertNotNull(tuples);
}

代码示例来源:origin: marklogic/java-client-api

queryMgr.tuples(queryDef, tuplesHandle);

代码示例来源:origin: marklogic/java-client-api

@Test
public void testBug19144WithXml() throws KeyManagementException, NoSuchAlgorithmException, IOException, ParserConfigurationException, SAXException, XpathException,
  TransformerException
{
 System.out.println("Running testBug19144WithXml");
 String[] filenames = { "aggr1.xml", "aggr2.xml", "aggr3.xml", "aggr4.xml", "aggr5.xml" };
 String queryOptionName = "aggregatesOpt.xml";
 DatabaseClient client = getDatabaseClient("rest-admin", "x", getConnType());
 // write docs
 for (String filename : filenames)
 {
  writeDocumentUsingInputStreamHandle(client, filename, "/bug19144/", "XML");
 }
 setQueryOption(client, queryOptionName);
 QueryManager queryMgr = client.newQueryManager();
 // create query def
 ValuesDefinition queryDef = queryMgr.newValuesDefinition("popularity", "aggregatesOpt.xml");
 queryDef.setAggregate("correlation", "covariance");
 queryDef.setName("pop-rate-tups");
 // create handle
 StringHandle resultHandle = new StringHandle().withFormat(Format.XML);
 queryMgr.tuples(queryDef, resultHandle);
 String result = resultHandle.get();
 System.out.println(result);
 assertEquals("<", result.substring(0, 1));
 // release client
 client.release();
}

代码示例来源:origin: marklogic/java-client-api

@Test
public void testBug19144WithJson() throws KeyManagementException, NoSuchAlgorithmException, IOException, ParserConfigurationException, SAXException, XpathException,
  TransformerException
{
 System.out.println("Running testBug19144WithJson");
 String[] filenames = { "aggr1.xml", "aggr2.xml", "aggr3.xml", "aggr4.xml", "aggr5.xml" };
 String queryOptionName = "aggregatesOpt.xml";
 DatabaseClient client = getDatabaseClient("rest-admin", "x", getConnType());
 // write docs
 for (String filename : filenames)
 {
  writeDocumentUsingInputStreamHandle(client, filename, "/bug19144/", "XML");
 }
 setQueryOption(client, queryOptionName);
 QueryManager queryMgr = client.newQueryManager();
 // create query def
 ValuesDefinition queryDef = queryMgr.newValuesDefinition("popularity", "aggregatesOpt.xml");
 queryDef.setAggregate("correlation", "covariance");
 queryDef.setName("pop-rate-tups");
 // create handle
 StringHandle resultHandle = new StringHandle().withFormat(Format.JSON);
 queryMgr.tuples(queryDef, resultHandle);
 String result = resultHandle.get();
 System.out.println(result);
 assertEquals("{", result.substring(0, 1));
 // release client
 client.release();
}

代码示例来源:origin: marklogic/java-client-api

queryMgr.tuples(queryDef1, tuplesHandle);

代码示例来源:origin: marklogic/java-client-api

@Test
public void testValues() {
 String str = head + lexiconOptions + tail;
 RawCombinedQueryDefinition rawCombinedQueryDefinition;
 rawCombinedQueryDefinition = queryMgr
  .newRawCombinedQueryDefinition(new StringHandle(str).withMimetype("application/xml"));
 StringHandle stringResults = null;
 ValuesDefinition vdef = queryMgr.newValuesDefinition("grandchild");
 vdef.setQueryDefinition(rawCombinedQueryDefinition);
 stringResults = queryMgr.tuples(vdef, new StringHandle());
 System.out.println(stringResults.get());
 ValuesHandle valuesResults = queryMgr.values(vdef,
  new ValuesHandle());
 assertFalse(valuesResults.getMetrics().getTotalTime() == -1);
 CountedDistinctValue[] values = valuesResults.getValues();
 assertNotNull(values);
}

代码示例来源:origin: marklogic/java-client-api

TuplesHandle t = queryMgr.tuples(vdef, new TuplesHandle(), 3);

代码示例来源:origin: marklogic/java-client-api

@Test
public void testAggregates()
 throws IOException, ParserConfigurationException, SAXException, ResourceNotFoundException, ForbiddenUserException, FailedRequestException, ResourceNotResendableException
{
 QueryOptionsManager optionsMgr = Common.adminClient.newServerConfigManager().newQueryOptionsManager();
 optionsMgr.writeOptions("valuesoptions2", new StringHandle(options));
 logger.debug(options.toString());
 QueryManager queryMgr = Common.client.newQueryManager();
 ValuesDefinition vdef = queryMgr.newValuesDefinition("co", "valuesoptions2");
 vdef.setAggregate("correlation", "covariance");
 TuplesHandle t = queryMgr.tuples(vdef, new TuplesHandle());
 AggregateResult[] agg = t.getAggregates();
 assertEquals("Two aggregates are expected", 2, agg.length);
 double cov = t.getAggregate("covariance").get("xs:double", Double.class);
 assertTrue("The covariance is between 1.551 and 1.552",
  cov > 1.551 && cov < 1.552);
 Tuple[] tuples = t.getTuples();
 assertEquals("Twelve tuples are expected", 12, tuples.length);
 assertEquals("The tuples are named 'co'", "co", t.getName());
 ValuesMetrics metrics = t.getMetrics();
 assertTrue("The values resolution time is >= 0", metrics.getValuesResolutionTime() >= 0);
 assertTrue("The aggregate resolution time is >= 0", metrics.getAggregateResolutionTime() >= 0);
 optionsMgr.deleteOptions("valuesoptions2");
}

代码示例来源:origin: marklogic/java-client-api

@Test
public void testCoVariances()
 throws IOException, ParserConfigurationException, SAXException, ResourceNotFoundException, ForbiddenUserException, FailedRequestException, ResourceNotResendableException
{
 QueryOptionsManager optionsMgr = Common.adminClient.newServerConfigManager().newQueryOptionsManager();
 optionsMgr.writeOptions("valuesoptions3", new StringHandle(options));
 QueryManager queryMgr = Common.client.newQueryManager();
 ValuesDefinition vdef = queryMgr.newValuesDefinition("co", "valuesoptions3");
 TuplesHandle t = queryMgr.tuples(vdef, new TuplesHandle());
 Tuple[] tuples = t.getTuples();
 assertEquals("Twelve tuples are expected", 12, tuples.length);
 assertEquals("The tuples are named 'co'", "co", t.getName());
 ValuesMetrics metrics = t.getMetrics();
 assertTrue("The values resolution time is >= 0", metrics.getValuesResolutionTime() >= 0);
 // Restore after bug:18747 is fixed
 // assertEquals("The aggregate resolution time is -1 (absent)", metrics.getAggregateResolutionTime(), -1);
 optionsMgr.deleteOptions("valuesoptions3");
}

代码示例来源:origin: marklogic/java-client-api

@Test
public void testValuesHandle()
 throws IOException, ParserConfigurationException, SAXException, ResourceNotFoundException, ForbiddenUserException, FailedRequestException, ResourceNotResendableException
{
 QueryOptionsManager optionsMgr = Common.adminClient.newServerConfigManager().newQueryOptionsManager();
 optionsMgr.writeOptions("valuesoptions", new StringHandle(options));
 QueryManager queryMgr = Common.client.newQueryManager();
 ValuesDefinition vdef = queryMgr.newValuesDefinition("co", "valuesoptions");
 TuplesHandle t = queryMgr.tuples(vdef, new TuplesHandle());
 Tuple[] tuples = t.getTuples();
 assertEquals("Twelve tuples are expected", 12, tuples.length);
 assertEquals("The tuples are named 'co'", "co", t.getName());
 TypedDistinctValue[] dv = tuples[0].getValues();
 assertEquals("Two values per tuple expected", 2, dv.length);
 assertEquals("First is long", "xs:double",  dv[0].getType());
 assertEquals("Second is int", "xs:int", dv[1].getType());
 assertEquals("Frequency is 1", 1, tuples[0].getCount());
 assertEquals("First value",  1.1, (double) dv[0].get(Double.class), 0.01);
 assertEquals("Second value", (int) 1, (int) dv[1].get(Integer.class));
 optionsMgr.deleteOptions("valuesoptions");
}

代码示例来源:origin: marklogic/java-client-api

@Test
public void testNWayTuples()
 throws ResourceNotFoundException, ForbiddenUserException, FailedRequestException, ResourceNotResendableException
{
 QueryOptionsManager optionsMgr = Common.adminClient.newServerConfigManager().newQueryOptionsManager();
 optionsMgr.writeOptions("valuesoptions", new StringHandle(options));
 QueryManager queryMgr = Common.client.newQueryManager();
 ValuesDefinition vdef = queryMgr.newValuesDefinition("n-way", "valuesoptions");
 TuplesHandle t = queryMgr.tuples(vdef, new TuplesHandle());
 Tuple[] tuples = t.getTuples();
 assertEquals("Four tuples are expected", 4, tuples.length);
 assertEquals("The tuples are named 'n-way'", "n-way", t.getName());
 TypedDistinctValue[] dv = tuples[0].getValues();
 assertEquals("Three values per tuple expected", 3, dv.length);
 assertEquals("First is long", "xs:double",  dv[0].getType());
 assertEquals("Second is int", "xs:int", dv[1].getType());
 assertEquals("Third is string", "xs:string", dv[2].getType());
 assertEquals("Frequency is 1", 1, tuples[0].getCount());
 assertEquals("First value",  1.1, (double) dv[0].get(Double.class), 0.01);
 assertEquals("Second value", (int) 1, (int) dv[1].get(Integer.class));
 assertEquals("Third value", "Alaska", (String) dv[2].get(String.class));
 optionsMgr.deleteOptions("valuesoptions");
}

相关文章