多租户实现之基于Mybatis,Mycat的共享数据库,共享数据架构

前言

SaaS模式是什么?

传统的软件模式是在开发出软件产品后,需要去客户现场进行实施,通常部署在局域网,这样开发、部署及维护的成本都是比较高的。

现在随着云服务技术的蓬勃发展,就出现了SaaS模式。

所谓SaaS模式即是把产品部署在云服务器上,从前的客户变成了“租户”,我们按照功能和租用时间对租户进行收费。

这样的好处是,用户可以按自己的需求来购买功能和时间,同时自己不需要维护服务器,而我们作为SaaS提供商也免去了跑到客户现场实施的麻烦,运维的风险则主要由IaaS提供商来承担。


SaaS多租户数据库方案

多租户技术或称多重租赁技术,是一种软件架构技术,

是实现如何在多用户环境下共用相同的系统或程序组件,并且可确保各用户间数据的隔离性。

在当下云计算时代,多租户技术在共用的数据中心以单一系统架构与服务提供多数客户端相同甚至可定制化的服务,并且仍可以保障客户的数据隔离。

目前各种各样的云计算服务就是这类技术范畴,例如阿里云数据库服务(RDS)、阿里云服务器等等。

多租户在数据存储上存在三种主要的方案,分别是:

独立数据库

这是第一种方案,即一个租户一个数据库,这种方案的用户数据隔离级别最高,安全性最好,但成本较高。 优点: 为不同的租户提供独立的数据库,有助于简化数据模型的扩展设计,满足不同租户的独特需求;如果出现故障,恢复数据比较简单。 缺点: 增多了数据库的安装数量,随之带来维护成本和购置成本的增加。 这种方案与传统的一个客户、一套数据、一套部署类似,差别只在于软件统一部署在运营商那里。如果面对的是银行、医院等需要非常高数据隔离级别的租户,可以选择这种模式,提高租用的定价。如果定价较低,产品走低价路线,这种方案一般对运营商来说是无法承受的。

共享数据库,隔离数据架构

这是第二种方案,即多个或所有租户共享Database,但是每个租户一个Schema(也可叫做一个user)。 优点: 为安全性要求较高的租户提供了一定程度的逻辑数据隔离,并不是完全隔离;每个数据库可支持更多的租户数量。 缺点: 如果出现故障,数据恢复比较困难,因为恢复数据库将牵涉到其他租户的数据; 如果需要跨租户统计数据,存在一定困难。

共享数据库,共享数据架构

这是第三种方案,即租户共享同一个Database、同一个Schema,但在表中增加TenantID多租户的数据字段。这是共享程度最高、隔离级别最低的模式。 优点: 三种方案比较,第三种方案的维护和购置成本最低,允许每个数据库支持的租户数量最多。 缺点: 隔离级别最低,安全性最低,需要在设计开发时加大对安全的开发量; 数据备份和恢复最困难,需要逐表逐条备份和还原。 如果希望以最少的服务器为最多的租户提供服务,并且租户接受牺牲隔离级别换取降低成本,这种方案最适合。

选择合理的实现模式 衡量三种模式主要考虑的因素是隔离还是共享。

成本角度因素 隔离性越好,设计和实现的难度和成本越高,初始成本越高。共享性越好,同一运营成本 下支持的用户越多,运营成本越低。

安全因素 要考虑业务和客户的安全方面的要求。安全性要求越高,越要倾向于隔离。

从租户数量上考虑 主要考虑下面一些因素 系统要支持多少租户?上百?上千还是上万?可能的租户越多,越倾向于共享。 平均每个租户要存储数据需要的空间大小。存贮的数据越多,越倾向于隔离。 每个租户的同时访问系统的最终用户数量。需要支持的越多,越倾向于隔离。 是否想针对每一租户提供附加的服务,例如数据的备份和恢复等。这方面的需求越多, 越倾向于隔离

多租户方案之共享数据库,隔离数据架构

技术选型

  • Mycat中间件(社区活跃,完全开源的分布式数据库架构)
  • MyBatis

简要描述

多租户方案采用的是MyBatis+MyCat。DEMO是基于Spring MVC的web项目。

在用户操作过程中获取用户的id信息,利用MyCat强大的注解功能,根据用户id将SQL语句路由到对应该用户的schema或者database去执行。

对SQL加注解的实现则交由MyBatis的插件功能完成,通过自定义MyBatis的Interceptor类,拦截要执行的sql语句加上对应注解。这样就实现了数据库的多租户改造。下面分几个部分来说明。

MyCat 与MySQL设置

MyCat是一个开源的分布式数据库系统,是一个实现了MySQL协议的服务器,

前端用户可以把它看作是一个数据库代理,用MySQL客户端工具和命令行访问,而其后端可以用MySQL原生协议与多个MySQL服务器通信,

也可以用JDBC协议与大多数主流数据库服务器通信,其核心功能是分表分库,即将一个大表水平分割为N个小表,存储在后端MySQL服务器里或者其他数据库里。

MyCat相当于一个逻辑上的大数据库,又N多个物理数据库组成,可以通过各种分库分表规则(rule)将数据存到规则对应的数据库或schema或表中。

MyCat对自身不支持的Sql语句提供了一种解决方案——在要执行的SQL语句前添加额外的一段由注解SQL组织的代码,这样Sql就能正确执行,这段代码称之为“注解”。

注解的使用相当于对mycat不支持的sql语句做了一层透明代理转发,直接交给目标的数据节点进行sql语句执行,其中注解SQL用于确定最终执行SQL的数据节点。

注解使用方式如下:

<code class="language-html">/*!mycat: schema=node1*/真正执行Sql</code>  

由于这个项目是根据MyCat的SQL注解来选择在哪个schema或者database上执行的,所以不需要设置rule.xml。

数据库设置

 1 create database db01;
 2  CREATE TABLE `bom`  (
 3   `cate_id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT ‘物料编码‘,
 4   `parent_id` bigint(20) NULL DEFAULT NULL COMMENT ‘父物料ID,一级物料为0‘,
 5   `cate_code` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘物料编码‘,
 6   `name` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘物料名称‘,
 7   `unit` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘计量单位‘,
 8   `used_count` double(32, 4) NULL DEFAULT NULL,
 9   `specify` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘规格‘,
10   `property` tinyint(4) NULL DEFAULT NULL COMMENT ‘2=自制件,1=采购件‘,
11   `status` tinyint(4) NULL DEFAULT NULL COMMENT ‘状态(0:开启 1:禁用)‘,
12   `description` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘描述‘,
13   PRIMARY KEY (`cate_id`) USING BTREE
14 ) ENGINE = InnoDB AUTO_INCREMENT = 101 CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = ‘物料表‘ ROW_FORMAT = Dynamic;
15
16 create database db02;
17 CREATE TABLE `bom`  (
18   `cate_id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT ‘物料编码‘,
19   `parent_id` bigint(20) NULL DEFAULT NULL COMMENT ‘父物料ID,一级物料为0‘,
20   `cate_code` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘物料编码‘,
21   `name` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘物料名称‘,
22   `unit` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘计量单位‘,
23   `used_count` double(32, 4) NULL DEFAULT NULL,
24   `specify` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘规格‘,
25   `property` tinyint(4) NULL DEFAULT NULL COMMENT ‘2=自制件,1=采购件‘,
26   `status` tinyint(4) NULL DEFAULT NULL COMMENT ‘状态(0:开启 1:禁用)‘,
27   `description` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT ‘描述‘,
28   PRIMARY KEY (`cate_id`) USING BTREE
29 ) ENGINE = InnoDB AUTO_INCREMENT = 101 CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = ‘物料表‘ ROW_FORMAT = Dynamic;

设置两个数据库分表为db01,db02,两个库中都有bom。

MyCat的配置

server.xml

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <!DOCTYPE mycat:server SYSTEM "server.dtd">
 3 <mycat:server xmlns:mycat="http://io.mycat/">
 4     <system>
 5     <property name="useSqlStat">0</property>
 6     <property name="useGlobleTableCheck">0</property>
 7     <property name="sequnceHandlerType">2</property>
 8     <property name="handleDistributedTransactions">0</property>
 9     <property name="useOffHeapForMerge">1</property>
10         <property name="memoryPageSize">1m</property>
11         <property name="spillsFileBufferSize">1k</property>
12         <property name="useStreamOutput">0</property>
13         <property name="systemReserveMemorySize">384m</property>
14         <property name="useZKSwitch">true</property>
15     </system>
16
17     <user name="root">
18         <property name="password">james</property>
19         <property name="schemas">james</property>
20     </user>
21
22 </mycat:server>

