minor, more stable DeployUtil
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/d50a845f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/d50a845f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/d50a845f Branch: refs/heads/yang22-cdh5.7 Commit: d50a845fb877bfddb6d80983be7c1fce6d0b5833 Parents: f931a6a Author: Yang Li <liy...@apache.org> Authored: Tue Dec 27 06:52:41 2016 +0800 Committer: Yang Li <liy...@apache.org> Committed: Tue Dec 27 06:52:41 2016 +0800 ---------------------------------------------------------------------- .../src/test/java/org/apache/kylin/job/DeployUtil.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/d50a845f/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java ---------------------------------------------------------------------- diff --git a/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java b/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java index 23b3670..0d6a6b6 100644 --- a/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java +++ b/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java @@ -265,8 +265,9 @@ public class DeployUtil { private static String[] generateCreateTableHql(TableDesc tableDesc) { String dropsql = "DROP TABLE IF EXISTS " + tableDesc.getIdentity(); + String dropsql2 = "DROP VIEW IF EXISTS " + tableDesc.getIdentity(); + StringBuilder ddl = new StringBuilder(); - ddl.append("CREATE TABLE " + tableDesc.getIdentity() + "\n"); ddl.append("(" + "\n"); @@ -282,17 +283,18 @@ public class DeployUtil { ddl.append("ROW FORMAT DELIMITED FIELDS TERMINATED BY ','" + "\n"); ddl.append("STORED AS TEXTFILE"); - return new String[] { dropsql, ddl.toString() }; + return new String[] { dropsql, dropsql2, ddl.toString() }; } private static String[] generateCreateViewHql(String viewName, TableDesc tableDesc) { - String dropsql = "DROP VIEW IF EXISTS " + viewName + ";"; - StringBuilder ddl = new StringBuilder(); + String dropsql = "DROP TABLE IF EXISTS " + viewName + ";"; + String dropsql2 = "DROP VIEW IF EXISTS " + viewName + ";"; + StringBuilder ddl = new StringBuilder(); ddl.append("CREATE VIEW " + viewName + " AS SELECT * FROM " + tableDesc.getIdentity() + ";\n"); - return new String[] { dropsql, ddl.toString() }; + return new String[] { dropsql, dropsql2, ddl.toString() }; } private static String getHiveDataType(String javaDataType) {
