云社区 博客 博客详情
云社区 博客 博客详情

GaussDB(DWS)存储过程中实现作业执行过程日志记录方法

dual 发表于 2020-08-28 15:58:56 08-28 15:58
dual 发表于 2020-08-28 15:58:56 2020/08/28
0
0

【摘要】 本文提供了GaussDB(DWS)存储过程实现作业执行过程的日志记录方法示例,根据该示例可以更好的为业务开发提供业务的日志审计和作业审查工作。

GaussDB(DWS)存储过程中实现作业执行过程日志记录方法
具体示例如下:

--存储过程日志记录
--创建日志表
create table fun_all_execute_log(
id varchar2(32) default lower(sys_guid()),
pro_name varchar2(60),
patch_num int,
log_date date,
deal_date date,
log_mesage text);
--创建测试表和数据准备:
create table test(no int,id int);
insert into test select dbms_random.value(1,1000)::int,generate_series(1,100);
--创建业务存储过程:
CREATE OR REPLACE FUNCTION fun_affect_rows(out exe_info text)
  LANGUAGE plpgsql
  as $$
  declare v_count int;
  pro_result text;
  fun_name   text;
  patch_no   int;
begin
  fun_name := 'fun_affect_rows';
  select nvl(max(patch_num), '0') + 1 into patch_no from fun_all_execute_log where pro_name = fun_name;
  insert into test  values (dbms_random.value(1, 1000)::int,generate_series(1, dbms_random.value(10000, 20000)::int));
  GET DIAGNOSTICS v_count = ROW_COUNT;
  exe_info = sysdate || '# step1:本次插入数据量:' || v_count || '行。;';
  delete from test where no = dbms_random.value(1, 1000)::int;
  GET DIAGNOSTICS v_count = ROW_COUNT;
  exe_info = exe_info || sysdate || '# step2:本次删除数据量:' || v_count || '行。;';
  update test set id = dbms_random.value(1, 100)::int where no = dbms_random.value(1, 1000)::int and c1 = 0;
  exe_info = exe_info || sysdate || '# step3:本次更新数据量:' || sql%rowcount || '行。';
  RAISE INFO '本次信息为: %', exe_info;
  insert into fun_all_execute_log(pro_name, patch_num, log_date, deal_date, log_mesage)
  values (fun_name,patch_no,sysdate,split_part(regexp_split_to_table(exe_info, ';'), '#', 1),split_part(regexp_split_to_table(exe_info, ';'), '#', 2));
EXCEPTION
  WHEN OTHERS THEN
    pro_result := exe_info || sysdate || '# z exception error message is: ' || sqlerrm;
    insert into fun_all_execute_log(pro_name, patch_num, log_date, deal_date, log_mesage)
    values(fun_name,patch_no,sysdate,split_part(regexp_split_to_table(pro_result, ';'), '#', 1),split_part(regexp_split_to_table(pro_result, ';'), '#', 2));
END; $$;
--调用存储过程
select fun_affect_rows();
--查询日志
select * from fun_all_execute_log order by log_date desc,deal_date,log_mesage;

登录后可下载附件,请登录或者注册

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区),文章链接,文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:huaweicloud.bbs@huawei.com进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。
评论文章 //点赞 收藏 0
点赞
分享文章到微博
分享文章到朋友圈

评论 (0)


0/1000
评论

登录后可评论,请 登录注册

评论

您没有权限执行当前操作

温馨提示

您确认删除评论吗?

确定
取消
温馨提示

您确认删除评论吗?

删除操作无法恢复,请谨慎操作。

确定
取消
温馨提示

您确认删除博客吗?

确定
取消

确认删除

您确认删除博客吗?

确认删除

您确认删除评论吗?

温馨提示

登录超时或用户已下线,请重新登录!!!

确定
取消