6.1.13、Hbase

6.1.13、Hbase 1、导包

    org.apache.phoenix
    phoenix-core
    4.15.0-Hbase-1.4

支持hint，索引

public class Demo01 {
    public static void main(String[] args) throws Exception {
        Connection conn = DriverManager.getConnection("jdbc:phoenix:master,node1,node2:2181");
        String sql = "select  * from DIANXIN where end_date=?";
        PreparedStatement statement = conn.prepareStatement(sql);
        statement.setString(1,"20180503154014");
        ResultSet resultSet = statement.executeQuery();
        while (resultSet.next()) {
            String mdn = resultSet.getString("mdn");
            String start_date = resultSet.getString("start_date");
            String end_date = resultSet.getString("end_date");
            String x = resultSet.getString("x");
            String y = resultSet.getString("y");
            String county = resultSet.getString("county");
            String res = mdn + "t" + start_date + "t" + end_date + "t" + x + "t" + y + "t" + county;
            System.out.println(res);
        }
        resultSet.close();
        conn.close();
        statement.close();
    }
}