SpringBoot 2.x （9）：整合Mybatis注解实战

2019-05-10 06:06:19来源：博客园阅读 ()

SSM框架再熟悉不过了，不过以前通常是使用XML写SQL语句

这里用SpringBoot整合Mybatis并且使用注解进行开发

依赖：

        <!-- Mybatis -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>
        <!-- MySQL -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!-- Druid -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.6</version>
        </dependency>

配置：不需要指定驱动类，SpringBoot会自动扫描：com.mysql.cj.jdbc.Driver

spring.datasource.url=jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=utf-8
spring.datasource.username=root
spring.datasource.password=xuyiqing
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

user表：

CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(128) DEFAULT NULL,
  `phone` varchar(16) DEFAULT NULL,
  `create_time` datetime DEFAULT NULL,
  `age` int(4) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

对应实体类：

package org.dreamtech.springboot.domain;

import java.util.Date;

public class User {
    private int id;
    private String name;
    private String phone;
    private int age;
    private Date createTime;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPhone() {
        return phone;
    }

    public void setPhone(String phone) {
        this.phone = phone;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    @Override
    public String toString() {
        return "User [id=" + id + ", name=" + name + ", phone=" + phone + ", age=" + age + ", createTime=" + createTime
                + "]";
    }
}

添加用户的Demo做整合

Mapper:

package org.dreamtech.springboot.mapper;

import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Options;
import org.dreamtech.springboot.domain.User;

public interface UserMapper {
    @Insert("INSERT INTO user(name,phone,create_time,age) VALUES(#{name},#{phone},#{createTime},#{age})")
    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
    int insert(User user);
}

Service:

package org.dreamtech.springboot.service;

import org.dreamtech.springboot.domain.User;

public interface UserService {
    int add(User user);
}

package org.dreamtech.springboot.service.impl;

import org.dreamtech.springboot.domain.User;
import org.dreamtech.springboot.mapper.UserMapper;
import org.dreamtech.springboot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;

    @Override
    public int add(User user) {
        userMapper.insert(user);
        int id = user.getId();
        return id;
    }

}

Controller:

package org.dreamtech.springboot.controller;

import java.util.Date;

import org.dreamtech.springboot.domain.User;
import org.dreamtech.springboot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

    @GetMapping("/add")
    private Object add() {
        User user = new User();
        user.setAge(18);
        user.setCreateTime(new Date());
        user.setName("admin");
        user.setPhone("100000");
        userService.add(user);
        return user;
    }
}

最后别忘了一个细节：在启动类加上Mapper扫描注解

package org.dreamtech.springboot;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan("org.dreamtech.springboot.mapper")
public class SpringbootApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootApplication.class, args);
    }

}

启动后访问localhost:8080/user/add

测试成功！

继续完成增删改查

有时候，开发者希望能够在控制台打印SQL语句，需要加一行配置文件

mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

CRUD完整实现：

package org.dreamtech.springboot.mapper;

import java.util.List;

import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Options;
import org.apache.ibatis.annotations.Result;
import org.apache.ibatis.annotations.Results;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import org.dreamtech.springboot.domain.User;

public interface UserMapper {
    /**
     * 插入对象
     * 
     * @param user 对象
     * @return int
     */
    @Insert("INSERT INTO user(name,phone,create_time,age) VALUES(#{name},#{phone},#{createTime},#{age})")
    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
    int insert(User user);

    /**
     * 查找全部
     * 
     * @return
     */
    @Select("SELECT * FROM user")
    @Results({ @Result(column = "create_time", property = "createTime", javaType = java.util.Date.class) })
    List<User> getAll();

    /**
     * 根据ID找对象
     * 
     * @param id ID
     * @return
     */
    @Select("SELECT * FROM user WHERE id=#{id}")
    @Results({ @Result(column = "create_time", property = "createTime", javaType = java.util.Date.class) })
    User findById(Long id);

    /**
     * 更新对象
     * 
     * @param user 对象
     * @return
     */
    @Update("UPDATE user SET name=#{name} WHERE id=#{id}")
    int update(User user);