server.xml主要是设置登录用户名密码,登录端口之类的信息。

重头戏是schema.xml的设置

 1 <?xml version="1.0"?>
 2 <!DOCTYPE mycat:schema SYSTEM "schema.dtd">
 3 <mycat:schema xmlns:mycat="http://io.mycat/">
 4
 5     <schema name="james" checkSQLschema="false" sqlMaxLimit="100">
 6         <table name="bom" dataNode="dn1,dn2" />
 7     </schema>
 8     <dataNode name="dn1" dataHost="localhost1" database="db01" />
 9     <dataNode name="dn2" dataHost="localhost1" database="db02" />
10     <dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
11               writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
12         <heartbeat>select user()</heartbeat>
13         <writeHost host="hostS1" url="localhost:3306" user="root"
14                    password="jamesmsw" />
15     </dataHost>
16
17 </mycat:schema>

这里配置好两个数据库节点dn1,dn2对应的就是这前面建立的数据库db02,db03.

这样数据库和Mycat就设置好了,我们可以测试一下,向两个库中插入一些数据:

这是db01的数据,共40条.

这是db02中的数据,共8条.

这是mycat的逻辑库james中的数据,可以看到,包含了所有的db01和db02的数据。

再来试试MyCat的注解:

在mycat的逻辑库TESTDB中分别执行以下语句:

mysql> select count(*) from bom;
/*!mycat: datanode=dn1*/select count(*) from bom;
/*!mycat: datanode=dn2*/select count(*) from bom;

可以看到,注解实实在在地把SQL语句路由到对应的数据库中去执行了,而不加注解的SQL则在整个逻辑库上执行。

MyBatis设置插件拦截器

MyBatis要使用MyCat很方便,SpringBoot下,只需要将对应的url改成MyCat的端口就行了。

1 spring.thymeleaf.mode=LEGACYHTML5
2 spring.datasource.url=jdbc:mysql://localhost:8066/james?serverTimezone=GMT
3 spring.datasource.username=root
4 spring.datasource.password=james
5 spring.datasource.driver-class-name=com.mysql.jdbc.Driver
6 mybatis.config-location=classpath:mybatis.xml

MyBatis 允许你在已映射语句执行过程中的某一点进行拦截调用。

默认情况下,MyBatis 允许使用插件来拦截的方法调用包括:

  • Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed)
  • ParameterHandler (getParameterObject, setParameters)
  • ResultSetHandler (handleResultSets, handleOutputParameters)
  • StatementHandler (prepare, parameterize, batch, update, query)

这些类中方法的细节可以通过查看每个方法的签名来发现,或者直接查看 MyBatis 的发行包中的源代码。

假设你想做的不仅仅是监控方法的调用,那么你应该很好的了解正在重写的方法的行为。

因为如果在试图修改或重写已有方法的行为的时候,你很可能在破坏 MyBatis 的核心模块。 这些都是更低层的类和方法,所以使用插件的时候要特别当心。

通过 MyBatis 提供的强大机制,使用插件是非常简单的,只需实现 Interceptor 接口,并指定了想要拦截的方法签名即可。

在这里为了实现SQL的改造增加注解,Executor通过调度StatementHandler来完成查询的过程,通过调度它的prepare方法预编译SQL,因此我们可以拦截StatementHandler的prepare方法,在此之前完成SQL的重新编写。

 1 package org.apache.ibatis.executor.statement;
 2
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 import java.sql.Statement;
 6 import java.util.List;
 7 import org.apache.ibatis.cursor.Cursor;
 8 import org.apache.ibatis.executor.parameter.ParameterHandler;
 9 import org.apache.ibatis.mapping.BoundSql;
10 import org.apache.ibatis.session.ResultHandler;
11
12 public interface StatementHandler {
13     Statement prepare(Connection var1, Integer var2) throws SQLException;
14
15     void parameterize(Statement var1) throws SQLException;
16
17     void batch(Statement var1) throws SQLException;
18
19     int update(Statement var1) throws SQLException;
20
21     <E> List<E> query(Statement var1, ResultHandler var2) throws SQLException;
22
23     <E> Cursor<E> queryCursor(Statement var1) throws SQLException;
24
25     BoundSql getBoundSql();
26
27     ParameterHandler getParameterHandler();
28 }

