osgi实战项目(osmp)一步一步玩转osgi之jdbc（6）
已经有很长一段时间没有更新了，年底了比较忙，最近很多新加入的朋友在问jdbc这段,今天抽点空讲一下osmp-jdbc的封装。
osmp的jdbc相比其它框架的来讲主要有以下几点不同。
- 基于druid的多数据源管理
- 支持多种类型的数据库，目前支持mysql,oracle,mssql。
- 提供数据源动态创建和消毁
- 提供基于动态sql管理和解析
- 提供类似于mybaties的springTemplate的dao封装
最开始的时候我的想法很简单，给我一个数据库链接，给我一个sql语句，我就能给你想要的数据，结合osgi的动态性来实现。
先从动态数据源来说，从resources/META-INF/spring/jdbc-context.xml 配置文件当中我们可以看到，spring配置文件加载后，我们实例化了 com.osmp.jdbc.service.SqlStatementManager, com.osmp.jdbc.service.SqlStatementMonitor, com.osmp.jdbc.service.DataSourceManager, com.osmp.jdbc.service.DataSourceMonitor这四个类，分别为sql语句管理，sql语句监控，数据源管理，数据源监控。
DataSourceMonitor（数据源监控）实现spring 的 InitializingBean和 DisposableBean接口，实例化传入了数据源配置目录和数据源管理两个参数，bean初始时通过传入的数据源配置目录获取所有配置并解析后实例化DruidDataSource 添加到DataSourceManager中。 同时启了一个线程监控数据源配置目录，如果一旦有新增的配置后解析并添加到数据源管理里。代码如下
@Override
public void afterPropertiesSet() throws Exception {
Assert.notNull(dataSourceDir, "dataSource文件目录不能为空...");
Assert.notNull(dataSourceManager, "dataSourceManager未初始化...");
final File resFile = new File(dataSourceDir);
Assert.isTrue(resFile.exists(), "dataSource文件目录不存在...");
filepath2datasourceNameMap.clear();
for(File file : resFile.listFiles()){
addDataSource(file.getName());
}
new Thread(){
public void run(){
try {
monitor(resFile);
} catch (Exception e) {
e.printStackTrace();
}
}
}.start();
}
文件监控使用的是jdk1.7的 WatchService 服务，这里不作详细介绍 ，有兴趣的同学自己百度吧。
private void monitor(File file) throws Exception{
watchService = FileSystems.getDefault().newWatchService();
file.toPath().register(watchService, StandardWatchEventKinds.ENTRY_CREATE,StandardWatchEventKinds.ENTRY_DELETE);
while(running){
WatchKey watchKey = watchService.take();
List<WatchEvent<?>> events = watchKey.pollEvents();
if(events != null){
for(WatchEvent<?> e : events){
//事件处理
final WatchEvent<Path> watchEventPath = (WatchEvent<Path>)e;
final Path filename = watchEventPath.context();
if(e.kind() == StandardWatchEventKinds.ENTRY_CREATE){
addDataSource(filename.toString());
}else if(e.kind() == StandardWatchEventKinds.ENTRY_DELETE){
removeDataSource(filename.toString());
}
}
}
if(!watchKey.reset()){
watchKey.cancel();
logger.error("移除dataSource文件目录监控服务");
break;
}
}
running = false;
watchService.close();
}
只要数据源配置目录一旦有文件添加、删除、修改事件发生，都会进行相应的处理，新增、删除、修改数据源，这也是动态数据源的核心部分，我相信同学们看了后，在以后的项目当中也可以使用 WatchService 服务实现更多动态功能吧。切记WatchService 服务是 JDK1.7以后才提供的功能。
有了数据源后，我们更进一步的将数据源与springTemplate结合，通过JdbcTemplateManager来管理模板，通过 JdbcTemplateManager 的 addDataSource方法，根据数据库类型实例化不同数据库的模板并添加到JdbcTemplateManager里。
com.osmp.jdbc.service.JdbcTemplateManager
//添加数据源信息
public void addDataSource(DataSource ds,String catalog,DBType dbType){
if(ds == null || catalog == null || dbType == null) return;
BaseTemplate jdbcTemplate = null;
if(dbType.equals(DBType.SQLSERVER)){
jdbcTemplate = new MSSQLTemplate();
}else if(dbType.equals(DBType.MYSQL)){
jdbcTemplate = new MysqlTemplate();
}else{
jdbcTemplate = new OracleTemplate();
}
jdbcTemplate.setOwnJdbcTemplate(new NamedParameterJdbcTemplate(ds));
jdbcTemplate.setTransactionManager(new DataSourceTransactionManager(ds));
//dsTransactionManager.setGlobalRollbackOnParticipationFailure(false); //指定主事务决定回滚
templates.put(catalog.toUpperCase(), jdbcTemplate);
}
com.osmp.jdbc.support.JdbcTemplate 封装了大量的C,R,U,D操作，方便业务开发直接调用。
现在我们只需要一个数据源的标识加一句sql，我们就可以执行C,R,U,D操作了。
上面我们介绍了动态数据源这部分，下面我们该聊一聊动态sql了。我大概记得当时我是想直接在osgi环境下集成mybaties来着，好像研究了两周最后我放弃了，基于mybaties的开发习惯，自己写了一套类似于东东，有点儿重复造*吧。
其实实现也很简单：
sql配置文件 + 一个sql配置文件解析器 + 一个RowMapper实现类
首先我们定义了一个dtd文件用以限定sql 配置文件。
我们通过动态数据的方式，SqlStatementMonitor监听一个目录作为sql脚本xml的目录。当有sql配置脚本xml添加的时候就解析xml文件并保存到SqlStatmentManager里。
一旦有新的sql配置xml被添加后，就会进入SqlStatementMonitor.SqlUpdateTask.run() 方法被解析后加载到SqlStatementManager 里。
//sql文件更新任务
private class SqlUpdateTask implements Runnable {
private File file;
private boolean isDelete;
public SqlUpdateTask(File file,boolean isDelete){
this.file = file;
this.isDelete = isDelete;
}
public void run() {
if(file == null) return;
String filename = file.getAbsolutePath();
if(!filename.endsWith(".xml")){
return;
}
sqlStatementManager.removeSqls(filename);
if(isDelete) return;
sqlStatementManager.putSql(filename, SqlParserUtils.parse(file));
}
}
SQL配置是类mybaties的配置。最开始想直接mybaties的解析部分，看了一下很难，还不如自己写了，所以基本上myabties支持的。osmp也基本支持，甚至支持更多的高级特性，比如include advanced等，有待同学们自己发掘，当时你也可以自己扩充。这部有兴趣的同学可以重构，将数据源与sql解析剥离出来。
osmp同时提供 JdbcDao封装，只需要sql配置xml里的 id + 数据源名称就可以返回数据了。这也对应上面提到的需求，给一个sql + 数据源链接 我返给你结果。。。
随便提一下。对于实体bean 和 ResultSet之间的转换是通过定义 Column注解来进行的。获取数据的时候 需要传入一个 实体.class 通过反射解析@Column 从 ResultSet里获取数据 详见 com.osmp.jdbc.define.tool.ToolsRowMapper
最后看一下 sql xml的定义例子
<?xml version="1.0" encoding="UTF-8" standalone="no" ?> <!DOCTYPE sqls SYSTEM "osmp_sql.dtd"> <sqls> <select id="demo.queryuser"> select * from demo_user <where> <if test="name not empty"> and name=:name </if> <if test="age not empty"> and age=:age </if> </where> </select> <insert id="demo.adduser"> insert into demo_user(id,name,age,remark) values(:id,:name,:age,:remark) </insert> <delete id="demo.deluser"> delete demo_user where id=:id </delete> <update id="demo.upuser"> update demo_user set <if test="name not empty"> name = :name </if> <if test="age not empty"> name = :age </if> <if test="remark not empty"> remark = :remark </if> <where> id = :id </where> </update> <select id="demo.choose.when"> select x,y,z from xxx WITH ( NOLOCK ) where x in ( select x,y,z from yyy with(nolock) where ISNULL(x, '') != '' <choose> <when test="acctype == 0"><![CDATA[ and x=:x ]]></when> <when test="acctype == 1">and y=:y</when> </choose> ) </select> </sqls>
sql更多高级动态特性还有待朋友们自己去发掘，我们开发的时候只需要将 此sql的配置xml和 数据源的properties配置 分别放到 ${servicemix_home}/etc/sqls 和 ${servicemix_home}/etc/datasources 目录下，就会被动态解析保存和动态创建数据源。
最后一步，我们将JdbcFinderManager发布为一个osgi的服务供其它的bundle调用。
resource/META-INF/spring/jdbc-context.xml
<osgi:service interface="com.osmp.jdbc.support.JdbcFinderManager" ref="osmp.JdbcFinderManager"> </osgi:service>
接下来我们只需要写一个简单的demo调用他们就行了。
下一讲我们实战讲解怎么demo开发一个用户的增删改查。
