首先我們應該先建立一個資料庫,用於操作我們CRUD的資料(可以使用視覺化工具進行創建,也可以使用SQL指令進行建立),資料庫的名字可以自己定義,創建完資料庫之後,我們就要創建表進行資料的儲存了,表的名字叫’ user ‘表,字段可以自己設置,只要和後邊自己創建的實體對應就好了。
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選擇1.8,Java8版本。
2、初始化元件選擇Spring Web、JDBC API、Mybatis Framework、MySQL Driver,Lombok也可以選擇一下,可能會用到。
3、選擇好了之後點選Finish創建就好了。
4、創建好了SpringBoot之後看看自己的Maven有沒用配置好,如果沒有配置好去查詢如何配置Maven,不然你的pom依賴是加載不了的,就下載Maven,如何換個阿里源鏡像位址和本地倉庫,然後IDEA選擇一下Maven的xml檔案和本地倉庫位址就好了。
#以上是所需要的依賴包,如果忘記引入的,可以直接添加即可,不用再重新創建項目了
#首先需要建立四個資料夾,分別是:Entity(使用者實體)、Controller、Service、Dao,然後還需要在resource 目錄下新建Mapper 目錄,這個Mapper 目錄是用來存放SQL 語句的地方。到這裡我覺得需要理解MVC模式,由於我們的存取一層呼叫一層,然後查詢到資料之後再回到過去的,所以我們的層級應該是:Controller(控制層,也是接收前端傳遞參數的層) -> Service(業務層,我們所有的業務,如判斷和一些循環語句就需要寫到這個層當中) -> Dao(持久層,這個層主要是和數據庫打交道的,主要負責數據的操作,也就是CRUD操作) -> 資料庫,
##如下圖所示:
沒有啥好的畫圖工具,就隨便畫了一下,反正數據的流向就是這樣的,大家可以湊合來看一下。在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檔案之後,我們去看右側的Databases去看看能不能連接自己本地的MySQL資料庫:
#依序分別填,資料表名字(這裡我們的表是user表),使用者名稱和密碼、還有資料庫名稱第四:依序寫Entity、Dao、Service、Controller層,還有建立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); }
Controller套件:建立一個UserController類,內容為:Service套件:建立一個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); } }
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; } }######寫完上面的內容之後我們需要在Mapper資料夾下建立mapper.xml文件,如下圖:############ ######
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中文網其他相關文章!