Support Questions

Find answers, ask questions, and share your expertise
Announcements
Now Live: Explore expert insights and technical deep dives on the new Cloudera Community BlogsRead the Announcement

Who agreed with this solution

avatar
Super Collaborator

Hi,

 

Maybe you could share the java source code doing the connection ?

Here is a really small working sample :

 

 

public class ManageHive {

private static String driverName = "org.apache.hive.jdbc.HiveDriver";
private static Logger logger = Logger.getLogger(ManageHive.class);

public static Connection getConnection(LoadProperties prop, String user) throws ClassNotFoundException, SQLException {

String hiveJdbc = prop.getPropertyByName("hive_jdbc");

try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
throw e;
}
Connection conn2 = DriverManager.getConnection(hiveJdbc+"/extraction", user, "");
return conn2;
}

public static void execSql(LoadProperties prop, String user, String sql) throws SQLException, ClassNotFoundException {

Connection maConn = getConnection(prop,user);
Statement stmt = maConn.createStatement();

int result = stmt.executeUpdate(sql);
if ( result == Statement.EXECUTE_FAILED ) {
throw new SQLException("Erreur d'execution.");
}
}
}

 

 

 

View solution in original post

Who agreed with this solution