phoenix-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Josh Elser <els...@apache.org>
Subject Re: how to connect phoenix cluster enabled with Kerberos using Java JDBC
Date Fri, 31 Jul 2020 14:22:40 GMT
You're missing a colon between the port and root znode in your JDBC URL.

 From http://phoenix.apache.org/

```
jdbc:phoenix [ :<zookeeper quorum> [ :<port number> [ :<root node> [ 
:<principal> [ :<keytab file> ] ] ] ] ]
```

On 7/23/20 4:24 AM, Istvan Toth wrote:
> The code looks OK.
> Check that you can resolve the name of, and have IP connectivity to 
> *each *HBase host (master/regionserver) in the cluster.
> 
> regards
> Istvan
> 
> On Wed, Jul 22, 2020 at 3:01 PM 黄乐平 <18702515445@163.com 
> <mailto:18702515445@163.com>> wrote:
> 
>     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
>     <http://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 INTEGERNOT 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
> 
>     <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E9%BB%84%E4%B9%90%E5%B9%B3&uid=18702515445%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fsm3214e50fe940c3f555b8ce0825ca3497.jpg&items=%5B%2218702515445%40163.com%22%5D>
> 
>     签名由 网易邮箱大师
>     <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制
> 

Mime
View raw message