1、各存储类型连接-工具类

  1. 1、需引入各个存储类型sdk依赖
  2. 2、Demo：
  3.     @Slf4j
  4.     public class JdbcUtil {
  5.         private static String PHOENIX_DRIVER = "org.apache.phoenix.queryserver.client.Driver";
  6.         //private static final String PHOENIX_DRIVER = "org.apache.phoenix.jdbc.PhoenixDriver";
  7.         private static final String HIVE_DRIVER = "org.apache.hive.jdbc.HiveDriver";
  8.         private static final String ODPS_DRIVER = "com.aliyun.odps.jdbc.OdpsDriver";
  10.         /**
  11.          * 获取odps连接
  12.          * @param record 数据源信息
  13.          * @return
  14.          * @throws Exception
  15.          */
  16.         public static Connection getOdpsConnection(DataSourceConfDO record) throws Exception {
  17.             //odps.url=jdbc:odps:http://service.cn.maxcompute.aliyun.com/api?project=city_brain_dev1
  18.             ReqParamCheckUtil.objCheck(record, "数据源连接信息为空");
  19.             String url = "jdbc:odps:" + record.getEndpoint() + "?project=" + record.getProjectName();
  20.             Class.forName(ODPS_DRIVER);
  21.             Connection conn = DriverManager.getConnection(url, record.getUserName(), record.getPassword());
  22.             log.debug("获取odps连接信息，连接成功");
  23.             return conn;
  24.         }
  26.         /**
  27.          * 获取hive连接
  28.          *
  29.          * @param record 数据源信息
  30.          * @return
  31.          * @throws Exception
  32.          */
  33.         public static Connection getHiveConnection(DataSourceConfDO record) throws Exception {
  34.             ReqParamCheckUtil.objCheck(record, "数据源连接信息为空");
  35.             Class.forName(HIVE_DRIVER);
  36.             Connection conn = DriverManager.getConnection(record.getEndpoint(), record.getUserName(), record.getPassword());
  37.             log.debug("获取hive连接信息，连接成功");
  38.             return conn;
  39.         }
  41.         /**
  42.          * 获取phoenix连接
  43.          *
  44.          * @param record 数据源信息
  45.          * @return
  46.          * @throws Exception
  47.          */
  48.         public static Connection getPhoenixConnection(DataSourceConfDO record) throws Exception {
  49.             ReqParamCheckUtil.objCheck(record, "数据源连接信息为空");
  50.             Class.forName(PHOENIX_DRIVER);
  51.             Connection conn = DriverManager.getConnection(record.getEndpoint(), record.getUserName(), record.getPassword());
  52.             log.debug("获取phoenix连接信息，连接成功");
  53.             return conn;
  54.         }
  56.         /**
  57.          * 获取hbase连接信息
  58.          * @param dataSourceConf
  59.          * @return
  60.          * @throws IOException
  61.          */
  62.         public static org.apache.hadoop.hbase.client.Connection getHBaseConnect(DataSourceConfDO dataSourceConf) throws IOException {
  63.             ReqParamCheckUtil.objCheck(dataSourceConf, "数据源连接信息为空");
  64.             System.setProperty("hadoop.home.dir", "/");
  65.             Configuration conf = HBaseConfiguration.create();
  66.             conf.set("hbase.zookeeper.quorum", dataSourceConf.getEndpoint());
  67.             conf.set("hbase.zookeeper.property.clientPort", dataSourceConf.getPort());
  68.             conf.set("log4j.logger.org.apache.hadoop.hbase", "WARN");
  69.             org.apache.hadoop.hbase.client.Connection conn = ConnectionFactory.createConnection(conf);
  70.             return conn;
  71.         }
  73.         /**
  74.          *  获取ots连接信息
  75.          * @param dataSourceConf
  76.          * @return
  77.          */
  78.         public static SyncClient getOtsClient(DataSourceConfDO dataSourceConf) {
  79.             ReqParamCheckUtil.objCheck(dataSourceConf, "数据源连接信息为空");
  80.             ClientConfiguration clientConfiguration = new ClientConfiguration();
  81.             clientConfiguration.setConnectionTimeoutInMillisecond(5000);
  82.             clientConfiguration.setSocketTimeoutInMillisecond(5000);
  83.             clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy());
  84.             SyncClient client = new SyncClient(
  85.                     dataSourceConf.getEndpoint(),
  86.                     dataSourceConf.getUserName(),
  87.                     dataSourceConf.getPassword(),
  88.                     dataSourceConf.getProjectName(),
  89.                     clientConfiguration);
  90.             return client;
  91.         }
  92.     }