连接数据库,这里要创建一个sql实例来操作数据库,必须加载jdbc驱动包,使用两个注解,否则会报错:
import groovy.sql.Sql
url='jdbc:mysql://localhost:3307/test?useUnicode=true&characterEncoding=utf8'
driver='com.mysql.jdbc.Driver'
username='root'
passwd='123456'
//可以指定maven仓库
//@GrabResolver(name = 'aliyun', root = 'http://maven.aliyun.com/nexus/content/groups/public/')
//加载数据库连接驱动包
@Grab('mysql:mysql-connector-java:5.1.25')
@GrabConfig(systemClassLoader = true)
//创建sql实例
def sql = Sql.newInstance(url, username, passwd, driver)
查询:
eachRow: 对结果在闭包中进行处理:
sql.eachRow("select * from `user`") {
println it[0] //可以按表字段从左到右依次下标访问
println it.name //直接按字段名访问
}
//支持元数据闭包显示
sql.eachRow("select * from `user`",{ meta->
//元数据闭包只会调用一次
meta.columnCount.times {
print meta.getColumnName(it+1)+" "
print meta.getColumnClassName(it+1)+" "
print meta.getColumnDisplaySize(it+1)+" "
print meta.getColumnType(it+1)+"---"
println meta.getColumnTypeName(it+1)
}
}) {
//可以按表字段从左到右依次下标访问或者字段名字访问
println it[0]+" "+it.name
}
可以看到输出:
还有rows等查询方法,支持非常多的重载方法,可以根据需求传入各种参数,和jdbc用法基本都一样,比如:
println sql.rows(['id':3],"select * from `user` where id>:id").size() //map参数
println sql.rows("select * from `user` where id>?",[3]).size() // list参数
println sql.firstRow("select * from `user`") //返回第一个
最后贴上表结构: