Groovy对Java?JDBC?API进行了封装,提供了一个Facade?--?groovy.sql.Sql,从而隐藏了获取数据库连接、关闭资源等细节
用法如下:
import groovy.sql.Sql; db = Sql.newInstance ( url:"jdbc:sqlserver://localhost;databaseName=db_test", user:"sa", password:"sa", driverClassName:"com.microsoft.sqlserver.jdbc.SQLServerDriver" )
?
Sql对象中有很多查询方法,常用的方式如下所示:
l?Query(GString,?Closure),对返回的ResultSet执行Closure,示例方法如下:
? l?rows(GString),返回List。示例用法如下:
? l?eachRow(GString,Closure),对结果集的每行执行Closure。示例用法如下:
? l?firstRow(GString),返回结果集的第一条记录,示例用法如下:
? 常用GUID方法 l?execute(GString),execute(String)或者execute(string,paramsList),可用于增加、更新、删除记录; 使用execute(GString)执行插入的代码如下:
? 使用PreparedStatement的代码如下:
? 使用execute(String)执行Sql脚本的代码如下:
? l?executeInsert(GString),executeInsert(String)或者executeInsert(string,paramsList),用于增加记录; l?executeUpdate(GString),executeUpdate(String)或者executeUpdate(string,paramsList),用于更新记录。
数据集(DataSet) 这里要重点介绍的是另外一种快捷增加记录的方法--DataSet。 DataSet和数据库里的表对应,可以对DataSet的内容进行查询、增加操作。请看如下代码:
Date.findAll方法的成功运行要将groovy类文件的src目录放在classpath下,详情参见: http://jira.codehaus.org/browse/GROOVY-2450
http://jira.codehaus.org/browse/GROOVY-544 从上述代码中可以看到,创建DateSet实例后,就能够获得一个Map,可以对这个Map执行findAll(whereClosure)以及sort(sortClosure)。而这里增加数据使用的是add(Map)方法。在对数据库进行增加、更新或者删除时,需要考虑事务性,以保证数据的完整性。对于此,Groovy同样提供了一个非常方便的用法。对于需要在同一个事务中完成的代码,可以使用Sql或者DataSet的withTransaction(Closure)方法实现,参见如下代码:
? 上述代码中,由于在第8行代码会出错,所以整段代码不会在T_user表中插入新的纪录的。读者可以将withTransaction方法去掉,再看看程序运行的结果。 DateSet虽然进一步简化了SQL操作,但缺点是只能适用于一张表。可以使用SQL将复杂的结果生成一个视图,之后用DataSet来访问这个视图。 上述这些就是Groovy提供的方法,它们使得跟数据库的交互变得轻松了许多! db.query "Select * From T_Sport", {
while(it.next()){
println it.getString("F_Name")
}
}
db.rows( "Select * From T_Sport").each {row->
println row['F_Name']
}
db.eachRow "Select * From T_Sport", {
println it['F_Name']
}
def arow = db.firstRow("Select * From T_Sport")
println arow
def ACode = "ACode"
def AName = "AName"
def AMemo = "AMemo"
db.execute """insert into T_User(F_Code, F_Name, F_Memo)
Values(${ACode}, ${AName}, ${AMemo})"""
val = db.execute ("select * from T_User where F_ID = ?", [1])
String sqlFilePath = 'path/to/your/script.sql'
String sqlString = new File(sqlFilePath).text
db.execute (sqlString)
def users = db.dataSet ('T_User')
users.each { println it }
users.add (
F_Name:'李四',
F_Code:'M002',
F_Memo:'memo'
)
users.findAll {it.F_ID>0 }.sort{it.F_Name desc}.each {println it}
db.withTransaction {
for(i in 0..<5){
users.add (
F_Name:"name"+i,
F_Code:"code"+i,
F_Memo:"memo"+i)
}
db.execute 'delete from T_User Where i>0'
}