spring boot整合mybatis基础操作（Restful风格接口）

╰+攻爆jí腚メ 2022-10-17 00:40 87阅读 0赞

**1、项目结构**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk4MTMxNQ_size_16_color_FFFFFF_t_70]

**2、yml配置文件**

server:
      port: 8080
    
    spring:
      datasource:
        username: root
        password: 123456
        url: jdbc:mysql://localhost:3306/dailyTrain?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
        driver-class-name: com.mysql.cj.jdbc.Driver
    
    mybatis:
      mapper-locations: classpath:mapper/*Mapper.xml
      type-aliases-package: com.dailytrain.Pojo

**3、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>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.5.0</version>
            <relativePath/> 
        </parent>
        <groupId>com</groupId>
        <artifactId>dailyTrain</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>dailyTrain</name>
        <description>Demo project for Spring Boot</description>
        <properties>
            <java.version>1.8</java.version>
        </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>1.3.2</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <configuration>
                        <excludes>
                            <exclude>
                                <groupId>org.projectlombok</groupId>
                                <artifactId>lombok</artifactId>
                            </exclude>
                        </excludes>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    </project>

**4、实体类**

package com.dailytrain.Pojo;
    import lombok.*;
    import org.springframework.stereotype.Component;
    import java.sql.Timestamp;
    import java.sql.Date;
    
    @AllArgsConstructor
    @NoArgsConstructor
    @Getter
    @Setter
    public class User {
        
        private String userId;
        private String userName;
        private Integer money;
        private String address;
        private Date birthday;
        private Timestamp createTime;
        private Timestamp updateTime;
    }

**5、Dao接口**

package com.dailytrain.Dao;
    
    import com.dailytrain.Pojo.User;
    import org.apache.ibatis.annotations.Mapper;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.stereotype.Repository;
    
    import java.util.List;
    
    @Repository
    @Mapper
    public interface UserDao {
        
        public List<User> SelectAll();
    
        public User SelectById(String userId);
    
        public Integer insertUser(User user);
    
        public Integer updateUser(User user);
    
        public Integer deleteUser(User user);
    }

6、Dao层接口对应的maper文件

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org/DTD Mapper 3.0" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.dailytrain.Dao.UserDao">
        <select id="SelectAll" resultType="com.dailytrain.Pojo.User">
            select userId,userName,money,address,birthday,createtime,updatetime from user;
        </select>
    
        <select id="SelectById" resultType="com.dailytrain.Pojo.User">
            select userId,userName,money,address,birthday,createtime,updatetime from user
            where userid=#{user.userid}
        </select>
        <insert id="insertUser" parameterType="com.dailytrain.Pojo.User">
            insert into user (userId,userName,money,address,birthday)
                    values (
                    #{userId},
                    #{userName},
                    #{money},
                    #{address},
                    #{birthday}
                    )
        </insert>
        <update id="updateUser" >
            update user set
                    userId=#{userId},
                    userName=#{userName},
                    money=#{money},
                    address=#{address},
                    birthday=#{birthday}
            where  userId=#{userId}
        </update>
        <delete id="deleteUser">
            delete from user where userId=#{userId}
        </delete>
    </mapper>

7、Service相应业务逻辑代码

package com.dailytrain.Sevice;
    
    import com.dailytrain.Dao.UserDao;
    import com.dailytrain.Pojo.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.sql.Date;
    import java.util.List;
    
    @Service
    public class UserService {
        
        @Autowired
        private UserDao userDao;
        public List<User> SelectAll(){
        
            List<User> result=userDao.SelectAll();
            return result;
        }
    
        public User SelectById(String userId){
        
            User user= userDao.SelectById(userId);
            return user;
        }
    
        public User insertUser(User user){
        
            user.setBirthday(new Date(System.currentTimeMillis()));
            userDao.insertUser(user);
            return userDao.SelectById(user.getUserId());
        }
        public User updateUser(User user){
        
            System.out.println(user.getUserName());
            userDao.updateUser(user);
            return userDao.SelectById(user.getUserId());
        }
    
        public int deleteUser(User user){
        
            userDao.deleteUser(user);
            if(userDao.SelectById(user.getUserId())==null){
        
                return 1;
            }
            return 0;
        }
    }

**8、controller层**（注意@RequestBody的使用）

package com.dailytrain.Contrller;
    
    import com.dailytrain.Pojo.User;
    import com.dailytrain.Sevice.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    
    import java.util.List;
    
    @RestController
    @RequestMapping("/User")
    public class UserController {
        
        @Autowired
        private UserService userService;
    
    
    
        //查询操作使用get
        @GetMapping("/selectAll")
        public List<User> SelectAll(){
        
            return userService.SelectAll();
        }
    
        @GetMapping("/selectById")
        public User SelectById(String userId){
        
            return userService.SelectById(userId);
        }
    //均以json数据传入，content-type=application/json；
    //postman测试需要以body里的raw，输入格式改为json，便可以进行测试使用；
        @PostMapping("/insert")
        public User insertUser(@RequestBody User user){
        
            System.out.println(user.getUserId());
            return userService.insertUser(user);
        }
    
        @PutMapping("/update")
        public User updateUser(@RequestBody User user){
        
            return userService.updateUser(user);
        }
    
        @DeleteMapping("/delete")
        public int deleteUser(@RequestBody User user){
        
            return userService.deleteUser(user);
        }
    }

**9、数据库表**  
注意：数据项包含createTime与UpdateTIME，其值设置了自动更新，当我们插入或者更新时，其值会自动更新为最后更新时间；这样做的好处是有利于进行高并发的修改等操作时，以创建时间，更新时间来作为一个版本控制，从而来达到CAS的目的。也可以去进行一个增量同步，找出某个时间以后进行更新的数据，同步其他数据库和缓存当中；  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk4MTMxNQ_size_16_color_FFFFFF_t_70 1]

## 批量处理部分： ##

**1、Dao层：**

package com.dailytrain.Dao;
    
    import com.dailytrain.Pojo.User;
    import org.apache.ibatis.annotations.Mapper;
    import org.springframework.stereotype.Repository;
    
    import java.util.List;
    
    @Repository
    @Mapper
    public interface UserBatchDao {
        
    
        public List<User> selectBatchById(List<String> id);
        public Integer InsertBatch(List<User> list);
        public Integer updateBatch(List<User> list);
        public Integer deleteBatchById(List<String> id);
    }

**2、mapper映射文件**

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org/DTD Mapper 3.0" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.dailytrain.Dao.UserBatchDao">
        <select id="selectBatchById" resultType="com.dailytrain.Pojo.User">
            select userId,userName,money,address,birthday,createtime,updatetime from user
            where userId in
            <foreach collection="list" item="userId" open="(" close=")" separator=",">
                #{userId}
            </foreach>
        </select>
    
        <insert id="InsertBatch" parameterType="com.dailytrain.Pojo.User">
            insert into user (userId,userName,money,address,birthday)
            values
            <foreach collection="list" item="user" separator=",">
                (
                #{user.userId},
                #{user.userName},
                #{user.money},
                #{user.address},
                #{user.birthday}
                )
            </foreach>
        </insert>
    
        <update id="updateBatch" parameterType="com.dailytrain.Pojo.User">
            <foreach collection="list" item="user" index="index" open="" close="" separator=";">
                update user
                <set>
                    userName=#{user.userName},
                    money=#{user.money},
                    address=#{user.address}
                </set>
                where userId=#{user.userId}
            </foreach>
        </update>
    
        <delete id="deleteBatchById">
            delete from user where userId in
            <foreach collection="list" item="id" open="(" close=")" separator=",">
                #{id}
            </foreach>
        </delete>
    </mapper>

**3、Service层**

import com.dailytrain.Dao.UserBatchDao;
    import com.dailytrain.Dao.UserDao;
    import com.dailytrain.Pojo.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.util.ArrayList;
    import java.util.List;
    
    @Service
    public class UserBatchService {
        
        @Autowired
        private UserBatchDao userBatchDao;
    
        @Autowired
        private UserDao userDao;
    
        public List<User> selectBatchById(List<String> ids){
        
            System.out.println(ids);
            return userBatchDao.selectBatchById(ids);
        }
    
        public List<User> InsertBatch(List<User> list){
        
            int insertSuccess=userBatchDao.InsertBatch(list);
            List<User> result=new ArrayList<>(insertSuccess);
            for(User user:list){
        
                if(userDao.SelectById(user.getUserId())!=null) result.add(user);
            }
            return result;
        }
    
        public Integer updateBatch(List<User> list){
        
            return userBatchDao.updateBatch(list);
        }
        public Integer deleteBatchById(List<String> ids){
        
            return userBatchDao.deleteBatchById(ids);
        }
    }

**4、controller层**

import com.dailytrain.Pojo.User;
    import com.dailytrain.Sevice.UserBatchService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    
    import java.util.List;
    
    @RestController
    @RequestMapping("/batch")
    public class UserBatchController {
        
        @Autowired
        private UserBatchService userBatchService;
    
        @PostMapping("/selectBatchById")
        public List<User> selectBatchById(@RequestBody List<String> ids){
        
            return userBatchService.selectBatchById(ids);
        }
        @PostMapping("/InsertBatch")
        public List<User> InsertBatch(@RequestBody List<User> list){
        
            return userBatchService.InsertBatch(list);
        }
        @PutMapping("/updateBatch")
        public Integer updateBatch(@RequestBody List<User> list){
        
            return userBatchService.updateBatch(list);
        }
        @DeleteMapping("/deleteBatchById")
        public Integer deleteBatchById(@RequestBody List<String> ids){
        
            return userBatchService.deleteBatchById(ids);
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk4MTMxNQ_size_16_color_FFFFFF_t_70]: /images/20221014/c4d26b5992594c13b0382a8c526a10b8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk4MTMxNQ_size_16_color_FFFFFF_t_70 1]: /images/20221014/af23f418429142c5b691047f95483824.png