This is an automated email from the ASF dual-hosted git repository. larsh pushed a commit to branch 4.x-HBase-1.3 in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x-HBase-1.3 by this push: new 0c5f0d6 Revert "PHOENIX-5616 Speed up ParameterizedIndexUpgradeToolIT." 0c5f0d6 is described below commit 0c5f0d6d308b3c9be9537e9a0915f0ee19f2271c Author: Lars Hofhansl <la...@apache.org> AuthorDate: Sat Dec 21 07:47:03 2019 -0800 Revert "PHOENIX-5616 Speed up ParameterizedIndexUpgradeToolIT." This reverts commit 53c0089a29a33124b0a0be4c5315995ace2c70fd. --- .../end2end/ParameterizedIndexUpgradeToolIT.java | 38 ++++++++++++---------- 1 file changed, 21 insertions(+), 17 deletions(-) diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java index 5a2cef9..16f99e3 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java @@ -310,40 +310,44 @@ public class ParameterizedIndexUpgradeToolIT extends BaseTest { } @Test - public void testDryRunAndFailures() throws Exception { + public void testToolWithIncorrectTables() throws Exception { validate(true); - - // test with incorrect table iut.setInputTables("TEST3.TABLE_NOT_PRESENT"); iut.prepareToolSetup(); int status = iut.executeTool(); Assert.assertEquals(-1, status); validate(true); + } - // test with input file parameter + @Test + public void testToolWithNoIndex() throws Exception { + if (!upgrade || isNamespaceEnabled) { + return; + } + conn.createStatement().execute("CREATE TABLE TEST.NEW_TABLE (id bigint NOT NULL " + + "PRIMARY KEY, a.name varchar, sal bigint, address varchar)" + tableDDLOptions); + iut.setInputTables("TEST.NEW_TABLE"); + iut.prepareToolSetup(); + int status = iut.executeTool(); + Assert.assertEquals(0, status); + conn.createStatement().execute("DROP TABLE TEST.NEW_TABLE"); + } + + @Test + public void testToolWithInputFileParameter() throws Exception { BufferedWriter writer = new BufferedWriter(new FileWriter(new File(INPUT_FILE))); writer.write(INPUT_LIST); writer.close(); + validate(true); + iut.setInputTables(null); iut.setInputFile(INPUT_FILE); iut.prepareToolSetup(); - status = iut.executeTool(); - Assert.assertEquals(0, status); + iut.executeTool(); validate(true); - - // test table without index - if (upgrade && !isNamespaceEnabled) { - conn.createStatement().execute("CREATE TABLE TEST.NEW_TABLE (id bigint NOT NULL " - + "PRIMARY KEY, a.name varchar, sal bigint, address varchar)" + tableDDLOptions); - iut.setInputTables("TEST.NEW_TABLE"); - iut.prepareToolSetup(); - status = iut.executeTool(); - Assert.assertEquals(0, status); - conn.createStatement().execute("DROP TABLE TEST.NEW_TABLE"); - } } @After