1. 程式人生 > >SpringBoot系列7-SpringBoot+mybatis+druid+TypeHandler

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

介紹在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 utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '姓名', `parent_phone` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '家長電話號碼逗號分隔', `city` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '居住城市json格式儲存{\"province\":\"廣東省\",\"city\":\"深圳市\",\"district\":\"南山區\"}'
, `net_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '網名逗號分隔', PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- 插入學生資訊 -- ----------------------------
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<Student> selectStudentList();
    
}

編寫StudentDao.xml Mapper.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.tiankonglanlande.cn.springboot.mybatis.dao.StudentDao" >

    <select id="selectStudentList" resultType="Student">
        SELECT * FROM student
    </select>

</mapper>

編寫StudentService

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

編寫StudentController

@RestController
public class StudentController {

    @Autowired
    private StudentService studentService;

    @RequestMapping("/students")
    public List<Student> selectStudentList(){
        List<Student> students = studentService.selectStudentList();
        return 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

    @Select("SELECT * FROM student")
    List<Student> selectStudentListByAnnotation();

StudentService新增方法selectStudentListByAnnotation

public List<Student> selectStudentListByAnnotation(){
        return studentDao.selectStudentListByAnnotation();
    }

StudentController呼叫

@RequestMapping("/students2")
    public List<Student> selectStudentListByAnnotation(){
        List<Student> students = studentService.selectStudentListByAnnotation();
        return 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"
  }
]

解決上面返回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<String> 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;
}

修改Student將CityBean作為他的屬性


/**
 * 學生實體類
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class Student implements Serializable {

    private String id;
    private String name;
    private String[] parentPhone;//此處修改為陣列物件
    private CityBean city;//修改為CityBean類
    private String[] netName;//此處修改為陣列物件
}

定義JsonCityBeanTypeHandler


public class JsonCityBeanTypeHandler extends BaseTypeHandler<CityBean> {
    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 <T>
 */
public class JsonListTypeHandler<T> extends BaseTypeHandler<List<T>> {
    public static ObjectMapper objectMapper = new ObjectMapper();

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

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

        return getBeanList(str);
    }

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

        return getBeanList(str);
    }

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

        return getBeanList(str);
    
            
           

相關推薦

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

介紹在SpringBoot中整合mybatis和druid以及自定義TypeHandler 建立資料庫表 SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- --------------------------

SpringBoot系列(7)---SpringBoot-Cache(EhCache)

SpringBoot提供資料快取的功能,相信非常多人已經用過cache了。因為資料庫的IO瓶頸應該大家也吃過不少虧了,所以一般情況下我們都會引入非常多的快取策略,例如引入redis,引入hibernate的二級快取等等。 SpringBoot在annotation的層面給我

Springboot系列SpringbootMybatis整合

前言 技術部落格那麼多,為什麼自己整理呢?太過零散的知識點不易記憶,且查詢的時候也不是太方便,眼過千遍不如手過一遍的操作一遍,即使Springboot已經很好的整合了各項的技術框架,但實際操作的時候也會發現一些問題。我會將可能出現的問題記錄一下,博文時刻更新。 預備知識: Springboot 2.0.6

springboot 2.1.3 + mybatis + druid配置多數據源

tab sys cal 1.9 path exc http bject cat 在一些大型的項目中,通常會選擇多數據庫來滿足一些業務需求,此處講解使用springboot、mybatis和druid來配置多數據源 1、依賴配置   pom文件引入相關依賴

SpringBoot系列SpringBoot註解詳解

一、註解(annotations)列表  @SpringBootApplication:包含了@ComponentScan、@Configuration和@EnableAutoConfiguration註解。其中@ComponentScan讓Spring Boot掃描到Con

SpringBoot系列springboot整合Redis

引入依賴: <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-b

SpringBoot系列springboot靜態變數注入

【場景】 配置檔案中的配置項的讀取,例如:defaultTimes=3 【變數獲取】 1.一般變數獲取 @Value("${defaultTimes}") private String defaultTimes; 2.靜態變數獲取 @Component public cl

SpringBoot系列SpringBoot打包成war,並在tomcat下執行

1、實現繼承SpringBootServletInitializer類package com.example.demo; import org.springframework.boot.builder.SpringApplicationBuilder; import org

Springboot系列Springboot的郵件服務

前言 Springboot集常用的功能於一體,當然郵件功能作為最常見的功能,自然不能缺席Springboot的大家庭,spring-boot-starter-mail這個jar裡面封裝了SpringBoot的郵件功能。下面來看一下常見的郵件用途 預備知識: Springboot 2.1.1 Maven 3

SpringBoot 系列-3 SpringBoot 第一個Controller

註解這塊與springmvc都是一樣的 我們看一個簡單點例子。 package com.example.demo; import org.springframework.stereotype.Controller; import org.springframework.web.bind.a

SpringBoot 系列-2 SpringBoot demo

spring官方提供一個demo  https://start.spring.io/ 可以選擇你的構建工具、版本、Group、Artifact 等資訊。 點選generate之後會下載一個zip包。 本文以eclipse 和  maven 作為工作, 匯入zip

Springboot系列Springboot與Thymeleaf模板引擎整合基礎教程(附原始碼)

前言 由於在開發My Blog專案時使用了大量的技術整合,針對於部分框架的使用和整合的流程沒有做詳細的介紹和記錄,導致有些朋友用起來有些吃力,因此打算在接下來的時間裡做一些基礎整合的介紹,當然,可能也不會特別的基礎,但是原始碼會開放給大家,方便大家學習,此次的原始碼地址為s

SpringCloud系列——SSO 單點登入 SpringCloud系列——Zuul 動態路由 SpringBoot系列——Redis SpringBoot系列——Redis

  前言   作為分散式專案,單點登入是必不可少的,文字基於之前的的部落格(猛戳:SpringCloud系列——Zuul 動態路由,SpringBoot系列——Redis)記錄Zuul配合Redis實現一個簡單的sso單點登入例項   sso單點登入思路:   1、訪問分散式系統的任意請求,被Zuul的

SpringBoot系列(6)---SpringBoot-JPA

JPA 應該都熟悉了,我就不多說了什麼是JPA了。目前JPA主要實現由hibernate和openJPA等。Spring Data JPA 是Spring Data 的一個子專案,它通過提供基於JPA的Repository極大了減少了操作JPA的程式碼。筆者覺得這個由Spri

springboot + mybatis +druid

ima eth hid time col sele ons getname uid Druid Spring Boot Starter mybatis-spring-boot-autoconfigure 新建spring boot工程,添加pom依賴 <depen

SpringBoot 使用yml配置 mybatis+pagehelper+druid+freemarker實例

fontsize () mysq 分頁插件 findall req 實體 select ppp SpringBoot 使用yml配置 mybatis+pagehelper+druid+freemarker實例這是一個簡單的SpringBoot整合實例這裏是項

mybatis+druid+springboot 註解方式配置多個數據源

pat nts println service ssp bsp manager 打開 iba 1\數據庫配置 #test數據源 spring.datasource.test.url=jdbc:mysql://*:3306/db?useUnicode=true&ch

springboot+mybatis+druid 多資料來源整合

       前言:在上一篇文章裡面我們進行了spring boot 和 mybatis 的整合 《springboot整合mybatis使用druid資料來源》, 文中是使用的單資料來源,因為專案中有很多需要用到多資料來源的場景,比如主從同步(讀寫分離)

SpringBoot入門篇--整合mybatis+generator自動生成程式碼+druid連線池+PageHelper分頁外掛

我們這一一篇部落格講的是如何整合Springboot和Mybatis框架,然後使用generator自動生成mapper,pojo等檔案。然後再使用阿里巴巴提供的開源連線池druid,這個連線池的好處我就不說了,集合了所有連線池的好處,並且還提供了監控等功能,加大了可擴充套件性等等。   1.&

Spring全家桶系列一一SpringBootMybatis結合

本文首發於"Java知音"。 Mybatis 是一個持久層ORM框架,負責Java與資料庫資料互動,也可以簡易理解為中介,相對於它,還有個中介是hibernate,不過在mybatis中sql語句的靈活性,可優化性比較強,這也是現在大多數人選擇的原因。 1. mapper.