phoenix-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 黄乐平 <18702515...@163.com>
Subject how to connect phoenix cluster enabled with Kerberos using Java JDBC
Date Wed, 22 Jul 2020 13:01:25 GMT
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? 
| |
黄乐平
|
|
18702515445@163.com
|
签名由网易邮箱大师定制
Mime
View raw message