LightDB 23.3 通过GUC参数控制commit fetch

2023-11-22 13:40
文章标签 参数 commit 控制 23.3 fetch lightdb guc

本文主要是介绍LightDB 23.3 通过GUC参数控制commit fetch，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

背景

commit游标提交之后，可以继续使用fetch进行结果集的操作。commit和fetch结合使用功能开发时不考虑分布式。后续，又对分布式进行了测试，发现持有portal后，代码中会对querydesc进行非空判断。当querydesc为空时，LightDB数据库崩溃。修改成对querydesc作非空判断之后，又会导致之前使用一个全局变量接收portal的方案失败。现在一个sql执行完，portal就会释放掉。在事务中调用打开游标的函数， 由于portal被释放，打开的游标就不能继续被fetch，故报游标不存在。

解决方案

因此决定将commit游标提交之后，可以继续使用fetch进行结果集的操作的功能利用GUC参数lightdb_cursor_after_commit 进行限制，去掉之前使用全局变量存储持有的portal的全部逻辑。
lightdb_cursor_after_commit 为off,不能在一个事务提交之后，再去fetch
操作这个结果集;为on时，一个事务提交之后，这个游标还可以继续使用。

测试

lightdb_cursor_after_commit 设置成 off

set lightdb_cursor_after_commit to off;                              
create function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab;
return 0;
end;
/
CREATE FUNCTION
lightdb@test_createdb_oracle=# begin;
BEGIN
lightdb@test_createdb_oracle=*# select fg('cf');fg 
----0
(1 row)lightdb@test_createdb_oracle=*# fetch all in cf;id | name  |  job  | age 
----+-------+-------+-----1 | asda  | gfdgd |  122 | sdfsd | cvxvx |  143 | uyiy  | mmbv  |  16
(3 rows)

lightdb_cursor_after_commit 设置成 on

set lightdb_cursor_after_commit to on; 
create or replace function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab;
return 0;
end;
/
lightdb@test_createdb_oracle=#  begin;
BEGIN
lightdb@test_createdb_oracle=*# select fg('cf');fg 
----0
(1 row)lightdb@test_createdb_oracle=*# fetch all in cf;id | name  |  job  | age 
----+-------+-------+-----1 | asda  | gfdgd |  122 | sdfsd | cvxvx |  143 | uyiy  | mmbv  |  16
(3 rows)lightdb@test_createdb_oracle=*# commit;
COMMIT
lightdb@test_createdb_oracle=# fetch all in cf;id | name | job | age 
----+------+-----+-----
(0 rows)lightdb@test_createdb_oracle=# fetch all in cf;
ERROR:  cursor "cf" does not exist

java测试：

package test;import java.math.BigDecimal;
import java.sql.*;public class PGJdbcOOMTest {public static void main(String[] args) {Connection conn = null;Statement stmt = null;ResultSet rs = null;try {Class.forName("org.postgresql.Driver");java.lang.String  dbURL = "jdbc:postgresql://192.168.105.161:5432/test_hs_oracle";conn = DriverManager.getConnection(dbURL, "lightdb", "1");//Thread.sleep(50000);conn.setAutoCommit(false); //NOTE: 为了设置fetchSize,必须设置为false// 语句stmt = conn.createStatement();stmt.setFetchSize(1);System.out.println("ps.getQueryTimeout():" + stmt.getQueryTimeout());System.out.println("ps.getFetchSize():" + stmt.getFetchSize());System.out.println("ps.getFetchDirection():" + stmt.getFetchDirection());System.out.println("ps.getMaxFieldSize():" + stmt.getMaxFieldSize());// 查询//rs = stmt.executeQuery("set lightdb_cursor_after_commit to on");//rs = stmt.executeQuery("set lightdb_syntax_compatible_type to oracle");ResultSet resultSet = stmt.executeQuery("SELECT pg_backend_pid()");rs = stmt.executeQuery("SELECT * FROM nested_tab;");while(rs.next()){System.out.println(rs.getObject(1));conn.commit();}} catch (Exception e) {System.err.println(e.getMessage());e.printStackTrace();}finally {try {if(rs != null){rs.close();}} catch (SQLException e) {System.err.println(e.getMessage());e.printStackTrace();}try {if(stmt != null) {stmt.close();}} catch (SQLException e) {System.err.println(e.getMessage());e.printStackTrace();}try {if(conn != null) {conn.close();}} catch (SQLException e) {System.err.println(e.getMessage());e.printStackTrace();}}}}

–lightdb_cursor_after_commit 设置成 off
test1
–lightdb_cursor_after_commit 设置成 on

test2

针对for update和for share测试

set lightdb_cursor_after_commit to on

for update
create table nested_tab(id int primary key, name varchar2(100), job varchar2(100), age int);
insert into nested_tab values (1, 'asda', 'gfdgd', 12);
insert into nested_tab values (2, 'sdfsd', 'cvxvx', 14);
insert into nested_tab values (3, 'uyiy', 'mmbv', 16);create  or replace function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab for update;
return 0;
end;
/lightdb@test_hs_oracle=#  begin;
BEGIN
lightdb@test_hs_oracle=*# select fg('cf');fg 
----0
(1 row)lightdb@test_hs_oracle=*# fetch all in cf;id | name  |  job  | age 
----+-------+-------+-----1 | asda  | gfdgd |  122 | sdfsd | cvxvx |  143 | uyiy  | mmbv  |  16
(3 rows)lightdb@test_hs_oracle=*# commit;
COMMIT
lightdb@test_hs_oracle=# fetch all in cf;id | name | job | age 
----+------+-----+-----
(0 rows)lightdb@test_hs_oracle=# fetch all in cf;
ERROR:  cursor "cf" does not exist

test5

for share
create  or replace function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab for share;
return 0;
end;
/lightdb@test_hs_oracle=# begin;
BEGIN
lightdb@test_hs_oracle=*# select fg('cf');fg 
----0
(1 row)lightdb@test_hs_oracle=*# fetch all in cf;id | name  |  job  | age 
----+-------+-------+-----1 | asda  | gfdgd |  122 | sdfsd | cvxvx |  143 | uyiy  | mmbv  |  16
(3 rows)lightdb@test_hs_oracle=*#  commit;
COMMIT
lightdb@test_hs_oracle=# fetch all in cf;id | name | job | age 
----+------+-----+-----
(0 rows)lightdb@test_hs_oracle=# fetch all in cf;
ERROR:  cursor "cf" does not exist

test7

分布式测试

lightdb分布式参照：分布式

set lightdb_cursor_after_commit to off

create table nested_tab(id int primary key, name varchar2(100), job varchar2(100), age int);
insert into nested_tab values (1, 'asda', 'gfdgd', 12);
insert into nested_tab values (2, 'sdfsd', 'cvxvx', 14);
insert into nested_tab values (3, 'uyiy', 'mmbv', 16);select create_distributed_table('nested_tab','id');create function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab;
return 0;
end;
/
lightdb@test_hs_oracle=# begin;
BEGIN
lightdb@test_hs_oracle=*# select fg('cf');fg 
----0
(1 row)lightdb@test_hs_oracle=*# fetch all in cf;id | name  |  job  | age 
----+-------+-------+-----1 | asda  | gfdgd |  123 | uyiy  | mmbv  |  162 | sdfsd | cvxvx |  14
(3 rows)lightdb@test_hs_oracle=*# commit;
COMMIT
lightdb@test_hs_oracle=# fetch all in cf;
ERROR:  cursor "cf" does not exist

test3

set lightdb_cursor_after_commit to on

create table nested_tab(id int primary key, name varchar2(100), job varchar2(100), age int);
insert into nested_tab values (1, 'asda', 'gfdgd', 12);
insert into nested_tab values (2, 'sdfsd', 'cvxvx', 14);
insert into nested_tab values (3, 'uyiy', 'mmbv', 16);select create_distributed_table('nested_tab','id');create function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab;
return 0;
end;
/lightdb@test_hs_oracle=# begin;
BEGIN
lightdb@test_hs_oracle=*# select fg('cf');fg 
----0
(1 row)lightdb@test_hs_oracle=*# fetch all in cf;id | name  |  job  | age 
----+-------+-------+-----1 | asda  | gfdgd |  123 | uyiy  | mmbv  |  162 | sdfsd | cvxvx |  14
(3 rows)lightdb@test_hs_oracle=*# commit;
COMMITlightdb@test_hs_oracle=# fetch all in cf;id | name | job | age 
----+------+-----+-----
(0 rows)lightdb@test_hs_oracle=# fetch all in cf;
ERROR:  cursor "cf" does not exist

tesst4

for update/for share
create  or replace function fg(ref inout refcursor) return int as
begin             
open ref for select * from nested_tab for update;
return 0;
end;
/
lightdb@test_hs_oracle=# create  or replace function fg(ref inout refcursor) return int as
lightdb@test_hs_oracle$# begin             
lightdb@test_hs_oracle$# open ref for select * from nested_tab for update;
lightdb@test_hs_oracle$# return 0;
lightdb@test_hs_oracle$# end;
lightdb@test_hs_oracle$# /
CREATE FUNCTION
lightdb@test_hs_oracle=# begin;
BEGIN
lightdb@test_hs_oracle=*# select fg('cf');
ERROR:  could not run distributed query with FOR UPDATE/SHARE commands
HINT:  Consider using an equality filter on the distributed table's partition column.
CONTEXT:  SQL statement "select * from nested_tab for update"
PL/oraSQL function fg(refcursor) line 3 at OPEN

test5

总结

set lightdb_cursor_after_commit to on；在同一个会话中的后续事务中还能够继续访问该游标（ 但是如果创建事务被中止，游标会被移除）。对于for update和for share lightdb_cursor_after_commit 参数使能单机模式还是支持的，分布式模式下由于不支持for update和for share直接报错。java端同理。
参见：declare

这篇关于LightDB 23.3 通过GUC参数控制commit fetch的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/410545。

相关文章

用js控制视频播放进度基本示例代码

用js控制视频播放进度基本示例代码

《用js控制视频播放进度基本示例代码》写前端的时候,很多的时候是需要支持要网页视频播放的功能,下面这篇文章主要给大家介绍了关于用js控制视频播放进度的相关资料,文中通过代码介绍的非常详细,需要的朋友可... 目录前言html部分:JavaScript部分:注意：总结前言在javascript中控制视频播放
阅读更多...
一文带你了解SpringBoot中启动参数的各种用法

一文带你了解SpringBoot中启动参数的各种用法

《一文带你了解SpringBoot中启动参数的各种用法》在使用SpringBoot开发应用时,我们通常需要根据不同的环境或特定需求调整启动参数,那么,SpringBoot提供了哪些方式来配置这些启动参... 目录一、启动参数的常见传递方式二、通过命令行参数传递启动参数三、使用 application.pro
阅读更多...
Python异步编程中asyncio.gather的并发控制详解

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法：给并发装上"节流阀"三、进阶控制
阅读更多...
使用DrissionPage控制360浏览器的完美解决方案

使用DrissionPage控制360浏览器的完美解决方案

《使用DrissionPage控制360浏览器的完美解决方案》在网页自动化领域,经常遇到需要保持登录状态、保留Cookie等场景,今天要分享的方案可以完美解决这个问题：使用DrissionPage直接... 目录完整代码引言为什么要使用已有用户数据？核心代码实现1. 导入必要模块2. 关键配置（重点！）3.
阅读更多...
基于@RequestParam注解之Spring MVC参数绑定的利器

基于@RequestParam注解之Spring MVC参数绑定的利器

《基于@RequestParam注解之SpringMVC参数绑定的利器》：本文主要介绍基于@RequestParam注解之SpringMVC参数绑定的利器,具有很好的参考价值,希望对大家有所帮助... 目录@RequestParam注解：Spring MVC参数绑定的利器什么是@RequestParam？@
阅读更多...
SpringSecurity 认证、注销、权限控制功能(注销、记住密码、自定义登入页)

SpringSecurity 认证、注销、权限控制功能(注销、记住密码、自定义登入页)

《SpringSecurity认证、注销、权限控制功能(注销、记住密码、自定义登入页)》SpringSecurity是一个强大的Java框架,用于保护应用程序的安全性,它提供了一套全面的安全解决方案... 目录简介认识Spring Security“认证”（Authentication）“授权” （Auth
阅读更多...
python之流程控制语句match-case详解

python之流程控制语句match-case详解

《python之流程控制语句match-case详解》：本文主要介绍python之流程控制语句match-case使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录match-case 语法详解与实战一、基础值匹配（类似 switch-case）二、数据结构解构匹
阅读更多...
SpringBoot接收JSON类型的参数方式

SpringBoot接收JSON类型的参数方式

《SpringBoot接收JSON类型的参数方式》：本文主要介绍SpringBoot接收JSON类型的参数方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、jsON二、代码准备三、Apifox操作总结一、JSON在学习前端技术时，我们有讲到过JSON，而在
阅读更多...
Spring Security注解方式权限控制过程

Spring Security注解方式权限控制过程

《SpringSecurity注解方式权限控制过程》：本文主要介绍SpringSecurity注解方式权限控制过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、摘要二、实现步骤2.1 在配置类中添加权限注解的支持2.2 创建Controller类2.3 Us
阅读更多...
JAVA虚拟机中 -D, -X, -XX ，-server参数使用

JAVA虚拟机中 -D, -X, -XX ，-server参数使用

《JAVA虚拟机中-D,-X,-XX，-server参数使用》本文主要介绍了JAVA虚拟机中-D,-X,-XX,-server参数使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有... 目录一、-D参数二、-X参数三、-XX参数总结：在Java开发过程中，对Java虚拟机（JVM）的启动参数进
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2