Spring Boot+Mybatis+Annotation+Druid（五）

快来打我* 2024-02-18 19:23 54阅读 0赞

## 1. Druid是什么？ ##

Druid是Java语言中最好的数据库连接池。Druid能够提供强大的监控和扩展功能。

Druid 核心主要包括三部分：  
1. DruidDriver 代理 Driver，能够提供基于 Filter－Chain 模式的插件体系。  
2. DruidDataSource 高效可管理的数据库连接池  
3. SQLParser

## 2. 在哪里下载druid ##

正式版本下载：

*  maven中央仓库: [http://central.maven.org/maven2/com/alibaba/druid/][http_central.maven.org_maven2_com_alibaba_druid]

3.多数据源的应用

当业务数据量达到了一定程度，DBA 需要合理配置数据库资源。即配置主库的机器高配置，把核心高频的数据放在主库上；把次要的数据放在从库，低配置,开源节流。把数据放在不同的数据库里，就需要通过不同的数据源进行操作数据。

![Center][]

**那么user 用户表在主库 master 上，城市表 city 在从库 cluster 上。**

**User表**

/*
    Navicat MySQL Data Transfer
    
    Source Server         : aaaa
    Source Server Version : 50512
    Source Host           : localhost:3306
    Source Database       : springbootdb_custer
    
    Target Server Type    : MYSQL
    Target Server Version : 50512
    File Encoding         : 65001
    
    Date: 2018-04-04 17:05:30
    */
    
    SET FOREIGN_KEY_CHECKS=0;
    
    -- ----------------------------
    -- Table structure for user
    -- ----------------------------
    DROP TABLE IF EXISTS `user`;
    CREATE TABLE `user` (
      `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '用户编号',
      `user_name` varchar(25) DEFAULT NULL COMMENT '用户名称',
      `description` varchar(25) DEFAULT NULL COMMENT '描述',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Records of user
    -- ----------------------------
    INSERT INTO `user` VALUES ('1', '李福', '这是个测试网站哦!');

City表

/*
    Navicat MySQL Data Transfer
    
    Source Server         : aaaa
    Source Server Version : 50512
    Source Host           : localhost:3306
    Source Database       : springbootdb
    
    Target Server Type    : MYSQL
    Target Server Version : 50512
    File Encoding         : 65001
    
    Date: 2018-04-02 10:45:36
    */
    
    SET FOREIGN_KEY_CHECKS=0;
    
    -- ----------------------------
    -- Table structure for city
    -- ----------------------------
    DROP TABLE IF EXISTS `city`;
    CREATE TABLE `city` (
      `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '城市编号',
      `province_id` int(10) unsigned NOT NULL COMMENT '省份编号',
      `city_name` varchar(25) DEFAULT NULL COMMENT '城市名称',
      `description` varchar(25) DEFAULT NULL COMMENT '描述',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Records of city
    -- ----------------------------
    INSERT INTO `city` VALUES ('1', '1', '杭州市', '刘飞的家在杭州市');
    INSERT INTO `city` VALUES ('2', '1', '海宁市', '张三的家在海宁市')

工程架构图：

![Center 1][]

（1）使用Maven加入Druid.jar

<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    			<version>1.1.6</version>
    		</dependency>

（2）application.properties 配置两个数据源配置

## user
    master.datasource.url=jdbc:mysql://localhost:3306/springbootdb_custer?useUnicode=true&characterEncoding=utf8
    master.datasource.username=root
    master.datasource.password=root
    master.datasource.driver-class-name=com.mysql.jdbc.Driver
    
    ## city
    cluster.datasource.url=jdbc:mysql://localhost:3306/springbootdb?useUnicode=true&characterEncoding=utf8
    cluster.datasource.username=root
    cluster.datasource.password=root
    cluster.datasource.driver-class-name=com.mysql.jdbc.Driver

（3） 多数据源配置的时候注意，必须要有一个主数据源，即 MasterDataSourceConfig 配置：

import javax.sql.DataSource;
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    import com.alibaba.druid.pool.DruidDataSource;
    
    @Configuration
    // 扫描 Mapper 接口并容器管理
    //sqlSessionFactoryRef表示定义了 key ，表示一个唯一 SqlSessionFactory 实例
    @MapperScan(basePackages = MasterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory")
    public class MasterDataSourceConfig {
    	// 精确到 master 目录，以便跟其他数据源隔离
    	static final String PACKAGE = "com.hlx.springboot.dao.master";
    	// static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";
    
    	// 获取全局配置文件 application.properties 的 key=value 配置,并自动装配
    	@Value("${master.datasource.url}")
    	private String url;
    
    	@Value("${master.datasource.username}")
    	private String user;
    
    	@Value("${master.datasource.password}")
    	private String password;
    
    	@Value("${master.datasource.driver-class-name}")
    	private String driverClass;
    
    	/**
    	 * 数据源
    	 * 
    	 * @return
    	 */
    	@Bean(name = "masterDataSource")
    	@Primary
    	// 多数据源配置的时候注意，必须要有一个主数据源
    	public DataSource masterDataSource() {
    		// 数据源对象
    		DruidDataSource dataSource = new DruidDataSource();
    		// 将值设置中
    		dataSource.setDriverClassName(driverClass);
    		dataSource.setUrl(url);
    		dataSource.setUsername(user);
    		dataSource.setPassword(password);
    		return dataSource;
    	}
    
    	/**
    	 * 事务管理
    	 * 
    	 * @return
    	 */
    	@Bean(name = "masterTransactionManager")
    	@Primary
    	// 多数据源配置的时候注意，必须要有一个主数据源
    	public DataSourceTransactionManager masterTransactionManager() {
    		// spring事务管理
    		return new DataSourceTransactionManager(masterDataSource());
    	}
    
    	/**
    	 * 会话工厂
    	 * 
    	 * @param masterDataSource
    	 * @return
    	 * @throws Exception
    	 */
    
    	@Bean(name = "masterSqlSessionFactory")
    	@Primary
    	// 多数据源配置的时候注意，必须要有一个主数据源
    	public SqlSessionFactory masterSqlSessionFactory(
    			@Qualifier("masterDataSource") DataSource masterDataSource)
    			throws Exception {
    		// 会话工厂对象
    		final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    		// 设置数据源
    		sessionFactory.setDataSource(masterDataSource);
    		// 设置xml路径
    		// sessionFactory
    		// .setMapperLocations(new PathMatchingResourcePatternResolver()
    		// .getResources(MasterDataSourceConfig.MAPPER_LOCATION));
    		return sessionFactory.getObject();
    	}
    }

ClusterDataSourceConfig 配置：（忽略）注意这个不能再配置@Primary就OK了！

（4）数据层

@Mapper
    public interface UserDao {
    
    	/**
         * 根据用户名获取用户信息
         *
         * @param userName
         * @return
         */
    	@Select("select * from user where user_name=#{userName}")
    	@Results({
    		@Result(column="id",property="id"),
    		@Result(column="user_name",property="userName"),
    		@Result(column="description",property="description")
    	})
    	public User findUser(@Param("userName") String userName);
    }

（5）业务层

@Service
    public class CityServiceImpl implements UserService {
    
    	// 注入dao
    	@Autowired
    	private CityDao cityDao;
    
    	@Autowired
    	private UserDao userDao;
    
    	@Override
    	public User findUserName(String userName) {
    
    		User user = userDao.findUser(userName);
    		City city = cityDao.findCity("杭州市");
    		user.setCity(city);
    		return user;
    	}
    
    }

（6）控制层

@RestController
    public class UserRestController {
    
    	// 注入业务
    	@Autowired
    	private UserService userService;
    
    	/**
    	 * 返回JSON
    	 * 
    	 * @param cityName
    	 * @return
    	 */
    	@RequestMapping(value = "/my/user", method = RequestMethod.GET)
    	public User findUser(
    			@RequestParam(value = "userName", required = true) String userName) {
    		return userService.findUserName(userName);
    	}
    
    }

效果：

![Center 2][]

[http_central.maven.org_maven2_com_alibaba_druid]: http://central.maven.org/maven2/com/alibaba/druid/
[Center]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/c4a872087a3d4ffab2613ceacc049ce8.png
[Center 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/5094d70be4124ae589ee6e65cd6cadb0.png
[Center 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/72014eee83a54b6dbd095b1a347d07e3.png