Verbinden mit Apache Phoenix mit JDBC und Java

Question

Ich habe ein kleines Java-Programm, in dem ich versuche, eine Verbindung zu einem Remote-Phoenix-Server, den ich ausgeführt habe, herzustellen.

package jdbc_tests; 

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.sql.Statement; 

public class PhoenixTest { 

    static final String JDBC_DRIVER = "org.apache.phoenix.jdbc.PhoenixDriver"; 
    static final String IP = "<placeholder>" 
    static final String PORT = "<placeholder>" 
    static final String DB_URL = "jdbc:phoenix://" + IP + ":" + PORT + "/"; 

    public static void main(String[] args) { 
     Connection conn = null; 
     Statement st = null; 

     try { 
      Class.forName("org.apache.phoenix.jdbc.PhoenixDriver"); 

      System.out.println("Connecting to database.."); 

      conn = DriverManager.getConnection(DB_URL); 

      System.out.println("Creating statement..."); 

      st = conn.createStatement(); 
      String sql; 
      sql = "SELECT DISTINCT did FROM sensor_data"; 
      ResultSet rs = st.executeQuery(sql); 

      while(rs.next()) { 
       String did = rs.getString(1); 
       System.out.println("Did found: " + did); 
      } 

      rs.close(); 
      st.close(); 
      conn.close(); 

     } catch (SQLException se) { 
      se.printStackTrace(); 
     } catch (Exception e) { 
      // Handle errors for Class.forName 
      e.printStackTrace(); 
     } finally { 
      // finally block used to close resources 
      try { 
       if (st != null) 
        st.close(); 
      } catch (SQLException se2) { 
      } // nothing we can do 
      try { 
       if (conn != null) 
        conn.close(); 
      } catch (SQLException se) { 
       se.printStackTrace(); 
      } // end finally try 
     } // end try 
    System.out.println("Goodbye!"); 
    } 
} 

Wenn ich versuche, mein Programm laufen zu lassen, erhalte ich:

java.sql.SQLException: No suitable driver found for jdbc:phoenix://<ip>:<port>/ 

Ich habe das folgende Glas aus der Apache Phoenix Distribution hinzugefügt:

phoenix-4.9.0-HBase-1.2-client.jar 

die mein Phoenix und Hbase Spiele vesions .

Was mache ich falsch?

Answer 1

Ich glaube, Sie den Namen Ihrer Datenbank fehlen und auch die URL Nähte nicht korrekt:

"jdbc:phoenix://" + IP + ":" + PORT + "/" + DB_NAME 
//--------------------------------------------^^ 

Sie haben mit dieser URL Anstatt versuchen:

Connection con = DriverManager.getConnection("jdbc:phoenix:<IP>:<port>:/<DB_NAME>");