便捷，轻巧的Groovy数据库操作-阿里云开发者社区

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的闭包特性，列表数据结构。

下面是查询的结果：

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|\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应用的时候，会有那么一个夜晚，突然累了，疲惫了。人就像一只猴子被困在囚笼里，跳着千篇一律的舞蹈骗取欣赏，有自知索然无味却不得以为之的和这囚笼纠缠在一起，不得自己。不久，就被发展的潮流拍到沙滩，碎岩之上。

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

本文转自 secondriver 51CTO博客，原文链接：http://blog.51cto.com/aiilive/1555523，如需转载请自行联系原作者