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也基本相同，需要修改配置文件：

    <!-- phoenix配置 -->
    <bean id="phoenixJdbcTemplate"
          class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg ref="phoenixDataSource"/>
        <qualifier value="phoenixJdbcTemplate"></qualifier>
    </bean>
    <bean id="phoenixDataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="org.apache.phoenix.jdbc.PhoenixDriver"/>
        <property name="url" value="jdbc:phoenix:ccs01a:2181/hbase"/>
        <property name="username" value=""/>
        <property name="password" value=""/>
        <property name="initialSize" value="20"/>
        <property name="maxActive" value="0"/>
        <!--因為Phoenix進行數據更改時不會自動的commit,必須要添加defaultAutoCommit屬性,否則會導致數據無法提交的情況-->
        <property name="defaultAutoCommit" value="true"/>
    </bean>