深入浅出：SSM框架与ShardingSphere4.10的无缝集成指南

前言

官方网站http://shardingsphere.apache.org/index_zh.html

网上费了老大力气找各种整合ssm整合shardingjdbc的项目发现都是1.x的&＃xff0c;连个or查询都不支持&＃xff0c;有毛用&＃xff0c;废话不说了&＃xff0c;直接上干货

目录

一.sql准备

二. mvn配置

三.数据源配置

五&＃xff0c;实体层无任何区别

六&＃xff0c;dao层和原来没任何区别

七&＃xff0c;mapper层和原来没任何区别

八&＃xff0c;在一个service层中调用

一.sql准备

准备两张表user_0,user_1

DROP TABLE IF EXISTS &＃96;user_0&＃96;;
CREATE TABLE &＃96;user_0&＃96; (&＃96;id&＃96; int(11) NOT NULL AUTO_INCREMENT,&＃96;name&＃96; varchar(100) DEFAULT NULL,&＃96;age&＃96; int(11) DEFAULT NULL,PRIMARY KEY (&＃96;id&＃96;),UNIQUE KEY &＃96;id_UNIQUE&＃96; (&＃96;id&＃96;)
) ENGINE&＃61;InnoDB AUTO_INCREMENT&＃61;3 DEFAULT CHARSET&＃61;utf8;-- ----------------------------
-- Table structure for user_1
-- ----------------------------
DROP TABLE IF EXISTS &＃96;user_1&＃96;;
CREATE TABLE &＃96;user_1&＃96; (&＃96;id&＃96; int(11) NOT NULL AUTO_INCREMENT,&＃96;name&＃96; varchar(100) DEFAULT NULL,&＃96;age&＃96; int(11) DEFAULT NULL,PRIMARY KEY (&＃96;id&＃96;),UNIQUE KEY &＃96;id_UNIQUE&＃96; (&＃96;id&＃96;)
) ENGINE&＃61;InnoDB AUTO_INCREMENT&＃61;2 DEFAULT CHARSET&＃61;utf8;

二. mvn配置

org.apache.shardingspheresharding-jdbc-core4.1.0
org.apache.shardingspheresharding-jdbc-spring-namespace4.1.0


注意&＃xff1a;此处只贴出shardingsphere的&＃xff0c;此次示例是老ssm项目新加shardingsphere的故其它不再展示

ssm和druid版本也贴一下吧

4.0.8.RELEASE
3.2.8
1.2.2
1.1.10

三.数据源配置

在你的原数据配置文件中找到老数据源配置&＃xff0c;在老数据源配置下面新增数据源配置 shardingDataSource&＃xff0c;并把老数据源连接改成  shardingDataSource

{id % 2}" />{0..1}" table-strategy-ref&＃61;"userTableStrategy" />false

 注意&＃xff1a;一定要用$->{...}  不要用  ${...}  来自官方建议&＃xff0c;不信可以试试哈&＃xff0c;有惊喜呀

https://shardingsphere.apache.org/document/current/cn/user-manual/shardingsphere-jdbc/configuration/spring-namespace/sharding/

行表达式标识符可以使用 ${...} 或 $->{...}&＃xff0c;但前者与 Spring 本身的属性文件占位符冲突&＃xff0c;因此在 Spring 环境中使用行表达式标识符建议使用 $->{...}。

五&＃xff0c;实体层无任何区别

public class UserEntity {private int id;private String name;private int age;public UserEntity() {}public UserEntity(int id, String name, int age) {this.id &＃61; id;this.name &＃61; name;this.age &＃61; age;}public int getAge() {return age;}public void setAge(int age) {this.age &＃61; age;}public String getName() {return name;}public void setName(String name) {this.name &＃61; name;}public int getId() {return id;}public void setId(int id) {this.id &＃61; id;}&＃64;Overridepublic String toString() {return "UserEntity{" &＃43;"id&＃61;" &＃43; id &＃43;", name&＃61;&＃39;" &＃43; name &＃43; &＃39;\&＃39;&＃39; &＃43;", age&＃61;" &＃43; age &＃43;&＃39;}&＃39;;}
}

六&＃xff0c;dao层和原来没任何区别

import com.thinkgem.jeesite.common.persistence.CrudDao;
import com.thinkgem.jeesite.common.persistence.annotation.MyBatisDao;
import com.thinkgem.jeesite.modules.sharding.entity.UserEntity;&＃64;MyBatisDao
public interface ShardingUserDao extends CrudDao {int insertOne(UserEntity user);UserEntity selectByPk(int id);
}

七&＃xff0c;mapper层和原来没任何区别


INSERT INTO user(id, name,age) VALUE(#{id},#{name},#{age})select * from user where id&＃61;#{id}

八&＃xff0c;在一个service层中调用


&＃64;Autowiredprivate ShardingUserDao userDao;&＃64;Transactional(readOnly &＃61; false)public void save() {userDao.insertOne(new UserEntity(12, "333", 1122));userDao.insertOne(new UserEntity(14, "3333", 1122));System.out.println(userDao.selectByPk(1));System.out.println(userDao.selectByPk(2));}

结果

原创不易&＃xff0c;转载请注明出处