extcol

Mybatis深度整合Mysql的Json字段
授权协议 Apache
开发语言 Java
所属分类 程序开发、 ORM/持久层框架
软件类型 开源软件
地区 国产
投 递 者 张淳
操作系统 跨平台
开源组织
适用人群 未知
 软件概览

概述

以前当业务数据结构变化时,往往需要采用的方案是:

  1. 修改表结构增加字段
  2. 遇到数据结构有list结构时,新建1对多的关联子表
  3. 用字典表表示字段的增加

以上方案对代码侵入性很强,同时与旧业务数据结构不兼容。导致代码从实体类

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

 

随着NOSQL数据库的广泛应用,可扩展的存储方式在关系型数据库中也有了很好的支持,最新的MySQL5.7中就新增加了一个数据类型JSON,使用mysql的json类型字段做扩展字段,可以以json串形式动态的存储任意结构的数据,包括list结构的数据也不必再创建子表。代码的实体类和Dao层不必修改,其他层代码修改量也能够减少。

 

Mysql常见json字段操作

Mysql5.7开始支持json字段

创建带有json字段的表micro_test,其中extcol为json类型字段

CREATE TABLE `micro_test` (

  `id` int(11) NOT NULL AUTO_INCREMENT,

  `meta_name` varchar(100) DEFAULT NULL COMMENT '元数据名称',

  `create_time` datetime DEFAULT NULL COMMENT '创建时间',

  `update_time` datetime DEFAULT NULL COMMENT '更新时间',

  `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字段

可以根据path查询json字段中全部或部分数据

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

 

修改json字段

可以根据path局部更新json字段中数据

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

 

Mysql5.7.22版本以后支持JSON_MERGE_PATCH

可以省略path参数,全面更新json字段中数据

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

 

Mybatis使用Json字段

按照mybatis常规方式把json函数写入到xml文件中的sql中,即可支持json字段增删改查。但查询出的json字段为字符串类型,需要手工转成bean,插入时需手工把bean转成json字符串,这样做不利于面向对象编程。

Mybatis深度整合Json字段

实现bean与json串在mybatis内部转换,这样做的优点是dao层代码和sql不变,service层可以增删改查不同的动态Entity对象。更符合面向对象编程习惯提高开发效率。

 

 

Extcol开源项目实现Mybatis与mysql的json字段深度整合

项目地址为:

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

 

pom引用extcol的jar

<dependency>

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

<artifactId>extcol</artifactId>

<version>0.0.1-RELEASE</version>

</dependency>

 

Extcol包中TypeHandler子类TagToJsonTypeHandler 实现mybatis在数据库操作过程中的参数输入和结果转换的拦截。拦截父类为ExtBeanWrapper的对象。

使TagToJsonTypeHandler生效需要配置

mybatis-plus:

  typeHandlersPackage: com.nh.micro.ext.th

 

 

Extcol包中ExtBeanWrapper类,作为json对象转换的目标对象,内有map成员变量保存实际数据,getobj和setobj方法是使用fastjson做对象与map的转换。

 

使用Extcol的Demo

引入和配置好extcol后,在demo业务系统工程中编写对应micro_test表的实体类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) {

}

 

扩展字段业务bean

例如扩展bean为ExtEntity有两个在数据库中json字段动态存储的字段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为更新和插入时的参数操作时,mybatis将负责将bean转为json串

<update id="insertInfo4JsonXml" parameterType="com.test.nm.order.dto.TestDto">

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

</update>

 

 

 

 

当执行查询语句时,返回的结果映射到ExtBeanWrapper 类型的字段时,mybatis将负责将json串转为ExtBeanWrapper ,且这个ExtBeanWrapper 可以按照不同的业务bean自适应转化。

  <resultMap id="TestDto" type="com.test.nm.order.dto.TestDto" >

    <id column="id" property="id" jdbcType="INTEGER" />

    <result column="meta_name" property="metaName" jdbcType="VARCHAR" />

    <result column="create_time" property="createTime" jdbcType="TIMESTAMP" />

    <result column="extcol" property="extcol" jdbcType="VARCHAR" />

  </resultMap>

 

<select id="getInfo4JsonXml" resultMap="TestDto" parameterType="java.lang.String">

SELECT * from micro_test where meta_name=#{name}

</select>

 

取查询结果中JSON字段中存储的业务类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更新时使用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>"

                        + "</if>"

        );

        System.out.println(sql);

 

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

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

    }

 

 

 

 相关资料
  • 问题内容: Python中是否有一个可用于深度合并字典的库: 以下: 当我结合时,我希望它看起来像: 问题答案: 我希望我不会重新发明轮子,但是解决方案相当短。而且,超级有趣的代码。 因此,其想法是将源复制到目标,并且每次源中的命令都进行递归。因此,如果在A中给定元素包含字典而在B中包含任何其他类型,则确实存在错误。

  • 问题列表 《深度学习》 8.4 参数初始化策略 一般总是使用服从(截断)高斯或均匀分布的随机值,具体是高斯还是均匀分布影响不大,但是也没有详细的研究。 但是,初始值的大小会对优化结果和网络的泛化能力产生较大的影响。 一些启发式初始化策略通常是根据输入与输出的单元数来决定初始权重的大小,比如 Glorot and Bengio (2010) 中建议建议使用的标准初始化,其中 m 为输入数,n 为输出

  • 注意 由于JS对象包括的范围非常广,加上ES6又有众多的新特性,很难、也没必要做到囊括所有的类型和情况,这里说的"对象",指的是普通的对象,不包括修改对象原型链, 或者为"Function","Promise"等的情况,请留意。 在ES6中,我们可以很方便的使用Object.assign进行对象合并,但这只是浅层的合并,如果对象的属性为数组或者对象的时候,会导致属性内部的值丢失。 注意: 此处合并

  • 问题内容: G’day, 我试图找到拖网字典的函数的递归深度,但我有点迷路了……目前,我有类似以下内容: 我想知道嵌套最多的字典是如何嵌套的…所以我要做以下… 唯一的问题是,递归循环仅返回最终值(0)的返回值。如果我输入一条打印语句, 那么我至少可以打印出最高的递归值,但是返回值是另一回事… 我敢肯定,这很简单-我刚买了果冻脑。 干杯 问题答案: 确保将递归调用的结果分配给 depth 。此外,正

  • 问题内容: 示例文档中有一个简化的文档。这对我理解非嵌套类型与嵌套类型的聚合差异很有帮助。但是,这种简化掩盖了进一步的复杂性,因此我不得不在这里扩展这个问题。 所以我的实际文件更接近以下内容: 因此,我保留了,和的关键属性,但隐藏了许多其他使情况复杂化的内容。首先,请注意,与引用的问题相比,有很多额外的嵌套:在根和“项目”之间,以及在“项目”和“ item_property_1”之间。此外,还请注

  • 问题内容: 通常我会使用浅拷贝对象 这是一个例子: 将给我们: 但是,如果我想合并对象以使父键不会被子对象覆盖,该怎么办: 将给我们: 是否有一个Angular函数已经执行了我不知道的深度合并? 如果不是,则有一种本机方法可以在javascript中递归地执行n个级别的操作。 问题答案: Angular 1.4或更高版本 用途: 不同于,递归地进入源对象的对象属性,执行深层复制。 旧版本的Angu

  • 大家都知道立方体的顶点数据经过顶点着色器、光栅、片元着色器等渲染管线单元处理后会得到立方体每个面的片元数据, 每个片元不仅包含RGB像素值,还有透明度分量A,片元的深度值Z,屏幕坐标(X,Y)等数据。 屏幕坐标(X,Y) 屏幕坐标指的是每一个片元的像素值在显示器canvas画布上的显示位置,如果一个网页上有多个canvas画布,或者打开多个包含canvas画布的网页窗口, 每一个引入WebGL的c

  • 问题内容: 如何使用JSON.NET从JSON中获取“ myThings”数组,如下所示? 范例1: 范例2: 我遇到的一些困难: 属性名称之一是不可预测的数字(“ 1234”和“ 7890”) 有时“ myThings”数组不存在-在这种情况下,我想要的是null或空数组/集合 可以帮助您的另一个考虑因素:我确实有一个静态类来表示myThings数组中的内容,所以我的理想返回值是 我的第一个尝试