SpringBoot가 Mybatis를 통합하여 추가, 삭제, 수정 및 쿼리를 구현하는 방법

먼저: MySQL 데이터베이스 만들기

먼저 CRUD 데이터를 작동하기 위한 데이터베이스를 만들어야 합니다(시각적 도구를 사용하여 만들거나 SQL 명령을 사용하여 만들 수 있습니다). 데이터베이스를 생성한 후 데이터를 저장할 테이블을 만들어야 합니다. 테이블 이름은 ‘ 나중에 생성하세요.

CREATE TABLE `user` (
  `userId` bigint NOT NULL AUTO_INCREMENT,
  `userName` varchar(255) COLLATE utf8mb4_bin NOT NULL,
  `userAddress` varchar(255) COLLATE utf8mb4_bin NOT NULL,
  PRIMARY KEY (`userId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;

두 번째: SpringBoot 프로젝트를 생성하고 필요한 종속성 패키지를 도입합니다.

IDEA를 사용하여 SpringBoot 프로젝트를 생성합니다.

• 1 생성할 Spring Initializr를 선택한 다음 JDK, Java8용 1.8을 선택합니다. 버전.

• 2. 사용할 수 있는 초기화 구성 요소로 Spring Web, JDBC API, Mybatis Framework, MySQL Driver 및 Lombok을 선택합니다.

• 3. 선택 후 완료를 클릭하면 생성됩니다.

• 4. SpringBoot가 제대로 구성되었는지 확인하세요. 구성되지 않은 경우 Maven을 구성하는 방법을 확인하세요. 그렇지 않으면 Maven을 다운로드할 수 없습니다. 미러 주소와 로컬 창고를 선택한 다음 IDEA는 Maven의 xml 파일과 로컬 창고 주소를 선택합니다.

위 항목은 필수 종속성 패키지입니다. 소개하는 것을 잊었다면 프로젝트를 다시 생성하지 않고 직접 추가할 수 있습니다.

셋째: 프로그램 디렉터리를 만듭니다. 핵심 application.xml 파일을 구성하려면 먼저 Entity(사용자 엔터티), Controller, Service, Dao라는 네 개의 폴더를 생성한 다음 리소스 디렉터리 아래에 새 Mapper 디렉터리를 생성해야 합니다. SQL 문을 저장하는 데 사용됩니다. 이 시점에서 우리는 MVC 모델을 이해해야 한다고 생각합니다. 우리의 액세스는 한 번에 한 레이어씩 호출되고 데이터를 쿼리한 후 반환되므로 우리의 레벨은 다음과 같아야 합니다. 컨트롤러(컨트롤 레이어, 수신하는 레이어이기도 함) 프런트 엔드에 의해 전달된 매개변수) -> 서비스(비즈니스 계층, 판단 및 일부 루프 문과 같은 모든 비즈니스는 이 계층에 작성되어야 함) -> Dao(지속성 계층, 이 계층은 주로 데이터베이스를 다룹니다.) , 주로 데이터 작업을 담당합니다.) -> 데이터베이스,

는 아래 그림과 같습니다.

좋은 그리기 도구가 없어서 그냥 그렸습니다. 무심코. 어쨌든 데이터의 흐름은 이렇으니 보시면 됩니다.

resources 폴더에 yml 파일을 생성하고 다음 내용을 입력합니다:

server:
  port: 8080    //本机的端口号
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/自己数据库的名称?useUnicode=true & characterEncoding=utf-8 &
      useSSL=true & serverTimezone=Asia/Shanghai
    username: root      //数据库的用户名
    password: xxxxxx    //数据库的密码

mybatis:
  mapper-locations: classpath:/Mapper/*.xml
  type-aliases-package: com.example.test.Entity    //这个是扫描到Entity实体包的路径，可根据自己的配置

yml 파일을 구성한 후 오른쪽에 있는 데이터베이스로 이동하여 우리 데이터베이스에 연결할 수 있는지 확인합니다. 로컬 MySQL 데이터베이스:

데이터 테이블 이름(여기서의 테이블은 사용자 테이블임), 사용자 이름과 비밀번호, 데이터베이스 이름을 입력합니다.

넷째: 엔터티, Dao, 서비스 및 쓰기 컨트롤러 레이어, mapper.xml 파일 생성

Entity 패키지: UserEntity 클래스 생성, 내용은 다음과 같습니다:

public class UserEntity {
    private Integer userId;
    private String userName;
    private String userAddress;

    public Integer getUserId() {
        return userId;
    }

    public void setUserId(Integer userId) {
        this.userId = userId;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getUserAddress() {
        return userAddress;
    }

    public void setUserAddress(String userAddress) {
        this.userAddress = userAddress;
    }
}

Dao 패키지: UserDao 인터페이스 생성, 내용은 다음과 같습니다:

import com.example.test.Entity.UserEntity;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

@Mapper
public interface UserDao {
     List<UserEntity> queryLimit(Integer currentPage, Integer pageSize);

     Integer addUser(UserEntity user);

     Integer updateUser(UserEntity user);

     Integer deleteUser(UserEntity user);
}

서비스 패키지: UserService 클래스 생성, 콘텐츠는 다음과 같습니다.

import com.example.test.Dao.UserDao;
import com.example.test.Entity.UserEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service("UserService")
public class UserService {
    @Autowired
    private UserDao userDao;

    public List<UserEntity> queryLimit(Integer currentPage,Integer pageSzie){
        return userDao.queryLimit(currentPage,pageSzie);
    }

    public Integer addUser(UserEntity user){
        return userDao.addUser(user);
    }

    public Integer updateUser(UserEntity user){
        return userDao.updateUser(user);
    }

    public Integer deleteUser(UserEntity user){
        return userDao.deleteUser(user);
    }
}

Controller 패키지: UserController 클래스 생성, 콘텐츠는 다음과 같습니다.

import com.example.test.Entity.UserEntity;
import com.example.test.Service.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;

    String message = "";
    @RequestMapping("/queryLimit")
    public List<UserEntity> queryLimit(@RequestParam("currentPage") Integer currentPage,@RequestParam("pageSize") Integer pageSize){
        return userService.queryLimit(currentPage,pageSize);
    }

    @PostMapping("/addUser")
    public String addUer(@RequestBody UserEntity user){
        //用Mybatis执行insert语句的时候，插入成功会返回1，不成功则会抛出异常，捕获一下异常就好
        try {
            userService.addUser(user);
            message = "增加用户成功";
        }catch (Exception exception){
            message = "增加用户异常";
        }
        return message;
    }

    @PutMapping("/updateUser")
    public String updateUser(@RequestBody UserEntity user){
        //Mybatis的更新操作成功返回1，用户不存在返回0，失败则抛异常
        try {
            message = userService.updateUser(user) == 1?"更新用户成功":"用户不存在，更新失败";
        }catch (Exception exception){
            message = "更新异常";
        }
        return message;
    }

    @DeleteMapping("/deleteUser")
    public String deleteUser(@RequestBody UserEntity user){
        //Mybatis的删除操作和更新返回值一样，成功返回1，用户不存在返回0，失败则抛异常
        try {
            message = userService.deleteUser(user) == 1?"删除用户成功":"用户不存在，删除失败";
        }catch (Exception exception){
            message = "删除异常";
        }
        return message;
    }
}

위 콘텐츠를 작성한 후 매퍼를 생성해야 합니다. xml 파일을 아래와 같이 Mapper 폴더에 저장합니다.

mapper.xml文件内容如下：需要注意的地方是namespace：这个路径是你的UserDao接口的路径，因为你传过来的数据需要和xml进行一个绑定，这样你编写的SQL语句才能接收到你前端传过来的数据（大体意思可以这么理解），而id则是和你UserDao中的接口方法相对应，比如我的UserDao接口中的查找方法命名是queryLimit，那么我在xml文件中的查询语句的id就应该和queryLimit想对应，即：id=“queryLimit”。
resultType是返回数据的类型
parameterType则是传入的数据类型

<?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.example.test.Dao.UserDao">
    <select id="queryLimit" resultType="UserEntity">
        select * from user limit #{currentPage},#{pageSize};
    </select>

    <insert id="addUser" parameterType="UserEntity">
        insert into user(userName,userAddress) values(#{userName},#{userAddress});
    </insert>

    <update id="updateUser" parameterType="UserEntity">
        update user set userName=#{userName},userAddress=#{userAddress} where userId=#{userId};
    </update>

    <delete id="deleteUser" parameterType="UserEntity">
        delete from user where userId=#{userId};
    </delete>
</mapper>

最后我们需要在启动类加一点东西（MapperScan扫描的是我们Dao包的地址，填写自己的就好）

第五：测试结果（这里我用的postman来进行接口测试）

查询用户数据->地址为：http://localhost:8080/user/queryLimit?currentPage=0&pageSize=5

添加用户数据-> 地址为：http://localhost:8080/user/addUser

数据库也能看到数据：

更新用户数据-> 地址为：http://localhost:8080/user/updateUser

更新之后数据库数据为：

删除用户数据-> 地址为：http://localhost:8080/user/deleteUser

查看数据库数据已经删除：

위 내용은 SpringBoot가 Mybatis를 통합하여 추가, 삭제, 수정 및 쿼리를 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!