Support Questions
Find answers, ask questions, and share your expertise

how to connect phoenix cluster enabled with Kerberos using Java JDBC

New Contributor

My code is like this:

public class PhoenixDemo {

public static void main(String[] args) {
Connection connection = null;
Statement statement = null;
ResultSet rs = null;
PreparedStatement ps = null;
org.apache.hadoop.conf.Configuration conf = null;

try {
Connection conn = null;
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
connection = DriverManager.getConnection("jdbc:phoenix:cdp2.hadoop.com:2181/hbase:hbase@HADOOP.COM:C:\\hbase.keytab");
System.out.println("Connection established....");
// Create a JDBC statement
statement = connection.createStatement();
// Execute our statements
statement.executeUpdate(
"create table user (id INTEGER NOT NULL PRIMARY KEY, d.first_name VARCHAR,d.last_name VARCHAR)");
statement.executeUpdate("upsert into user values (1,'John','Mayer')");
statement.executeUpdate("upsert into user values (2,'Eva','Peters')");
connection.commit();

// Query for selecting records from table
ps = connection.prepareStatement("select * from user");
rs = ps.executeQuery();
System.out.println("Table Values");
while (rs.next()) {
Integer id = rs.getInt(1);
String name = rs.getString(2);
System.out.println("\tRow: " + id + " = " + name);
}
} catch (SQLException | ClassNotFoundException e) {
e.printStackTrace();
} finally {
if (ps != null) {
try {
ps.close();
} catch (Exception e) {
}
}
if (rs != null) {
try {
rs.close();
} catch (Exception e) {
}
}
if (statement != null) {
try {
statement.close();
} catch (Exception e) {
}
}
if (connection != null) {
try {
connection.close();
} catch (Exception e) {
}
}
}

}
}

 the code running result is a long time no response. are there any errors with my code? 

0 REPLIES 0