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。

相关文章

MySQL中时区参数time_zone解读

MySQL中时区参数time_zone解读

《MySQL中时区参数time_zone解读》MySQL时区参数time_zone用于控制系统函数和字段的DEFAULTCURRENT_TIMESTAMP属性,修改时区可能会影响timestamp类型... 目录前言1.时区参数影响2.如何设置3.字段类型选择总结前言mysql 时区参数 time_zon
阅读更多...
Python如何使用seleniumwire接管Chrome查看控制台中参数

Python如何使用seleniumwire接管Chrome查看控制台中参数

《Python如何使用seleniumwire接管Chrome查看控制台中参数》文章介绍了如何使用Python的seleniumwire库来接管Chrome浏览器,并通过控制台查看接口参数,本文给大家... 1、cmd打开控制台，启动谷歌并制定端口号，找不到文件的加环境变量chrome.exe --rem
阅读更多...
Linux中Curl参数详解实践应用

Linux中Curl参数详解实践应用

《Linux中Curl参数详解实践应用》在现代网络开发和运维工作中,curl命令是一个不可或缺的工具,它是一个利用URL语法在命令行下工作的文件传输工具,支持多种协议,如HTTP、HTTPS、FTP等... 目录引言一、基础请求参数1. -X 或 --request2. -d 或 --data3. -H 或
阅读更多...
详解Spring Boot接收参数的19种方式

详解Spring Boot接收参数的19种方式

《详解SpringBoot接收参数的19种方式》SpringBoot提供了多种注解来接收不同类型的参数,本文给大家介绍SpringBoot接收参数的19种方式,感兴趣的朋友跟随小编一起看看吧... 目录SpringBoot接受参数相关@PathVariable注解@RequestHeader注解@Reque
阅读更多...
Java向kettle8.0传递参数的方式总结

Java向kettle8.0传递参数的方式总结

《Java向kettle8.0传递参数的方式总结》介绍了如何在Kettle中传递参数到转换和作业中,包括设置全局properties、使用TransMeta和JobMeta的parameterValu... 目录1.传递参数到转换中2.传递参数到作业中总结1.传递参数到转换中1.1. 通过设置Trans的
阅读更多...
java如何调用kettle设置变量和参数

java如何调用kettle设置变量和参数

《java如何调用kettle设置变量和参数》文章简要介绍了如何在Java中调用Kettle,并重点讨论了变量和参数的区别,以及在Java代码中如何正确设置和使用这些变量,避免覆盖Kettle中已设置... 目录Java调用kettle设置变量和参数java代码中变量会覆盖kettle里面设置的变量总结ja
阅读更多...
spring 参数校验Validation示例详解

spring 参数校验Validation示例详解

《spring参数校验Validation示例详解》Spring提供了Validation工具类来实现对客户端传来的请求参数的有效校验,本文给大家介绍spring参数校验Validation示例详... 目录前言一、Validation常见的校验注解二、Validation的简单应用三、分组校验四、自定义校
阅读更多...
Python实现局域网远程控制电脑

Python实现局域网远程控制电脑

《Python实现局域网远程控制电脑》这篇文章主要为大家详细介绍了如何利用Python编写一个工具,可以实现远程控制局域网电脑关机,重启,注销等功能,感兴趣的小伙伴可以参考一下... 目录1.简介2. 运行效果3. 1.0版本相关源码服务端server.py客户端client.py4. 2.0版本相关源码1
阅读更多...
SpringBoot中Get请求和POST请求接收参数示例详解

SpringBoot中Get请求和POST请求接收参数示例详解

《SpringBoot中Get请求和POST请求接收参数示例详解》文章详细介绍了SpringBoot中Get请求和POST请求的参数接收方式,包括方法形参接收参数、实体类接收参数、HttpServle... 目录1、Get请求1.1 方法形参接收参数 这种方式一般适用参数比较少的情况，并且前后端参数名称必须
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2