便捷轻巧的Groovy数据库操作

本文主要介绍Groovy对数据的CRUD操作，熟悉groovy.sql包，测试使用的数据库是H2。

　　1.数据库连接配置

//数据库连接配置 def db = [ url:'jdbc:h2:mem:groovy', user:'root', password:'root', driver:'org.h2.Driver' ];

　　2.创建数据库连接，这里使用到Groovy的Sql类。

//创建数据库连接 def sql = Sql.newInstance(db.url, db.user, db.password, db.driver);

　　3.创建数据库表

//创建数据库表 sql.execute(''' CREATE TABLE account( id integer NOT NULL, name varchar(20), url varchar(100) ) ''');

　　使用了groovy.sql.Sql类的execute方法执行一条SQL命令，在数据库groovy中创建了表account。

　　4.向数据库表中写入数据，并查询写入的数据

//写入数据 def datas=[ [100, 'Jack', 'http://www.jack.net'], [101, 'Groovy', 'http://groovy.com'], [102, 'Apache', 'http://apache.org'] ]; datas.each { param-> sql.execute('INSERT INTO account(id, name, url) values(?,?,?)', param); } println('Insert After:'); sql.eachRow('SELECT id, name, url FROM account') { row-> printf('|%d|%s|%s|\n', row.id, row.name, row.url); }

　　从4中的程序可以看出，向表account中写入3条数据记录，然后查询并遍历出查询结果，再这一过程中使用了Groovy的闭包特性，列表数据结构。

　　下面是查询的结果：

　　5.查询数据

//查询第一行数据 def rs=sql.firstRow('SELECT * FROM account'); println('Query First Row:'); println(rs);

　　Groovy的Sql类提供了大量的查询方法（具体参见Groovy的API），上面5中的代码是查询第一条记录，返回的类型是GroovyRowReasult，其实现了Map接口。打印输出则是一个Groovy的Map类型表示。如下：

