做网站第三方,h5case是什么网站,密云石家庄网站建设,做网站后有人抢注品牌关键字在Spring中配置Spark hive-thriftserver的连接DataSource与配置其他数据源连接方式是一样的#xff0c;如一般Oracle数据源配置#xff0c;使用如下必须的Jar包#xff1a;使用JDBC程序示例#xff1a;package com.hadoop.test;import java.sql.Connection;
import java.sq… 在Spring中配置Spark hive-thriftserver的连接DataSource与配置其他数据源连接方式是一样的如一般Oracle数据源配置使用如下必须的Jar包使用JDBC程序示例package com.hadoop.test;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;public class ThreadSql extends Thread {Overridepublic void run() {excSparkSql();}public void excSparkSql() {String result ;Connection conn null;Statement stmt null;try {Class.forName(org.apache.hadoop.hive.jdbc.HiveDriver);conn DriverManager.getConnection(jdbc:hive://10.20.12.214:10000/test_db, hduser001, );stmt conn.createStatement();String sql select count(1) from test_data ; long start System.currentTimeMillis();ResultSet res stmt.executeQuery(sql);long cost System.currentTimeMillis() - start;result Thread.currentThread().getName() : cost/1000.0f s;System.out.println(result);stmt.close();conn.close();} catch (Exception e) {try {stmt.close();conn.close();} catch (SQLException e1) {// TODO Auto-generated catch blocke1.printStackTrace();}e.printStackTrace();}}}在Spring中配置如下类似oracle的datasource配置并在其他的ServiceBean中将其注入即可 bean iddataService classcom.sun.dt.service.impl.DataServiceImplproperty namedataDao refsparkDataSource/property/beanbean idoralceDataSource classorg.apache.commons.dbcp.BasicDataSource destroy-methodclose property namedriverClassName value${jdbc.driver} / property nameurl value${jdbc.url} / property nameusername value${jdbc.username} / property namepassword value${jdbc.password} /property namemaxActive value${jdbc.maxActive} /property namemaxIdle value${jdbc.maxIdle} /property namemaxWait value${jdbc.maxWait} /property namedefaultAutoCommit value${jdbc.defaultAutoCommit} //bean bean idsparkDataSource classorg.apache.commons.dbcp.BasicDataSource destroy-methodclose property namedriverClassName valueorg.apache.hadoop.hive.jdbc.HiveDriver / property nameurl valuejdbc:hive://192.168.10.124:10000/test_db / property nameusername valuehduser001 / property namepassword value /property namemaxActive value8 /property namemaxIdle value3 /property namemaxWait value5 //bean 转载于:https://blog.51cto.com/xubcing/1607384
