wueasy框架之MyBatis使用

使用wueasy框架过程中，怎么使用MyBatis对数据库进行操作？

引入数据库客户端工具

<dependency>
    <groupId>com.wueasy</groupId>
    <artifactId>wueasy-database-client</artifactId>
    <version>2.0.0</version>
</dependency>

新增数据库映射

编写数据库表结构映射实体bean。

为了简化自定义sql，这里使用的是通用Mapper，部分属性需要使用注解方式，注解可参考以下api文档https://github.com/abel533/Mapper/wiki/2.2-mapping

package com.wueasy.demo.entity;

import java.io.Serializable;
import javax.persistence.Id;
import javax.persistence.Table;
import tk.mybatis.mapper.annotation.KeySql;

@Table(name = "user")
public class User implements Serializable {

    private static final long serialVersionUID = 1L;

    /**
     * 主键id
     */
    @Id
    @KeySql(useGeneratedKeys = true)
    private Long id;

    /**
     * 姓名
     */
    private String name;

    /**
     * 年龄
     */
    private Integer age;

    /**
     * 邮箱
     */
    private String email;

    /**
     * 主键id
     */
    public Long getId() {
        return id;
    }

    /**
     * 主键id
     */
    public void setId(Long id) {
        this.id = id;
    }

    /**
     * 姓名
     */
    public String getName() {
        return name;
    }

    /**
     * 姓名
     */
    public void setName(String name) {
        this.name = name;
    }

    /**
     * 年龄
     */
    public Integer getAge() {
        return age;
    }

    /**
     * 年龄
     */
    public void setAge(Integer age) {
        this.age = age;
    }

    /**
     * 邮箱
     */
    public String getEmail() {
        return email;
    }

    /**
     * 邮箱
     */
    public void setEmail(String email) {
        this.email = email;
    }

}

新增mapper接口

接口需要继承通用Mapper接口，Mapper接口提供了常见的增删改查方法，可以直接使用。

package com.wueasy.demo.mapper;

import com.wueasy.demo.entity.User;
import tk.mybatis.mapper.common.Mapper;

public interface UserMapper extends Mapper<User> {

}

自定义sql

对于一些特殊的需求或者复杂的sql，通用mapper接口无法满足时，我们可以通过自定义sql方式实现。

mapper接口中新增一个查询方法

public interface UserMapper extends Mapper<User> {

    List<User> selectByName(@Param("name")String name);
}

创建mapper.xml文件

• 首先创建一个mapper.xml文件，对应mapper接口。

mapper.xml文件内容如下，和普通mybatis文件一样。

<?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.wueasy.demo.mapper.UserMapper">
  <resultMap id="BaseResultMap" type="com.wueasy.demo.entity.User">
     <id column="id" property="id" />
     <result column="name" property="name" />
     <result column="age" property="age" />
     <result column="email" property="email" />
  </resultMap>

  <sql id="Base_Column_List">
    id
    ,name
    ,age
    ,email
  </sql>

  <select id="selectByName" resultMap="BaseResultMap">
    select
    <include refid="Base_Column_List" />
    from user where name = #{name}
      order by id desc
  </select>

</mapper>

数据库连接配置

配置数据库连接信息和mybatis扫描信息

wueasy:
  datasource :
    demo :
      mybatis:
        basePackage: com.wueasy.demo.mapper
        mapperLocations: classpath*:mybatis/wueasy/demo/*.xml
      connection:
        url : jdbc:mysql://localhost:3306/easy_data?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8
        username : easyadmin
        password : easyadmin
        #连接池配置
        initialSize : 10  #初始化大小
        minIdle : 10  #最小连接
        maxActive : 20  #最大连接
        maxWait : 60000  #配置获取连接等待超时的时间
        timeBetweenEvictionRunsMillis : 2000  #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
        minEvictableIdleTimeMillis : 600000  #配置一个连接在池中最小生存的时间，单位是毫秒
        maxEvictableIdleTimeMillis : 600000  #配置一个连接在池中最大生存的时间，单位是毫秒
        validationQuery : SELECT 1 from dual
        testWhileIdle : true
        testOnBorrow : false
        testOnReturn : false
        keepAlive : true

测试接口

使用junit测试接口

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes=Application.class)
public class DbTests {

    @Autowired
    private UserMapper userMapper;

    @Test
    public void testObj()  {

        try{
            //查询全部
            System.err.println(JsonHelper.toJSONString(userMapper.selectAll()));

        }catch(Exception e) {
            e.printStackTrace();
        }

    }
}

原文地址

原文地址