Spring Boot系列7-SpringBoot+mybatis+druid+TypeHandler

猿份哥 1年前 ⋅ 781 阅读 ⋅ 0 个赞

介绍在SpringBoot中集成mybatis和druid以及自定义TypeHandler

创建数据库表

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- 创建student表
-- ----------------------------
DROP TABLE IF EXISTS `student`;
CREATE TABLE `student`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '姓名',
  `parent_phone` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '家长电话号码逗号分隔',
  `city` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '居住城市json格式存储{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}',
  `net_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '网名逗号分隔',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = COMPACT;

-- ----------------------------
-- 插入学生信息
-- ----------------------------
INSERT INTO `student` VALUES (1, '小英', '13222222222,13333333333,15777777777', '{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}', '会飞的鱼,小小雪,茉莉香果果');
INSERT INTO `student` VALUES (2, '小明', '13222222222,13333333333,15777777777', '{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}', '会飞的鱼2,小小雪2,茉莉香果果2');

SET FOREIGN_KEY_CHECKS = 1;

 

xml方式

在pom.xml添加mybatis,druid,mysql驱动配置

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.3.2</version>
    </dependency>

    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>

    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.1.10</version>
    </dependency>
    
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>

在application.yml中配置mybatis

# 使用druid数据源
spring:
    datasource:
        druid:
          driver-class-name: com.mysql.jdbc.Driver
          filters: stat
          maxActive: 20
          initialSize: 1
          maxWait: 60000
          minIdle: 1
          timeBetweenEvictionRunsMillis: 60000
          minEvictableIdleTimeMillis: 300000
          validationQuery: select 'x'
          testWhileIdle: true
          testOnBorrow: false
          testOnReturn: false
          poolPreparedStatements: true
          maxOpenPreparedStatements: 20
          db-type: com.alibaba.druid.pool.DruidDataSource
    thymeleaf:
      cache: false

mybatis:
  type-handlers-package:  com.tiankonglanlande.cn.springboot.mybatis.typehandler
  mapperLocations: classpath:mapper/**.xml
  typeAliasesPackage:  com.tiankonglanlande.cn.springboot.mybatis.bean
  # 开启自动映射
  configuration:
    map-underscore-to-camel-case: true
    lazy-loading-enabled: false
    auto-mapping-behavior: full

数据库信息相关配置

spring.datasource.url = jdbc:mysql://localhost:3306/school?useUnicode=true&characterEncoding-utf8&allowMultiQueries=true
spring.datasource.username= root
spring.datasource.password= root

启动文件相关配置

@SpringBootApplication
@MapperScan("com.tiankonglanlande.cn.springboot.mybatis.dao")
public class MybatisDruidApplication {

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

说明:@MapperScan扫描注入指定的包名下Mapper接口注入容器

编写数据库表对应的Student实体类

/**
 * 学生实体类
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class Student implements Serializable {

    private String id;
    private String name;
    private String parentPhone;
    private String city;
    private String netName;
}

编写StudentDao Mapper接口

public interface StudentDao {

    /**
     * 查询所有的学生信息
     * @return
     */
    List selectStudentList();
    
}

编写StudentDao.xml Mapper.xml

@Service
public class StudentService {
    @Autowired
    private StudentDao studentDao;
    public List selectStudentList(){
        return studentDao.selectStudentList();
    }
}

编写StudentController

@RestController
public class StudentController {

    @Autowired
    private StudentService studentService;

    @RequestMapping("/students")
    public List selectStudentList(){
        List students = studentService.selectStudentList();
        return students;
    }
}

在浏览器访问:http://localhost:8080/students得到结果

[
  {
    "id": "1",
    "name": "小英",
    "parentPhone": "13222222222,13333333333,15777777777",
    "city": "{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}",
    "netName": "会飞的鱼,小小雪,茉莉香果果"
  },
  {
    "id": "2",
    "name": "小明",
    "parentPhone": "13222222222,13333333333,15777777777",
    "city": "{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}",
    "netName": "会飞的鱼2,小小雪2,茉莉香果果2"
  }
]

使用纯注解方式

StudentDao添加方法selectStudentListByAnnotation

public List selectStudentListByAnnotation(){
        return studentDao.selectStudentListByAnnotation();
    }

StudentController調用

@RequestMapping("/students2")
    public List selectStudentListByAnnotation(){
        List students = studentService.selectStudentListByAnnotation();
        return students;
    }

在浏览器访问:http://localhost:8080/students得到与xml访问相同的结果

[
  {
    "id": "1",
    "name": "小英",
    "parentPhone": "13222222222,13333333333,15777777777",
    "city": "{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}",
    "netName": "会飞的鱼,小小雪,茉莉香果果"
  },
  {
    "id": "2",
    "name": "小明",
    "parentPhone": "13222222222,13333333333,15777777777",
    "city": "{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}",
    "netName": "会飞的鱼2,小小雪2,茉莉香果果2"
  }
]

解决上面返回json数据的问题
从上面json的数据可以看出parentPhone和netName是多条数据通过逗号拼接成的一个字段,还有city是json字符串组成的文本
这样前端拿到数据可能还需要进行处理成集合再遍历出来;city是一个json字符串文本,要想转化成json还需要一番周折,
那么作为认真负责的后台开发的我们可以使用Mybatis的TypeHandler将parentPhone和netName转化成集合,将city转化成标准的json方便前端绑定数据。

 

处理逗号拼接的字符串为集合

首先我们看之前在application.yml中配置mybatis的一段代码

mybatis:
  type-handlers-package:  com.tiankonglanlande.cn.springboot.mybatis.typehandler

说明:这一段代码会扫描com.tiankonglanlande.cn.springboot.mybatis.typehandler包下面的TypeHandler注入到spring容器

 

修改一下Student实体属性为集合

/**
 * 学生实体类
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class Student implements Serializable {

    private String id;
    private String name;
    private String[] parentPhone;//此处修改为数组对象
    private String city;
    private String[] netName;//此处修改为数组对象
}

自定义typehandler

/**
 * 字符串转int数组
 */
public class StringArrayTypeHandler extends BaseTypeHandler<String[]>{
    private static final String delimiter=",";

    @Override
    public void setNonNullParameter(PreparedStatement preparedStatement, int i, String[] strings, JdbcType jdbcType) throws SQLException {
        List list=new ArrayList<>();
        for (String item:strings){
            list.add(String.valueOf(item));
        }
        preparedStatement.setString(i,String.join(delimiter,list));
    }

    @Override
    public String[] getNullableResult(ResultSet resultSet, String s) throws SQLException {
        String str=resultSet.getString(s);
        if (resultSet.wasNull()){
            return null;
        }
        return str.split(delimiter);
    }


    @Override
    public String[] getNullableResult(ResultSet resultSet, int i) throws SQLException {
        String str= resultSet.getString(i);
        if (resultSet.wasNull()){
            return null;
        }
        return str.split(delimiter);
    }

    @Override
    public String[] getNullableResult(CallableStatement callableStatement, int i) throws SQLException {
        String str= callableStatement.getString(i);
        if (callableStatement.wasNull()){
            return null;
        }
        return str.split(delimiter);
    }
}

说明:setNonNullParameter方法会在保存数据库之前执行,我们在此方法将保存的数组使用逗号拼接还原数据库存储方式
其他方法是从数据库取出数据时mybatis将把数据映射成实体类执行,此时我们将逗号拼接的字符串转换为数组形式

 

验收逗号拼接字符串转换为数组成果

浏览器输入http://localhost:8080/students可以看到原先逗号拼接的字符串已经转换为集合对象

[
  {
    "id": "1",
    "name": "小英",
    "parentPhone": [
      "13222222222",
      "13333333333",
      "15777777777"
    ],
    "city": "{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}",
    "netName": [
      "会飞的鱼",
      "小小雪",
      "茉莉香果果"
    ]
  },
  {
    "id": "2",
    "name": "小明",
    "parentPhone": [
      "13222222222",
      "13333333333",
      "15777777777"
    ],
    "city": "{\"province\":\"广东省\",\"city\":\"深圳市\",\"district\":\"南山区\"}",
    "netName": [
      "会飞的鱼2",
      "小小雪2",
      "茉莉香果果2"
    ]
  }
]

解决最后一个问题:将city转化成标准的json方便前端绑定数据

定义CityBean

@Data
@AllArgsConstructor
@NoArgsConstructor
public class CityBean implements Serializable{
    private String province;
    private String city;
    private String district;
}

定义JsonCityBeanTypeHandler

public class JsonCityBeanTypeHandler extends BaseTypeHandler {
    public ObjectMapper objectMapper=new ObjectMapper();

    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, CityBean t, JdbcType jdbcType) throws SQLException {
        try {
            ps.setString(i,objectMapper.writeValueAsString(t));
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
    }

    @Override
    public CityBean getNullableResult(ResultSet resultSet, String s) throws SQLException {
        String str=resultSet.getString(s);
        if (resultSet.wasNull()){
            return null;
        }
        return getBean(str);
    }

    @Override
    public CityBean getNullableResult(ResultSet resultSet, int i) throws SQLException {
        return null;
    }

    @Override
    public CityBean getNullableResult(CallableStatement callableStatement, int i) throws SQLException {
        return null;
    }

    private CityBean getBean(String str){
        if (StringUtils.isEmpty(str))
            return null;
        try {
            return objectMapper.readValue(str,CityBean.class);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }
}

如果是存储的是json集合字符串可以这样

修改student表添加一个visited字段(数据随便插入的不要当真哈!)

alter table student add visited varchar(256) COMMENT '去过的地方jsonarray存储[{"province":"广东省","city":"深圳市","district":"南山区"}]';
UPDATE student SET visited='[{"province":"四川省","city":"深圳市","district":"南山区"}]' WHERE id=1;
UPDATE student SET visited='[{"province":"四川省","city":"深圳市","district":"南山区"},{"province":"广东省","city":"成都市","district":"青羊区"}]' WHERE id=2;

定义VisitedBean

/**
 * 去过的地方
 */
public class VisitedBean extends CityBean{

}

定义JsonListTypeHandler

/**
 * json集合字符串转集合
 * @param 
 */
public class JsonListTypeHandler extends BaseTypeHandler {
    public static ObjectMapper objectMapper = new ObjectMapper();

    @Override
    public void setNonNullParameter(PreparedStatement ps, int i,  List parameter, JdbcType jdbcType) throws SQLException {
        try {
            ps.setString(i, objectMapper.writeValueAsString(parameter));
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
    }

    @Override
    public List getNullableResult(ResultSet rs, String columnName) throws SQLException {
        String str = rs.getString(columnName);
        if (rs.wasNull())
            return null;

        return getBeanList(str);
    }

    @Override
    public List getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        String str = rs.getString(columnIndex);
        if (rs.wasNull())
            return null;

        return getBeanList(str);
    }

    @Override
    public List getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        String str = cs.getString(columnIndex);
        if (cs.wasNull())
            return null;

        return getBeanList(str);
    }

    private List getBeanList(String str) {
        if (StringUtils.isEmpty(str)){
            return null;
        }
        try {
            List beanList =objectMapper.readValue(str,new TypeReference(){});
            return beanList;
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }
}

测试结果,浏览器输入:http://localhost:8080/students
结果如下:

[
  {
    "id": "1",
    "name": "小英",
    "parentPhone": [
      "13222222222",
      "13333333333",
      "15777777777"
    ],
    "city": {
      "province": "广东省",
      "city": "深圳市",
      "district": "南山区"
    },
    "visited": [
      {
        "province": "四川省",
        "city": "深圳市",
        "district": "南山区"
      }
    ],
    "netName": [
      "会飞的鱼",
      "小小雪",
      "茉莉香果果"
    ]
  },
  {
    "id": "2",
    "name": "小明",
    "parentPhone": [
      "13222222222",
      "13333333333",
      "15777777777"
    ],
    "city": {
      "province": "广东省",
      "city": "深圳市",
      "district": "南山区"
    },
    "visited": [
      {
        "province": "四川省",
        "city": "深圳市",
        "district": "南山区"
      },
      {
        "province": "广东省",
        "city": "成都市",
        "district": "青羊区"
      }
    ],
    "netName": [
      "会飞的鱼2",
      "小小雪2",
      "茉莉香果果2"
    ]
  }
]

源码下载链接https://github.com/tiankonglanlande/springboot


全部评论: 0

    我有话说:

    Spring Boot系列1-helloword

      使用springboot简单轻松创建helloword SpringBoot系列1-helloword 关于springboot这是摘自官方的一段话 Spring Boot

    Spring Boot系列6-SpringBoot中使用servlet

    介绍在SpringBoot中如何使用servlet pom.xml <dependency> <groupId>org.springframework.boot<

    spring boot面试题及答案持续更新中

    2019-07-28最新整理的spring boot面试题及答案 1.Spring Boot是什么 这是摘自官方的一段话 Spring Boot is designed to get you up

    springboot1.5.9升级到springboot2.1.3遇到的问题

    1.问题描述: Failed to bind properties under 'spring.datasource.druid.driver' to java.sql.Driver:  

    ...jar中没有主清单属性, spring boot或者spring cloud的maven项目 java -jar test.jar 方式启动报错:...jar中没有主清单属性

    1.spring boot或者spring cloud的maven项目老是遇到问题...jar中没有主清单属性 2.解决方法:在pom.xml中添加如下代码 <build> <

    SpringBoot系列19-防止重复请求,重复表单提交超级简单注解的实现之四(终极版II)

    前言: 根据最新spring boot:2.5.0版本和在《SpringBoot防止重复请求,重复表单提交超级简单的注解实现之四(终极版I)》之上化繁为简抽取更实用的代码,新增超时机制 防重复提交

    Spring Boot系列2-全局统一异常处理

    原创: 天空和唯美 天空唯美  点击查看原文 为什么要全局统一异常处理呢?如果系统发生了异常,不做统一异常处理,前端会给用户展示一大片看不懂的文字。做统一异常处理后当

    SpringBoot系列16-Spring boot2x快速整合swagger2(Open Api3注解版)

    前言:为什么要使用swagger 传统的web开发,前端和后端的HTTP接口文档交互都是使用word文档记录,存在不仅限于这些问题;不能时时更新,不易于传输etc. swagger2可以使用配置文件的方式和注解的方式生成HTTP请求文档代码各有优...

    Spring Boot应用或SpringCloud程序设置端口号的几种方式

    前言:springboot项目的每个应用都需要设置端口号,如何设置端口号呢?主要有以下这几种方式 1.通过配置文件设置: (1)在/src/main/resources/路径下的

    spring boot系列4-定时任务-springboot自带的scheduled超级简单

    需求:创建一个每天凌晨0点执行的定时任务1.创建任务 /** * @author 天空蓝蓝的 */ @Slf4j @EnableScheduling @Component public class MyTask { @Async @Schedul...

    Spring Boot系列5-定时任务-springboot整合quartz实现动态定时任务

    MyJob实现Job接口,重写execute方法在里面操作我们要执行的业务逻辑。 @Slf4j public class MyJob implements Job { @Autowired private MyService myService;...

    SpringBoot系列15-mysql-multiple-data-sources1

    springboot 多数据源的一个简单示例 多数据源分包加载 新建数据库test1和表tbl_user CREATE TABLE `tbl_user` ( `id` int(11) NOT

    如果SpringBoot与SpringCloud老是出各种问题,别急!请看下面的SpringBoot与SpringCloud的版本对应详细版

    1.问题 当我们在开发微服务的时候因为SpringBoot和SpringCloud这两兄弟版本没有对应好老是出现各种各样的问题。特别苦逼!别急,往下看!遇到就是缘分,我叫猿份哥! 2.原因

    idea离线安装better-mybatis-generator

    1.idea离线安装better-mybatis-generator 2.下载better-mybatis-generator 浏览器输入链接http://plugins.jetbrains.com

    加入公众号
    加入公众号