没有合适的资源?快使用搜索试试~ 我知道了~
本文主要介绍Groovy对数据的CRUD操作,熟悉groovy.sql包,测试使用的数据库是H2。 1.数据库连接配置 <span xss=removed>//数据库连接配置<br>def db = [<br> url:'jdbc:h2:mem:groovy',<br> user:'root',<br> password:'root',<br> driver:'org.h2.Driver'<br>];<br></span> 2.创建数据库连接,这里使用到Groovy的Sql类。
资源推荐
资源详情
资源评论




















便捷轻巧的便捷轻巧的Groovy数据库操作数据库操作
本文主要介绍Groovy对数据的CRUD操作,熟悉groovy.sql包,测试使用的数据库是H2。
1.数据库连接配置
<span style="font-family:'宋体', SimSun;font-size:16px;">//数据库连接配置<br>def db = [<br>
url:'jdbc:h2:mem:groovy',<br> user:'root',<br> password:'root',<br> driver:'org.h2.Driver'<br>];<br></span>
2.创建数据库连接,这里使用到Groovy的Sql类。
<span style="font-family:'宋体', SimSun;font-size:16px;">//创建数据库连接<br>def sql = Sql.newInstance(db.url,
db.user, db.password, db.driver);<br></span>
3.创建数据库表
<span style="font-size:14px;font-family:'宋体', SimSun;">//创建数据库表<br>sql.execute('''<br> CREATE TABLE
account(<br> id integer NOT NULL,<br> name varchar(20),<br> url varchar(100)<br> )<br>''');<br>
</span>
使用了groovy.sql.Sql类的execute方法执行一条SQL命令,在数据库groovy中创建了表account。
4.向数据库表中写入数据,并查询写入的数据
<span style="font-family:'宋体', SimSun;font-size:16px;">//写入数据<br>def datas=[<br> [100, 'Jack',
'http://www.jack.net'], <br> [101, 'Groovy', 'http://groovy.com'], <br> [102, 'Apache', 'http://apache.org']<br>];
<br>datas.each { param-><br> sql.execute('INSERT INTO account(id, name, url) values(?,?,?)', param);<br>}
<br>println('Insert After:');<br>sql.eachRow('SELECT id, name, url FROM account') { row-><br> printf('|%d|%s|%s|
', row.id, row.name, row.url);<br>}<br></span>
从4中的程序可以看出,向表account中写入3条数据记录,然后查询并遍历出查询结果,再这一过程中使用了Groovy的闭
包特性,列表数据结构。
下面是查询的结果:
<span style="font-family:'宋体', SimSun;font-size:16px;">Insert After:<br>|100|Jack|http://www.jack.net|
<br>|101|Groovy|http://groovy.com|<br>|102|Apache|http://apache.org|<br></span>
5.查询数据
<span style="font-family:'宋体', SimSun;font-size:16px;">//查询第一行数据<br>def rs=sql.firstRow('SELECT * FROM
account');<br>println('Query First Row:');<br>println(rs);<br></span>
Groovy的Sql类提供了大量的查询方法(具体参见Groovy的API),上面5中的代码是查询第一条记录,返回的类型是
GroovyRowReasult,其实现了Map接口。打印输出则是一个Groovy的Map类型表示。如下:
<span style="font-family:'宋体', SimSun;font-size:16px;">Query First Row:<br>[ID:100, NAME:ZhangSan,
URL:http://aiilive.blog.51cto.com]<br></span>
6.更新数据
<span style="font-family:'宋体', SimSun;font-size:16px;">def name='ZhangSan';<br>def
url='http://aiilive.blog.51cto.com';<br>sql.executeUpdate("UPDATE account SET name=$name, url=$url where id=100");
<br>println('Update After:');<br>sql.eachRow('SELECT id, name, url FROM account') { row-><br> printf('|%d|%s|%s|
', row.id, row.name, row.url);<br>}<br></span>
7.删除数据
<span style="font-family:'宋体', SimSun;font-size:16px;">//删除指定条件的数据<br>name='Groovy';
<br>sql.executeUpdate('DELETE FROM account WHERE name = ?', [name]);<br>name='Apache';
<br>sql.execute('DELETE FROM account WHERE name=:name', ['name':name]);<br>println('Delete After:');
<br>sql.eachRow('SELECT id, name, url FROM account') { row-><br> printf('|%d|%s|%s|
', row.id, row.name, row.url);<br>}<br></span>
8.使用DataSet来处理数据
DataSet是Sql类的直接子类,用DataSet来操作数据库表更加有操作对象的样子。
<span style="font-family:'宋体', SimSun;font-size:16px;">def account=sql.dataSet('account');<br>
<br>account.add([id:103, name:'h2', url:'http://h2.org']);<br><br>name='51cto';<br>url='http://www.51cto.com';
<br>account.add([id:104, name:name, url:url]);<br><br>println('DataSet Update After');<br>account.eachRow('SELECT
id, name, url FROM account') { row-><br> printf('|%d|%s|%s|
', row.id, row.name, row.url);<br>};<br>def accountRows=account.rows();<br>accountRows.each { row-><br>
printf('|%d|%s|%s|
', row.id, row.name, row.url);<br>}<br></span>
如上dataSet的参数account表示数据库中的表名。account是一个DataSet类型的对象,通过add方法想数据库表中添加一
条记录,通过rows方法返回数据库表中的所有记录,如果rows方法添加参数则可以实现分页的功能。
上面通过groovy.sql包提供的API实现了数据库的基本操作,而该包中的类的其它更多的方法能够实现更丰富的操作。下
面介绍数据库表和对象的映射操作以及集成Spring来操作数据库表。数据库表和对象的映射操作:
1.准备工作
创建一个抽象的类SqlQuery
<span style="font-family:'宋体', SimSun;font-size:16px;">import groovy.sql.*;<br><br>abstract class SqlQuery {<br>
<br> def sql;<br> def query;<br><br> def SqlQuery(sql,query){<br> this.sql=sql;<br> this.query=query;<br> }
<br><br> def execute(){<br> def rowList=sql.rows(query);<br> def results=[];<br> def size=rowList.size();
<br> 0.upto(size-1) { index-><br> results <<this.mapRow(rowList[index]);<br> }<br> return results;<br> }
<br><br> def abstract mapRow(row);<br>}<br></span>
创建一个Account类,其属性对应account表的字段
<span style="font-family:'宋体', SimSun;font-size:16px;">class Account {<br><br> def id;<br> def name;<br> def url;
<br><br> @Override<br> public String toString() {<br> return "|$id|$name|$url|";<br> }<br>}<br></span>
创建一个AccountQuery类继承SqlQuery类并实现其中的抽象方法rowMap
资源评论

weixin_38526914
- 粉丝: 7
- 资源: 912

上传资源 快速赚钱
我的内容管理 展开
我的资源 快来上传第一个资源
我的收益
登录查看自己的收益我的积分 登录查看自己的积分
我的C币 登录后查看C币余额
我的收藏
已下载
下载帮助

相关资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈



安全验证
文档复制为VIP权益,开通VIP直接复制