以上的任何方法都可以拦截。从接口定义而言,Prepare方法有一个参数Connection对象,因此按如下代码设计拦截器:

 1 package com.sanshengshui.multitenant.interceptor;
 2
 3 import com.sanshengshui.multitenant.utils.SessionUtil;
 4 import org.apache.ibatis.executor.statement.StatementHandler;
 5 import org.apache.ibatis.plugin.*;
 6 import org.apache.ibatis.reflection.MetaObject;
 7 import org.apache.ibatis.reflection.SystemMetaObject;
 8
 9 import java.sql.Connection;
10 import java.util.Properties;
11
12 @Intercepts(value = {
13         @Signature(type = StatementHandler.class,
14                 method = "prepare",
15                 args = {Connection.class,Integer.class})})
16 public class MyInterceptor implements Interceptor {
17     private static final String preState="/*!mycat:datanode=";
18     private static final String afterState="*/";
19
20     @Override
21     public Object intercept(Invocation invocation) throws Throwable {
22         StatementHandler statementHandler=(StatementHandler)invocation.getTarget();
23         MetaObject metaStatementHandler=SystemMetaObject.forObject(statementHandler);
24         Object object=null;
25         //分离代理对象链
26         while(metaStatementHandler.hasGetter("h")){
27             object=metaStatementHandler.getValue("h");
28             metaStatementHandler=SystemMetaObject.forObject(object);
29         }
30         statementHandler=(StatementHandler)object;
31         String sql=(String)metaStatementHandler.getValue("delegate.boundSql.sql");
32         /*
33         String node=(String)TestController.threadLocal.get();
34         */
35         String node=(String) SessionUtil.getSession().getAttribute("corp");
36         if(node!=null) {
37             sql = preState + node + afterState + sql;
38         }
39
40         System.out.println("sql is "+sql);
41         metaStatementHandler.setValue("delegate.boundSql.sql",sql);
42         Object result = invocation.proceed();
43         System.out.println("Invocation.proceed()");
44         return result;
45     }
46
47     @Override
48     public Object plugin(Object target) {
49
50         return Plugin.wrap(target, this);
51     }
52
53     @Override
54     public void setProperties(Properties properties) {
55         String prop1 = properties.getProperty("prop1");
56         String prop2 = properties.getProperty("prop2");
57         System.out.println(prop1 + "------" + prop2);
58     }
59 }

简单说明一下:

intercept 真个是插件真正运行的方法,它将直接覆盖掉你真实拦截对象的方法。里面有一个Invocation对象,利用它可以调用你原本要拦截的对象的方法

plugin 它是一个生成动态代理对象的方法,

setProperties 它是允许你在使用插件的时候设置参数值。

1 @Intercepts(value = {
2         @Signature(type = StatementHandler.class,
3                 method = "prepare",
4                 args = {Connection.class,Integer.class})})

这段说明了要拦截的目标类和方法以及参数。

StatementHandler是一个借口,真实的对象是RoutingStatementHandler,但它不是真实的服务对象,里面的delegate是StatementHandler中真实的StatementHandler实现的类,有多种,它里面的boundSql中存储着SQL语句。具体的可以参考MyBatis的源码。

MetaObject是一个工具类,由于MyBatis四大对象提供的public设置参数的方法很少,难以通过自身得到相关属性信息,但是有个MetaObject这个工具类就可以通过其他的技术手段来读取和修改这些重要对象的属性。

SessionUtil的getSession方法是用来获取之前用户登录时获得的记录在session中的corp信息,根据这个信息拼装SQL注解达到多租户的目的。

Interceptor写好后,写入到mybatis.xml的plugin中

<?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="logImpl" value="STDOUT_LOGGING" />
    </settings>

    <typeAliases>
        <typeAlias alias="BomDO" type="com.sanshengshui.multitenant.pojo.BomDO"/>

    </typeAliases>

    <plugins>
        <plugin interceptor="com.sanshengshui.multitenant.interceptor.MyInterceptor">
        </plugin>
    </plugins>
</configuration>

实际运行

