먼저 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;
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 파일과 로컬 창고 주소를 선택합니다.
위 항목은 필수 종속성 패키지입니다. 소개하는 것을 잊었다면 프로젝트를 다시 생성하지 않고 직접 추가할 수 있습니다.
좋은 그리기 도구가 없어서 그냥 그렸습니다. 무심코. 어쨌든 데이터의 흐름은 이렇으니 보시면 됩니다.
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实体包的路径,可根据自己的配置
데이터 테이블 이름(여기서의 테이블은 사용자 테이블임), 사용자 이름과 비밀번호, 데이터베이스 이름을 입력합니다.
넷째: 엔터티, 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;
}
}
서비스 패키지: UserService 클래스 생성, 콘텐츠는 다음과 같습니다.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); }로그인 후 복사
Controller 패키지: UserController 클래스 생성, 콘텐츠는 다음과 같습니다.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); } }로그인 후 복사
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包的地址,填写自己的就好)
查询用户数据->地址为: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 중국어 웹사이트의 기타 관련 기사를 참조하세요!