Spring Boot + MyBatis CRUD + H2 数据库示例

以你之姓@ 2023-10-01 03:19 18阅读 0赞

在本教程中，我们将学习如何使用**MyBatis**创建一个连接到 H2 数据库的 Spring Boot 应用程序。您将使用 **MyBatis** 构建一个应用程序来访问存储在内存 H2 数据库中的数据。  
  
**注意：我们使用**[Spring boot][] 配置 H2 数据库以  在运行时创建和使用内存数据库，通常用于 单元测试 或 POC 目的。请记住，在应用程序启动时会创建/初始化内存数据库；并在应用程序关闭时销毁。

**MyBatis** 消除了手动编写代码来设置参数和检索结果的需要。它提供了简单的 XML 或基于注释的配置来将 Java POJO 映射到数据库。在本例中，我们将使用 **MyBatis** 注解进行配置，将 Java POJO 映射到数据库。

在本教程中，我们将学习 -

*  如何使用**myBatis**将 Spring Boot 项目连接到数据库？
 *  如何使用所有 CRUD 方法编写一个简单的存储库类来使用**myBatis**执行查询？
 *  如何使用**myBatis**执行基本查询？
 *  如何使用 Spring Boot、myBatis 和 H2 创建项目？

## 使用的工具和技术 ##

1. Spring boot 2+

2. MyBatis

3. Maven 3+

4. JDK 1.8

5. IDE - Eclipse or STS

6. H2 database

## 开发步骤 ##

1.  创建一个 Spring Boot 应用程序
2.  Maven 依赖项
3.  数据库设置
4.  数据库和日志配置
5.  创建学生 Bean
6.  创建员工 JDBC 存储库
7.  运行应用程序

## 1. 创建一个 Spring Boot 应用程序 ##

有很多方法可以创建 Spring Boot 应用程序。您可以参考以下文章来创建 Spring Boot 应用程序。

>> [使用 Spring Initializer创建 Spring Boot 项目][Spring Initializer_ Spring Boot]  
>> [在 Spring Tool Suite \[STS\] 中创建 Spring Boot 项目][Spring Tool Suite _STS_ _ Spring Boot]

## 2.Maven依赖 ##

<?xml version="1.0" encoding="UTF-8"?>
    <project
        xmlns="http://maven.apache.org/POM/4.0.0"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>net.guides.springboot2</groupId>
        <artifactId>springboot2-mybatis-crud-example</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
        <name>springboot2-mybatis-crud-example</name>
        <description>Demo project for Spring Boot</description>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.5.RELEASE</version>
            <relativePath />
            
        </parent>
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>1.2.1</version>
            </dependency>
            <dependency>
                <groupId>com.h2database</groupId>
                <artifactId>h2</artifactId>
                <scope>runtime</scope>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

## 3. 数据库设置 ##

我们将创建一个名为employees 的表，其中包含几个简单的列。我们可以通过在资源中创建一个*schema.sql*文件来初始化一个模式。

create table employees
    (
       id integer not null,
       first_name varchar(255) not null, 
       last_name varchar(255) not null,
       email_address varchar(255) not null,
       primary key(id)
    );

## 4. 数据库和日志配置 ##

logging.level.org.hibernate.stat=debug
    # Show all queries
    spring.jpa.show-sql=true
    spring.jpa.properties.hibernate.format_sql=true
    logging.level.org.hibernate.type=trace

## 5. 创建员工 Bean ##

让我们创建一个简单的*Employee* bean：

package net.guides.springboot2.jdbc.model;
    
    public class Employee {
    
        private long id;
        private String firstName;
        private String lastName;
        private String emailId;
    
        public Employee() {
    
        }
    
        public Employee(long id, String firstName, String lastName, String emailId) {
            this.id = id;
            this.firstName = firstName;
            this.lastName = lastName;
            this.emailId = emailId;
        }
    
        public long getId() {
            return id;
        }
        public void setId(long id) {
            this.id = id;
        }
    
        public String getFirstName() {
            return firstName;
        }
        public void setFirstName(String firstName) {
            this.firstName = firstName;
        }
    
        public String getLastName() {
            return lastName;
        }
        public void setLastName(String lastName) {
            this.lastName = lastName;
        }
    
        public String getEmailId() {
            return emailId;
        }
        public void setEmailId(String emailId) {
            this.emailId = emailId;
        }
    }

