1.核心思想:
思路 写道
通过spring对多数据源的管理,在dao中动态的指定相对应的datasource。
2.动态指定数据源的方法约定:
约定 写道
不同库的dao放到对应的包下例:Master库中的dao的包路径是com.***.db.master.*。slave库的dao包的路径应是com.***.db.slave.***。
判定数据原方法 写道
判定dao类的路径是否包含master或者slave从而加载对应的数据源
3.实现代码
- private void fixSession(){
- String name=this.getClass().getName();
- /**
- * 如果是master 包下的dao 全部指定为 masterSessionFactory
- */
- if(name.indexOf("com.xkorey.db.master")>-1){
- sessionFactory = masterSessionFactory;
- }
- /**
- * 默认的dao是 slaveSessionFactory 下的库
- */
- else{
- sessionFactory = slaveSessionFactory;
- }
- }
4.这样实现的缺点,暂时还未想到。欢迎网友补充。
缺陷 写道
未知
5.开始贴代码,附件(hsm.zip)是eclipse下的项目工程包。
6.建库、表sql
- --create database
- -- master database
- create database master character set `gbk` collate `gbk_chinese_ci`;
- -- slave database
- create database slave character set `gbk` collate `gbk_chinese_ci`;
- -- create tables
- use master;
- create table users(
- id int not null auto_increment,
- name varchar(20),
- age int,
- primary key(id)) ENGINE = INNODB,AUTO_INCREMENT=1000;
- use slave;
- create table user_info(
- id int not null auto_increment,
- uid int,
- info varchar(20),
- primary key(id)) ENGINE = INNODB,AUTO_INCREMENT=1000;
- --insert data
- use master;
- insert into users(name,age) values('xkorey',28);
- use slave;
- insert into user_info(uid,info) values(1000,'hello xkorey.');
7.maven jar包依赖 pom.xml
- <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <groupId>hsm</groupId>
- <artifactId>hsm</artifactId>
- <packaging>war</packaging>
- <version>0.0.1-SNAPSHOT</version>
- <name>hsm Maven Webapp</name>
- <url>http://maven.apache.org</url>
- <dependencies>
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <version>3.8.1</version>
- <scope>test</scope>
- </dependency>
- <!-- spring -->
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-context</artifactId>
- <version>3.2.3.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-context-support</artifactId>
- <version>3.2.3.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-orm</artifactId>
- <version>3.2.3.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-webmvc</artifactId>
- <version>3.2.3.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-web</artifactId>
- <version>3.2.3.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework.security</groupId>
- <artifactId>spring-security-core</artifactId>
- <version>3.1.4.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-tx</artifactId>
- <version>3.2.3.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-test</artifactId>
- <version>3.2.1.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.aspectj</groupId>
- <artifactId>aspectjweaver</artifactId>
- <version>1.7.2</version>
- </dependency>
- <!-- hibernate -->
- <dependency>
- <groupId>org.hibernate</groupId>
- <artifactId>hibernate-core</artifactId>
- <version>4.2.2.Final</version>
- </dependency>
- <dependency>
- <groupId>org.hibernate</groupId>
- <artifactId>hibernate-validator</artifactId>
- <version>4.2.0.Final</version>
- </dependency>
- <!-- mysql -->
- <dependency>
- <groupId>mysql</groupId>
- <artifactId>mysql-connector-java</artifactId>
- <version>5.1.25</version>
- </dependency>
- </dependencies>
- <build>
- <finalName>hsm</finalName>
- </build>
- </project>
8.spring配置文件
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:aop="http://www.springframework.org/schema/aop"
- xmlns:tx="http://www.springframework.org/schema/tx"
- xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
- http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
- http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
- http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
- ">
- <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
- <property name="locations">
- <list>
- <value>classpath:hsm-db-master.properties</value>
- <value>classpath:hsm-db-slave.properties</value>
- </list>
- </property>
- </bean>
- <context:annotation-config />
- <context:component-scan base-package="com.xkorey.db" />
- <import resource="db-master.xml" />
- <import resource="db-slave.xml" />
- </beans>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:aop="http://www.springframework.org/schema/aop"
- xmlns:tx="http://www.springframework.org/schema/tx"
- xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
- http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
- http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
- http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
- ">
- <!-- Hibernate Data Source -->
- <bean id="masterDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
- <property name="driverClassName"><value>${connection.master.driver_class}</value></property>
- <property name="url"><value>${connection.master.url}</value></property>
- <property name="username"><value>${connection.master.username}</value></property>
- <property name="password"><value>${connection.master.password}</value></property>
- </bean>
- <!-- Hibernate Session Factory -->
- <bean id="masterSessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
- <property name="dataSource"><ref local="masterDataSource"/></property>
- <property name="packagesToScan" value="com.xkorey.db.master" />
- <property name="hibernateProperties">
- <props>
- <prop key="hibernate.dialect">${hibernate.master.dialect}</prop>
- <prop key="hibernate.show_sql">true</prop>
- </props>
- </property>
- </bean>
- <!-- Transaction manager for a single Hibernate SessionFactory (alternative to JTA) HibernateTransactionManager -->
- <tx:annotation-driven transaction-manager="masterTransactionManager"/>
- <bean id="masterTransactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
- <property name="sessionFactory"><ref local="masterSessionFactory"/></property>
- </bean>
- </beans>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:aop="http://www.springframework.org/schema/aop"
- xmlns:tx="http://www.springframework.org/schema/tx"
- xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
- http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
- http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
- http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
- ">
- <!-- Hibernate Data Source -->
- <bean id="slaveDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
- <property name="driverClassName"><value>${connection.slave.driver_class}</value></property>
- <property name="url"><value>${connection.slave.url}</value></property>
- <property name="username"><value>${connection.slave.username}</value></property>
- <property name="password"><value>${connection.slave.password}</value></property>
- </bean>
- <!-- Hibernate Session Factory -->
- <bean id="slaveSessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
- <property name="dataSource"><ref local="slaveDataSource"/></property>
- <property name="packagesToScan" value="com.xkorey.db.slave" />
- <property name="hibernateProperties">
- <props>
- <prop key="hibernate.dialect">${hibernate.slave.dialect}</prop>
- <prop key="hibernate.show_sql">true</prop>
- </props>
- </property>
- </bean>
- <!-- Transaction manager for a single Hibernate SessionFactory (alternative to JTA) HibernateTransactionManager -->
- <tx:annotation-driven transaction-manager="slaveTransactionManager"/>
- <bean id="slaveTransactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
- <property name="sessionFactory"><ref local="slaveSessionFactory"/></property>
- </bean>
- </beans>
9.properties 配置文件
- hibernate.master.dialect=org.hibernate.dialect.MySQLInnoDBDialect
- connection.master.driver_class=com.mysql.jdbc.Driver
- connection.master.url=jdbc:mysql://localhost:3306/master?useUnicode=true&characterEncoding=gbk
- connection.master.username=root
- connection.master.password=这里是你连库的密码
- hibernate.slave.dialect=org.hibernate.dialect.MySQLInnoDBDialect
- connection.slave.driver_class=com.mysql.jdbc.Driver
- connection.slave.url=jdbc:mysql://localhost:3306/slave?useUnicode=true&characterEncoding=gbk
- connection.slave.username=root
- connection.slave.password=这里是你连库的密码
10.java 代码 略去 java bean 即spring中的model代码只贴 dao 。
父类dao
- public class GenericDao<T extends java.io.Serializable> {
- @Autowired
- @Qualifier("masterSessionFactory")
- private SessionFactory masterSessionFactory;
- @Autowired
- @Qualifier("slaveSessionFactory")
- private SessionFactory slaveSessionFactory;
- private SessionFactory sessionFactory;
- private void fixSession(){
- String name=this.getClass().getName();
- /**
- * 如果是master 包下的dao 全部指定为 masterSessionFactory
- */
- if(name.indexOf("com.xkorey.db.master")>-1){
- sessionFactory = masterSessionFactory;
- }
- /**
- * 默认的dao是 slaveSessionFactory 下的库
- */
- else{
- sessionFactory = slaveSessionFactory;
- }
- }
- public Session getSession() {
- fixSession();
- return sessionFactory.getCurrentSession();
- }
注意UsersDao的包路径是 package com.xkorey.db.master.dao;
- @Repository("UsersDao")
- public class UsersDao extends GenericDao<Users>{
- //根据网友建议其实也可以在dao中直接注入 sessionFactory 像这样
- // @Autowired
- // @Qualifier("masterSessionFactory")
- // private SessionFactory sessionFactory;
- }
注意UserinfoDao的包路径是 package com.xkorey.db.slave.dao;
- @Repository("UserinfoDao")
- public class UserinfoDao extends GenericDao<Userinfo>{
- // 根据网友建议实也可以在dao中直接注入 sessionFactory 像这样
- // @Autowired
- // @Qualifier("slaveSessionFactory")
- // private SessionFactory sessionFactory;
- }
- @Service("UsersService")
- @Transactional(value="masterTransactionManager")
- public class UsersService {
- @Autowired
- @Qualifier("UsersDao")
- private UsersDao usersDao;
- public int findUserAgeById(int id){
- Users users = (Users) usersDao.getSession().get(Users.class,id);
- return users.age;
- }
- }
- @Service("UserinfoService")
- @Transactional(value="slaveTransactionManager")
- public class UserinfoService {
- @Autowired
- @Qualifier("UserinfoDao")
- private UserinfoDao userinfoDao;
- public String findUserInfoById(int id){
- Userinfo userinfo = (Userinfo) userinfoDao.getSession().get(Userinfo.class,id);
- return userinfo.info;
- }
- }
11.junit 测试类
- @RunWith(SpringJUnit4ClassRunner.class)
- @ContextConfiguration(locations={"classpath:spring-base.xml"})
- public class TestDao {
- @Autowired
- @Qualifier("UsersService")
- private UsersService usersService;
- @Autowired
- @Qualifier("UserinfoService")
- private UserinfoService userinfoService;
- @Test
- public void testMutilDataSource(){
- int id=1000;
- System.out.println(usersService.findUserAgeById(id));
- System.out.println(userinfoService.findUserInfoById(id));
- }
- }
测试类运行结果:
- Hibernate: select users0_.id as id1_0_0_, users0_.age as age2_0_0_, users0_.name as name3_0_0_ from users users0_ where users0_.id=?
- 28
- Hibernate: select userinfo0_.id as id1_0_0_, userinfo0_.info as info2_0_0_, userinfo0_.uid as uid3_0_0_ from user_info userinfo0_ where userinfo0_.id=?
- hello xkorey.
截图:
12.最后贴张工程截图
13.项目环境
jdk7,eclipse Version: Kepler Release.maven:apache-maven-3.0.4
转载于:http://xkorey.iteye.com/blog/1920059
相关推荐
本文将深入探讨如何在SpringBoot项目中配置多数据源,并实现数据源的动态切换,帮助你理解和掌握这一核心技能。 首先,我们理解"多数据源"的概念。在SpringBoot应用中,多数据源意味着系统能够连接并操作多个不同的...
已经测试,分享下,spring mvc oracle双数据源,其他如mysql之类修改下sources.properties文件即可,描述可以到这个博客看 http://blog.csdn.net/wangpeng047/article/details/8866239
1. **数据源配置**:在Spring配置文件中,我们需要定义多个数据源bean,每个数据源对应一个数据库连接。这可能包括Druid或HikariCP这样的连接池配置。 2. **动态数据源**:Spring的AbstractRoutingDataSource类允许...
要配置双数据源,首先需要创建两个不同的`DataSource`实例,分别代表两个数据库。在Spring Boot中,我们可以使用`@Configuration`注解创建一个配置类,然后使用`@Bean`注解声明两个数据源。例如: ```java @...
在Spring Boot应用中,多数据源配置是一项重要的技术实践,特别是在大型系统中,可能需要连接到多个数据库以实现数据隔离、读写分离或是分布式事务管理。Spring Boot以其强大的自动化配置能力,使得设置多数据源变得...
本项目“springboot双数据源(oracle,mysql).rar”显然是一个使用SpringBoot实现多数据源的例子,允许应用程序同时连接并操作Oracle和MySQL两个数据库。以下将详细介绍实现这一功能的关键知识点。 1. **SpringBoot...
以上就是Spring Boot中结合MyBatis和Oracle配置双数据源的基本步骤。在实际开发中,还需要考虑事务管理、读写分离、路由策略等问题,但这里主要介绍了基础配置。通过这种方式,我们可以灵活地管理和操作多个数据库,...
在Spring Boot应用中,多数据源配置是一项关键的技术,它允许我们连接并操作多个数据库,例如MySQL和SQL Server。在本场景中,我们将探讨如何在Spring Boot中设置和管理这样的多数据源配置。 首先,我们需要了解`...
1. **配置双数据源** - 首先,为每个数据源创建一个配置类,通常命名为`DataSourceConfig`,并在其中定义两个`@Bean`方法,分别返回两个数据源。例如,我们可以用`primaryDataSource()`和`secondaryDataSource()`来...
本项目"springboot + mybatis +mysql+ sqlserver 双数据源"正是针对这种需求的一个解决方案,它利用SpringBoot框架、MyBatis持久层框架以及MySQL和SQLServer两种数据库,实现了数据源的自动切换,以满足不同业务场景...
接下来,我们将深入探讨如何使用这些技术实现双数据源配置。 首先,我们需要在SpringBoot项目中引入相关的依赖。对于MySQL,我们需要添加SpringBoot对JDBC的支持以及Mybatis-Plus的依赖。对于Oracle,除了JDBC支持...
当我们面临需要连接多个数据库的情况时,Spring的多数据源配置就显得尤为重要。本文将详细介绍如何在Spring中配置并实现多数据源,以及如何与MyBatis框架整合。 首先,我们需要理解什么是多数据源。在单数据源中,...
本项目基于SpringBoot 2.0框架和MyBatis持久层技术,实现了主从数据库双数据源的配置,确保在高并发环境下既能保证数据的一致性,又能提升读取效率。 SpringBoot 2.0是Spring框架的一个轻量级版本,它简化了Spring...
本文将详细讲解如何利用SpringBoot整合Oracle数据库实现双数据源的配置和使用,帮助开发者构建可扩展、高可用的应用系统。 首先,我们需要理解"双数据源"的概念。双数据源意味着应用程序可以同时访问两个不同的...
当项目需要同时连接并操作多个数据库时,就需要配置双数据源。本篇文章将详细介绍如何在Spring MVC项目中实现双数据源,以便应用程序能够根据业务需求灵活地切换或使用不同的数据库。 首先,我们需要在配置文件中...
**SpringBoot+MyBatis+阿里双数据源框架基础** 在现代企业级应用开发中,SpringBoot和MyBatis已经成为非常流行的开发框架。SpringBoot以其便捷的启动方式、自动配置和简化Spring应用的复杂性而受到广泛欢迎。...
本示例"mysql和Oracle的多数据源配置demo"聚焦于如何在SpringBoot框架下同时集成和管理MySQL与Oracle这两种不同的数据库系统,以实现多数据源的配置。这在需要处理不同数据库类型或者需要实现数据冗余和故障切换的...
在Spring配置文件中,原本的单数据源配置会被替换为双数据源配置。主数据源和从数据源的配置都是基于`DriverManagerDataSource`,这是一个简单的数据源实现,适合开发和测试环境。在生产环境中,通常会使用更高效的...
总之,"twodatasource.rar"提供了关于Spring配置双数据源的实践教程,对于理解和实现这一高级技术非常有帮助。通过对这两个数据源的管理,开发者能够更有效地处理多数据库环境中的复杂业务逻辑,提高系统的灵活性和...
在开发企业级应用程序时,有时需要连接到多个数据库来实现...以上内容详细阐述了如何在Spring Boot项目中整合Mybatis并配置连接SQL Server的双数据源,提供了关键的配置步骤和代码示例,希望能对你的开发工作提供帮助。