java操作Apache druid的例項程式碼
阿新 • • 發佈:2020-11-15
1. 新增maven依賴包
<dependency> <groupId>org.apache.calcite.avatica</groupId> <artifactId>avatica-core</artifactId> <version>1.15.0</version> </dependency>
2. 編寫工具類
package com.hnu.druid; import org.apache.calcite.avatica.AvaticaConnection; import org.apache.calcite.avatica.AvaticaStatement; import org.springframework.stereotype.Component; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; import java.util.Properties; /** * @description: * @author: YUANHX * @create: 7:11 下午 **/ @Component public class DruidJdbcUtil { private static ThreadLocal<AvaticaConnection> threadLocal = new ThreadLocal<>(); private static final String DRUID_URL = "jdbc:avatica:remote:url=http://172.16.0.160:8888/druid/v2/sql/avatica/"; /** * 開啟連線 * @param * @return * @throws SQLException */ public static AvaticaConnection connection() throws SQLException { Properties properties = new Properties(); AvaticaConnection connection = (AvaticaConnection) DriverManager.getConnection(DRUID_URL,properties); threadLocal.set(connection); return connection; } /** * 關閉連線 * @throws SQLException */ public static void closeConnection() throws SQLException{ System.out.println("關閉執行緒:"+threadLocal.get()); AvaticaConnection conn = threadLocal.get(); if(conn != null){ conn.close(); threadLocal.remove(); } } /** * 根據sql查詢結果 * @param * @param sql * @return * @throws SQLException */ public static ResultSet executeQuery (String sql) throws SQLException{ AvaticaStatement statement = connection().createStatement(); ResultSet resultSet = statement.executeQuery(sql); return resultSet; } /*public static Object crud(String sql,Class clazz,List<Object> params) throws SQLException{ AvaticaStatement statement = connection().createStatement(); Object obj = null; for (int i = 0; i < params.size(); i++) { statement.set } return obj; }*/ public static void main(String[] args) { try { String sql = "SELECT * FROM \"vehicleCondition\" limit 20"; for (int i = 0; i < 5; i++) { ResultSet resultSet = executeQuery(sql); System.out.println("開始連線"+i + "; 連線執行緒:"+threadLocal.get()); while(resultSet.next()){ String equipmentCode = resultSet.getString("EquipmentCode"); String vkaCode = resultSet.getString("VKACode"); // System.out.println(equipmentCode + " ; "+ vkaCode); } closeConnection(); } } catch (SQLException throwables) { throwables.printStackTrace(); } } }
到此這篇關於java操作Apache druid的例項程式碼的文章就介紹到這了,更多相關java操作Apache druid內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們!