## 6. 创建员工 MyBatis 存储库 ##

我们希望从创建一个简单的存储库开始。*@Mapper*表示这是一个**MyBatis**映射器类。

package net.guides.springboot2.jdbc.repository;
    
    import java.util.List;
    
    import org.apache.ibatis.annotations.Delete;
    import org.apache.ibatis.annotations.Insert;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Select;
    import org.apache.ibatis.annotations.Update;
    
    import net.guides.springboot2.jdbc.model.Employee;
    
    @Mapper
    public interface EmployeeMyBatisRepository {
        @Select("select * from employees")
        public List < Employee > findAll();
    
        @Select("SELECT * FROM employees WHERE id = #{id}")
        public Employee findById(long id);
    
        @Delete("DELETE FROM employees WHERE id = #{id}")
        public int deleteById(long id);
    
        @Insert("INSERT INTO employees(id, first_name, last_name,email_address) " +
            " VALUES (#{id}, #{firstName}, #{lastName}, #{emailId})")
        public int insert(Employee employee);
    
        @Update("Update employees set first_name=#{firstName}, " +
            " last_name=#{lastName}, email_address=#{emailId} where id=#{id}")
        public int update(Employee employee);
    }

让我们理解上面的代码。**通过id**检索员工的*findById*方法：

@Select("SELECT * FROM employees WHERE id = #{id}")
     public Employee findById(long id);

*@Select("SELECT \* FROM employees WHERE id = \#\{id\}")* \- *@Select*强调这是一个选择查询。*\#\{id\}*用于指示 id 是此查询的参数。

您可以观察到它们定义了一个没有实现的简单接口方法。

@Select("select * from employees")
    public List<Employee> findAll();

*@Select("select \* from student")* \- 因为我们想要返回一个学生列表，所以我们不需要传递任何参数。这是一个简单的*@Select*查询。

## 7. 运行应用程序 ##

为简单起见，我们将让 Application 类实现 CommandLineRunner 并实现 run 方法来测试 JDBC 方法。

package net.guides.springboot2.jdbc;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    import net.guides.springboot2.jdbc.model.Employee;
    import net.guides.springboot2.jdbc.repository.EmployeeMyBatisRepository;
    
    @SpringBootApplication
    public class Application implements CommandLineRunner {
    
        private Logger logger = LoggerFactory.getLogger(this.getClass());
    
        @Autowired
        private EmployeeMyBatisRepository employeeRepository;
    
        @Override
        public void run(String...args) throws Exception {
    
            logger.info("Inserting -> {}", employeeRepository.insert(new Employee(10011 L, "Ramesh", "Fadatare", "ramesh@gmail.com")));
            logger.info("Inserting -> {}", employeeRepository.insert(new Employee(10012 L, "John", "Cena", "john@gmail.com")));
            logger.info("Inserting -> {}", employeeRepository.insert(new Employee(10013 L, "tony", "stark", "stark@gmail.com")));
    
            logger.info("Employee id 10011 -> {}", employeeRepository.findById(10011 L));
    
            logger.info("Update 10003 -> {}", employeeRepository.update(new Employee(10011 L, "ram", "Stark", "ramesh123@gmail.com")));
    
            employeeRepository.deleteById(10013 L);
    
            logger.info("All users -> {}", employeeRepository.findAll());
        }
    
        public static void main(String[] args) {
            SpringApplication.run(Application.class, args);
        }
    }

## 输出 ##

[在我的GitHub 存储库][GitHub] 中获取本教程的源代码 。

[Spring boot]: https://www.javaguides.net/p/spring-boot-tutorial.html
[Spring Initializer_ Spring Boot]: https://www.javaguides.net/2019/04/create-spring-boot-project-with-spring-initializer.html
[Spring Tool Suite _STS_ _ Spring Boot]: https://www.javaguides.net/2019/04/create-spring-boot-project-in-spring-tool-suite.html
[GitHub]: https://github.com/RameshMF/spring-boot-tutorial