gaussdb json解析

gaussdb (GaussDB Kernel 503.1.0.SPC1200 build c28d95e9) -- 序列
CREATE SEQUENCE seq_head_id START WITH 1;
CREATE SEQUENCE seq_line_id START WITH 1;-- 头表
CREATE TABLE head_t (head_id BIGINT PRIMARY KEY DEFAULT nextval('seq_head_id'),productName VARCHAR(200) NOT NULL,price DECIMAL(10,2) NOT NULL,isActive BOOLEAN DEFAULT true,updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);-- 创建产品表
CREATE TABLE line_t (line_Id BIGINT PRIMARY KEY DEFAULT nextval('seq_line_id'),from_head_id BIGINT,demand_date TIMESTAMP,quantity  number(28,10),updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);-------------------------------------------------------------------------------
-- 测试1：检查GaussDB的JSON函数支持
SELECT json_typeof('{"test": "value"}'::json) as typeof_json,json_typeof('[1,2,3]'::json) as typeof_array,('{"test": "value"}'::json)->'test' as get_value,json_array_length('[1,2,3]'::json) as array_length;-- 测试2：简化函数版本
CREATE OR REPLACE FUNCTION test_json_support() 
RETURNS INTEGER
LANGUAGE plpgsql
AS $$
DECLAREv_test_json JSON;v_result TEXT;
BEGINRAISE NOTICE '测试JSON基本功能';-- 测试1：解析JSONv_test_json := '{"insertlists": [{"name": "test"}]}'::JSON;RAISE NOTICE '测试1通过: JSON解析成功';-- 测试2：检查字段是否存在IF v_test_json->'insertlists' IS NOT NULL THENRAISE NOTICE '测试2通过: 字段检查成功';END IF;-- 测试3：检查类型v_result := json_typeof(v_test_json->'insertlists');RAISE NOTICE '测试3通过: 类型检查成功, 类型: %', v_result;RETURN 1;
EXCEPTIONWHEN OTHERS THENRAISE NOTICE '测试失败: %', SQLERRM;RETURN 0;
END;
$$;-- 运行测试
SELECT test_json_support();-------------------------------------------------------------------------------
CREATE OR REPLACE FUNCTION process_json_data_batch(json_data TEXT) 
RETURNS INTEGER
LANGUAGE plpgsql
AS $$
DECLAREv_json JSON;v_head_id BIGINT;v_elem JSON;v_update_elem JSON;v_key TEXT;v_value TEXT;v_num_value NUMERIC(28,10);i INT;j INT;v_insert_count INT := 0;v_update_count INT := 0;v_product_name TEXT;v_price DECIMAL(10,2);v_is_active BOOLEAN;v_from_head_id BIGINT;
BEGINRAISE NOTICE '=== 开始执行函数 ===';-- 解析JSONBEGINv_json := json_data::JSON;RAISE NOTICE 'JSON解析成功';EXCEPTIONWHEN OTHERS THENRAISE NOTICE 'JSON解析失败: %', SQLERRM;RETURN 0;END;BEGIN-- 处理insertlistsIF json_typeof(v_json) = 'object' THENRAISE NOTICE '开始处理insertlists';BEGINIF json_array_length(v_json->'insertlists') > 0 THENRAISE NOTICE 'insertlists数组长度: %', json_array_length(v_json->'insertlists');i := 0;WHILE i < json_array_length(v_json->'insertlists') LOOPBEGIN-- 获取数组元素v_elem := v_json->'insertlists'->i;RAISE NOTICE '处理第 % 个产品', i;-- 先提取字段值v_product_name := v_elem->>'productName';v_price := (v_elem->>'price')::DECIMAL(10,2);v_is_active := COALESCE((v_elem->>'isActive')::BOOLEAN, true);RAISE NOTICE '产品名称: %, 价格: %, 是否激活: %', v_product_name, v_price, v_is_active;-- 插入head_t表（不使用RETURNING，直接获取序列值）v_head_id := nextval('seq_head_id');INSERT INTO head_t (head_id, productName, price, isActive)VALUES (v_head_id, v_product_name, v_price, v_is_active);RAISE NOTICE '插入head_t成功, ID: %', v_head_id;v_insert_count := v_insert_count + 1;-- 处理日期字段j := 0;FOR v_key, v_value IN SELECT key, value FROM json_each_text(v_elem)LOOPIF v_key ~ '^\d{4}-\d{2}$' THENBEGINv_num_value := v_value::NUMERIC(28,10);-- 插入line_t表INSERT INTO line_t (line_id, from_head_id, demand_date, quantity)VALUES (nextval('seq_line_id'),v_head_id,(v_key || '-01')::date,v_num_value);RAISE NOTICE '插入line_t: % -> %', v_key, v_num_value;v_insert_count := v_insert_count + 1;j := j + 1;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '插入line_t失败: key=%, value=%, error=%', v_key, v_value, SQLERRM;END;END IF;END LOOP;RAISE NOTICE '为该产品插入了 % 个日期记录', j;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '处理产品失败: %', SQLERRM;END;i := i + 1;END LOOP;ELSERAISE NOTICE 'insertlists为空数组';END IF;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '处理insertlists异常: %', SQLERRM;END;END IF;-- 处理updatelistsIF json_typeof(v_json) = 'object' THENRAISE NOTICE '开始处理updatelists';BEGINIF json_array_length(v_json->'updatelists') > 0 THENRAISE NOTICE 'updatelists数组长度: %', json_array_length(v_json->'updatelists');i := 0;WHILE i < json_array_length(v_json->'updatelists') LOOPBEGINv_update_elem := v_json->'updatelists'->i;v_from_head_id := (v_update_elem->>'from_head_id')::BIGINT;RAISE NOTICE '处理更新项, head_id: %', v_from_head_id;-- 处理日期字段j := 0;FOR v_key, v_value IN SELECT key, value FROM json_each_text(v_update_elem)LOOPIF v_key ~ '^\d{4}-\d{2}$' THENBEGINv_num_value := v_value::NUMERIC(28,10);-- 先检查记录是否存在PERFORM 1 FROM line_t WHERE from_head_id = v_from_head_id AND demand_date = (v_key || '-01')::date;IF FOUND THEN-- 更新记录UPDATE line_t SET quantity = v_num_value,updated_at = CURRENT_TIMESTAMPWHERE from_head_id = v_from_head_id AND demand_date = (v_key || '-01')::date;RAISE NOTICE '更新成功: head_id=%, date=%', v_from_head_id, v_key;v_update_count := v_update_count + 1;ELSE-- 插入新记录INSERT INTO line_t (line_id, from_head_id, demand_date, quantity)VALUES (nextval('seq_line_id'),v_from_head_id,(v_key || '-01')::date,v_num_value);RAISE NOTICE '插入成功: head_id=%, date=%', v_from_head_id, v_key;v_update_count := v_update_count + 1;END IF;j := j + 1;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '更新失败: head_id=%, date=%, error=%', v_from_head_id, v_key, SQLERRM;END;END IF;END LOOP;RAISE NOTICE '为该head_id处理了 % 个日期记录', j;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '处理更新项失败: %', SQLERRM;END;i := i + 1;END LOOP;ELSERAISE NOTICE 'updatelists为空数组';END IF;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '处理updatelists异常: %', SQLERRM;END;END IF;RAISE NOTICE '=== 函数执行完成 ===';RAISE NOTICE '总计插入: % 条记录', v_insert_count;RAISE NOTICE '总计更新: % 条记录', v_update_count;RETURN 1;EXCEPTIONWHEN OTHERS THENRAISE NOTICE '=== 函数执行异常 ===';RAISE NOTICE '错误信息: %', SQLERRM;RAISE NOTICE '错误详情: %', SQLSTATE;RETURN 0;END;
END;
$$;------------------------------------------------------------------------------
-- 清空数据
TRUNCATE TABLE head_t CASCADE;
TRUNCATE TABLE line_t;-- 删除并重建序列
DROP SEQUENCE IF EXISTS seq_head_id cascade;
CREATE SEQUENCE seq_head_id START WITH 1;DROP SEQUENCE IF EXISTS seq_line_id cascade;
CREATE SEQUENCE seq_line_id START WITH 1;-------------------------------------------------------------------------------- 测试调用
SELECT process_json_data_batch('{"insertlists": [{"productName": "产品1","price": "12.3","2025-12": 480,"2026-01": 0,"2026-02": 480,"2026-03": 0,"2026-04": 480,"2026-05": 0,"2026-06": 56,"isActive": true},{"productName": "产品2","price": "16.3","2025-12": 482,"2026-01": 10,"2026-02": 4380,"2026-03": 0,"2026-04": 4780,"isActive": true}],"updatelists": [{"from_head_id": "1","2025-12": 485,"2026-01": 13,"2026-02": 470,"2026-03": 0,"2026-04": 47380},{"from_head_id": "2","2025-12": 4812,"2026-01": 110,"2026-02": 41380,"2026-03": 0,"2026-04": 47780}]}');[2025-12-07 15:52:03.618 CST] : [NOTICE] === 开始执行函数 ===
[2025-12-07 15:52:03.618 CST] : [NOTICE] JSON解析成功
[2025-12-07 15:52:03.618 CST] : [NOTICE] 开始处理insertlists
[2025-12-07 15:52:03.618 CST] : [NOTICE] insertlists数组长度: 2
[2025-12-07 15:52:03.618 CST] : [NOTICE] 处理第 0 个产品
[2025-12-07 15:52:03.618 CST] : [NOTICE] 产品名称: 产品1, 价格: 12.30, 是否激活: t
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入head_t成功, ID: 1
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2025-12 -> 480.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-01 -> 0.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-02 -> 480.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-03 -> 0.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-04 -> 480.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-05 -> 0.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-06 -> 56.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 为该产品插入了 7 个日期记录
[2025-12-07 15:52:03.618 CST] : [NOTICE] 处理第 1 个产品
[2025-12-07 15:52:03.618 CST] : [NOTICE] 产品名称: 产品2, 价格: 16.30, 是否激活: t
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入head_t成功, ID: 2
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2025-12 -> 482.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-01 -> 10.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-02 -> 4380.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-03 -> 0.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 插入line_t: 2026-04 -> 4780.0000000000
[2025-12-07 15:52:03.618 CST] : [NOTICE] 为该产品插入了 5 个日期记录
[2025-12-07 15:52:03.618 CST] : [NOTICE] 开始处理updatelists
[2025-12-07 15:52:03.618 CST] : [NOTICE] updatelists数组长度: 2
[2025-12-07 15:52:03.618 CST] : [NOTICE] 处理更新项, head_id: 1
[2025-12-07 15:52:03.618 CST] : [NOTICE] 更新成功: head_id=1, date=2025-12
[2025-12-07 15:52:03.618 CST] : [NOTICE] 更新成功: head_id=1, date=2026-01
[2025-12-07 15:52:03.618 CST] : [NOTICE] 更新成功: head_id=1, date=2026-02
[2025-12-07 15:52:03.618 CST] : [NOTICE] 更新成功: head_id=1, date=2026-03
[2025-12-07 15:52:03.618 CST] : [NOTICE] 更新成功: head_id=1, date=2026-04
[2025-12-07 15:52:03.618 CST] : [NOTICE] 为该head_id处理了 5 个日期记录
[2025-12-07 15:52:03.618 CST] : [NOTICE] 处理更新项, head_id: 2
[2025-12-07 15:52:03.846 CST] : [INFO] 操作影响的记录行数 : 1
[2025-12-07 15:52:03.846 CST] : [INFO] 执行时间 : 405 ms
[2025-12-07 15:52:03.846 CST] : [INFO] 执行成功... 
[2025-12-07 15:52:03.884 CST] : [NOTICE] 更新成功: head_id=2, date=2025-12
[2025-12-07 15:52:03.884 CST] : [NOTICE] 更新成功: head_id=2, date=2026-01
[2025-12-07 15:52:03.884 CST] : [NOTICE] 更新成功: head_id=2, date=2026-02
[2025-12-07 15:52:03.884 CST] : [NOTICE] 更新成功: head_id=2, date=2026-03
[2025-12-07 15:52:03.884 CST] : [NOTICE] 更新成功: head_id=2, date=2026-04
[2025-12-07 15:52:03.884 CST] : [NOTICE] 为该head_id处理了 5 个日期记录
[2025-12-07 15:52:03.884 CST] : [NOTICE] === 函数执行完成 ===
[2025-12-07 15:52:03.884 CST] : [NOTICE] 总计插入: 14 条记录
[2025-12-07 15:52:03.884 CST] : [NOTICE] 总计更新: 10 条记录------------------------------------------------------------------------------
-- 查看head_t表数据
SELECT * FROM head_t ORDER BY head_id;-- 查看line_t表数据，按产品和日期排序
SELECT h.head_id,h.productName,h.price,l.demand_date,l.quantity,l.updated_at
FROM head_t h
JOIN line_t l ON h.head_id = l.from_head_id
ORDER BY h.head_id, l.demand_date;-- 统计每个产品的记录数
SELECT h.head_id,h.productName,COUNT(l.line_id) as line_count
FROM head_t h
LEFT JOIN line_t l ON h.head_id = l.from_head_id
GROUP BY h.head_id, h.productName
ORDER BY h.head_id;