当前位置:网站首页> Mysql如何对json数据进行查询及修改
Mysql如何对json数据进行查询及修改
2022-07-05 18:57:00 【1024问】
对json数据进行查询及修改
几个相关函数
示例
查询
来看看修改
删除
插入
Mysql处理json数据
对json数据进行查询及修改使用 字段->'$.json属性' 进行查询条件
使用 json_extract 函数查询,json_extract(字段, "$.json属性")
根据json数组查询,用 JSON_CONTAINS(字段, JSON_OBJECT('json属性', "内容")) : [{}]查询这种形式的json数组
MySQL5.7以上支持JSON的操作,以及增加了JSON存储类型
一般数据库存储JSON类型的数据会用JSON类型或者TEXT类型
几个相关函数示例我这里没有创建json的字段格式,而是使用了text存储json 。
注意:用JSON类型的话1)JSON列存储的必须是JSON格式数据,否则会报错。2)JSON数据类型是没有默认值的。
插入json格式的数据到这一列中:
{"age": "28", "pwd": "lisi", "name": "李四"}
查询1、
select * from `offcn_off_main` where json_extract(json_field,"$.name") = '李四'
2、
select * from `offcn_off_main` where json_field->'$.name' = '李四'
使用explain可以查看到无法使用索引。
所以需要修改:
mysql原生并不支持json列中的属性索引,但是我们可以通过mysql的虚拟列间接的为json中的某些属性创建索引,原理就是为json中的属性创建虚拟列,然后通过给虚拟列建立索引,从而间接的给属性创建了索引。
在MySQL 5.7中,支持两种Generated Column,即Virtual Generated Column和Stored Generated Column,前者只将Generated Column保存在数据字典中(表的元数据),并不会将这一列数据持久化到磁盘上;后者会将Generated Column持久化到磁盘上,而不是每次读取的时候计算所得。很明显,后者存放了可以通过已有数据计算而得的数据,需要更多的磁盘空间,与Virtual Column相比并没有优势----(其实我觉得还是有优势毕竟会少一些查询计算)
因此,MySQL 5.7中,不指定Generated Column的类型,默认是Virtual Column。
如果需要Stored Generated Golumn的话,可能在Virtual Generated Column上建立索引更加合适,一般情况下,都使用Virtual Generated Column,这也是MySQL默认的方式。
格式如下:
fieldname <type> [ GENERATED ALWAYS ] AS ( <expression> ) [ VIRTUAL|STORED ] [ UNIQUE [KEY] ] [ [PRIMARY] KEY ] [ NOT NULL ] [ COMMENT <text> ]
所以我这里:
ALTER TABLE 'off_main' `names_virtual` VARCHAR(20) GENERATED ALWAYS AS (`json_field` ->> '$.name') not null;
Note: 利用操作符-» 来引用JSON字段中的KEY。在本例中字段names_virtual为虚拟字段,我把它定义成不可以为空。在实际的工作中,一定要集合具体的情况来定。因为JSON本身是一种弱结构的数据对象。也就是说的它的结构不是固定不变的。
给虚拟字段增加索引:
CREATE INDEX `names` ON `off_main`(`names_virtual`);
注意如果虚拟字段并不是创建表是添加的,而是后面加的,增加索引时如果有的行中虚拟字段为null,但是又设置了它不能为null,那么索引无法创建成功,提示column can not be null.
增加索引后 explain看下即可看到用到了索引,并且虚拟字段的值会随着json字段的属性修改而自动变化。
来看看修改update off_main set json_field = json_set(json_field,'$.phone', '132') WHERE id = 45 //同时修改多个UPDATE offcn_off_main set json_field = json_set(json_field,'$.name',456,'$.age','bbb') WHERE id = 45
json_set() 方法存在的则会覆盖,不存在的会添加。
删除UPDATE offcn_off_main set json_field = json_remove(json_field,'$.pwd','$.phone') WHERE id = 45
插入UPDATE offcn_off_main set json_field = json_insert(json_field,'$.pwd','111') WHERE id = 45
insert与update不同之处在于insert不存在的会增加,存在的不会覆盖
Mysql处理json数据1.如果数据量小的话,将json数据直接复制到mysql的json字段中,如果数据过大可以通过java等后台形式对json数据解析,然后写入数据库中。
查询操作
select *,json->'$.features[0].geometry.rings' as rings from JSON;
从一张表读取一部分数据存入另一张表中(一条数据)
insert into DT_village(name, border) SELECT json->'$.features[0].attributes.CJQYMC',json->'$.features[0].geometry.rings'from JSON;
读取json数据并写入数据库(此时使用的是定义函数的形式来执行方法,可以定义便量)
#清空数据库TRUNCATE table DT_village;#定义存储过程delimiter //DROP PROCEDURE IF EXISTS insert_test_val;##num_limit 要插入数据的数量,rand_limit 最大随机的数值CREATE PROCEDURE insert_test_val() BEGIN DECLARE i int default 0; DECLARE a,b varchar(5000); WHILE i<10 do set a=CONCAT('$.features[',i,'].attributes.CJQYMC'); set b=CONCAT('$.features[',i,'].geometry.rings'); insert into DT_village(name, border) select #json->'$.features[0].attributes.CJQYMC',json->'$.features[0].geometry.rings' # (json->a),(json->b) json_extract(json,a),json_extract(json,b) from JSON; set i = i + 1; END WHILE; END//#调用存储过程call insert_test_val();
调用游标的方式获取jsosn数据中的一行,并执行插入操作
delimiter //drop procedure if exists StatisticStore;CREATE PROCEDURE StatisticStore() BEGIN #创建接收游标数据的变量 declare j json;#存储json数据 DECLARE i int default 0; #创建总数变量,记录执行次数,控制循环 DECLARE a,b,c varchar(5000);#定义json数组中的某个数据的键值 #创建结束标志变量 declare done int default false; #创建游标 declare cur cursor for select json from JSON where name = '1'; #指定游标循环结束时的返回值 declare continue HANDLER for not found set done = true; #设置初始值 set a=CONCAT('$.features[',i,'].attributes.XZQDM'); set b=CONCAT('$.features[',i,'].attributes.XZQMC'); set c=CONCAT('$.features[',i,']'); #打开游标 open cur; #开始循环游标里的数据 read_loop:loop #根据游标当前指向的一条数据 fetch cur into j; #判断游标的循环是否结束 if done then leave read_loop;#跳出游标循环 end if; #这里可以做任意你想做的操作 WHILE i<11 do insert into dt_border(xzq_code,name,border) select json_extract(j,a),json_extract(j,b),json_extract(j,c) from JSON; set i = i + 1; END WHILE; #结束游标循环 end loop; #关闭游标 close cur; #输出结果 select j,i; END;#调用存储过程call StatisticStore();
以上为个人经验,希望能给大家一个参考,也希望大家多多支持软件开发网。
边栏推荐
- Oracle故障处理:Ora-10873:file * needs to be either taken out of backup or media recovered
- Go语言学习教程(十五)
- EasyCVR电子地图中设备播放器loading样式的居中对齐优化
- Interprocess communication (IPC): shared memory
- Emqx 5.0 officially released: a single cluster supports 100million mqtt connections
- 视频融合云平台EasyCVR增加多级分组,可灵活管理接入设备
- 如何实现游戏中的在线计时器和离线计时器
- EMQX 5.0 正式发布:单集群支持 1 亿 MQTT 连接
- uniapp获取微信头像和昵称
- HiEngine:可媲美本地的云原生内存数据库引擎
猜你喜欢
彻底理解为什么网络 I/O 会被阻塞?
After the company went bankrupt, the blackstones came
2022最新Android面试笔试,一个安卓程序员的面试心得
手把手教你处理 JS 逆向之图片伪装
cf:B. Almost Ternary Matrix【对称 + 找规律 + 构造 + 我是构造垃圾】
Ultrasonic ranging based on FPGA
数据库 逻辑处理功能
ELK分布式日志分析系统部署(华为云)
How to quickly advance automated testing? Listen to the personal feelings of the three bat test engineers
2022 the most complete Tencent background automation testing and continuous deployment practice in the whole network [10000 words]
随机推荐
手机开户选择哪家券商公司比较好哪家平台更安全
AI金榜题名时,MLPerf榜单的份量究竟有多重?
Blue sky drawing bed Apple quick instructions
After the company went bankrupt, the blackstones came
面试官:Redis 过期删除策略和内存淘汰策略有什么区别?
Cf:b. almost Terry matrix [symmetry + finding rules + structure + I am structural garbage]
EasyCVR授权到期页面无法登录,该如何解决?
flume系列之:拦截器过滤数据
Mysql database indexing tutorial (super detailed)
Simple query cost estimation
Word finds red text word finds color font word finds highlighted formatted text
CDB 实例的启动与关闭
Go语言学习教程(十五)
蚂蚁集团开源可信隐私计算框架「隐语」:开放、通用
集合处理的利器
【历史上的今天】7 月 5 日:Google 之母出生;同一天诞生的两位图灵奖先驱
Debezium系列之:解析默认值字符集
Windows Oracle open remote connection Windows Server Oracle open remote connection
开源 SPL 消灭数以万计的数据库中间表
Taishan Office Technology Lecture: from the layout height of the line, talk about the height overflow and height shrinkage of the drawing height (launched in the whole network)