Spring+MyBatis双数据库配置

以你之姓@ 2022-08-21 03:30 486阅读 0赞

**Spring+MyBatis双数据库配置**

最近项目中遇到要调用其他数据库的情况，本来只使用一个MySQL数据库，但随着项目内容越来越多，逻辑越来越复杂。原来一个数据库已经不够用了，需要分库分表，所以决定扩充数据库，正好Spring可以灵活的扩充数据库。下面简单写一篇博文，记录下多数据库配置的过程。

#  1.项目结构如下图： #

![Center][]

其中mkhl和ulab分别对应两个数据库模块，同时也对应两个不同的功能模块。

#  2.整个Maven项目的配置文件：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/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    
    	<groupId>ULAB_UsersProvider</groupId>
    	<artifactId>ULAB_UsersProvider</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>ULAB_UsersProvider</name>
    	<url>http://maven.apache.org</url>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<spring.version>4.0.0.RELEASE</spring.version>
    		<jackson.version>2.5.0</jackson.version>
    	</properties>
    
    	<dependencies>
    		
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    			<version>4.8.1</version>
    			<scope>test</scope>
    		</dependency>
    		
    		<dependency>
    			<groupId>javax.activation</groupId>
    			<artifactId>activation</artifactId>
    			<version>1.1</version>
    		</dependency>
    		<dependency>
    			<groupId>commons-lang</groupId>
    			<artifactId>commons-lang</artifactId>
    			<version>2.6</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-web</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-context</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-webmvc</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-aspects</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-context-support</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-tx</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-jdbc</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-orm</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-oxm</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.5.3</version>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>org.apache.zookeeper</groupId>
    			<artifactId>zookeeper</artifactId>
    			<version>3.4.6</version>
    		</dependency>
    		<dependency>
    			<groupId>com.github.sgroschupf</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.1</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<version>5.1.34</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>commons-pool</groupId>
    			<artifactId>commons-pool</artifactId>
    			<version>1.6</version>
    		</dependency>
    		<dependency>
    			<groupId>commons-dbcp</groupId>
    			<artifactId>commons-dbcp</artifactId>
    			<version>1.4</version>
    		</dependency>
    
    		
    		
            
            
            <dependency>
              <groupId>com.microsoft.sqlserver</groupId>
              <artifactId>sqljdbc4</artifactId>
              <version>4.0</version>
            </dependency>
    
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    			<version>1.0.12</version>
    		</dependency>
    		<dependency>
    			<groupId>org.aspectj</groupId>
    			<artifactId>aspectjweaver</artifactId>
    			<version>1.8.4</version>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>net.sf.ehcache</groupId>
    			<artifactId>ehcache-core</artifactId>
    			<version>2.6.10</version>
    		</dependency>
    		<dependency>
    			<groupId>org.mybatis</groupId>
    			<artifactId>mybatis-ehcache</artifactId>
    			<version>1.0.0</version>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>log4j</groupId>
    			<artifactId>log4j</artifactId>
    			<version>1.2.17</version>
    		</dependency>
    		<dependency>
    			<groupId>com.googlecode.log4jdbc</groupId>
    			<artifactId>log4jdbc</artifactId>
    			<version>1.2</version>
    			<scope>runtime</scope>
    		</dependency>
    		<dependency>
    			<groupId>net.bull.javamelody</groupId>
    			<artifactId>javamelody-core</artifactId>
    			<version>1.50.0</version>
    		</dependency>
    
    		
    		
    
    		
    		<dependency>
    			<groupId>org.codehaus.jackson</groupId>
    			<artifactId>jackson-mapper-asl</artifactId>
    			<version>1.9.13</version>
    		</dependency>
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>fastjson</artifactId>
    			<version>1.2.3</version>
    		</dependency>
    		<dependency>
    			<groupId>com.fasterxml.jackson.core</groupId>
    			<artifactId>jackson-annotations</artifactId>
    			<version>${jackson.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>com.fasterxml.jackson.core</groupId>
    			<artifactId>jackson-core</artifactId>
    			<version>${jackson.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>com.fasterxml.jackson.core</groupId>
    			<artifactId>jackson-databind</artifactId>
    			<version>${jackson.version}</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>org.mybatis</groupId>
    			<artifactId>mybatis</artifactId>
    			<version>3.2.4</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>org.mybatis</groupId>
    			<artifactId>mybatis-spring</artifactId>
    			<version>1.2.2</version>
    		</dependency>
    
    		
    		
    		
    		
    		
    		
    		
    		
    		
    		<dependency>
    			<groupId>com.github.pagehelper</groupId>
    			<artifactId>pagehelper</artifactId>
    			<version>4.0.1</version>
    		</dependency>
    		
    	</dependencies>
    
    	<build>
    		<finalName>ULAB_UsersProvider1.0</finalName>
    		<plugins>
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-compiler-plugin</artifactId>
    				<version>3.1</version>
    				<configuration>
    					<source>1.7</source>
    					<target>1.7</target>
    				</configuration>
    			</plugin>
    
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-shade-plugin</artifactId>
    				<version>1.4</version>
    				<executions>
    					<execution>
    						<phase>package</phase>
    						<goals>
    							<goal>shade</goal>
    						</goals>
    						<configuration>
    							<filters>
    								<filter>
    									<artifact>*:*</artifact>
    									<excludes>
    										<exclude>META-INF/*.SF</exclude>
    										<exclude>META-INF/*.DSA</exclude>
    										<exclude>META-INF/*.RSA</exclude>
    									</excludes>
    								</filter>
    							</filters>
    							<transformers>
    								<transformer
    									implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
    									<mainClass>com.ouc.ulab.main.UsersProvider</mainClass>
    								</transformer>
    								<transformer
    									implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
    									<resource>META-INF/spring.handlers</resource>
    								</transformer>
    								<transformer
    									implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
    									<resource>META-INF/spring.schemas</resource>
    								</transformer>
    							</transformers>
    						</configuration>
    					</execution>
    				</executions>
    			</plugin>
    
    		</plugins>
    
    	</build>
    </project>

#  3.接下来介绍与Spring和MyBatis相关的配置文件： #

##  1）数据库配置文件：jdbc.properties ##

#jdbc.driverClassName=oracle.jdbc.driver.OracleDriver
    #jdbc.url=jdbc\:oracle\:thin\:@192.168.151.239\:1521\:orcl
    #jdbc.username=ULab
    #jdbc.password=123456
    #jdbc.validationQuery=SELECT 1 FROM DUAL
    
    jdbc.B.driverClassName=com.mysql.jdbc.Driver
    jdbc.B.url=jdbc\:mysql\://110.126.70.48\:3310/ulab?useUnicode\=true&characterEncoding\=UTF-8
    jdbc.B.username=mkhl
    jdbc.B.password=123456
    
    jdbc.driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver
    jdbc.url=jdbc\:sqlserver\://110.135.60.233\:1433;DatabaseName=OUCJiance
    jdbc.username=OUCUser
    jdbc.password=OUC,789
    
    jdbc.initialSize=1
    jdbc.maxActive=20
    jdbc.minIdle=0
    jdbc.maxWait=60000
    jdbc.validationQuery=SELECT 1
    jdbc.testOnBorrow=false
    jdbc.testOnReturn=false
    jdbc.testWhileIdle=true
    jdbc.timeBetweenEvictionRunsMillis=60000
    jdbc.minEvictableIdleTimeMillis=25200000
    jdbc.removeAbandoned=true
    jdbc.removeAbandonedTimeout=1800
    jdbc.logAbandoned=true
    jdbc.filters=stat

##  2）ehcache缓存配置：ehcache.xml ##

##  3）日志配置：log4j.properties ##

log4j.rootLogger=INFO,stdout,logfile
    
    log4j.appender.stdout=org.apache.log4j.ConsoleAppender 
    log4j.appender.stdout.layout=org.apache.log4j.PatternLayout 
    log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n  
    
    log4j.appender.logfile=org.apache.log4j.DailyRollingFileAppender
    log4j.appender.logfile.File=D:/log4j/U-LAB/usersProvide_log
    log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
    log4j.appender.logfile.DatePattern='_'yyyy-MM-dd'.log'
    log4j.appender.logfile.layout.ConversionPattern=%d{yyyy-MM-dd HH\:mm\:ss} %-5p [%t] %c.%M(%L) - %m%n
      
    log4j.logger.com.ibatis=debug
    log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=debug
    log4j.logger.com.ibatis.common.jdbc.ScriptRunner=debug
    log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate=debug
    log4j.logger.java.sql.Connection=debug
    log4j.logger.java.sql.Statement=debug
    log4j.logger.java.sql.PreparedStatement=debug,stdout
    
    log4j.logger.jdbc.sqlonly=OFF
    log4j.logger.jdbc.sqltiming=OFF
    log4j.logger.jdbc.audit=OFF
    log4j.logger.jdbc.resultset=OFF
    log4j.logger.jdbc.connection=OFF

##  4）mybatis基础配置：mybatis-configure.xml ##

<?xml version="1.0" encoding="UTF-8"?>   
    <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">   
    <configuration>   
        <settings>
     	 <setting name="cacheEnabled" value="true" />
     	 <setting name="jdbcTypeForNull" value="NULL" />
       </settings> 
    </configuration>

##  5）数据库连接池Druid配置：spring-druid.xml ##

##  6）MyBatis数据库相关的配置，双数据库配置主要内容在这里：spring-mybatis.xml ##

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
    	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:cache="http://www.springframework.org/schema/cache"
    	xmlns:task="http://www.springframework.org/schema/task" xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
    	xsi:schemaLocation="    
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
            http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-4.0.xsd
            http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd  
            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd  
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd  
            http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd  
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
    
    	
    	<bean name="dataSource1" class="com.alibaba.druid.pool.DruidDataSource"
    		init-method="init" destroy-method="close">
    		<property name="driverClassName" value="${jdbc.driverClassName}" />
    		<property name="url" value="${jdbc.url}" />
    		<property name="username" value="${jdbc.username}" />
    		<property name="password" value="${jdbc.password}" />
    
    		
    		<property name="initialSize" value="${jdbc.initialSize}" />
    		
    		<property name="maxActive" value="${jdbc.maxActive}" />
    		
    		<property name="minIdle" value="${jdbc.minIdle}" />
    		
    		<property name="maxWait" value="${jdbc.maxWait}" />
    
    		<property name="validationQuery" value="${jdbc.validationQuery}" />
    		<property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
    		<property name="testOnReturn" value="${jdbc.testOnReturn}" />
    		<property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
    
    		
    		<property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
    		
    		<property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
    
    		
    		<property name="removeAbandoned" value="${jdbc.removeAbandoned}" />
    		
    		<property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
    		
    		<property name="logAbandoned" value="${jdbc.logAbandoned}" />
    
    		
    		<property name="filters" value="${jdbc.filters}" />
    	</bean>
    
        
    	<bean name="dataSource2" class="com.alibaba.druid.pool.DruidDataSource"
    		init-method="init" destroy-method="close">
    		<property name="driverClassName" value="${jdbc.B.driverClassName}" />
    		<property name="url" value="${jdbc.B.url}" />
    		<property name="username" value="${jdbc.B.username}" />
    		<property name="password" value="${jdbc.B.password}" />
    
    		
    		<property name="initialSize" value="${jdbc.initialSize}" />
    		
    		<property name="maxActive" value="${jdbc.maxActive}" />
    		
    		<property name="minIdle" value="${jdbc.minIdle}" />
    		
    		<property name="maxWait" value="${jdbc.maxWait}" />
    
    		<property name="validationQuery" value="${jdbc.validationQuery}" />
    		<property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
    		<property name="testOnReturn" value="${jdbc.testOnReturn}" />
    		<property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
    
    		
    		<property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
    		
    		<property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
    
    		
    		<property name="removeAbandoned" value="${jdbc.removeAbandoned}" />
    		
    		<property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
    		
    		<property name="logAbandoned" value="${jdbc.logAbandoned}" />
    
    		
    		<property name="filters" value="${jdbc.filters}" />
    	</bean>
    	
    	
    	<bean id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">
    		<property name="dataSource" ref="dataSource1" />
    		<property name="mapperLocations" value="classpath:com/ouc/ulab/mapping/*.xml" />
    		<property name="typeAliasesPackage" value="com.ouc.ulab.model" />
    		<property name="plugins">
    			<array>
    				<bean class="com.github.pagehelper.PageHelper">
    					<property name="properties">
    						<value>
    							dialect=sqlserver
    						</value>
    					</property>
    				</bean>
    			</array>
    		</property>
    		<property name="configLocation" value="classpath:mybatis-configure.xml" />
    	</bean>
        
        <bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
    		<property name="dataSource" ref="dataSource2" />
    		<property name="mapperLocations" value="classpath:com/ouc/mkhl/mapping/*.xml" />
    		<property name="typeAliasesPackage" value="com.ouc.mkhl.model" />
    		<property name="configLocation" value="classpath:mybatis-configure.xml" />
    	</bean>
    
    	<bean id = "mapperScannerConfigurer1" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    		<property name="basePackage" value="com.ouc.ulab.dao" />
    		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory1" />
    	</bean>
    
        <bean id = "mapperScannerConfigurer2" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    		<property name="basePackage" value="com.ouc.mkhl.dao" />
    		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2" />
    	</bean>
    	
    	
    	<bean id="transactionManager"
    		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    		<property name="dataSource" ref="dataSource1" />
    	</bean>
    
    </beans>

##  7）Spring中Bean的注解扫描识别配置：spring.xml，此处为了发布Dubbo服务。 ##

##  8）发布Dubbo接口配置：spring-dubbo.xml，此处配置注册中心地址，发布接口等内容。 ##

#  4.以下以ulab模块为例，介绍相关的功能包：dao，model，mapping，service，service.impl，main。 #

##  1）model数据库表实体类包：VSupplyUser类 ##

package com.ouc.ulab.model;
    
    import java.io.Serializable;
    
    public class VSupplyUser implements Serializable {
    	
        private static final long serialVersionUID = 12L;
    	
        private String supplycode;
    
        private String supplyname;
    
        private String supplypass;
    
        public String getSupplycode() {
            return supplycode;
        }
    
        public void setSupplycode(String supplycode) {
            this.supplycode = supplycode == null ? null : supplycode.trim();
        }
    
        public String getSupplyname() {
            return supplyname;
        }
    
        public void setSupplyname(String supplyname) {
            this.supplyname = supplyname == null ? null : supplyname.trim();
        }
    
        public String getSupplypass() {
            return supplypass;
        }
    
        public void setSupplypass(String supplypass) {
            this.supplypass = supplypass == null ? null : supplypass.trim();
        }
    }

##  2）数据接口Dao包：VSupplyUserMapper ##

package com.ouc.ulab.dao;
    
    import java.util.List;
    
    import com.ouc.ulab.model.VSupplyUser;
    
    public interface VSupplyUserMapper {
        
        int insert(VSupplyUser record);
    
        int insertSelective(VSupplyUser record);
        
        public VSupplyUser getVSupplyUserByCode(String supplycode);
        
        public List <VSupplyUser> getAllVSupplyUser();
        
    }

##  3）SQL语句配置包：VSupplyUserMapper.xml ##

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
    <mapper namespace="com.ouc.ulab.dao.VSupplyUserMapper" >
      <resultMap id="BaseResultMap" type="VSupplyUser" >
        <result column="SupplyCode" property="supplycode" jdbcType="NVARCHAR" />
        <result column="SupplyName" property="supplyname" jdbcType="NVARCHAR" />
        <result column="SupplyPass" property="supplypass" jdbcType="NVARCHAR" />
      </resultMap>
      
      <select id="getVSupplyUserByCode" resultType="VSupplyUser" parameterType="java.lang.String" >
        select * from V_SupplyUser
        where SupplyCode = #{#{supplycode,jdbcType=NVARCHAR}
      </select>
      
      <select id="getAllVSupplyUser" resultMap="BaseResultMap" >
        select * from V_SupplyUser
      </select>
      
      <insert id="insert" parameterType="VSupplyUser" >
        insert into V_SupplyUser (SupplyCode, SupplyName, SupplyPass
          )
        values (#{supplycode,jdbcType=NVARCHAR}, #{supplyname,jdbcType=NVARCHAR}, #{supplypass,jdbcType=NVARCHAR}
          )
      </insert>
      <insert id="insertSelective" parameterType="VSupplyUser" >
        insert into V_SupplyUser
        <trim prefix="(" suffix=")" suffixOverrides="," >
          <if test="supplycode != null" >
            SupplyCode,
          </if>
          <if test="supplyname != null" >
            SupplyName,
          </if>
          <if test="supplypass != null" >
            SupplyPass,
          </if>
        </trim>
        <trim prefix="values (" suffix=")" suffixOverrides="," >
          <if test="supplycode != null" >
            #{supplycode,jdbcType=NVARCHAR},
          </if>
          <if test="supplyname != null" >
            #{supplyname,jdbcType=NVARCHAR},
          </if>
          <if test="supplypass != null" >
            #{supplypass,jdbcType=NVARCHAR},
          </if>
        </trim>
      </insert>
    </mapper>

##  4）Dubbo服务接口包：VSupplierUsersService ##

package com.ouc.ulab.service;
    
    import java.util.List;
    
    import com.ouc.ulab.model.VSupplyUser;
    
    public interface VSupplierUsersService {
    	
    	public VSupplyUser getVSupplyUserByCode(String supplycode);
    	
    	public List <VSupplyUser> getAllVSupplyUser();
    }

##  5）Dubbo服务接口具体实现包：VSupplierUsersSerImpl ##

package com.ouc.ulab.service.impl;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import com.ouc.ulab.dao.VSupplyUserMapper;
    import com.ouc.ulab.model.VSupplyUser;
    import com.ouc.ulab.service.VSupplierUsersService;
    
    @Service("vSupplierUsersService")
    public class VSupplierUsersSerImpl implements VSupplierUsersService{
    	
    	@Autowired  VSupplyUserMapper vSuppUserMapper;
    
    	@Override
    	public VSupplyUser getVSupplyUserByCode(String supplycode){
    	     return vSuppUserMapper.getVSupplyUserByCode(supplycode);
    	}
    	
    	@Override
    	public List <VSupplyUser> getAllVSupplyUser(){
    	    return vSuppUserMapper.getAllVSupplyUser();
    	}
    }

#  5.发布接口测试Main：UsersProvider #

package com.ouc.ulab.main;
    
    import java.util.ArrayList;
    import java.util.List;
    
    import org.apache.log4j.Logger;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import com.ouc.ulab.service.VSupplierUsersService;
    import com.ouc.ulab.model.VSupplyUser;
    import com.ouc.mkhl.service.UsersEvaluateService;
    import com.ouc.mkhl.model.PlanCount;
    
    public class UsersProvider {
    
        private static VSupplierUsersService vSuppUsersSer;
    
        private static UsersEvaluateService usersEvaluateSer;
        
        @Autowired
        public static void main(String[] args) throws Exception {
    	try {
    	    @SuppressWarnings("resource")
    	    ClassPathXmlApplicationContext cxt = new ClassPathXmlApplicationContext(
    		    new String[] { "classpath:spring.xml",
    			    "classpath:spring-mybatis.xml",
    			    "classpath:spring-dubbo.xml" });
    
    	    cxt.start();
    
    	    vSuppUsersSer = (VSupplierUsersService) cxt
    		    .getBean("vSupplierUsersService");
    
    	    String supplyCode = "V98758";
    	    VSupplyUser user = vSuppUsersSer.getVSupplyUserByCode(supplyCode);
    	    System.out.println("供应商用户信息:");
    	    System.out.println("V码:" + user.getSupplycode());
    	    System.out.println("供应商名称:" + user.getSupplyname());
    	    System.out.println("供应商登录密码:" + user.getSupplypass());
                
    	    List<VSupplyUser> supplyUserList = new ArrayList<VSupplyUser>();
    	    supplyUserList = vSuppUsersSer.getAllVSupplyUser();
    	    System.out.println("供应商用户总量:"+supplyUserList.size());
    	    
    	 
    	    usersEvaluateSer = (UsersEvaluateService) cxt.getBean("usersEvaluateService");
    	    List<PlanCount> planCountList = new ArrayList<PlanCount>();
    	    planCountList = usersEvaluateSer.getPlanCountByYearAndVCode("2016", "V13187");
    	    System.out.println("问题方案统计结果：" + planCountList.size());
    		
    	    PlanCount planCount = new PlanCount();
    	    planCount = usersEvaluateSer.getPlanCountByYearAndMonthAndVCode("2016", "V13187", 4);
    	    System.out.println("问题方案：" + planCount.getPlanNum() + planCount.getQuestionNum());
    	    
    	    System.in.read(); // 模拟开启
    
    	} catch (Exception e) {
    	    e.printStackTrace();
    	    System.out.println(e.getMessage());
    	    Logger log = Logger.getLogger(UsersProvider.class);
    	    log.error(e.getMessage()); // 将异常输出到文件
    	}
    
        }
    }

#  6.运行结果如下图： #

![Center 1][]

以上数据库分库已经大功告成，以后在与大家详细介绍如何分表，以及分表的原则。

文章中如有错误，欢迎高手指正，本人是一个小菜鸟，正在努力学习中。

[Center]: /images/20220731/8e09d5b9dbd64e7d89bcecea43bc42c7.png
[Center 1]: /images/20220731/e119caac647848daa9a0973de1ac7a71.png