1.数据库连接配置
|
1
2
3
4
5
6
7
|
//数据库连接配置
def
db = [
url:
'jdbc:h2:mem:groovy'
,
user:
'root'
,
password:
'root'
,
driver:
'org.h2.Driver'
];
|
2.创建数据库连接，这里使用到Groovy的Sql类。
|
1
2
|
//创建数据库连接
def
sql = Sql.newInstance(db.url, db.user, db.password, db.driver);
|
3.创建数据库表
|
1
2
3
4
5
6
7
8
|
//创建数据库表
sql.execute(
''
'
CREATE TABLE account(
id integer NOT NULL,
name varchar(
20
),
url varchar(
100
)
)
''
');
|
使用了groovy.sql.Sql类的execute方法执行一条SQL命令，在数据库groovy中创建了表account。
4.向数据库表中写入数据，并查询写入的数据
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
//写入数据
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的闭包特性，列表数据结构。
下面是查询的结果：
|
1
2
3
4
|
Insert After:
|100|Jack|http://www.jack.net|
|101|Groovy|http://groovy.com|
|102|Apache|http://apache.org|
|
5.查询数据
|
1
2
3
4
|
//查询第一行数据
def
rs=sql.firstRow(
'SELECT * FROM account'
);
println
(
'Query First Row:'
);
println
(rs);
|
Groovy的Sql类提供了大量的查询方法（具体参见Groovy的API），上面5中的代码是查询第一条记录，返回的类型是GroovyRowReasult，其实现了Map接口。打印输出则是一个Groovy的Map类型表示。如下：
|
1
2
|
Query First Row:
[ID:
100
, NAME:ZhangSan, URL:http:
//aiilive.blog.51cto.com]
|
6.更新数据
|
1
2
3
4
5
6
7
|
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.删除数据
|
1
2
3
4
5
6
7
8
9
|
//删除指定条件的数据
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来操作数据库表更加有操作对象的样子。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
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表的数据
|
1
2
3
4
5
6
7
|
//表映射对象查询
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方法来达到数据库表和对象的映射。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
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来实现数据库的操作，可以定义一个接口，然后另外实现该接口。应用程序操作数据库则只需要依赖定义的接口即可。这里省略了接口的定义。
|
1
2
3
4
5
6
7
|
class
AccountDao {
def
ds;
def
getAccounts(){
def
aq=
new
AccountQuery(ds);
return
aq.execute();
}
}
|
AccountDao有一个getAccounts方法，通过该方法则可以获取到表account的所有记录，通过AccountQuery的Mapping映射，将返回一个集合对象。
2.通过AccountDao类操作数据库
|
1
2
3
4
5
6
7
8
|
//集成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，如需转载请自行联系原作者
