上面直接介紹了druid訪問hbase phoenix的案例hbase Phoenix整合mybatis DruidDataSource

這里還是貼一下jdbc直接訪問的方式。public?static?void?main(String[]?args)?{

try?{

Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");

Properties?properties=new?Properties();

properties.setProperty("phoenix.query.timeoutMs",?"1200000");

properties.setProperty("hbase.rpc.timeout",?"1200000");

properties.setProperty("hbase.client.scanner.timeout.period",?"1200000");

Connection?conn?=?DriverManager.getConnection("jdbc:phoenix:master,slave1",properties);

Statement?stat?=?conn.createStatement();

ResultSet?rs?=?stat.executeQuery("select?count(1)?from?itxw.table");

int?count?=?0;

if(rs.next())?{

count=rs.getInt(1);

System.out.println("count:"+count);

}

conn.commit();

conn.close();

}?catch?(Exception?e)?{

e.printStackTrace();

}

}

需要注意其中配置的超時時間，否則phoenix只有60秒就會超時，當然服務端也要相應的配置。

還有如果phoenix配置了事務，需要顯示的調用commit來提交。