便捷轻巧的Groovy数据库操作

Veronica ·

更新时间:2024-11-10

· 534 次阅读

本文主要介绍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| '， row.id， row.name， row.url); } 　　从4中的程序可以看出，向表account中写入3条数据记录，然后查询并遍历出查询结果，再这一过程中使用了Groovy的闭包特性，列表数据结构。　　下面是查询的结果：　　Insert After: |100|Jack|http://www.jack.net| |101|Groovy|http://groovy.com| |102|Apache|http://apache.org| 　　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| '， 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| '， 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| '， row.id， row.name， row.url); }; def accountRows=account.rows(); accountRows.each { row-> printf('|%d|%s|%s| '， 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应用的时候，会有那么一个夜晚，突然累了，疲惫了。人像一只猴子被困在囚笼里，跳着千篇一律的舞蹈骗取欣赏，有自知索然无味却不得以为之的和这囚笼纠缠在一起，不得自己。不久，被发展的潮流拍到沙滩，碎岩之上。　　面对生产效率和机器效率之间的取舍不见得能达成一致的协议，但技术服务于生产，想法化为产品，则更需要容易表达和实现这些东西的技术，把复杂的事情简单化应该是技术追求的目标。

groovy

1024 个赞