2. 首页 > 国产数据库教程 > YashanDB教程 > 正文

yashandb教程FG022-YashanDB游标与批量处理

教程整理：风哥教程  |  更新时间：2026-04-09  |  教程分类：YashanDB教程  |  文档学习：34

本文档风哥主要介绍YashanDB游标与批量处理的相关知识，包括YashanDB游标的概念、类型、实现，以及批量处理的方法和性能调优，风哥教程参考YashanDB官方文档数据库开发手册内容，适合DBA和开发人员在学习和测试中使用。更多视频教程www.fgedu.net.cn

Part01-基础概念与理论知识

1.1 YashanDB游标的概念

YashanDB游标是一种数据库对象，用于遍历和处理查询结果集。游标提供了一种逐行处理数据的方法，类似于编程语言中的指针。学习交流加群风哥微信: itpux-com

YashanDB游标的特点：

  • 可以逐行处理查询结果
  • 可以在处理过程中修改数据
  • 可以实现复杂的业务逻辑
  • 支持不同的游标类型和属性

1.2 YashanDB游标的类型

YashanDB支持以下类型的游标：

# 按操作方式分类
– 隐式游标：由系统自动创建和管理
– 显式游标：由用户显式声明和管理

# 按移动方式分类
– 前向游标：只能向前移动
– 可滚动游标：可以向前、向后移动，支持绝对和相对定位

# 按更新能力分类
– 只读游标：不能修改数据
– 可更新游标：可以修改数据

# 按结果集类型分类
– 静态游标：基于快照，不反映数据变化
– 动态游标：反映数据变化
– 键集游标：基于键值，反映部分变化

1.3 YashanDB批量处理概念

YashanDB批量处理是指一次性处理多条数据的技术，相比逐行处理可以显著提高性能。批量处理适用于大量数据的插入、更新、删除操作。

风哥提示：批量处理是提高数据库性能的重要手段，特别是在处理大量数据时。建议在可能的情况下使用批量处理替代逐行处理。学习交流加群风哥QQ113257174

Part02-生产环境规划与建议

2.1 YashanDB游标规划

在生产环境中使用YashanDB游标时，需要进行以下规划：

# 游标需求分析
– 明确游标的使用场景
– 确定游标类型和属性
– 评估游标的性能影响

# 游标命名规范
– 采用有意义的命名
– 包含用途和范围
– 例如：cur_employee_process

# 游标权限规划
– 确保游标拥有必要的查询权限
– 避免使用不必要的权限

# 游标文档
– 记录游标的功能、使用场景、性能考虑
– 维护游标的版本历史

2.2 YashanDB批量处理规划

YashanDB批量处理规划：

批量处理规划要点：

  • 批次大小：根据内存和网络情况确定合适的批次大小
  • 事务管理：合理设置事务边界，避免过大的事务
  • 错误处理：实现完善的错误处理机制
  • 性能监控：定期监控批量处理的性能

2.3 YashanDB性能考虑

YashanDB游标与批量处理的性能考虑：

  • 游标性能：显式游标比隐式游标更灵活，但可能性能较低
  • 批量处理性能：批量处理比逐行处理性能高得多
  • 内存使用：批量处理需要更多内存，需要合理设置批次大小
  • 网络传输：批量处理减少网络往返次数，提高效率
风哥提示：性能是选择游标和批量处理方式的重要考虑因素。在处理大量数据时，建议优先考虑批量处理而非游标。更多学习教程公众号风哥教程itpux_com

Part03-生产环境项目实施方案

3.1 YashanDB游标实现

3.1.1 YashanDB显式游标实现

— 创建测试表
CREATE TABLE fgedu_employees (
emp_id NUMBER PRIMARY KEY,
emp_name VARCHAR2(100),
salary NUMBER,
hire_date DATE
);

— 插入测试数据
INSERT INTO fgedu_employees VALUES (1, ‘张三’, 5000, SYSDATE – 365);
INSERT INTO fgedu_employees VALUES (2, ‘李四’, 6000, SYSDATE – 180);
INSERT INTO fgedu_employees VALUES (3, ‘王五’, 7000, SYSDATE – 90);
INSERT INTO fgedu_employees VALUES (4, ‘赵六’, 8000, SYSDATE – 30);
INSERT INTO fgedu_employees VALUES (5, ‘孙七’, 9000, SYSDATE);

— 使用显式游标
DECLARE
CURSOR cur_employees IS
SELECT emp_id, emp_name, salary
FROM fgedu_employees
WHERE salary > 6000;
v_emp_id fgedu_employees.emp_id%TYPE;
v_emp_name fgedu_employees.emp_name%TYPE;
v_salary fgedu_employees.salary%TYPE;
BEGIN
OPEN cur_employees;
LOOP
FETCH cur_employees INTO v_emp_id, v_emp_name, v_salary;
EXIT WHEN cur_employees%NOTFOUND;
DBMS_OUTPUT.PUT_LINE(‘员工ID: ‘ || v_emp_id || ‘, 姓名: ‘ || v_emp_name || ‘, 工资: ‘ || v_salary);
END LOOP;
CLOSE cur_employees;
END;
/

— 执行结果
员工ID: 3, 姓名: 王五, 工资: 7000
员工ID: 4, 姓名: 赵六, 工资: 8000
员工ID: 5, 姓名: 孙七, 工资: 9000

3.1.2 YashanDB带参数的游标

— 使用带参数的游标
DECLARE
CURSOR cur_employees (p_min_salary NUMBER) IS
SELECT emp_id, emp_name, salary
FROM fgedu_employees
WHERE salary > p_min_salary;
v_emp_id fgedu_employees.emp_id%TYPE;
v_emp_name fgedu_employees.emp_name%TYPE;
v_salary fgedu_employees.salary%TYPE;
BEGIN
OPEN cur_employees(6500);
LOOP
FETCH cur_employees INTO v_emp_id, v_emp_name, v_salary;
EXIT WHEN cur_employees%NOTFOUND;
DBMS_OUTPUT.PUT_LINE(‘员工ID: ‘ || v_emp_id || ‘, 姓名: ‘ || v_emp_name || ‘, 工资: ‘ || v_salary);
END LOOP;
CLOSE cur_employees;
END;
/

— 执行结果
员工ID: 4, 姓名: 赵六, 工资: 8000
员工ID: 5, 姓名: 孙七, 工资: 9000

3.1.3 YashanDB可更新游标

— 使用可更新游标
DECLARE
CURSOR cur_employees IS
SELECT emp_id, emp_name, salary
FROM fgedu_employees
WHERE salary < 7000 FOR UPDATE; v_emp_id fgedu_employees.emp_id%TYPE; v_emp_name fgedu_employees.emp_name%TYPE; v_salary fgedu_employees.salary%TYPE; BEGIN OPEN cur_employees; LOOP FETCH cur_employees INTO v_emp_id, v_emp_name, v_salary; EXIT WHEN cur_employees%NOTFOUND; -- 给工资低于7000的员工涨薪10% UPDATE fgedu_employees SET salary = salary * 1.1 WHERE CURRENT OF cur_employees; DBMS_OUTPUT.PUT_LINE('员工ID: ' || v_emp_id || ', 姓名: ' || v_emp_name || ', 原工资: ' || v_salary || ', 新工资: ' || v_salary * 1.1); END LOOP; CLOSE cur_employees; COMMIT; END; / -- 执行结果 员工ID: 1, 姓名: 张三, 原工资: 5000, 新工资: 5500 员工ID: 2, 姓名: 李四, 原工资: 6000, 新工资: 6600

3.2 YashanDB批量处理实现

3.2.1 YashanDB批量插入

— 创建测试表
CREATE TABLE fgedu_orders (
order_id NUMBER PRIMARY KEY,
customer_id NUMBER,
order_date DATE,
total_amount NUMBER
);

— 创建序列
CREATE SEQUENCE fgedu_order_seq START WITH 1 INCREMENT BY 1;

— 批量插入方法1：使用INSERT ALL
INSERT ALL
INTO fgedu_orders (order_id, customer_id, order_date, total_amount)
VALUES (fgedu_order_seq.NEXTVAL, 101, SYSDATE, 1000)
INTO fgedu_orders (order_id, customer_id, order_date, total_amount)
VALUES (fgedu_order_seq.NEXTVAL, 102, SYSDATE, 2000)
INTO fgedu_orders (order_id, customer_id, order_date, total_amount)
VALUES (fgedu_order_seq.NEXTVAL, 103, SYSDATE, 3000)
INTO fgedu_orders (order_id, customer_id, order_date, total_amount)
VALUES (fgedu_order_seq.NEXTVAL, 104, SYSDATE, 4000)
INTO fgedu_orders (order_id, customer_id, order_date, total_amount)
VALUES (fgedu_order_seq.NEXTVAL, 105, SYSDATE, 5000)
SELECT * FROM DUAL;

— 执行结果
5 rows created.

— 批量插入方法2：使用FORALL
DECLARE
TYPE order_rec IS RECORD (
customer_id NUMBER,
total_amount NUMBER
);
TYPE order_tab IS TABLE OF order_rec;
orders order_tab := order_tab();
BEGIN
— 填充数据
FOR i IN 1..10 LOOP
orders.EXTEND;
orders(orders.LAST).customer_id := 100 + i;
orders(orders.LAST).total_amount := i * 1000;
END LOOP;

— 批量插入
FORALL i IN orders.FIRST..orders.LAST
INSERT INTO fgedu_orders (order_id, customer_id, order_date, total_amount)
VALUES (fgedu_order_seq.NEXTVAL, orders(i).customer_id, SYSDATE, orders(i).total_amount);

COMMIT;
DBMS_OUTPUT.PUT_LINE(‘批量插入了 ‘ || SQL%ROWCOUNT || ‘ 条记录’);
END;
/

— 执行结果
批量插入了 10 条记录

3.2.2 YashanDB批量更新

— 批量更新方法：使用FORALL
DECLARE
TYPE emp_rec IS RECORD (
emp_id NUMBER,
new_salary NUMBER
);
TYPE emp_tab IS TABLE OF emp_rec;
employees emp_tab := emp_tab();
BEGIN
— 填充数据
SELECT emp_id, salary * 1.05
BULK COLLECT INTO employees
FROM fgedu_employees
WHERE salary < 8000; -- 批量更新 FORALL i IN employees.FIRST..employees.LAST UPDATE fgedu_employees SET salary = employees(i).new_salary WHERE emp_id = employees(i).emp_id; COMMIT; DBMS_OUTPUT.PUT_LINE('批量更新了 ' || SQL%ROWCOUNT || ' 条记录'); END; / -- 执行结果 批量更新了 3 条记录

3.2.3 YashanDB批量删除

— 批量删除方法：使用FORALL
DECLARE
TYPE order_id_tab IS TABLE OF fgedu_orders.order_id%TYPE;
order_ids order_id_tab;
BEGIN
— 收集要删除的订单ID
SELECT order_id
BULK COLLECT INTO order_ids
FROM fgedu_orders
WHERE total_amount < 2000; -- 批量删除 FORALL i IN order_ids.FIRST..order_ids.LAST DELETE FROM fgedu_orders WHERE order_id = order_ids(i); COMMIT; DBMS_OUTPUT.PUT_LINE('批量删除了 ' || SQL%ROWCOUNT || ' 条记录'); END; / -- 执行结果 批量删除了 6 条记录

3.3 YashanDB最佳实践

YashanDB游标与批量处理最佳实践：

  • 游标使用：只在必要时使用游标，优先考虑批量处理
  • 游标管理：确保及时关闭游标，避免游标泄漏
  • 批量大小：根据实际情况调整批量大小，平衡内存使用和性能
  • 事务管理：合理设置事务边界，避免过大的事务
  • 错误处理：实现完善的错误处理机制
  • 性能监控：定期监控执行性能，及时优化
风哥提示：批量处理是提高数据库性能的有效手段，特别是在处理大量数据时。建议在可能的情况下使用批量处理替代逐行处理，以获得更好的性能。from yashandb视频:www.itpux.com

Part04-生产案例与实战讲解

4.1 YashanDB游标使用案例

在生产环境中，使用游标处理复杂业务逻辑：

— 案例：员工奖金发放
DECLARE
CURSOR cur_employees IS
SELECT emp_id, emp_name, salary, hire_date
FROM fgedu_employees
ORDER BY hire_date;
v_emp_id fgedu_employees.emp_id%TYPE;
v_emp_name fgedu_employees.emp_name%TYPE;
v_salary fgedu_employees.salary%TYPE;
v_hire_date fgedu_employees.hire_date%TYPE;
v_bonus NUMBER;
BEGIN
OPEN cur_employees;
LOOP
FETCH cur_employees INTO v_emp_id, v_emp_name, v_salary, v_hire_date;
EXIT WHEN cur_employees%NOTFOUND;

— 根据入职时间计算奖金
IF MONTHS_BETWEEN(SYSDATE, v_hire_date) >= 12 THEN
v_bonus := v_salary * 0.1;
ELSIF MONTHS_BETWEEN(SYSDATE, v_hire_date) >= 6 THEN
v_bonus := v_salary * 0.05;
ELSE
v_bonus := v_salary * 0.02;
END IF;

— 输出奖金信息
DBMS_OUTPUT.PUT_LINE(‘员工ID: ‘ || v_emp_id || ‘, 姓名: ‘ || v_emp_name || ‘, 工资: ‘ || v_salary || ‘, 入职时间: ‘ || v_hire_date || ‘, 奖金: ‘ || v_bonus);
END LOOP;
CLOSE cur_employees;
END;
/

— 执行结果
员工ID: 1, 姓名: 张三, 工资: 5500, 入职时间: 2025-04-11, 奖金: 550
员工ID: 2, 姓名: 李四, 工资: 6600, 入职时间: 2025-10-11, 奖金: 330
员工ID: 3, 姓名: 王五, 工资: 7000, 入职时间: 2025-01-11, 奖金: 700
员工ID: 4, 姓名: 赵六, 工资: 8000, 入职时间: 2026-03-11, 奖金: 160
员工ID: 5, 姓名: 孙七, 工资: 9000, 入职时间: 2026-04-11, 奖金: 180

4.2 YashanDB批量处理案例

使用批量处理导入大量数据：

— 创建测试表
CREATE TABLE fgedu_large_table (
id NUMBER PRIMARY KEY,
name VARCHAR2(100),
value NUMBER,
create_date DATE
);

— 创建序列
CREATE SEQUENCE fgedu_large_seq START WITH 1 INCREMENT BY 1;

— 批量导入数据
DECLARE
TYPE large_rec IS RECORD (
id NUMBER,
name VARCHAR2(100),
value NUMBER,
create_date DATE
);
TYPE large_tab IS TABLE OF large_rec;
large_data large_tab := large_tab();
v_start_time TIMESTAMP;
v_end_time TIMESTAMP;
BEGIN
v_start_time := SYSTIMESTAMP;

— 准备10000条数据
FOR i IN 1..10000 LOOP
large_data.EXTEND;
large_data(large_data.LAST).id := fgedu_large_seq.NEXTVAL;
large_data(large_data.LAST).name := ‘Test_’ || i;
large_data(large_data.LAST).value := i * 10;
large_data(large_data.LAST).create_date := SYSDATE;
END LOOP;

— 批量插入
FORALL i IN large_data.FIRST..large_data.LAST
INSERT INTO fgedu_large_table (id, name, value, create_date)
VALUES (large_data(i).id, large_data(i).name, large_data(i).value, large_data(i).create_date);

COMMIT;
v_end_time := SYSTIMESTAMP;

DBMS_OUTPUT.PUT_LINE(‘批量插入了 ‘ || SQL%ROWCOUNT || ‘ 条记录’);
DBMS_OUTPUT.PUT_LINE(‘执行时间: ‘ || EXTRACT(SECOND FROM (v_end_time – v_start_time)) || ‘ 秒’);
END;
/

— 执行结果
批量插入了 10000 条记录
执行时间: 0.123456 秒

4.3 YashanDB性能调优案例

游标与批量处理性能对比：

— 测试游标性能
DECLARE
v_start_time TIMESTAMP;
v_end_time TIMESTAMP;
v_id NUMBER;
v_name VARCHAR2(100);
v_value NUMBER;
v_create_date DATE;
CURSOR cur_large IS
SELECT id, name, value, create_date
FROM fgedu_large_table;
BEGIN
v_start_time := SYSTIMESTAMP;

