`
comicme_yanghe
  • 浏览: 8224 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

Nano Framework之启用多数据源支持并添加多数据源事务处理

    博客分类:
  • Java
阅读更多
本文基于前几篇文章为基础进行编写,需要了解前篇内容的浏览我的博客中的其他文章
今天的主题是使用Nano Framework开发多数据源及多数据源事务处理的示例

1、修改配置并添加新的数据源配置
1.1、修改context.properties
# 将属性mapper.package.jdbc=/examples-jdbc.properties修改为如下配置
mapper.package.root=examples,examples2
mapper.package.jdbc.examples=/examples-jdbc.properties
mapper.package.jdbc.examples2=/examples2-jdbc.properties


1.2、添加examples2-jdbc.properties
JDBC.environment.id=examples2

JDBC.pool.type=DRUID
JDBC.driver=org.h2.Driver
JDBC.url=jdbc:h2:~/test2
JDBC.username=test
JDBC.password=test
JDBC.autoCommit=false

# 省略连接池的属性配置


2、新建数据库及表结构
2.1、启动服务并访问 http://ip:port/first-webapp/console,使用以下信息登录
  • URL: jdbc:h2:~/test2
  • 用户名: test
  • 密码: test


2.2、建表
create table t_nano_test (
id int primary key,
name varchar(255)
)


3、添加多数据源操作代码
3.1、修改JdbcExamplesDao及JdbcExamplesDaoImpl,添加delete方法
long delete(int id) throws SQLException;

private final String deleteById = "DELETE FROM T_NANO_TEST WHERE ID = ? ";

@Override
public long delete(int id) throws SQLException {
    return get(DataSource.EXAMPLES.value()).executeUpdate(deleteById, new ArrayList<Object>() {
        private static final long serialVersionUID = 1L; { 
        add(id); 
    }});
}


3.2、增加JdbcExamplesMoveDao及JdbcExamplesMoveDaoImpl
@ImplementedBy(JdbcExamplesMoveDaoImpl.class)
public interface JdbcExamplesMoveDao { 
    long insert(Test test) throws SQLException;
}

public class JdbcExamplesMoveDaoImpl implements JdbcExamplesMoveDao {

    private final String insert = "INSERT INTO T_NANO_TEST(ID, NAME) VALUES (?, ?) ";

    @Override
    public long insert(Test test) throws SQLException {
        List<Object> values = new ArrayList<>();
        values.add(test.getId());
        values.add(test.getName());
        return get(DataSource.EXAMPLES2).executeUpdate(insert, values);
    }
}


3.3、添加Component实现,修改JdbcExamplesComponent及JdbcExamplesComponentImpl
@RequestMapping("/persist/move/{id}")
Object move(@PathVariable("id") Integer id);

@Inject
private JdbcExamplesMoveDao examplesMoveDao;

@JdbcTransactional(envId = {DataSource.EXAMPLES, DataSource.EXAMPLES2})
@Override
public Object move(Integer id) {
    try {
        Test test = examplsDao.select(id);
        if(test == null) {
            return ResultMap.create(200, "Not Found Data", "WARNING");
        } else {
            if(examplesMoveDao.insert(test) > 0) {
                examplsDao.delete(id);
            }
        }
    } catch(Exception e) {
        throw new ComponentInvokeException(e.getMessage(), e);
    }

    return ResultMap.create(200, "OK", "SUCCESS");
}


4、启动服务后进行以下操作
  • http://ip:port/first-webapp/jdbc/persist/move/1
  • http://ip:port/first-webapp/console并登陆test2库查询迁移数据


5、至此,多数据源及多数据源事务的示例就开发完了

0
1
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics