在mysql函数中循环JSON对象

Posted 2023-02-24

【中文标题】在mysql函数中循环JSON对象

【英文标题】：Loop through JSON object in mysql function

【发布时间】：2018-04-25 17:59:33

【问题描述】：

我有一个 json 对象，其中包含账单下的产品列表。我想为其编写一个 mysql 函数，该函数从 json 读取数据并一一迭代，并将相同的数据插入到产品和账单表中。

这是我的 json 对象

"billNo":16,"date":"2017-13-11 09:05:01","customerName":"Vikas","total":350.0,"fixedCharges":100,"taxAmount":25.78,"status":paid,"product":["productId":"MRR11","categoryId":72,"categoryName":"Parker Pen","cost":200,"quantity":2,"log":"supplierId":"725","supplierName":"Rihant General Stores","productId":"MRR12","categoryId":56,"categoryName":"Drawing Books","cost":150,"quantity":3,"log":"supplierId":"725","supplierName":"Rihant General Stores"]

这里我有一个从 JSON 读取数据的 mysql 函数

CREATE DEFINER=`mydb`@`%` FUNCTION `raiseOrder`(dataObject Json) 
RETURNS bigint(11)
BEGIN
    DECLARE billNo BIGINT(11) DEFAULT NULL;
    DECLARE customerName VARCHAR(64);
    DECLARE date datetime DEFAULT NOW();
    DECLARE total Float(12,2);
    DECLARE taxamt Float(12,2);
    DECLARE fixedCharges Float(12,2);

    DECLARE products json;
    DECLARE productId bigint(15) DEFAULT NULL;
    DECLARE categoryId bigint(11);
    DECLARE cost float;
    DECLARE categoryName varchar(64);
    DECLARE quantity int default 0;
    DECLARE supplierId bigint(11);
    DECLARE supplierName varchar(128);

    SET billNo = (SELECT JSON_EXTRACT(dataObject, "$.billNo"));
    SET customerName = (SELECT JSON_EXTRACT(dataObject, "$.customerName"));
    SET products = (SELECT JSON_EXTRACT(dataObject, "$.products"));        
    SET productId = (SELECT JSON_EXTRACT(products, "$[0].productId"));      
RETURN 1;
END

现在这些行

SET products = (SELECT JSON_EXTRACT(dataObject, "$.products"));        
SET productId = (SELECT JSON_EXTRACT(products, "$[0].productId"));      

我得到了内部产品 json 和第 0 个产品的 id。但我想要一种迭代产品数组的方法。

【问题讨论】：

老实说，我不会在 MySQL 函数中这样做。我会用 Python 或 Ruby 编写一个脚本来完成它。除了 MySQL 存储例程之外的所有其他语言都支持更方便的 JSON 处理方式。

但是这个我必须在Mysql中做。

目前 MySQL 对 JSON 处理的功能非常有限，因此建议使用其他语言，但是可以实现的第一个近似值是 db-fiddle，根据需要调整脚本。

【参考方案1】：

您可以将 WHILE 循环与 JSON_LENGTH 结合使用来实现：

DECLARE json, products, product VARCHAR(4000);
DECLARE i INT DEFAULT 0;
SELECT '"billNo":16,"date":"2017-13-11 09:05:01","customerName":"Vikas","total":350.0,"fixedCharges":100,"taxAmount":25.78,"status":"paid","product":["productId":"MRR11","categoryId":72,"categoryName":"Parker Pen","cost":200,"quantity":2,"log":"supplierId":"725","supplierName":"Rihant General Stores","productId":"MRR12","categoryId":56,"categoryName":"Drawing Books","cost":150,"quantity":3,"log":"supplierId":"725","supplierName":"Rihant General Stores"]
' INTO json;

SELECT json->"$.product" INTO products;

WHILE i < JSON_LENGTH(products) DO
    SELECT JSON_EXTRACT(products,CONCAT('$[',i,']')) INTO product;
    SELECT product;
    SELECT i + 1 INTO i;
END WHILE;

您可能需要做的不仅仅是“选择产品”；-)

注意：MySQL JSON 函数是在 5.7.8 中添加的，因此您需要先检查您的 MySQL 版本。