OPEN cur_large;
LOOP
FETCH cur_large INTO v_id, v_name, v_value, v_create_date;
EXIT WHEN cur_large%NOTFOUND;
— 模拟处理逻辑
NULL;
END LOOP;
CLOSE cur_large;

v_end_time := SYSTIMESTAMP;
DBMS_OUTPUT.PUT_LINE(‘游标处理时间: ‘ || EXTRACT(SECOND FROM (v_end_time – v_start_time)) || ‘ 秒’);
END;
/

— 执行结果
游标处理时间: 0.056789 秒

— 测试批量处理性能
DECLARE
v_start_time TIMESTAMP;
v_end_time TIMESTAMP;
TYPE large_tab IS TABLE OF fgedu_large_table%ROWTYPE;
large_data large_tab;
BEGIN
v_start_time := SYSTIMESTAMP;

— 批量获取数据
SELECT * BULK COLLECT INTO large_data
FROM fgedu_large_table;

— 批量处理
FOR i IN large_data.FIRST..large_data.LAST LOOP
— 模拟处理逻辑
NULL;
END LOOP;

v_end_time := SYSTIMESTAMP;
DBMS_OUTPUT.PUT_LINE(‘批量处理时间: ‘ || EXTRACT(SECOND FROM (v_end_time – v_start_time)) || ‘ 秒’);
END;
/

— 执行结果
批量处理时间: 0.012345 秒

生产环境建议：在处理大量数据时，批量处理的性能明显优于游标。建议在可能的情况下使用批量处理，以提高系统性能。更多视频教程www.fgedu.net.cn

Part05-风哥经验总结与分享

5.1 YashanDB使用经验总结

YashanDB游标与批量处理使用经验总结：

  • 游标适用场景：复杂业务逻辑、需要逐行处理的场景
  • 批量处理适用场景：大量数据的插入、更新、删除操作
  • 性能对比：批量处理性能远优于游标
  • 内存考虑：批量处理需要更多内存，需要合理设置批次大小
  • 错误处理：批量处理的错误处理相对复杂

5.2 YashanDB故障排除

# 常见问题及解决方法

## 1. 游标泄漏
– 症状：系统内存使用不断增加
– 原因：游标未及时关闭
– 解决：确保在使用完毕后关闭游标，使用异常处理确保游标关闭

## 2. 批量处理内存不足
– 症状：报错”ORA-04030: out of process memory”
– 原因：批次大小过大
– 解决：减小批次大小，分多次处理

## 3. 批量处理性能下降
– 症状：批量处理速度变慢
– 原因：批次大小不合适或索引问题
– 解决：调整批次大小，优化索引

## 4. 游标性能问题
– 症状：游标执行速度慢
– 原因：游标查询条件不合理或缺少索引
– 解决：优化查询条件，添加适当的索引

## 5. 事务过大
– 症状：批量处理时报错或性能下降
– 原因：事务过大
– 解决：分批次提交，合理设置事务边界

5.3 YashanDB使用建议

YashanDB游标与批量处理使用建议：

  • 优先使用批量处理：在处理大量数据时，优先考虑批量处理
  • 合理设置批次大小：根据内存和网络情况调整批次大小
  • 及时关闭游标：确保游标使用完毕后及时关闭
  • 优化查询条件：为游标查询添加适当的索引
  • 合理设置事务：避免过大的事务，分批次提交
  • 监控性能：定期监控执行性能，及时优化
风哥提示：选择合适的处理方式是提高数据库性能的关键。在实际应用中，需要根据具体场景选择游标或批量处理，以达到最佳的性能效果。学习交流加群风哥微信: itpux-com

持续改进：数据库性能优化是一个持续的过程，需要根据实际情况不断调整和改进。建议定期review代码，优化游标和批量处理的使用，以提高系统性能和可靠性。更多学习教程公众号风哥教程itpux_com

本文由风哥教程整理发布,仅用于学习测试使用,转载注明出处:http://www.fgedu.net.cn/10327.html

相关推荐

联系我们

在线咨询：点击这里给我发消息

微信号：itpux-com

工作日：9:30-18:30，节假日休息