首页 > 代码库 > Java访问Phoenix连接
Java访问Phoenix连接
两种方法,一种是直接使用jdbc连接,一种是使用spring连接。
jdbc连接和访问oracle步骤相同:
///////////// 测试Phoenix连接 /////////////// String testSQL = "select \"1\",\"2\" from fengji where rowid like ‘1-20170413%‘"; try { Class.forName("org.apache.phoenix.jdbc.PhoenixDriver"); } catch (ClassNotFoundException e1) { System.out.println("org.apache.phoenix.jdbc.PhoenixDriver未找到"); } List<Integer>resList = new ArrayList<Integer>(); Connection con1 = DriverManager.getConnection("jdbc:phoenix:ccs01a:2181/hbase","",""); Statement stmt = con1.createStatement(); ResultSet rset = stmt.executeQuery(testSQL); while (rset.next()) { resList.add(rset.getInt("1")); } System.out.println(resList.size()); stmt.close(); con1.close(); /////////////////////////////////////
2、spring与oracle也基本相同,需要修改配置文件:
1 <!-- phoenix配置 --> 2 <bean id="phoenixJdbcTemplate" 3 class="org.springframework.jdbc.core.JdbcTemplate"> 4 <constructor-arg ref="phoenixDataSource"/> 5 <qualifier value="phoenixJdbcTemplate"></qualifier> 6 </bean> 7 <bean id="phoenixDataSource" class="org.apache.commons.dbcp.BasicDataSource"> 8 <property name="driverClassName" value="org.apache.phoenix.jdbc.PhoenixDriver"/> 9 <property name="url" value="jdbc:phoenix:ccs01a:2181/hbase"/> 10 <property name="username" value=""/> 11 <property name="password" value=""/> 12 <property name="initialSize" value="20"/> 13 <property name="maxActive" value="0"/> 14 <!--因为Phoenix进行数据更改时不会自动的commit,必须要添加defaultAutoCommit属性,否则会导致数据无法提交的情况--> 15 <property name="defaultAutoCommit" value="true"/> 16 </bean>
Java访问Phoenix连接
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。