Springboot 整合 Mybatis 增删查改、连接 MYSQL 数据库及配置 druid 连接池
好了，一切准备就绪，我们开始 CRUD 操作，简单使用下。
先创建下目录文件夹，
然后开始编码！ （终于到写代码了！！）
首先，先从实体类 pojo 开始，对照着数据，我们创建一个实体类 User.java（把 set、get 方法，tostring 方法、构造方法都搞下）：
这里需要注意的是，因为数据库字段有下划线“_”，所以我们也在 mybatis-config 文件中特意开启了驼峰命名，所以字段对应的编写方式要注意了。
package com.test.mybatis.pojo;
/**
@Author : JCccc
@CreateTime : 2019-3-1
@Description :
@Point: Keep a good mood
**/
public class User {
private Integer id;
private String userName;
private String userAge;
@Override
public String toString() {
return "User{" +
"id=" + id +
", userName='" + userName + ''' +
", userAge='" + userAge + ''' +
'}';
}
public User() {
}
public User(Integer id, String userName, String userAge) {
this.id = id;
this.userName = userName;
this.userAge = userAge;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getUserAge() {
return userAge;
}
public void setUserAge(String userAge) {
this.userAge = userAge;
}
}
好了，实体类，简简单单创建完了，接下来是 mapper 层。
在 mapper 层，创建一个 UserMapper.java（因为是该篇是介绍如何整合，所以增删改查我就一次性都写了，调用的时候分开调用给大家展示下）：
这里注意了，@Mapper 注解别忘了。
package com.test.mybatis.mapper;
import com.test.mybatis.pojo.User;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
@Author : JCccc
@CreateTime : 2019-3-1
@Description :
@Point: Keep a good mood
**/
@Mapper
public interface UserMapper {
/**
添加 user 信息
@param user
@return
*/
int insertUser(User user);
/**
根据 ID 查询经销商信息
@param id
@return
*/
User getUserInfoById(int id);
/**
查询所有用户信息
@return
*/
List<User> queryUserInfo();
/**
更新用户信息
@param user
@return
*/
int updateUserInfoById(User user);
/**
删除用户信息
@param id
@return
*/
int deleteUserInfoById(int id);
}?
好了 mapper 层接口也已经写好了，下面是编写对应的 SQL 语句了，创建一个 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.test.mybatis.mapper.UserMapper">
</mapper>
这里需要注意的是，?mapper 的命名空间路径一定要写对了，这样写在这里的数据库语句才能根据对应的名称去路径下的 mapper 文件里适配对应的增删改查方法。
接下来，我们补全对应的增删改查方法：
<?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.test.mybatis.mapper.UserMapper">
<insert id="insertUser" useGeneratedKeys="true" keyProperty="id" keyColumn="id"
parameterType="com.test.mybatis.pojo.User">
insert into
user(id,user_name,user_age)
values (#{id},#{userName},#{userAge})
</insert>
<select id="getUserInfoById" resultType="com.test.mybatis.pojo.User" parameterType="int">
select *
from user
where id=#{id}
</select>
<select id="queryUserInfo" resultType="com.test.mybatis.pojo.User">
select *
from user
</select>
<update id="updateUserInfoById" parameterType="com.test.mybatis.pojo.User">
update user
set id=#{id},user_name=#{userName},user_age=#{userAge}
where id=#{id}
</update>
<delete id="deleteUserInfoById" parameterType="int">
delete
from user
where id=#{id}
</delete>
</mapper>
好了，mapper 这边的算是全部完毕，紧接着到 service 业务层：
UserService.java：
package com.test.mybatis.service;
import com.test.mybatis.pojo.User;
import java.util.List;
/**
@Author : JCccc
@CreateTime : 2019-3-1
@Description :
@Point: Keep a good mood
**/
public interface UserService {
//添加
boolean insertUser(User user);
//按 id 查找
User getUserInfoById(int id);
//查询所有
List<User> queryUserInfo();
//更新
boolean updateUserInfoById(User user);
//删除
boolean deleteUserInfoById(int id);
}
UserSerciceImpl.java:
(@Service 注解不能忘记！而且记得注入对于的 mapper 接口，也就是 @Autowired
UserMapper userMapper；认真看代码的话，你会发现我在增加和修改的方法都开启了事务注解)
package com.test.mybatis.service.impl;
import com.test.mybatis.mapper.UserMapper;
import com.test.mybatis.pojo.User;
import com.test.mybatis.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
@Author : JCccc
@CreateTime : 2019-3-1
@Description :
@Point: Keep a good mood
**/
@Service
public class UserServiceImpl implements UserService {
@Autowired
UserMapper userMapper;
/**
添加
@param user
@return
*/
@Transactional
@Override
public boolean insertUser(User user) {
if(user.getUserName()!=null&&!"".equals(user.getUserName())){
try{
//对 mysql 数据库做增加操作后，影响的行数 effecteNum
int effectNum= userMapper.insertUser(user);
if(effectNum>0){
//如果影响行数大于 0，那么就是增加成功
System.out.println("增加成功，主键为："+user.getId());
return true;
}else {
throw new RuntimeException("插入信息失败,插入行数有误");
}
}catch (Exception e){
throw new RuntimeException("插入信息失败了:"+e.getMessage());
}
}else{
throw new RuntimeException("信息不能为空！！！！");
}
}
/**
按 id 查找
@param id
@return
*/
@Override
public User getUserInfoById(int id) {
return userMapper.getUserInfoById(id);
}
/**
查询所有
@return
*/
@Override
public List<User> queryUserInfo() {
return userMapper.queryUserInfo();
}
/**
更新
@param user
@return
*/
@Transactional
@Override
public boolean updateUserInfoById(User user) {
if(user.getId()!=null&&!"".equals(user.getId())){
try{
//对 mysql 数据库做更新操作后，影响的行数 effecteNum
int effectNum= userMapper.updateUserInfoById(user);
if(effectNum>0){
//如果影响行数大于 0，那么就是更新成功
System.out.println("更新成功，主键为："+user.getId());
return true;
}else {
throw new RuntimeException("更新信息失败,插入行数有误");
}
}catch (Exception e){
throw new RuntimeException("更新信息失败了:"+e.getMessage());
}
}else{
throw new RuntimeException("信息不能为空！！！！");
}
}
/**
删除
@param id
@return
*/
@Override
public boolean deleteUserInfoById(int id) {
try {
//对 mysql 数据库做删除操作后，影响的行数 effecteNum
int effectNum= userMapper.deleteUserInfoById(id);
if (effectNum>0){
return true;
}else {
return false;
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
}
servcie 层写完了，到最后的 controller 控制层，写调试接口了，UserController.java：
（注意了。@RestController 注解不能忘，而且需要注入调用的 serviceImpl，也就是 @Autowired
UserServiceImpl userService）
package com.test.mybatis.controller;
import com.test.mybatis.pojo.User;
import com.test.mybatis.service.impl.UserServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import java.util.Map;
/**
@Author : JCccc
@CreateTime : 2019-3-1
@Description :
@Point: Keep a good mood
**/
@RestController
public class UserController {
@Autowired
UserServiceImpl userService;
/**
增加
@param userMap
@return
*/
@PostMapping("/insertUserInfo")
public String insertUserInfo(@RequestBody Map<String,String> userMap){
User user=new User();
user.setUserName(userMap.get("userName"));
user.setUserAge(userMap.get("userAge"));
boolean result= userService.insertUser(user);
if (result){
return "success";
}else {
return "fail";
}
}
/**
按 id 查找
@param id
@return
*/
@GetMapping("/getUserInfoById/
{id}")
public String getUserInfoById(@PathVariable("id") int id){
User user= userService.getUserInfoById(id);
return user.toString();
}
/**
查询所有
@return
*/
@GetMapping("/queryUserInfo")
public String getAllUserInfo(){
List<User> userList= userService.queryUserInfo();
return userList.toString();
}
/**
更新
@param userMap
@return
*/
@PostMapping("/updateUserInfoById")
public String updateUserInfoById(@RequestBody Map<String,String> userMap){
User user=new User();
user.setId(Integer.valueOf(userMap.get("id")));
user.setUserName(userMap.get("userName"));
user.setUserAge(userMap.get("userAge"));
boolean result= userService.updateUserInfoById(user);
if (result){
return "success";
}else {
return "fail";
}
}
/**
删除
@param id
@return
*/
@DeleteMapping("/deleteUserInfoById/{id}")
public String deleteUserInfoById(@PathVariable("id") int id){
boolean result= userService.deleteUserInfoById(id);
if (result){
return "success";
}else {
return "fail";
}
}
}
好了，用 postman 工具简单调试下，看看整体效果：
①先调用一下增加用户信息接口，
还未添加个人签名 2021.11.08 加入
还未添加个人简介
评论