apache phoenix的JAVA JDBC操作是怎樣的，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

專注于為中小企業提供成都網站設計、成都網站制作服務,電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業滿洲免費做網站提供優質的服務。我們立足成都，凝聚了一批互聯網行業人才，有力地推動了1000+企業的穩健成長，幫助中小企業通過網站建設實現規模擴充和轉變。

1.  引入jar 到pom 
    
          
               org.apache.hadoop
               hadoop-client
               2.5.2
           
           
               org.apache.hbase
               hbase-client
               1.0.1.1
           
           
               org.apache.phoenix
               phoenix-core
               4.4.0-HBase-1.0
           

2. 創建工具類
   
   import org.apache.log4j.Logger;
   
   import java.sql.Connection;
   import java.sql.DriverManager;
   import java.sql.SQLException;
   
   /**
    * 使用Phoenix提供標準的JDBC連接HBase
    * @author Chenj
    */
   public class PhoenixHelper {
   
       private static final Logger LOG = Logger.getLogger(PhoenixHelper.class);
       private static final String JDBC_DRIVER_CLASS = "org.apache.phoenix.jdbc.PhoenixDriver";
       // jdbc:phoenix:192.168.1.19:2181:/hbase中的/hbase為HBase注冊到zooKeeper的根目錄, 如使用HBase自帶的zooKeeper,默認為"hbase"
       private static final String JDBC_URL          = "jdbc:phoenix:192.168.1.19:2181:/hbase";
   
       public static Connection getConn(){
           try {
               // 注冊Driver
               Class.forName(JDBC_DRIVER_CLASS);
               // 返回Connection對象
               return DriverManager.getConnection(JDBC_URL);
           } catch (SQLException |  ClassNotFoundException e ) {
               e.printStackTrace();
               LOG.error("獲得連接失敗!");
               return null;
           }
       }
   
       public static void closeConn(Connection conn){
           try {
               if (!conn.isClosed())
                   conn.close();
           } catch (SQLException e) {
               e.printStackTrace();
               LOG.error("關閉連接失敗!");
           }
       }
   
   }

3. 測試
   
   import org.junit.Before;
   import org.junit.Test;
   
   import java.sql.Connection;
   import java.sql.PreparedStatement;
   import java.sql.SQLException;
   
   /**
    * 創建表測試
    * @author Chenj
    */
   public class TableTest {
   
       Connection conn = null;
   
       String sql = "CREATE TABLE IF NOT EXISTS user (" +
                   "username VARCHAR NOT NULL," +
                   "password VARCHAR, " +
                   "age INTEGER NOT NULL  CONSTRAINT my_pk PRIMARY KEY (username, age))";
   
       @Before
       public void init(){
           conn = PhoenixHelper.getConn();
       }
   
       @Test
       public void createTable() throws SQLException {
           PreparedStatement preparedStatement = conn.prepareStatement(sql);
           preparedStatement.execute();
           PhoenixHelper.closeConn(conn);
       }
   
       @Test
       public void dropTable() throws SQLException {
           PreparedStatement preparedStatement = conn.prepareStatement("drop table user");
           preparedStatement.execute();
           PhoenixHelper.closeConn(conn);
       }
   }

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注創新互聯行業資訊頻道，感謝您對創新互聯的支持。