多数据源 数据库切换 使用指南：spring和ibatis如何支持多个数据库？spring ibatis 多数据库

Spring + iBatis多数据库支持实战指南：轻松应对数据源切换

场景引入：当你的应用需要连接多个数据库

想象一下这个场景：你正在开发一个电商平台，用户数据存在MySQL，订单数据在Oracle，而商品信息又放在PostgreSQL里，每次查询都要手动切换连接？那太痛苦了！或者你的SaaS应用需要为每个租户提供独立数据库？别担心，Spring+iBatis的组合拳能帮你优雅解决这些问题。

下面我就手把手教你如何用Spring和iBatis实现多数据库支持,让你的应用像变魔术一样在不同数据库间自由切换。

基础配置：多数据源定义

我们需要在Spring配置中定义多个数据源,这里以MySQL和Oracle为例：

<!-- applicationContext.xml -->
<bean id="mysqlDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://localhost:3306/mydb"/>
    <property name="username" value="root"/>
    <property name="password" value="password"/>
</bean>
<bean id="oracleDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
    <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>
    <property name="username" value="scott"/>
    <property name="password" value="tiger"/>
</bean>

动态数据源路由：关键的核心

要实现动态切换,我们需要一个能根据当前上下文选择合适数据源的机制：

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DatabaseContextHolder.getDatabaseType();
    }
}
// 使用ThreadLocal保存当前数据源类型
public class DatabaseContextHolder {
    private static final ThreadLocal<DatabaseType> contextHolder = new ThreadLocal<>();
    public static void setDatabaseType(DatabaseType type) {
        contextHolder.set(type);
    }
    public static DatabaseType getDatabaseType() {
        return contextHolder.get();
    }
    public static void clearDatabaseType() {
        contextHolder.remove();
    }
}
public enum DatabaseType {
    MYSQL, ORACLE
}

然后在Spring配置中将它们组装起来：

<bean id="dynamicDataSource" class="com.your.package.DynamicDataSource">
    <property name="targetDataSources">
        <map key-type="com.your.package.DatabaseType">
            <entry key="MYSQL" value-ref="mysqlDataSource"/>
            <entry key="ORACLE" value-ref="oracleDataSource"/>
        </map>
    </property>
    <property name="defaultTargetDataSource" ref="mysqlDataSource"/>
</bean>

iBatis集成配置

接下来配置iBatis的SqlMapClient,使用我们刚定义的动态数据源：

<bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
    <property name="configLocation" value="classpath:sql-map-config.xml"/>
    <property name="dataSource" ref="dynamicDataSource"/>
</bean>

别忘了在sql-map-config.xml中配置你的SQL映射文件：

<sqlMapConfig>
    <sqlMap resource="com/your/package/maps/UserSQL.xml"/>
    <sqlMap resource="com/your/package/maps/OrderSQL.xml"/>
    <!-- 其他SQL映射文件 -->
</sqlMapConfig>

实战应用：如何切换数据库

现在到了最精彩的部分——实际使用中如何切换数据库，这里有几个实用方法：

方法1：手动切换（适合简单场景）

// 切换到MySQL
DatabaseContextHolder.setDatabaseType(DatabaseType.MYSQL);
userDao.getUserById(1); // 这个操作会在MySQL上执行
// 切换到Oracle
DatabaseContextHolder.setDatabaseType(DatabaseType.ORACLE);
orderDao.getOrderById(100); // 这个操作会在Oracle上执行
// 记得清理ThreadLocal
DatabaseContextHolder.clearDatabaseType();

方法2：注解驱动（推荐方式）

创建一个自定义注解来标记需要特定数据库的方法：

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface TargetDataSource {
    DatabaseType value() default DatabaseType.MYSQL;
}

然后通过AOP实现自动切换：

@Aspect
@Component
public class DataSourceAspect {
    @Before("@annotation(targetDataSource)")
    public void before(JoinPoint joinPoint, TargetDataSource targetDataSource) {
        DatabaseType databaseType = targetDataSource.value();
        DatabaseContextHolder.setDatabaseType(databaseType);
    }
    @After("@annotation(targetDataSource)")
    public void after(JoinPoint joinPoint, TargetDataSource targetDataSource) {
        DatabaseContextHolder.clearDatabaseType();
    }
}

