|
55 | 55 | public class TestBulkReadWriteWithJacksonParserHandle extends |
56 | 56 | BasicJavaClientREST { |
57 | 57 |
|
58 | | - private static final String DIRECTORY = "/bulkread/"; |
| 58 | + private static final String DIRECTORY = "/"; |
59 | 59 | private static String dbName = "TestBulkJacksonParserDB"; |
60 | 60 | private static String[] fNames = { "TestBulkJacksonParserDB-1" }; |
61 | 61 | private static String restServerName = "REST-Java-Client-API-Server"; |
@@ -491,6 +491,30 @@ public void testWriteMultiJSONFilesDefaultMetadata() throws Exception |
491 | 491 | @Test |
492 | 492 | public void testBulkSearchQBEWithJSONResponseFormat() throws IOException, ParserConfigurationException, SAXException, TransformerException { |
493 | 493 | int count; |
| 494 | + String docId[] = { "/a.json", "/b.json", "/c.json" }; |
| 495 | + String json1 = new String("{\"animal\":\"dog\", \"says\":\"woof\"}"); |
| 496 | + String json2 = new String("{\"animal\":\"cat\", \"says\":\"meow\"}"); |
| 497 | + String json3 = new String("{\"animal\":\"rat\", \"says\":\"keek\"}"); |
| 498 | + |
| 499 | + JsonFactory f = new JsonFactory(); |
| 500 | + |
| 501 | + JSONDocumentManager docMgr1 = client.newJSONDocumentManager(); |
| 502 | + docMgr1.setMetadataCategories(Metadata.ALL); |
| 503 | + DocumentWriteSet writeset = docMgr1.newWriteSet(); |
| 504 | + |
| 505 | + JacksonParserHandle jacksonParserHandle1 = new JacksonParserHandle(); |
| 506 | + JacksonParserHandle jacksonParserHandle2 = new JacksonParserHandle(); |
| 507 | + JacksonParserHandle jacksonParserHandle3 = new JacksonParserHandle(); |
| 508 | + |
| 509 | + jacksonParserHandle1.set(f.createParser(json1)); |
| 510 | + jacksonParserHandle2.set(f.createParser(json2)); |
| 511 | + jacksonParserHandle3.set(f.createParser(json3)); |
| 512 | + |
| 513 | + writeset.add(docId[0], jacksonParserHandle1); |
| 514 | + writeset.add(docId[1], jacksonParserHandle2); |
| 515 | + writeset.add(docId[2], jacksonParserHandle3); |
| 516 | + // Write to database. |
| 517 | + docMgr1.write(writeset); |
494 | 518 |
|
495 | 519 | //Creating a xml document manager for bulk search |
496 | 520 | XMLDocumentManager docMgr = client.newXMLDocumentManager(); |
@@ -533,11 +557,10 @@ public void testBulkSearchQBEWithJSONResponseFormat() throws IOException, Parser |
533 | 557 | pageNo = pageNo + page.getPageSize(); |
534 | 558 | }while(!page.isLastPage() && page.hasContent() ); |
535 | 559 |
|
536 | | - assertEquals("page count is ",5,page.getTotalPages()); |
537 | | - assertTrue("Page has previous page ?",page.hasPreviousPage()); |
| 560 | + assertEquals("page count is ",1,page.getTotalPages()); |
| 561 | + assertFalse("Page has previous page ?",page.hasPreviousPage()); |
538 | 562 | assertEquals("page size", 25,page.getPageSize()); |
539 | | - assertEquals("document count", 102,page.getTotalSize()); |
540 | | - |
| 563 | + assertEquals("document count", 1,page.getTotalSize()); |
541 | 564 | } |
542 | 565 |
|
543 | 566 | @AfterClass |
|
0 commit comments