概述

以前當(dāng)業(yè)務(wù)數(shù)據(jù)結(jié)構(gòu)變化時(shí)，往往需要采用的方案是：

修改表結(jié)構(gòu)增加字段
遇到數(shù)據(jù)結(jié)構(gòu)有l(wèi)ist結(jié)構(gòu)時(shí)，新建1對多的關(guān)聯(lián)子表
用字典表表示字段的增加

以上方案對代碼侵入性很強(qiáng)，同時(shí)與舊業(yè)務(wù)數(shù)據(jù)結(jié)構(gòu)不兼容。導(dǎo)致代碼從實(shí)體類

、Dao、Service、Controller層都要修改。

隨著NOSQL數(shù)據(jù)庫的廣泛應(yīng)用，可擴(kuò)展的存儲方式在關(guān)系型數(shù)據(jù)庫中也有了很好的支持，最新的MySQL5.7中就新增加了一個(gè)數(shù)據(jù)類型JSON，使用mysql的json類型字段做擴(kuò)展字段，可以以json串形式動態(tài)的存儲任意結(jié)構(gòu)的數(shù)據(jù)，包括list結(jié)構(gòu)的數(shù)據(jù)也不必再創(chuàng)建子表。代碼的實(shí)體類和Dao層不必修改，其他層代碼修改量也能夠減少。

Mysql常見json字段操作

Mysql5.7開始支持json字段

創(chuàng)建帶有json字段的表micro_test,其中extcol為json類型字段

CREATE TABLE `micro_test` (

`id` int(11) NOT NULL AUTO_INCREMENT,

`meta_name` varchar(100) DEFAULT NULL COMMENT '元數(shù)據(jù)名稱',

`create_time` datetime DEFAULT NULL COMMENT '創(chuàng)建時(shí)間',

`update_time` datetime DEFAULT NULL COMMENT '更新時(shí)間',

`extcol` json DEFAULT NULL,

PRIMARY KEY (`id`)

) ENGINE=InnoDB CHARSET=utf8;

插入json字段

可按照json字符串插入json字段

Insert into micro_test (extcol,meta_name,create_time)

values('{"name":"tomcat","age":15}',’123’,now());

查詢json字段

可以根據(jù)path查詢json字段中全部或部分?jǐn)?shù)據(jù)

Select meta_name,extcol->>'$.name' as name,extcol->>'$.age' as age from micro_test;

修改json字段

可以根據(jù)path局部更新json字段中數(shù)據(jù)

Update micro_test set extcol=json_set(extcol,'$.name','jeffrey') where meta_name='123'

Mysql5.7.22版本以后支持JSON_MERGE_PATCH

可以省略path參數(shù)，全面更新json字段中數(shù)據(jù)

Update micro_test set extcol=json_set(extcol,'{“name”:”n1”,”age”:30}') where meta_name='123'

Mybatis使用Json字段

按照mybatis常規(guī)方式把json函數(shù)寫入到xml文件中的sql中，即可支持json字段增刪改查。但查詢出的json字段為字符串類型，需要手工轉(zhuǎn)成bean，插入時(shí)需手工把bean轉(zhuǎn)成json字符串，這樣做不利于面向?qū)ο缶幊獭?/p>

Mybatis深度整合Json字段

實(shí)現(xiàn)bean與json串在mybatis內(nèi)部轉(zhuǎn)換，這樣做的優(yōu)點(diǎn)是dao層代碼和sql不變，service層可以增刪改查不同的動態(tài)Entity對象。更符合面向?qū)ο缶幊塘?xí)慣提高開發(fā)效率。

Extcol開源項(xiàng)目實(shí)現(xiàn)Mybatis與mysql的json字段深度整合

項(xiàng)目地址為：

https://github.com/jeffreyning/extcol.git

pom引用extcol的jar

<groupId>com.github.jeffreyning</groupId>

<artifactId>extcol</artifactId>

<version>0.0.1-RELEASE</version>

</dependency>

Extcol包中TypeHandler子類TagToJsonTypeHandler 實(shí)現(xiàn)mybatis在數(shù)據(jù)庫操作過程中的參數(shù)輸入和結(jié)果轉(zhuǎn)換的攔截。攔截父類為ExtBeanWrapper的對象。

使TagToJsonTypeHandler生效需要配置

mybatis-plus:

typeHandlersPackage: com.nh.micro.ext.th

Extcol包中ExtBeanWrapper類，作為json對象轉(zhuǎn)換的目標(biāo)對象，內(nèi)有map成員變量保存實(shí)際數(shù)據(jù),getobj和setobj方法是使用fastjson做對象與map的轉(zhuǎn)換。

使用Extcol的Demo