    /**
     * 根据ID删除对象
     * 
     * @param id ID
     * @return
     */
    @Delete("DELETE FROM user WHERE id=#{id}")
    int delete(Long id);
}

package org.dreamtech.springboot.service;

import java.util.List;

import org.dreamtech.springboot.domain.User;

public interface UserService {
    int add(User user);

    List<User> getAll();

    User findById(Long id);

    int update(User user);

    int delete(Long id);
}

package org.dreamtech.springboot.service.impl;

import java.util.List;

import org.dreamtech.springboot.domain.User;
import org.dreamtech.springboot.mapper.UserMapper;
import org.dreamtech.springboot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;

    @Override
    public int add(User user) {
        userMapper.insert(user);
        int id = user.getId();
        return id;
    }

    @Override
    public List<User> getAll() {
        return userMapper.getAll();
    }

    @Override
    public User findById(Long id) {
        return userMapper.findById(id);
    }

    @Override
    public int update(User user) {
        return userMapper.update(user);
    }

    @Override
    public int delete(Long id) {
        return userMapper.delete(id);
    }

}

package org.dreamtech.springboot.controller;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.dreamtech.springboot.domain.User;
import org.dreamtech.springboot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

    private Map<String, Object> modelMap = new HashMap<String, Object>();

    @GetMapping("/add")
    private Object add() {
        User user = new User();
        user.setAge(18);
        user.setCreateTime(new Date());
        user.setName("admin");
        user.setPhone("100000");
        userService.add(user);
        return user;
    }

    @GetMapping("/getall")
    private Object getAll() {
        modelMap.clear();
        List<User> list = userService.getAll();
        if (list.size() > 0) {
            modelMap.put("users", list);
            modelMap.put("success", true);
        } else {
            modelMap.put("success", false);
        }
        return modelMap;
    }

    @GetMapping("/findbyid")
    private Object findById(Long id) {
        if (id == null || id < 0) {
            modelMap.put("success", false);
        }
        modelMap.clear();
        User user = userService.findById(id);
        if (user != null) {
            modelMap.put("success", true);
            modelMap.put("user", user);
        } else {
            modelMap.put("success", false);
        }
        return modelMap;
    }

    @GetMapping("/update")
    private Object update() {
        modelMap.clear();
        User user = new User();
        user.setId(1);
        user.setName("newAmdin");
        int effectedNum = userService.update(user);
        if (effectedNum > 0) {
            modelMap.put("success", true);
        } else {
            modelMap.put("success", false);
        }
        return modelMap;
    }

    @GetMapping("/delete")
    private Object delete(Long id) {
        if (id == null || id < 0) {
            modelMap.put("success", false);
        }
        modelMap.clear();
        int effectedNum = userService.delete(id);
        if (effectedNum > 0) {
            modelMap.put("success", true);
        } else {
            modelMap.put("success", false);
        }
        return modelMap;
    }
}

事务：

如果用到事务相关的内容，需要在Service层加入一个注解@Transactional

    @Transactional(propagation = Propagation.REQUIRED)

原文链接:https://www.cnblogs.com/xuyiqing/p/10837299.html
如有疑问请与原作者联系

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：Java断点续传（基于socket与RandomAccessFile的简单实现）

下一篇：Spring相关BUG

springboot2配置JavaMelody与springMVC配置JavaMelody 2020-06-11
SpringBoot 2.3 整合最新版 ShardingJdbc + Druid + MyBatis 2020-06-11
掌握SpringBoot-2.3的容器探针：实战篇 2020-06-11
nacos~配置中心功能~springboot的支持 2020-06-10
SpringBoot + Vue + ElementUI 实现后台管理系统模板 -- 后 2020-06-10

IDC资讯：主机资讯注册资讯托管资讯 vps资讯网站建设

网站运营：建站经验策划盈利搜索优化网站推广免费资源

网站联盟：联盟新闻联盟介绍联盟点评网赚技巧

行业资讯：搜索引擎网络游戏电子商务广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器安全防护

软件技巧：其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识：网络协议网络安全网络管理组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条

最新资讯

热门关注

热门标签