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。

相关文章

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

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

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
Andrej Karpathy最新采访：认知核心模型10亿参数就够了，AI会打破教育不公的僵局

Andrej Karpathy最新采访：认知核心模型10亿参数就够了，AI会打破教育不公的僵局

夕小瑶科技说 原创  作者 | 海野 AI圈子的红人，AI大神Andrej Karpathy，曾是OpenAI联合创始人之一，特斯拉AI总监。上一次的动态是官宣创办一家名为 Eureka Labs 的人工智能+教育公司 ，宣布将长期致力于AI原生教育。 近日，Andrej Karpathy接受了No Priors（投资博客）的采访，与硅谷知名投资人 Sara Guo 和 Elad G
阅读更多...
C++11第三弹：lambda表达式 | 新的类功能 | 模板的可变参数

C++11第三弹：lambda表达式 | 新的类功能 | 模板的可变参数

🌈个人主页： 南桥几晴秋 🌈C++专栏： 南桥谈C++ 🌈C语言专栏： C语言学习系列 🌈Linux学习专栏： 南桥谈Linux 🌈数据结构学习专栏： 数据结构杂谈 🌈数据库学习专栏： 南桥谈MySQL 🌈Qt学习专栏： 南桥谈Qt 🌈菜鸡代码练习： 练习随想记录 🌈git学习： 南桥谈Git 🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈�
阅读更多...
如何在页面调用utility bar并传递参数至lwc组件

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件： 2.调用utility bar api的方式有两种： 方法一，通过lwc调用： import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca
阅读更多...
4B参数秒杀GPT-3.5：MiniCPM 3.0惊艳登场！

4B参数秒杀GPT-3.5：MiniCPM 3.0惊艳登场！

​ 面壁智能 在 AI 的世界里，总有那么几个时刻让人惊叹不已。面壁智能推出的 MiniCPM 3.0，这个仅有4B参数的"小钢炮"，正在以惊人的实力挑战着 GPT-3.5 这个曾经的AI巨人。 MiniCPM 3.0 MiniCPM 3.0 MiniCPM 3.0 目前的主要功能有： 长上下文功能：原生支持 32k 上下文长度，性能完美。我们引入了
阅读更多...
AI(文生语音)-TTS 技术线路探索学习:从拼接式参数化方法到Tacotron端到端输出

AI(文生语音)-TTS 技术线路探索学习:从拼接式参数化方法到Tacotron端到端输出

AI(文生语音)-TTS 技术线路探索学习:从拼接式参数化方法到Tacotron端到端输出 在数字化时代，文本到语音（Text-to-Speech, TTS）技术已成为人机交互的关键桥梁，无论是为视障人士提供辅助阅读，还是为智能助手注入声音的灵魂，TTS 技术都扮演着至关重要的角色。从最初的拼接式方法到参数化技术，再到现今的深度学习解决方案，TTS 技术经历了一段长足的进步。这篇文章将带您穿越时
阅读更多...
如何确定 Go 语言中 HTTP 连接池的最佳参数？

如何确定 Go 语言中 HTTP 连接池的最佳参数？

确定 Go 语言中 HTTP 连接池的最佳参数可以通过以下几种方式： 一、分析应用场景和需求 并发请求量： 确定应用程序在特定时间段内可能同时发起的 HTTP 请求数量。如果并发请求量很高，需要设置较大的连接池参数以满足需求。例如，对于一个高并发的 Web 服务，可能同时有数百个请求在处理，此时需要较大的连接池大小。可以通过压力测试工具模拟高并发场景，观察系统在不同并发请求下的性能表现，从而
阅读更多...
控制反转 的种类

控制反转 的种类

之前对控制反转的定义和解释都不是很清晰。最近翻书发现在《Pro Spring 5》（免费电子版在文章最后）有一段非常不错的解释。记录一下，有道翻译贴出来方便查看。如有请直接跳过中文，看后面的原文。 控制反转的类型 控制反转的类型您可能想知道为什么有两种类型的IoC，以及为什么这些类型被进一步划分为不同的实现。这个问题似乎没有明确的答案;当然，不同的类型提供了一定程度的灵活性，但
阅读更多...
多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

目录 多路转接之select 引入 介绍 fd_set 函数原型 nfds readfds / writefds / exceptfds readfds  总结  fd_set操作接口  timeout timevalue 结构体 传入值 返回值 代码 注意点 -- 调用函数 select的参数填充  获取新连接 注意点 -- 通信时的调用函数 添加新fd到
阅读更多...
深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理

深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理

深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理 秒杀系统是应对高并发、高压力下的典型业务场景，涉及到并发控制、库存管理、事务管理等多个关键技术点。本文将深入剖析秒杀商品业务中常见的几个核心问题，包括 AOP 事务管理、同步锁机制、乐观锁、CAS 操作，以及用户限购策略。通过这些技术的结合，确保秒杀系统在高并发场景下的稳定性和一致性。 1. AOP 代理对象与事务管理 在秒杀商品
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2