聲明：

此處需求是修改封裝的clickhouseUtil數(shù)據(jù)查詢引擎連接工具類。由于此類中的方法都是靜態(tài)方法。連接地址等參數(shù)需要根據(jù)不同環(huán)境改變。例如開發(fā)下地址，測試下地址，生產(chǎn)地址等，所有通過配置文件來獲取不同環(huán)境下的配置參數(shù)，但是使用的方法是靜態(tài)的，所有不能使用一般情況下的@value直接給變量賦值，需要用到spring 屬性的set方法來給靜態(tài)變量賦值，然后靜態(tài)方法使用靜態(tài)變量即可

方法：

第一步：在yml文件中配置需要的參數(shù)

clickhouse: address: jdbc:clickhouse://172.20.xxx.xxx:8123 username: default password: xxxxx db: marketing socketTimeout: 600000

第二步：

類上一定要先注明@Component注解，在程序啟動是自動加載，否則靜態(tài)參數(shù)仍舊獲取不到配置文件的值

創(chuàng)建靜態(tài)變量

給靜態(tài)變量set方法上添加@Value()

@Value('${clickhouse.address}') public void setClickhouseAddress(String address) { ClickHouseUtil.clickhouseAddress = address; }

最后在靜態(tài)方法中使用即可

@Componentpublic class ClickHouseUtil { private static String clickhouseAddress; private static String clickhouseUsername; private static String clickhousePassword; private static String clickhouseDB; private static Integer clickhouseSocketTimeout; @Value('${clickhouse.address}') public void setClickhouseAddress(String address) { ClickHouseUtil.clickhouseAddress = address; } @Value('${clickhouse.username}') public void setClickhouseUsername(String username) { ClickHouseUtil.clickhouseUsername = username; } @Value('${clickhouse.password}') public void setClickhousePassword(String password) { ClickHouseUtil.clickhousePassword = password; } @Value('${clickhouse.db}') public void setClickhouseDB(String db) { ClickHouseUtil.clickhouseDB = db; } @Value('${clickhouse.socketTimeout}') public void setClickhouseSocketTimeout(Integer socketTimeout) { ClickHouseUtil.clickhouseSocketTimeout = socketTimeout; } public static Connection getConn() { ClickHouseConnection conn = null; ClickHouseProperties properties = new ClickHouseProperties(); properties.setUser(clickhouseUsername); properties.setPassword(clickhousePassword); properties.setDatabase(clickhouseDB); properties.setSocketTimeout(clickhouseSocketTimeout); ClickHouseDataSource clickHouseDataSource = new ClickHouseDataSource(clickhouseAddress,properties); try { conn = clickHouseDataSource.getConnection(); return conn; } catch (SQLException e) { e.printStackTrace(); } return null; } public static List<JSONObject> exeSql(String sql){ log.info('cliockhouse 執(zhí)行sql：' + sql); Connection connection = getConn(); try { Statement statement = connection.createStatement(); ResultSet results = statement.executeQuery(sql); ResultSetMetaData rsmd = results.getMetaData(); List<JSONObject> list = new ArrayList(); while(results.next()){ JSONObject row = new JSONObject(); for(int i = 1;i<=rsmd.getColumnCount();i++){ row.put(rsmd.getColumnName(i),results.getString(rsmd.getColumnName(i))); } list.add(row); } return list; } catch (SQLException e) { e.printStackTrace(); } return null; } }

以上這篇springboot 使用yml配置文件給靜態(tài)變量賦值教程就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持好吧啦網(wǎng)。