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
|
签名由网易邮箱大师定制
