apache phoenix的JAVA JDBC操作是怎樣的

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

1.  引入jar 到pom 
    
          <dependency>
               <groupId>org.apache.hadoop</groupId>
               <artifactId>hadoop-client</artifactId>
               <version>2.5.2</version>
           </dependency>
           <dependency>
               <groupId>org.apache.hbase</groupId>
               <artifactId>hbase-client</artifactId>
               <version>1.0.1.1</version>
           </dependency>
           <dependency>
               <groupId>org.apache.phoenix</groupId>
               <artifactId>phoenix-core</artifactId>
               <version>4.4.0-HBase-1.0</version>
           </dependency>

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);
       }
   }

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