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.");
}
}
}
