Groovy访问oracle数据库
发布时间:2020-12-14 16:47:41 所属栏目:大数据 来源:网络整理
导读:Groovy访问数据库,间接,方便。 需要提前将ojdbc5.jar放到groovy'的lib文件夹下面,或者确保你Groovy能去读该驱动,例如-cp? .;xxx.jar;? 等等 import groovy.sql.Sql import java.sql.Connection; sql = Sql.newInstance( "jdbc:oracle:thin:@xxxxxx:orcl"
Groovy访问数据库,间接,方便。 需要提前将ojdbc5.jar放到groovy'的lib文件夹下面,或者确保你Groovy能去读该驱动,例如-cp? .;xxx.jar;? 等等 import groovy.sql.Sql import java.sql.Connection; sql = Sql.newInstance( "jdbc:oracle:thin:@xxxxxx:orcl","OR01","OR01PW","oracle.jdbc.driver.OracleDriver") println("执行查询语句"); //------------------------------------------------------------------------------ //-----从表------------------------------------------------------------------------- sql.connection.autoCommit = false; String insertSql = "INSERT INTO auth_token2(id,version,user2_id,token,expiration,description,os_user)"+ " VALUES(?,?,?)" String getOldTokenSql = "SELECT U.user2_id,AT.token,AT.expiration,"+ " AT.description,UU.name FROM auth_token AT LEFT JOIN user U ON AT.user_id = U.id " String deleteOldTokenSql = "DELETE FROM auth_token" sql.eachRow(getOldTokenSql) { row -> String tokenId = UUID.randomUUID() String user2Id = row['user2_id'] String token = row['token'] def expiration = row['expiration'] (该字段为Long类型,可以删除中文注释) String desc = row['description'] String name = row['name'] sql.executeUpdate(insertSql,[tokenId,user2Id,desc,name]) println "token ${token}" } sql.executeUpdate(deleteOldTokenSql); sql.commit(); (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |