Java通过jdbc接口连接hive
1、版本信息
hive版本:3.1.2
jdbc:hive-jdbc-uber-2.6.5.0-292.jar
下载驱动地址:https://github.com/timveil/hive-jdbc-uber-jar/releases/tag/v1.9-2.6.5
2、pom.xml引用
<dependency> <groupId>org.appache.hive</groupId> <artifactId>hive-jdbc-uber</artifactId> <version>2.6.5.0-292</version> <scope>system</scope> <systemPath>${pom.basedir}/src/main/resources/lib/hive-jdbc-uber-2.6.5.0-292.jar</systemPath> </dependency>
3、对应的数据库表
CREATE TABLE regre_one.hive2_varchar(
ID int,
aes varchar(1000),
sm4 varchar(1000),
sm4_a varchar(1000),
email varchar(1000),
phone varchar(1000),
ssn varchar(1000),
military varchar(1000),
passport varchar(1000),
intelssn varchar(1000),
intelpassport varchar(1000),
intelmilitary varchar(1000),
intelganghui varchar(1000),
inteltaitonei varchar(1000),
credit_card_short varchar(1000),
credit_card_long varchar(1000),文章来源:https://www.toymoban.com/news/detail-743347.html
job varchar(1000));文章来源地址https://www.toymoban.com/news/detail-743347.html
4、Java通过jdbc接口连接hive的Java代码
package utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
/**
* Description :
*
* @author : HMF
* Date : Created in 15:28 2023/3/21
* @version :
*/
public class dbTest_hive {
public Connection conn;
public dbTest_hive(){
//String driver="org.apache.hive.jdbc.HiveDriver";
String driver="com.ciphergateway.aoe.plugin.engine.AOEDriver";
String url="jdbc:hive2:aoe://10.1.1.242:10000/default";
String user="xxx";
String password="xxx";
try{
Class.forName(driver);
conn= DriverManager.getConnection(url,user,password);
}catch (Exception e){
e.printStackTrace();
System.exit(1);
}
}
public static void main(String[] args) {
dbTest_hive db=new dbTest_hive();
String insertSql="INSERT INTO default.hive_char (id,aes, sm4, sm4_a, email, phone, ssn, military, passport, intelssn, intelpassport, intelmilitary, intelganghui, inteltaitonei, credit_card_short, credit_card_long, job) VALUES (1,'小芬', '北京xx网络技术有限公司', '北京市', 'hmf@yahoo.com', '15652996964', '210302199608124861', '武水电字第3632734号', 'BWP018930705', '210302199608124861', 'BWP018930705', '武水电字第3632734号', 'H21157232', '9839487602', '117', '6227612145830440', '高级测试开发工程师')";
String selectSql="select id,aes, sm4, sm4_a, email, phone, ssn, military, passport, intelssn, intelpassport, intelmilitary, intelganghui, inteltaitonei, credit_card_short, credit_card_long, job from default.hive_char";
//String deleteSql="truncate table regre_one.hivetest_varchar";
//db.DBExecute(deleteSql);
db.DBExecute(insertSql);
db.DBQuery(selectSql);
System.exit(0);
}
void DBExecute(String sqlStr){
try{
Statement stmt=conn.createStatement();
boolean result=stmt.execute(sqlStr);
System.out.println("+++++sqlStr:"+sqlStr);
stmt.close();
}catch (Exception e){
e.printStackTrace();
}
}
void DBQuery(String sqlStr){
try{
Statement statement=conn.createStatement();
ResultSet rs=statement.executeQuery(sqlStr);
int columnCount=rs.getMetaData().getColumnCount();
System.out.println("+++++sqlStr:"+sqlStr);
while (rs.next()){
String result="";
for(int i=0;i<columnCount;i++){
result +="\t"+rs.getString(i+1);
}
System.out.println(result);
}
rs.close();
statement.close();
}catch (Exception e){
e.printStackTrace();
}
}
}
到了这里,关于Java(115)Java通过jdbc接口连接hive3.1.2的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!