mirror of
https://gitee.com/mybatis-flex/mybatis-flex.git
synced 2025-12-07 00:58:24 +08:00
refactor: FlexTransactionFactory.java
This commit is contained in:
parent
9f1e632c79
commit
d6bfe0e266
@ -18,7 +18,7 @@ package com.mybatisflex.spring;
|
|||||||
import com.mybatisflex.core.datasource.FlexDataSource;
|
import com.mybatisflex.core.datasource.FlexDataSource;
|
||||||
import org.apache.ibatis.session.TransactionIsolationLevel;
|
import org.apache.ibatis.session.TransactionIsolationLevel;
|
||||||
import org.apache.ibatis.transaction.Transaction;
|
import org.apache.ibatis.transaction.Transaction;
|
||||||
import org.apache.ibatis.transaction.TransactionFactory;
|
import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
|
||||||
|
|
||||||
import javax.sql.DataSource;
|
import javax.sql.DataSource;
|
||||||
import java.sql.Connection;
|
import java.sql.Connection;
|
||||||
@ -27,7 +27,7 @@ import java.sql.Connection;
|
|||||||
* @author life
|
* @author life
|
||||||
* @author michael
|
* @author michael
|
||||||
*/
|
*/
|
||||||
public class FlexTransactionFactory implements TransactionFactory {
|
public class FlexTransactionFactory extends SpringManagedTransactionFactory {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@inheritDoc}
|
* {@inheritDoc}
|
||||||
|
|||||||
@ -34,7 +34,7 @@ import javax.annotation.Resource;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
@UseDataSource("ds3333")
|
@UseDataSource("ds1")
|
||||||
public class AccountController {
|
public class AccountController {
|
||||||
|
|
||||||
@Resource
|
@Resource
|
||||||
@ -57,8 +57,8 @@ public class AccountController {
|
|||||||
public String add(@RequestBody Account account) {
|
public String add(@RequestBody Account account) {
|
||||||
jdbcTemplate.queryForObject("select count(*) from tb_account",Integer.class);
|
jdbcTemplate.queryForObject("select count(*) from tb_account",Integer.class);
|
||||||
DataSourceKey.use("ds2");
|
DataSourceKey.use("ds2");
|
||||||
jdbcTemplate.update("INSERT INTO `flex_test`.`tb_account` ( `user_name`, `age`, `birthday`, `gender`, `is_delete`) VALUES ( '王五', 18, '2023-07-04 15:00:26', NULL, 000);");
|
jdbcTemplate.update("INSERT INTO `flex_test`.`tb_account` ( `user_name`, `age`, `birthday`, `is_delete`) VALUES ( '王五', 18, '2023-07-04 15:00:26', 0);");
|
||||||
DataSourceKey.use("ds3333");
|
DataSourceKey.use("ds1");
|
||||||
accountMapper.insert(account);
|
accountMapper.insert(account);
|
||||||
DataSourceKey.use("ds2");
|
DataSourceKey.use("ds2");
|
||||||
accountMapper.insert(account);
|
accountMapper.insert(account);
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user