Query First Row: [ID:100, NAME:ZhangSan, URL:http://aiilive.blog.51cto.com]

　　6.更新数据

def name='ZhangSan'; def url='http://aiilive.blog.51cto.com'; sql.executeUpdate("UPDATE account SET name=$name, url=$url where id=100"); println('Update After:'); sql.eachRow('SELECT id, name, url FROM account') { row-> printf('|%d|%s|%s|\n', row.id, row.name, row.url); }

　　7.删除数据

//删除指定条件的数据 name='Groovy'; sql.executeUpdate('DELETE FROM account WHERE name = ?', [name]); name='Apache'; sql.execute('DELETE FROM account WHERE name=:name', ['name':name]); println('Delete After:'); sql.eachRow('SELECT id, name, url FROM account') { row-> printf('|%d|%s|%s|\n', row.id, row.name, row.url); }

　　8.使用DataSet来处理数据

　　DataSet是Sql类的直接子类，用DataSet来操作数据库表更加有操作对象的样子。

def account=sql.dataSet('account'); account.add([id:103, name:'h2', url:'http://h2.org']); name='51cto'; url='http://www.51cto.com'; account.add([id:104, name:name, url:url]); println('DataSet Update After'); account.eachRow('SELECT id, name, url FROM account') { row-> printf('|%d|%s|%s|\n', row.id, row.name, row.url); }; def accountRows=account.rows(); accountRows.each { row-> printf('|%d|%s|%s|\n', row.id, row.name, row.url); }

　　如上dataSet的参数account表示数据库中的表名。account是一个DataSet类型的对象，通过add方法想数据库表中添加一条记录，通过rows方法返回数据库表中的所有记录，如果rows方法添加参数则可以实现分页的功能。

　　上面通过groovy.sql包提供的API实现了数据库的基本操作，而该包中的类的其它更多的方法能够实现更丰富的操作。下面介绍数据库表和对象的映射操作以及集成Spring来操作数据库表。　数据库表和对象的映射操作：

　　1.准备工作

　　创建一个抽象的类SqlQuery

import groovy.sql.*; abstract class SqlQuery { def sql; def query; def SqlQuery(sql,query){ this.sql=sql; this.query=query; } def execute(){ def rowList=sql.rows(query); def results=[]; def size=rowList.size(); 0.upto(size-1) { index-> results <<this.mapRow(rowList[index]); } return results; } def abstract mapRow(row); }

　　创建一个Account类，其属性对应account表的字段

class Account { def id; def name; def url; @Override public String toString() { return "|$id|$name|$url|"; } }

　　创建一个AccountQuery类继承SqlQuery类并实现其中的抽象方法rowMap

import com.demo.db.SqlQuery; class AccountQuery extends SqlQuery { def AccountQuery(sql){ super(sql, 'SELECT id, name, url FROM account'); } @Override public Object mapRow(Object row) { //映射非常之灵活 //def acc=new Account(id:row.getAt('id'),name:row.getAt('name'),url:row.getAt('url')); //def acc=new Account(id:row.getAt(0),name:row.getAt(1),url:row.getAt(2)); def acc=new Account( id:row.getProperty('id'), name:row.getProperty('name'), url:row.getProperty('url')); return acc; } }

　　AccountQuery类实现了rowMap方法，正是该方法将对象和表记录关联起来的，即达到了Table - Object的映射效果。

　　注意：上面代码中的注释部分是实现同样功能的不同写法。

　　2.通过SqlQuery类来查询account表的数据

//表映射对象查询 def accountQuery=new AccountQuery(sql); def accList=accountQuery.execute(); println 'Table <-> Object Query: '; accList.each { acc-> println acc.toString(); }

　　accList则是Account对象的一个数组集合，这样就实现了数据库表和对象的映射操作。

　　集成Spring来操作数据库表：

　　1.准备工作

　　Spring提供了一个MappingSqlQuery类，我们可以用AccountQuery继承该类并实行其中的rowMap方法来达到数据库表和对象的映射。

import com.demo.db.Account; import org.springframework.jdbc.object.MappingSqlQuery class AccountQuery extends MappingSqlQuery { def AccountQuery(ds){ super(ds,'SELECT id, name, url FROM account'); this.compile(); } @Override protected Object mapRow(ResultSet rs, int rowNumber) throws SQLException { def acc=new Account( id:rs.getInt('id'), name:rs.getString('name'), url:rs.getString('url')); return acc; } }

　　需要注意的地方是Spring的MappingSqlQuery类的带参数构造方法需要提供一个DataSource对象和查询的SQL命令。

　　创建一个Account类的DAO类，AccountDAO来实现数据库的操作，可以定义一个接口，然后另外实现该接口。应用程序操作数据库则只需要依赖定义的接口即可。这里省略了接口的定义。

class AccountDao { def ds; def getAccounts(){ def aq=new AccountQuery(ds); return aq.execute(); } }

　　AccountDao有一个getAccounts方法，通过该方法则可以获取到表account的所有记录，通过AccountQuery的Mapping映射，将返回一个集合对象。

　　2.通过AccountDao类操作数据库

//集成Spring def ds=new DriverManagerDataSource(db.url, db.user, db.password); def accountDao=new AccountDao(ds:ds); accLists=accountDao.getAccounts(); println 'Spring MappingSqlObject Query: '; accList.each { acc-> println acc.toString(); }

　　至此Groovy操作数据库就到这里了。Groovy让Java操作数据库变得轻巧许多，同时又没有引入多余复杂的API负担。了解PHP的数据库操作就能很快感受到Groovy让Java操作数据库不那么繁琐了。

　　题外话：

　　很遗憾过了这么就才反映过来，应该拥抱Groovy，在经历学习的Python,PHP和Nodejs之后，就更应该在已有的Java知识的基础上使用这个据说是"Java时代的王储"的动态语言。固步自封是可怕的，停留在舒适区更是后果不堪设想。放下，才能更轻松的上路，才能走的更远。

　　在面对动不动就SSH， SSM，TSH，JSF等框架堆砌Java应用的时候，会有那么一个夜晚，突然累了，疲惫了。人就像一只猴子被困在囚笼里，跳着千篇一律的舞蹈骗取欣赏，有自知索然无味却不得以为之的和这囚笼纠缠在一起，不得自己。不久，就被发展的潮流拍到沙滩，碎岩之上。

　　面对生产效率和机器效率之间的取舍不见得能达成一致的协议，但技术服务于生产，想法化为产品，则更需要容易表达和实现这些东西的技术，把复杂的事情简单化应该是技术追求的目标。

posted on 2014-09-23 09:48 顺其自然EVO 阅读(1650) 评论(0) 编辑收藏所属分类: 测试学习专栏、数据库

新用户注册刷新评论列表


只有注册用户登录后才能发表评论。




网站导航: 博客园 IT新闻知识库 C++博客博问管理
相关文章: 如何进行Web服务的性能测试？利用drozer进行Android渗透测试 Appium Android Bootstrap源码分析之命令解析执行 Fliptest—iOS 的应用A/B测试框架 iOS功能测试工具 Frank iOS单元测试框架Kiwi for iOS Appium Android Bootstrap之控件AndroidElement 移动应用测试框架—Calabash Android 简介 Appium Server源码分析之作为Bootstrap客户端移植MonkeyRunner的图片对比功能实现-Appium篇

qileilove

便捷轻巧的Groovy数据库操作

导航

统计

常用链接

留言簿(55)

随笔分类

随笔档案

文章分类

文章档案

搜索

最新评论

阅读排行榜

评论排行榜