This is just a simple example of using a custom JDBC class to connect to an HBase cluster that is secured by kerberos.<\/p>\n
\r\nimport java.sql.*;\r\nimport java.util.*;\r\n\r\npublic class phoenixTest {\r\n public static void main(String args[]) throws Exception {\r\n Connection conn;\r\n Properties prop = new Properties();\r\n prop.setProperty(\"zookeeper.znode.parent\",\"hbase-secure\");\r\n Class.forName(\"org.apache.phoenix.jdbc.PhoenixDriver\");\r\n System.out.println(\"getting connection\");\r\n conn = DriverManager.getConnection(\"jdbc:phoenix:zookeeperhost:2181:hbase@EXPRESSCO.COM:\/etc\/security\/keytabs\/hbase.headless.keytab\");\r\n System.out.println(\"got connection\");\r\n try {\r\n conn.createStatement().execute(\"create table dim_member(member_key integer primary key,first_name varchar(40), last_name varchar(40))\");\r\n }\r\n catch (SQLException e) {\r\n e.printStackTrace();\r\n Thread.sleep(5000);\r\n }\r\n ResultSet rst = conn.createStatement().executeQuery(\"select * from dim_member\");\r\n while (rst.next()) {\r\n System.out.println(rst.getString(1) + \" \" + rst.getString(2));\r\n }\r\n System.out.println(conn.createStatement().executeUpdate(\"delete from dim_member\"));\r\n conn.rollback();\r\n rst = conn.createStatement().executeQuery(\"select * from dim_member\");\r\n while (rst.next()) {\r\n System.out.println(rst.getString(1) + \" \" + rst.getString(2));\r\n }\r\n System.out.println(conn.createStatement().executeUpdate(\"upsert into dim_member values(1,'Steve','Howard')\"));\r\n conn.commit();\r\n }\r\n}\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"This is just a simple example of using a custom JDBC class to connect to an HBase cluster that is secured by kerberos. import java.sql.*; import java.util.*; public class phoenixTest { public static void main(String args[]) throws Exception { Connection…<\/p>\n