public static void main()

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();
    }

  }