package packagename;
import java.sql.*;
public class DrillJDBCExample1 {
static final String JDBC_DRIVER = "org.apache.drill.jdbc.Driver";
static final String DB_URL = "jdbc:drill:zk=machineName:5181/drill/x-drillbits";
//You can get this URL from drill explorer, if you have installed
//Zookeeper port is 5181 in MapR hadoop
//static final String USER = "admin";
//static final String PASS = "admin";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try{
Class.forName(JDBC_DRIVER);
conn = DriverManager.getConnection(DB_URL," "," ");
stmt = conn.createStatement();
/* Perform a select on data in the classpath storage plugin. */
String sql = "select transaction_week_end,SUM(SumOfSale) as sq,SUM(SumOfPrice) as sp from dfs.`StoragepluginName`.`drillTableName` GROUP BY `transaction_week_end`";
ResultSet rs = stmt.executeQuery(sql);
while(rs.next()) {
System.out.print(rs.getBigDecimal("sq")+"\t");
System.out.print(rs.getBigDecimal("sp")+"\n");
}
rs.close();
stmt.close();
conn.close();
} catch(SQLException se) {
//Handle errors for JDBC
se.printStackTrace();
} catch(Exception e) {
//Handle errors for Class.forName
e.printStackTrace();
} finally {
try{
if(stmt!=null)
stmt.close();
} catch(SQLException se2) {
}
try {
if(conn!=null)
conn.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
}
}
No comments:
Post a Comment