读写分离

02aa66b7 · xubo · 02aa66b7 · 02aa66b7 · 02aa66b7 · 02aa66b7
15 changed file
--- a/.gitignore
+++ b/.gitignore
+/**/.DS_Store
+/logs/
+/dubbo/
+/**/*.iml
+/**/test/**/*.java
+
+target/
+data/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+nbproject/private/
+build/
+nbbuild/
+dist/
+nbdist/
+
+
+.nb-gradle/
+.settings
+.classpath
+.project
+.springBeans
+mvnw
+mvnw.cmd
+.mvn
+/bin/
+
+
+.flattened-pom.xml
\ No newline at end of file
--- a/README.md
+++ b/README.md
+# spring-boot-sharding-sphere
--- a/db-read-write/pom.xml
+++ b/db-read-write/pom.xml
+<?xml version="1.0" encoding="UTF-8"?>
+<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">
+    <parent>
+        <artifactId>spring-boot-sharding-sphere</artifactId>
+        <groupId>com.jincou.sharding.sphere</groupId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>db-read-write</artifactId>
+</project>
--- a/db-read-write/src/main/java/com/jincou/Application.java
+++ b/db-read-write/src/main/java/com/jincou/Application.java
+package com.jincou;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.context.annotation.ComponentScan;
+
+/**
+ * @Description: 启动类
+ *
+ * @author xub
+ * @date 2019/10/08 下午6:33
+ */
+@SpringBootApplication
+public class Application {
+
+	public static void main(String[] args) {
+		SpringApplication.run(Application.class, args);
+	}
+
+}
--- a/db-read-write/src/main/java/com/jincou/controller/UserController.java
+++ b/db-read-write/src/main/java/com/jincou/controller/UserController.java
+package com.jincou.controller;
+
+
+import com.jincou.entity.User;
+import com.jincou.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+
+/**
+ * @Description: 接口测试
+ *
+ * @author xub
+ * @date 2019/8/24 下午6:31
+ */
+@RestController
+public class UserController {
+
+    @Autowired
+    private UserService userService;
+
+    /**
+     * @Description: 保存用户
+     */
+    @PostMapping("save-user")
+    public Object saveUser() {
+        return userService.saveOne(new User("小小", "女", 3));
+    }
+
+    /**
+     * @Description: 获取用户列表
+     */
+    @GetMapping("list-user")
+    public Object listUser() {
+        return userService.list();
+    }
+
+}
--- a/db-read-write/src/main/java/com/jincou/entity/User.java
+++ b/db-read-write/src/main/java/com/jincou/entity/User.java
+package com.jincou.entity;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * user表
+ */
+@Data
+public class User {
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 性别
+     */
+    private String sex;
+
+    /**
+     * 年龄
+     */
+    private Integer age;
+
+    /**
+     *
+     */
+    private Date createTime;
+
+    /**
+     *
+     */
+    private Date updateTime;
+
+    /**
+     * 是否删除 1删除 0未删除
+     */
+    private Integer status;
+
+    public User(String name, String sex, Integer age) {
+        this.name = name;
+        this.sex = sex;
+        this.age = age;
+    }
+}
\ No newline at end of file
--- a/db-read-write/src/main/java/com/jincou/mapper/UserMapper.java
+++ b/db-read-write/src/main/java/com/jincou/mapper/UserMapper.java
+package com.jincou.mapper;
+
+
+import com.jincou.entity.User;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @Description: 用户mapper
+ *
+ * @author xub
+ * @date 2019/10/8 下午9:23
+ */
+@Mapper
+public interface UserMapper {
+
+    /**
+     * 插入一条记录
+     *
+     * @param record 实体对象
+     * @return 更新条目数
+     */
+    int insert(User record);
+
+    /**
+     * 获取所有用户
+     */
+    List<User> selectAll();
+
+}
\ No newline at end of file
--- a/db-read-write/src/main/java/com/jincou/service/UserService.java
+++ b/db-read-write/src/main/java/com/jincou/service/UserService.java
+package com.jincou.service;
+
+import com.jincou.entity.User;
+
+import java.util.List;
+
+/**
+ * @Description: 用户相关接口
+ *
+ * @author xub
+ * @date 2019/8/24 下午6:32
+ */
+public interface UserService {
+
+    /**
+     * 获取所有用户信息
+     */
+    List<User>  list();
+
+    /**
+     *  单个 保存用户信息
+     * @param user
+     */
+    String  saveOne(User user);
+
+}
\ No newline at end of file
--- a/db-read-write/src/main/java/com/jincou/service/impl/UserServiceImpl.java
+++ b/db-read-write/src/main/java/com/jincou/service/impl/UserServiceImpl.java
+package com.jincou.service.impl;
+
+import com.jincou.entity.User;
+import com.jincou.mapper.UserMapper;
+import com.jincou.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+
+/**
+ * @author xub
+ * @Description: 用户实现类
+ * @date 2019/8/8 上午9:13
+ */
+@Service
+public class UserServiceImpl implements UserService {
+
+    @Autowired
+    private UserMapper userMapper;
+
+    @Override
+    public  List<User> list() {
+        List<User> users = userMapper.selectAll();
+        return users;
+    }
+
+    @Override
+    public String saveOne(User user) {
+        user.setCreateTime(new Date());
+        user.setUpdateTime(new Date());
+        user.setStatus(1);
+        userMapper.insert(user);
+        return "保存成功";
+    }
+}
--- a/db-read-write/src/main/resources/application.properties
+++ b/db-read-write/src/main/resources/application.properties
+server.port=8088
+
+#指定mybatis信息
+mybatis.config-location=classpath:mybatis-config.xml
+
+spring.shardingsphere.datasource.names=master,slave0
+
+# 数据源 主库
+spring.shardingsphere.datasource.master.type=com.alibaba.druid.pool.DruidDataSource
+spring.shardingsphere.datasource.master.driver-class-name=com.mysql.jdbc.Driver
+spring.shardingsphere.datasource.master.url=jdbc:mysql://localhost:3306/master?characterEncoding=utf-8
+spring.shardingsphere.datasource.master.username=root
+spring.shardingsphere.datasource.master.password=123456
+
+# 数据源 从库
+spring.shardingsphere.datasource.slave0.type=com.alibaba.druid.pool.DruidDataSource
+spring.shardingsphere.datasource.slave0.driver-class-name=com.mysql.jdbc.Driver
+spring.shardingsphere.datasource.slave0.url=jdbc:mysql://local:3306/slave?characterEncoding=utf-8
+spring.shardingsphere.datasource.slave0.username=root
+spring.shardingsphere.datasource.slave0.password=123456
+
+# 读写分离
+spring.shardingsphere.masterslave.load-balance-algorithm-type=round_robin
+spring.shardingsphere.masterslave.name=ms
+spring.shardingsphere.masterslave.master-data-source-name=master
+spring.shardingsphere.masterslave.slave-data-source-names=slave0
+
+#打印sql
+spring.shardingsphere.props.sql.show=true
--- a/db-read-write/src/main/resources/mapper/UserMapper.xml
+++ b/db-read-write/src/main/resources/mapper/UserMapper.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.jincou.mapper.UserMapper">
+  <resultMap id="BaseResultMap" type="com.jincou.entity.User">
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="sex" jdbcType="VARCHAR" property="sex" />
+    <result column="age" jdbcType="INTEGER" property="age" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="status" jdbcType="INTEGER" property="status" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, name, sex, age, create_time, update_time, status
+  </sql>
+  <select id="selectAll"  resultMap="BaseResultMap">
+    select
+    <include refid="Base_Column_List" />
+    from tab_user
+  </select>
+
+  <insert id="insert" parameterType="com.jincou.entity.User">
+    insert into tab_user (id, name, sex,
+      age, create_time, update_time,
+      status)
+    values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, #{sex,jdbcType=VARCHAR},
+      #{age,jdbcType=INTEGER}, #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP},
+      #{status,jdbcType=INTEGER})
+  </insert>
+</mapper>
\ No newline at end of file
--- a/db-read-write/src/main/resources/master_user.sql
+++ b/db-read-write/src/main/resources/master_user.sql
+
+
+DROP TABLE IF EXISTS `tab_user`;
+
+CREATE TABLE `tab_user` (
+  `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `name` varchar(64) DEFAULT NULL COMMENT '姓名',
+  `sex` varchar(32) DEFAULT NULL COMMENT '性别',
+  `age` int(11) DEFAULT NULL COMMENT '年龄',
+  `create_time` datetime DEFAULT NULL COMMENT '创建时间',
+  `update_time` datetime DEFAULT NULL COMMENT '更新时间',
+  `status` tinyint(1) DEFAULT NULL COMMENT '是否删除 1删除 0未删除',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+
+
+INSERT INTO `tab_user` (`id`, `name`, `sex`, `age`, `create_time`, `update_time`, `status`)
+VALUES
+	(1,'爸爸','男',29,'2019-10-08 20:11:43','2019-10-08 20:11:43',0);
+
+
+
+
+
--- a/db-read-write/src/main/resources/mybatis-config.xml
+++ b/db-read-write/src/main/resources/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">
+<configuration>
+    <typeAliases>
+        <package name="com.jincou.entity"/>
+    </typeAliases>
+    <mappers>
+        <mapper resource="mapper/UserMapper.xml"/>
+    </mappers>
+</configuration>
+
--- a/db-read-write/src/main/resources/slave_user.sql
+++ b/db-read-write/src/main/resources/slave_user.sql
+DROP TABLE IF EXISTS `tab_user`;
+
+CREATE TABLE `tab_user` (
+  `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `name` varchar(64) DEFAULT NULL COMMENT '姓名',
+  `sex` varchar(32) DEFAULT NULL COMMENT '性别',
+  `age` int(11) DEFAULT NULL COMMENT '年龄',
+  `create_time` datetime DEFAULT NULL COMMENT '创建时间',
+  `update_time` datetime DEFAULT NULL COMMENT '更新时间',
+  `status` tinyint(1) DEFAULT NULL COMMENT '是否删除 1删除 0未删除',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+
+
+INSERT INTO `tab_user` (`id`, `name`, `sex`, `age`, `create_time`, `update_time`, `status`)
+VALUES
+	(1,'妈妈','女',27,'2019-10-08 20:11:43','2019-10-08 20:11:43',0);
+
--- a/pom.xml
+++ b/pom.xml
+<?xml version="1.0" encoding="UTF-8"?>
+<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>pom</packaging>
+    <modules>
+        <module>db-read-write</module>
+    </modules>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.0.6.RELEASE</version>
+        <relativePath/>
+    </parent>
+    <groupId>com.jincou.sharding.sphere</groupId>
+    <artifactId>spring-boot-sharding-sphere</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>spring-boot-sharding-sphere</name>
+    <description>Demo project for Spring Boot</description>
+
+    <properties>
+        <java.version>1.8</java.version>
+        <mybatis-spring-boot>2.0.1</mybatis-spring-boot>
+        <druid>1.1.16</druid>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>${mybatis-spring-boot}</version>
+        </dependency>
+        <!--mybatis驱动-->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <!--druid数据源-->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+            <version>${druid}</version>
+        </dependency>
+        <!--shardingsphere最新版本-->
+        <dependency>
+            <groupId>org.apache.shardingsphere</groupId>
+            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
+            <version>4.0.0-RC1</version>
+        </dependency>
+        <!--lombok实体工具-->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>