写一个实体类.

  1 package com.sanshengshui.multitenant.pojo;
  2
  3 import lombok.Data;
  4
  5 import java.io.Serializable;
  6
  7 @Data
  8 public class BomDO implements Serializable {
  9     private static final long serialVersionUID = 1L;
 10     //物料编码
 11     private Long cateId;
 12     //父物料ID,一级物料为0
 13     private Long parentId;
 14     //物料编码
 15     private String cateCode;
 16     //物料名称
 17     private String name;
 18     //计量单位
 19     private String unit;
 20     //规格
 21     private String specify;
 22     //状态(0:开启 1:禁用)
 23     private Integer status;
 24     //使用数量
 25     private Double usedCount;
 26     //描述
 27     private String description;
 28     //2=自制件,1=采购件
 29     private Integer property;
 30
 31     public Long getCateId() {
 32         return cateId;
 33     }
 34
 35     public void setCateId(Long cateId) {
 36         this.cateId = cateId;
 37     }
 38
 39     public Long getParentId() {
 40         return parentId;
 41     }
 42
 43     public void setParentId(Long parentId) {
 44         this.parentId = parentId;
 45     }
 46
 47     public String getCateCode() {
 48         return cateCode;
 49     }
 50
 51     public void setCateCode(String cateCode) {
 52         this.cateCode = cateCode;
 53     }
 54
 55     public String getName() {
 56         return name;
 57     }
 58
 59     public void setName(String name) {
 60         this.name = name;
 61     }
 62
 63     public String getUnit() {
 64         return unit;
 65     }
 66
 67     public void setUnit(String unit) {
 68         this.unit = unit;
 69     }
 70
 71     public String getSpecify() {
 72         return specify;
 73     }
 74
 75     public void setSpecify(String specify) {
 76         this.specify = specify;
 77     }
 78
 79     public Integer getStatus() {
 80         return status;
 81     }
 82
 83     public void setStatus(Integer status) {
 84         this.status = status;
 85     }
 86
 87     public Double getUsedCount() {
 88         return usedCount;
 89     }
 90
 91     public void setUsedCount(Double usedCount) {
 92         this.usedCount = usedCount;
 93     }
 94
 95     public String getDescription() {
 96         return description;
 97     }
 98
 99     public void setDescription(String description) {
100         this.description = description;
101     }
102
103     public Integer getProperty() {
104         return property;
105     }
106
107     public void setProperty(Integer property) {
108         this.property = property;
109     }
110 }

写一个mapper

 1 package com.sanshengshui.multitenant.mapper;
 2
 3 import com.sanshengshui.multitenant.pojo.BomDO;
 4 import org.apache.ibatis.annotations.Mapper;
 5
 6 import java.util.List;
 7 import java.util.Map;
 8
 9 @Mapper
10 public interface BomMapper {
11
12     List<BomDO> list(Map<String, Object> map);
13
14     int count(Map<String, Object> map);
15
16 }package com.sanshengshui.multitenant.mapper;
17
18 import com.sanshengshui.multitenant.pojo.BomDO;
19 import org.apache.ibatis.annotations.Mapper;
20
21 import java.util.List;
22 import java.util.Map;
23
24 @Mapper
25 public interface BomMapper {
26
27     List<BomDO> list(Map<String, Object> map);
28
29     int count(Map<String, Object> map);
30
31 }

以及对应的BomMapper.xml,配置好sql语句。

