From b31315fb7d585f675ec1baaba454f134f0fd44aa Mon Sep 17 00:00:00 2001 From: Dhaval Kapil Date: Thu, 23 Jun 2016 02:45:59 +0530 Subject: [PATCH] Added ReindexTest --- tests/integration/ReindexTest.lua | 37 +++++++++++++++++++++++++++++++ tests/integration/init.lua | 3 ++- 2 files changed, 39 insertions(+), 1 deletion(-) create mode 100644 tests/integration/ReindexTest.lua diff --git a/tests/integration/ReindexTest.lua b/tests/integration/ReindexTest.lua new file mode 100644 index 0000000..16efb83 --- /dev/null +++ b/tests/integration/ReindexTest.lua @@ -0,0 +1,37 @@ +-- Tests: +-- reindex() +-- + +-- Setting up environment +local _ENV = lunit.TEST_CASE "tests.integration.ReindexTest" + +local index1 = "elasticsearch-lua-reindex-index-1" +local index2 = "elasticsearch-lua-reindex-index-2" + +function test() + local dataset_1 = util.subarr(dataset, 1, math.floor(#dataset/2)) + local dataset_2 = util.subarr(dataset, math.floor(#dataset/2) + 1, #dataset) + local searchBody = { + query = { + match = { + type = "PushEvent" + } + } + } + + operations.bulkDelete(dataset, index1) + operations.bulkDelete(dataset, index2) + operations.bulkIndex(dataset_1, index1) + operations.getNonExistingDocuments(dataset_1, index2) + operations.reindex(index1, index2) + operations.getExistingDocuments(dataset_1, index2) + operations.bulkIndex(dataset_2, index1) + operations.getNonExistingDocuments(dataset_2, index2) + operations.reindex(index1, index2, searchBody) + local res = operations.searchBody(searchBody, index2) + assert_equal(103, res.hits.total) + operations.reindex(index1, index2) + operations.getExistingDocuments(dataset, index2) + operations.bulkDelete(dataset, index1) + operations.bulkDelete(dataset, index2) +end diff --git a/tests/integration/init.lua b/tests/integration/init.lua index a2fb987..f908559 100644 --- a/tests/integration/init.lua +++ b/tests/integration/init.lua @@ -5,5 +5,6 @@ operations = require "integration.operations" -- Integration tests require "integration.BasicTest" require "integration.BulkTest" -require "integration.SearchTest" require "integration.ScanAndScrollTest" +require "integration.SearchTest" +require "integration.ReindexTest"