java 調(diào)用groovy腳本，實現(xiàn)多個sql按指定邏輯運(yùn)行，可做報表預(yù)聚合

1、引入pom

<dependency><groupId>org.codehaus.groovy</groupId><artifactId>groovy</artifactId><version>2.1.6</version></dependency><dependency><groupId>org.codehaus.groovy</groupId><artifactId>groovy-jsr223</artifactId><version>2.1.6</version></dependency>

2、調(diào)用腳本

其中，getConnection()方法需自己實現(xiàn)，就是簡單的根據(jù)用戶名密碼獲取數(shù)據(jù)庫連接

public static void main(String[] args) throws Exception {ScriptEngineManager factory = new ScriptEngineManager();ScriptEngine engine = factory.getEngineByName("groovy");Bindings binding = engine.createBindings();binding.put("connection", getConnection());// 綁定jdbc鏈接String script = getScript();engine.eval(script, binding);// 綁定腳本和connectionObject res = ((Invocable) engine).invokeFunction("execute", null);// 執(zhí)行System.out.println(res);List<Map<String, Object>> list = getList((ResultSet)res); // 轉(zhuǎn)換結(jié)果listSystem.out.println(list);}// 返回groovy腳本語言，這個只做示例，里面可以寫各種邏輯，且不局限于mysqlprivate static String getScript(){return "def execute(){return connection.prepareStatement('select * from business').executeQuery();}";}// executeQuery方法返回的對象轉(zhuǎn)成listprivate static List<Map<String, Object>> getList(ResultSet resultSet) throws SQLException {ResultSetMetaData metaData = resultSet.getMetaData();int cols_len = metaData.getColumnCount();List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();while (resultSet.next()) {Map<String, Object> map = new HashMap<>();String colName;for (int i = 0; i < cols_len; i++) {map.put(colName = metaData.getColumnLabel(i + 1), resultSet.getString(colName));}list.add(map);}return list;}

總結(jié)

以上是生活随笔為你收集整理的java 调用groovy脚本，实现多个sql按指定逻辑运行，可做报表预聚合的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。