You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2018/09/28 11:23:49 UTC
[kylin] branch master updated: KYLIN-3597 delete unused test cases
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/master by this push:
new 65ab55e KYLIN-3597 delete unused test cases
65ab55e is described below
commit 65ab55e920a611c12a331f084599bbca6e3381bc
Author: shaofengshi <sh...@apache.org>
AuthorDate: Fri Sep 28 19:22:48 2018 +0800
KYLIN-3597 delete unused test cases
---
.../kylin/common/util/InstallJarIntoMavenTest.java | 68 --------
.../apache/kylin/metadata/model/TableDescTest.java | 25 ---
.../storage/hbase/common/HiveJDBCClientTest.java | 192 ---------------------
3 files changed, 285 deletions(-)
diff --git a/core-common/src/test/java/org/apache/kylin/common/util/InstallJarIntoMavenTest.java b/core-common/src/test/java/org/apache/kylin/common/util/InstallJarIntoMavenTest.java
deleted file mode 100644
index f0326b5..0000000
--- a/core-common/src/test/java/org/apache/kylin/common/util/InstallJarIntoMavenTest.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
-*/
-
-package org.apache.kylin.common.util;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-import java.io.Writer;
-import java.nio.charset.StandardCharsets;
-import java.util.Locale;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
-import org.junit.Ignore;
-
-/**
- */
-public class InstallJarIntoMavenTest {
-
- @Ignore("convenient trial tool for dev")
- public void testInstall() throws IOException {
- File folder = new File("/export/home/b_kylin/tmp");
- File out = new File("/export/home/b_kylin/tmp/out.sh");
- out.createNewFile();
-
- Writer fw = new OutputStreamWriter(new FileOutputStream(out), StandardCharsets.UTF_8);
-
- for (File file : folder.listFiles()) {
- String name = file.getName();
-
- if (!name.endsWith(".jar"))
- continue;
-
- int firstSlash = name.indexOf('-');
- int lastDot = name.lastIndexOf('.');
- String groupId = name.substring(0, firstSlash);
-
- Pattern pattern = Pattern.compile("-\\d");
- Matcher match = pattern.matcher(name);
- match.find();
- String artifactId = name.substring(0, match.start());
- String version = name.substring(match.start() + 1, lastDot);
-
- fw.write(String.format(Locale.ROOT, "mvn install:install-file -Dfile=%s -DgroupId=%s -DartifactId=%s "
- + "-Dversion=%s " + "-Dpackaging=jar", name, "org.apache." + groupId, artifactId, version));
- fw.write("\n");
- }
- fw.close();
- }
-
-}
diff --git a/core-metadata/src/test/java/org/apache/kylin/metadata/model/TableDescTest.java b/core-metadata/src/test/java/org/apache/kylin/metadata/model/TableDescTest.java
deleted file mode 100644
index 12d13c3..0000000
--- a/core-metadata/src/test/java/org/apache/kylin/metadata/model/TableDescTest.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
-*/
-
-package org.apache.kylin.metadata.model;
-
-/**
- */
-public class TableDescTest {
-
-}
diff --git a/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/common/HiveJDBCClientTest.java b/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/common/HiveJDBCClientTest.java
deleted file mode 100644
index 0b83af4..0000000
--- a/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/common/HiveJDBCClientTest.java
+++ /dev/null
@@ -1,192 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
-*/
-
-package org.apache.kylin.storage.hbase.common;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-import java.io.Writer;
-import java.nio.charset.StandardCharsets;
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-
-/**
- * A simple test case to check whether the Hive JDBC interface can fulfill Kylin's need;
- * Before run it, you need startup the hive server on localhost: $HIVE_HOME/bin/hiveserver2
- * @author shaoshi
- *
- */
-public class HiveJDBCClientTest {
-
- private static String driverName = "org.apache.hive.jdbc.HiveDriver";
-
- private static String tempFileName = "/tmp/a.txt";
-
- //@Before
- public void setup() {
-
- try {
- Class.forName(driverName);
- } catch (ClassNotFoundException e) {
- e.printStackTrace();
- System.exit(1);
- }
-
- File testFile = new File(tempFileName);
-
- if (!testFile.exists()) {
-
- Writer writer;
- try {
- writer = new OutputStreamWriter(new FileOutputStream(testFile), StandardCharsets.UTF_8);
- writer.write("1 a\n");
- writer.write("2 b\n");
-
- writer.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
-
- }
-
- //@After
- public void tearDown() {
-
- }
-
- protected Connection getHiveConnection() throws SQLException {
-
- return DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "hive", "");
- }
-
- //@Test
- public void testConnectToHive() throws SQLException {
-
- //replace "hive" here with the name of the user the queries should run as
- Connection con = getHiveConnection();
-
- Statement stmt = con.createStatement();
- String tableName = "testHiveDriverTable";
- stmt.execute("drop table if exists " + tableName);
- stmt.execute(
- "create table " + tableName + " (key int, value string) row format delimited fields terminated by ' '");
- // show tables
- String sql = "show tables '" + tableName + "'";
- System.out.println("Running: " + sql);
- ResultSet res = stmt.executeQuery(sql);
- if (res.next()) {
- System.out.println(res.getString(1));
- }
- res.close();
-
- // describe table
- sql = "describe " + tableName;
- System.out.println("Running: " + sql);
- res = stmt.executeQuery(sql);
- while (res.next()) {
- System.out.println(res.getString(1) + "\t" + res.getString(2));
- }
- res.close();
-
- // load data into table
- // NOTE: filepath has to be local to the hive server
- // NOTE: /tmp/a.txt is a ctrl-A separated file with two fields per line
- String filepath = tempFileName;
- sql = "load data local inpath '" + filepath + "' into table " + tableName;
- System.out.println("Running: " + sql);
- stmt.execute(sql);
-
- // select * query
- sql = "select * from " + tableName;
- System.out.println("Running: " + sql);
- res = stmt.executeQuery(sql);
- while (res.next()) {
- System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2));
- }
- res.close();
-
- // regular hive query
- sql = "select count(1) from " + tableName;
- System.out.println("Running: " + sql);
- res = stmt.executeQuery(sql);
- while (res.next()) {
- System.out.println(res.getInt(1));
- }
- res.close();
-
- stmt.close();
- con.close();
- }
-
- //@Test
- public void testShowExtendedTable() throws SQLException {
- Connection con = getHiveConnection();
-
- String tableName = "testHiveDriverTable";
- String sql = "show table extended like " + tableName + "";
-
- ResultSet res = executeSQL(con, sql);
- while (res.next()) {
- System.out.println("--- " + res.getString("tab_name"));
- }
-
- sql = "describe extended " + tableName + "";
- res = executeSQL(con, sql);
- while (res.next()) {
- System.out.println("---" + res.getString(1) + " | " + res.getString(2));
- }
-
- res.close();
- con.close();
- }
-
- protected ResultSet executeSQL(Connection con, String sql) throws SQLException {
-
- Statement stmt = con.createStatement();
- System.out.println("Running: " + sql);
- stmt.execute(sql);
-
- return stmt.getResultSet();
- }
-
- public void runTests() throws SQLException {
- try {
- setup();
- testConnectToHive();
- testShowExtendedTable();
- } catch (Exception e) {
- e.printStackTrace();
- throw e;
- } finally {
- tearDown();
- }
-
- }
-
- public static void main(String[] args) throws SQLException {
- HiveJDBCClientTest test = new HiveJDBCClientTest();
- test.runTests();
- }
-
-}