使用示例：

@Repository
public class OrderDaoImpl extends SqlMapClientDaoSupport implements OrderDao {
    @TargetDataSource(DatabaseType.ORACLE)
    public Order getOrderById(long id) {
        return (Order) getSqlMapClientTemplate().queryForObject("Order.getById", id);
    }
    @TargetDataSource(DatabaseType.MYSQL)
    public User getUserByOrder(long orderId) {
        return (User) getSqlMapClientTemplate().queryForObject("Order.getUserByOrder", orderId);
    }
}

高级技巧：处理跨数据库事务

当你需要跨数据库操作时,事务管理变得复杂，Spring的JtaTransactionManager可以帮到你：

<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
    <!-- 配置你的JTA实现，如Atomikos或Bitronix -->
</bean>

或者,如果你不想用分布式事务，可以采用最终一致性模式：

@Transactional
public void placeOrder(Order order) {
    try {
        // 在Oracle中创建订单
        DatabaseContextHolder.setDatabaseType(DatabaseType.ORACLE);
        orderDao.create(order);
        // 在MySQL中更新用户状态
        DatabaseContextHolder.setDatabaseType(DatabaseType.MYSQL);
        userDao.updateOrderCount(order.getUserId());
    } catch (Exception e) {
        // 补偿逻辑
        DatabaseContextHolder.setDatabaseType(DatabaseType.ORACLE);
        orderDao.cancel(order.getId());
        throw e;
    } finally {
        DatabaseContextHolder.clearDatabaseType();
    }
}

常见问题及解决方案

问题1：SQL方言差异 不同数据库SQL语法可能有差异，解决方法：

• 为不同数据库准备不同的SQL映射文件
• 使用iBatis的动态SQL功能处理差异

<!-- 在SQL映射文件中 -->
<select id="getUsers" parameterClass="map" resultClass="User">
    <isEqual property="databaseType" compareValue="MYSQL">
        SELECT * FROM users LIMIT #offset#, #limit#
    </isEqual>
    <isEqual property="databaseType" compareValue="ORACLE">
        SELECT * FROM (
            SELECT a.*, ROWNUM rnum FROM (
                SELECT * FROM users
            ) a WHERE ROWNUM <= #offset# + #limit#
        ) WHERE rnum > #offset#
    </isEqual>
</select>

问题2：连接泄漏 确保每次操作后清理ThreadLocal，可以使用Filter或Interceptor：

public class DataSourceCleanupFilter implements Filter {
    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) 
            throws IOException, ServletException {
        try {
            chain.doFilter(request, response);
        } finally {
            DatabaseContextHolder.clearDatabaseType();
        }
    }
}

性能优化建议

1. 连接池配置：为每个数据源单独配置合适的连接池参数
2. SQL缓存：iBatis的SqlMapClient可以缓存预处理语句
3. 批量操作：跨数据库批量操作时考虑分批处理
4. 监控：实现数据源使用情况的监控

<!-- 示例：更细致的连接池配置 -->
<bean id="mysqlDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <!-- 基础配置省略 -->
    <property name="initialSize" value="5"/>
    <property name="maxActive" value="20"/>
    <property name="maxIdle" value="10"/>
    <property name="minIdle" value="5"/>
    <property name="testWhileIdle" value="true"/>
    <property name="timeBetweenEvictionRunsMillis" value="60000"/>
</bean>

通过Spring和iBatis的组合,我们实现了：

1. 多数据源的统一管理
2. 运行时动态数据库切换
3. 简洁的注解驱动编程模型
4. 基本的跨数据库事务支持

记住几个最佳实践：

• 总是清理ThreadLocal
• 为不同数据库准备差异化的SQL
• 考虑使用连接池监控工具
• 复杂的跨库事务考虑最终一致性模式

现在你的应用已经具备了在多个数据库间自由穿梭的能力,无论是多租户架构、数据分区还是遗留系统集成，都能应对自如了！