question Re: Not able to connect phoenix via java jdbc in Support Questions

Not able to connect phoenix via java jdbc

nejmhadjmbarek — Mon, 11 Apr 2016 22:28:52 GMT

i'm trying to connect to phoenix using java jdbc , but i not succeed to etablish connection ,there is exemple show me how to write url of connection ??, i succeed to connect to phoenix by using sqlline.py

". /sqlline.py node4.bigdatau:2181 " this is my code java , thx

  try {
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
    }catch (ClassNotFoundException e) {
		System.out.println("Where is your  JDBC Driver?");
		e.printStackTrace();
	}
   conn =  DriverManager.getConnection(" jdbc:phoenix:195.154.55.93:2181");
    System.out.println("got connection");

Re: Not able to connect phoenix via java jdbc

rgelhausen — Mon, 11 Apr 2016 22:33:18 GMT

Hi @nejm hadjmbarek, can you post the error you're seeing? From the above, it looks like you've forgotten to include the ZooKeeper znode for HBase: "/hbase-unsecure". Try with the following connection string instead: "jdbc:phoenix:195.154.55.93:2181:/hbase-unsecure".

If you need a simple simple java application (with maven pomfile) that embeds and uses the Phoenix JDBC driver, take a look here.

Re: Not able to connect phoenix via java jdbc

elserj — Mon, 11 Apr 2016 22:34:11 GMT

The leading space in your JDBC url is likely problematic.

If that doesn't fix it, you should provide the error you are experiencing.

Re: Not able to connect phoenix via java jdbc

nejmhadjmbarek — Mon, 11 Apr 2016 22:46:31 GMT

thx ,@Randy Gelhausen,@Josh Elser

i get this error "

Exception in thread "main" java.sql.SQLException: ERROR 103 (08004): Unable to establish connection

Caused by: java.io.IOException: java.lang.reflect.InvocationTargetException" , yes i 'am using simple java app with maven pomfile but i get always this error .

Re: Not able to connect phoenix via java jdbc

ajay_kumar — Tue, 19 Apr 2016 06:11:41 GMT

@nejm hadjmbarek Remove the space inside connection string. Add zookeeper znode in the connection string .

jdbc:phoenix:<quorom>:<port>:[zk_rootNode]

If this doesn't work plz paste whole stack trace.

Re: Not able to connect phoenix via java jdbc

rkm6677 — Sun, 18 Aug 2019 11:20:40 GMT

Hi @nejm hadjmbarek, I'm Posting my code, which is working Fine:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.Statement;
public class phoenix_hbase 
{
 public static void main(String[] args) throws SQLException 
 {
  @SuppressWarnings("unused")
  Statement stmt = null;
  ResultSet rset = null;
 
  try 
  {
   Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
  } 
  catch (ClassNotFoundException e1) 
  {
   System.out.println("Exception Loading Driver");
   e1.printStackTrace();
  }
  try
  {
   Connection con = DriverManager.getConnection("jdbc:phoenix:172.31.124.43:2181:/hbase-unsecure");  //172.31.124.43 is the adress of VM, not needed if ur running the program from vm itself
   stmt = con.createStatement();
    
   PreparedStatement statement = con.prepareStatement("select * from javatest");
   rset = statement.executeQuery();
   while (rset.next()) 
   {
    System.out.println(rset.getString("mycolumn"));
   }
   statement.close();
   con.close();
  }
  catch(Exception e)
  {
   System.out.println(e.getMessage());
  }
 }
}