引入和配置好extcol后，在demo業(yè)務(wù)系統(tǒng)工程中編寫對應(yīng)micro_test表的實(shí)體類TestDto，其中json字段的成員變量類型是ExtBeanWrapper。

public class TestDto {

private Integer id;

private String metaKey;

private String metaName;

private String metaType;

private Date createTime;

private ExtBeanWrapper extcol;

public ExtBeanWrapper getExtcol() {

return extcol;

}

public void setExtcol(ExtBeanWrapper extcol) {

}

擴(kuò)展字段業(yè)務(wù)bean

例如擴(kuò)展bean為ExtEntity有兩個(gè)在數(shù)據(jù)庫中json字段動態(tài)存儲的字段t1和t2

public class ExtEntity {

private String t1;

private String t2;

public String getT1() {

return t1;

}

public void setT1(String t1) {

this.t1 = t1;

}

public String getT2() {

return t2;

}

public void setT2(String t2) {

this.t2 = t2;

}

在以TestDto為更新和插入時(shí)的參數(shù)操作時(shí)，mybatis將負(fù)責(zé)將bean轉(zhuǎn)為json串

insert into micro_test(meta_name,extcol,create_time) values (#{metaName},#{extcol},now())

</update>

當(dāng)執(zhí)行查詢語句時(shí)，返回的結(jié)果映射到ExtBeanWrapper 類型的字段時(shí)，mybatis將負(fù)責(zé)將json串轉(zhuǎn)為ExtBeanWrapper ，且這個(gè)ExtBeanWrapper 可以按照不同的業(yè)務(wù)bean自適應(yīng)轉(zhuǎn)化。

</resultMap>

SELECT * from micro_test where meta_name=#{name}

</select>

取查詢結(jié)果中JSON字段中存儲的業(yè)務(wù)類ExtEntity 的代碼

public List<TestDto> testQuery4JsonXml(String name){

List<TestDto> retList=testDao.getInfo4JsonXml(name);

if(retList!=null){

for(TestDto testDto:retList){

ExtBeanWrapper extBeanWrapper=testDto.getExtcol();

ExtEntity extEntity=(ExtEntity) extBeanWrapper.getObj(ExtEntity.class);

System.out.println(extEntity.getT1());

}

return retList;

}

Mybatisplus的bean更新時(shí)使用JSON_MERGE_PATCH

修改mybatisplus的AutoSqlInjector

private String getPlaceTag(String row){

int start=row.indexOf("#{");

int end=row.indexOf("}")+1;

String temp=row.substring(start,end);

System.out.println(temp);

return temp;

}

private String getColTag(String row){

int end=row.indexOf("=#{");

int start=0;

if(row.contains("<if")){

start=row.indexOf(">")+1;

}

String temp=row.substring(start,end);

System.out.println(temp);

return temp;

}

private String createNewPlace(String colTag,String placeTag){

String temp="json_merge_patch("+colTag+","+placeTag+")";

return temp;

}

protected void injectUpdateByIdSql(boolean selective, Class<?> mapperClass, Class<?> modelClass, TableInfo table) {

SqlMethod sqlMethod = selective ? SqlMethod.UPDATE_BY_ID : SqlMethod.UPDATE_ALL_COLUMN_BY_ID;

String temp=sqlSet(selective, table, "et.");

String osql=temp;

if(selective){

String[] tempArray=temp.split("\n\t");

StringBuilder sb=new StringBuilder("");

for(String row:tempArray){

if(row.contains("typeHandler")){

System.out.println(getPlaceTag(row));

String placeTag=getPlaceTag(row);

System.out.println(getColTag(row));

String colTag=getColTag(row);

String nPlaceTag=createNewPlace(colTag, placeTag);

System.out.println(nPlaceTag);

row=row.replace(placeTag, nPlaceTag);

sb.append(row).append("\n\t");

}else{

sb.append(row).append("\n\t");

}

osql=sb.toString();

}

String sql = String.format(sqlMethod.getSql(), table.getTableName(), osql, table.getKeyColumn(),

"et." + table.getKeyProperty(),

"<if test=\"et instanceof java.util.Map\">"

+ "<if test=\"et.MP_OPTLOCK_VERSION_ORIGINAL!=null\">"

+ "and ${et.MP_OPTLOCK_VERSION_COLUMN}=#{et.MP_OPTLOCK_VERSION_ORIGINAL}"

+ "</if>"

);

System.out.println(sql);

SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, modelClass);

this.addUpdateMappedStatement(mapperClass, modelClass, sqlMethod.getMethod(), sqlSource);

}

extcolMybatis深度整合Mysql的Json字段

概述

Mysql常見json字段操作

Mybatis使用Json字段

Mybatis深度整合Json字段

使用Extcol的Demo