in src/main/java/com/aliyun/odps/jdbc/JdbcSessionTest.java [35:74]
public static void main(String[] args) throws SQLException {
if (args.length < 2) {
System.out.println(
"Usage: java -cp odps-jdbc-...-jar-with-dependencies.jar com.aliyun.odps.jdbc.JdbcTest connection_string sql");
System.out.println(
" eg. JdbcTest 'jdbc:odps:http://service.odps.aliyun.com/api?project=odpsdemo&accessId=..."
+
"&accessKey=...&charset=UTF-8&interactiveMode=true&interactiveServiceName=public.default&majorVersion=default&longPolling=false' 'select * from dual'");
System.exit(1);
}
String connectionString = args[0];
String sql = args[1];
try {
String driverName = "com.aliyun.odps.jdbc.OdpsDriver";
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}
System.out.println("Connection: " + connectionString);
Connection conn = DriverManager.getConnection(connectionString);
ResultSet res;
try {
System.out.println("Running : " + sql);
if (sql.trim().equalsIgnoreCase("show tables")) {
res = conn.getMetaData().getTables(null, null, null, null);
} else {
Statement stmt = conn.createStatement();
res = stmt.executeQuery(sql);
}
System.out.println("Result :");
printResultSet(res);
} catch (Exception e) {
throw e;
} finally {
conn.close();
}
}