<?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.sanshengshui.multitenant.mapper.BomMapper">

    <select id="get" resultType="com.sanshengshui.multitenant.pojo.BomDO">
        select `cate_id`,`parent_id`,`cate_code`,`name`,`unit`,`used_count`,`specify`,`property`,`status`,`description` from bom where cate_id = #{value}
    </select>

    <select id="list" resultType="com.sanshengshui.multitenant.pojo.BomDO">
        select `cate_id`,`parent_id`,`cate_code`,`name`,`unit`,`used_count`,`specify`,`property`,`status`,`description` from bom
        <where>
                    <if test="cateId != null and cateId != ‘‘"> and cate_id = #{cateId} </if>
                    <if test="parentId != null and parentId != ‘‘"> and parent_id = #{parentId} </if>
                    <if test="cateCode != null and cateCode != ‘‘"> and cate_code = #{cateCode} </if>
                    <if test="name != null and name != ‘‘"> and name = #{name} </if>
                    <if test="unit != null and unit != ‘‘"> and unit = #{unit} </if>
                    <if test="usedCount != null and usedCount != ‘‘"> and used_count = #{usedCount} </if>
                    <if test="specify != null and specify != ‘‘"> and specify = #{specify} </if>
                    <if test="property != null and property != ‘‘"> and property = #{property} </if>
                    <if test="status != null and status != ‘‘"> and status = #{status} </if>
                    <if test="description != null and description != ‘‘"> and description = #{description} </if>
                  </where>
        <choose>
            <when test="sort != null and sort.trim() != ‘‘">
                order by ${sort} ${order}
            </when>
            <otherwise>
                order by cate_id desc
            </otherwise>
        </choose>
        <if test="offset != null and limit != null">
            limit #{offset}, #{limit}
        </if>
    </select>
    <!-- 为了保证mycat分库的操作会进行,同一查询会重新执行而不是在sqlSession中查找,需要加上flushCache="true"-->
     <select id="count" flushCache="true" resultType="int">
        select count(*) from bom
         <where>
                    <if test="cateId != null and cateId != ‘‘"> and cate_id = #{cateId} </if>
                    <if test="parentId != null and parentId != ‘‘"> and parent_id = #{parentId} </if>
                    <if test="cateCode != null and cateCode != ‘‘"> and cate_code = #{cateCode} </if>
                    <if test="name != null and name != ‘‘"> and name = #{name} </if>
                    <if test="unit != null and unit != ‘‘"> and unit = #{unit} </if>
                    <if test="usedCount != null and usedCount != ‘‘"> and used_count = #{usedCount} </if>
                    <if test="specify != null and specify != ‘‘"> and specify = #{specify} </if>
                    <if test="property != null and property != ‘‘"> and property = #{property} </if>
                    <if test="status != null and status != ‘‘"> and status = #{status} </if>
                    <if test="description != null and description != ‘‘"> and description = #{description} </if>
                  </where>
    </select>

    <insert id="save" parameterType="com.sanshengshui.multitenant.pojo.BomDO" useGeneratedKeys="true" keyProperty="cateId">
        insert into bom
        (
            `parent_id`,
            `cate_code`,
            `name`,
            `unit`,
            `used_count`,
            `specify`,
            `property`,
            `status`,
            `description`
        )
        values
        (
            #{parentId},
            #{cateCode},
            #{name},
            #{unit},
            #{usedCount},
            #{specify},
            #{property},
            #{status},
            #{description}
        )
    </insert>

</mapper>

这里还是来测试count方法。

写一个controller

 1 package com.sanshengshui.multitenant.controller;
 2
 3 import com.sanshengshui.multitenant.mapper.BomMapper;
 4 import com.sanshengshui.multitenant.pojo.BomDO;
 5 import com.sanshengshui.multitenant.utils.SessionUtil;
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.stereotype.Controller;
 8 import org.springframework.web.bind.annotation.GetMapping;
 9 import org.springframework.web.bind.annotation.PathVariable;
10 import org.springframework.web.bind.annotation.ResponseBody;
11
12 import javax.servlet.http.HttpSession;
13 import java.util.HashMap;
14 import java.util.List;
15 import java.util.Map;
16
17 @Controller
18 public class TestController {
19
20     @Autowired
21     BomMapper bomMapper;
22
23     //简化,直接通过这里设置session
24     @GetMapping("/set/{sess}")
25     @ResponseBody
26     public Object setSession(@PathVariable("sess") String sess){
27         HttpSession httpSession= SessionUtil.getSession();
28         httpSession.setAttribute("corp",sess);
29         return "ok";
30     }
31
32     @ResponseBody
33     @GetMapping("/list")
34     public List<BomDO> list(){
35         Map<String, Object> query = new HashMap<>(16);
36         List<BomDO> bomList = bomMapper.list(query);
37         return bomList;
38     }
39
40     @GetMapping("/count")
41     @ResponseBody
42     public Object getCount(){
43         //要测试的方法
44         Map<String, Object> map = new HashMap<String, Object>();
45         return bomMapper.count(map);
46     }
47 }

首先通过localhost:8080/set/{sess}设置session,假设session设置为dn1.

浏览器中输入localhost:8080/set/dn1.

之后,输入localhost:8080/count.

结果如下:

来看下打印的sql语句:

可以看到,SQL注解已经成功添加进去了。

