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:hb...@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? | | 黄乐平 | | 18702515...@163.com | 签名由网易邮箱大师定制