? ?
? ? ?本文主要介绍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,?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,SimSun;font-size:16px;">?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,SimSun;font-size:16px;">? 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,?row.url);
};
def?accountRows=account.rows();
accountRows.each?{?row->
????printf('|%d|%s|%s|n',SimSun;font-size:16px;">? ?如上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,?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,?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.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应用的时候,会有那么一个夜晚,突然累了,疲惫了。人就像一只猴子被困在囚笼里,跳着千篇一律的舞蹈骗取欣赏,有自知索然无味却不得以为之的和这囚笼纠缠在一起,不得自己。不久,就被发展的潮流拍到沙滩,碎岩之上。
? ? ? ? 面对生产效率和机器效率之间的取舍不见得能达成一致的协议,但技术服务于生产,想法化为产品,则更需要容易表达和实现这些东西的技术,把复杂的事情简单化应该是技术追求的目标。