在设置session为dn2

结果如下。

打印的sql语句:

附件工程代码

作者github账号:https://github.com/sanshengshui

原文地址:https://www.cnblogs.com/sanshengshui/p/9702904.html

时间: 2024-10-07 07:45:37

多租户实现之基于Mybatis,Mycat的共享数据库,共享数据架构的相关文章

基于Mybatis的Dao层的开发

基于Mybatis的Dao层开发 SqlSessionFactoryBuilder用于创建SqlSessionFacoty,SqlSessionFacoty一旦创建完成就不需要SqlSessionFactoryBuilder了,因为SqlSession是通过SqlSessionFactory生产,所以可以将SqlSessionFactoryBuilder当成一个工具类使用,最佳使用范围是方法范围即方法体内局部变量. SqlSessionFactory是一个接口,接口中定义了openSession

基于Mybatis的Dao层开发

转自:https://www.cnblogs.com/rodge-run/p/6528398.html 基于Mybatis的Dao层开发 SqlSessionFactoryBuilder用于创建 SqlSessionFacoty,SqlSessionFacoty一旦创建完成就不需要SqlSessionFactoryBuilder了,因为 SqlSession是通过SqlSessionFactory生产,所以可以将SqlSessionFactoryBuilder当成一个工具类使用, 最佳使用范围是

基于MyBatis实现Dao编程

基于MyBatis实现Dao编程 1.建立mybatis-config.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"><co

基于MyBatis实现Dao理论

基于MyBatis实现Dao理论 推荐使用xml提供sql 实现接口推荐使用Mapper自动实现DAO接口,让我们更关注sql书写本身 原文地址:https://www.cnblogs.com/sinceForever/p/8454481.html

基于Mybatis分页插件PageHelper

基于Mybatis分页插件PageHelper 1.分页插件使用 1.POM依赖 PageHelper的依赖如下.需要新的版本可以去maven上自行选择 <!-- PageHelper 插件分页 --><dependency>    <groupId>com.github.pagehelper</groupId>    <artifactId>pagehelper</artifactId>    <version>4.0.

基于MyBatis框架链接数据库

基于Mybatis框架 特点:给予MyBatis框架半成品 站在巨人肩膀上 连接访问数据库,封装成工具类 方便调用连接 减少代码的冗余 提高效率 支持多线程并发访问 public class BatisUtil { private static final ThreadLocal<SqlSession> thl = new ThreadLocal<SqlSession>(); private static SqlSessionFactoryBuilder builder =null

分表需要解决的问题 &amp; 基于MyBatis 的轻量分表落地方案

分表:垂直拆分.水平拆分 垂直拆分:根据业务将一个表拆分为多个表. 如:将经常和不常访问的字段拆分至不同的表中.由于与业务关系密切,目前的分库分表产品均使用水平拆分方式. 水平拆分:根据分片算法将一个表拆分为多个表. 如:按照ID的最后一位以3取余,尾数是1的放入第1个库(表),尾数是2的放入第2个库(表)等. 解决的问题:单纯的分表可以解决数据量过大导致检索变慢的问题. 分表无法解决过多并发请求访问同一个库,导致数据库响应变慢的问题.所以通常水平拆分都至少要采用分库的方式,用于一并解决大数据量

springboot + mybatis + mycat整合

1.mycat服务 搭建mycat服务并启动,windows安装参照. 系列文章: [Mycat 简介] [Mycat 配置文件server.xml] [Mycat 配置文件schema.xml] [Mycat 配置文件rule.xml] 2.相关配置文件 此处我的配置为: schema.xml <?xml version="1.0"?> <!DOCTYPE mycat:schema SYSTEM "schema.dtd"> <myca

Mybatis高级教程之数据库分页插件

mybatis分页 mybatis的数据库分页是基于内存实现的,这样不符合我们实际的应用场景,所有我们需要自己实现分页. 刚开始和朋友们争论是使用插件实现,还是使用原生的sql实现,最后公说公有理婆说婆有理,也没有争论出什么来. 但是最后想想我们使用mybatis的初衷不就是抛弃原生jdbc的繁琐,让mybatis替我们做了繁杂的步骤, 那么mybatis的分页必须通过mybatis内部的一些机制来实现才能满足我们的需要. Mybatis高级教程之数据库分页插件