欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

bboss持久层操作hive实例

程序员文章站 2022-05-24 12:29:55
...
先在应用中导入bboss 持久层和hive驱动(bboss persistent版本号5.0.1,以实际为准:查看[url=http://repo1.maven.org/maven2/com/bbossgroups/bboss-persistent/]最新版本号[/url]):
[size=large][b]maven坐标[/b][/size]

<dependency>
<groupId>com.bbossgroups</groupId>
<artifactId>bboss-persistent</artifactId>
<version>5.0.1</version>
</dependency>
<dependency>
<groupId>org.apache.hive</groupId>
<artifactId>hive-jdbc</artifactId>
<version>2.1.0</version>
</dependency>


[size=large][b]gradle坐标[/b][/size]
compile 'com.bbossgroups:bboss-persistent:5.0.1'
compile 'org.apache.hive:hive-jdbc:'2.1.0'

bboss持久层操作hive实例
[size=large][b]启动hive数据源,dbname为test[/b][/size]
 try{
SQLUtil.startPool("test",//数据源名称
"org.apache.hive.jdbc.HiveDriver",//hive驱动
"jdbc:hive2://hadoop34:10000/default",//hive链接串
"hadoop","hadoop",//数据库账号和口令
"select 1 " //数据库连接校验sql
);

[size=large][b]在hive数据源上执行查询,dbname为test:[/b][/size]
List<HashMap> datas = SQLExecutor.queryListWithDBName(HashMap.class,"test", "select * from t_hive");
for(int i = 0; datas != null && i < datas.size(); i ++)
{
System.out.println(datas.get(i));
}
} catch(SQLException e) {
e.printStackTrace();
}