Início / dba / Perguntas / 52968
Accepted
A-K
Asked: 2013-11-08 11:02:28 +0800 CST

Como posso manter um conjunto de resultados sem manter a transação aberta?

  • 772

A documentação a seguir descreve como ver o refcursor retornado de uma função, aqui , assim:

    CREATE FUNCTION reffunc(refcursor) RETURNS refcursor AS '
BEGIN
    OPEN $1 FOR SELECT col FROM test;
    RETURN $1;
END;
' LANGUAGE plpgsql;

BEGIN;
SELECT reffunc('funccursor');
FETCH ALL IN funccursor;
COMMIT;

Isso funciona para mim. Porém, se eu quiser manter os resultados na minha tela, tenho que manter a transação aberta. Quando executo o COMMIT, meu conjunto de resultados é descartado. Quando executo FETCH e COMMIT ao mesmo tempo, o primeiro conjunto de resultados é descartado.

Existe uma maneira de confirmar a transação, mas manter o conjunto de resultados? A versão do PgAdmin é 1.18.1.

postgresql pgadmin

2 respostas

  1. Best Answer

    Quando um cursor é definido no nível SQL com DECLARE , existe uma opção WITH HOLDque faz com que ele continue existindo após o commit da transação atual. Citando o documento:

    WITH HOLD especifica que o cursor pode continuar a ser usado depois que a transação que o criou for confirmada com sucesso

    Por outro lado, um refcursor aberto por uma função plpgsql é fechado ao final da transação. Citando o documento plpgsql :

    Todos os portais são implicitamente fechados no final da transação. Portanto, um valor refcursor é utilizável para referenciar um cursor aberto somente até o final da transação.

    Para criar um cursor em uma função plpgsql que pode ser usada fora de sua transação "pai", é apenas uma questão de sintaxe. Você deseja a implementação SQL de um cursor, não a variante plpgsql. Para isso, EXECUTEdeve ser usado.

    Como exemplo, aqui está o esqueleto de uma função semelhante à sua, mas usando cursores de nível SQL que sobrevivem à transação:

    CREATE FUNCTION dyncursor(name text) RETURNS VOID AS
$$
DECLARE
  query text;
BEGIN
  query='SELECT 1 as col1, 2 as col2'; -- sample query
  EXECUTE 'DECLARE ' || quote_ident(name) || ' CURSOR WITH HOLD FOR ' || query;
END
$$ language plpgsql;

    Demonstração:

    teste => início;
teste=> selecione dynccursor('foo');
 cursor dinâmico
-----------

(1 linha)
teste=> confirmar;
test=> busca tudo de foo;
 col1 | col2
------+------
    1 | 2
(1 linha)
teste=> fechar foo;
FECHAR CURSOR
    • 8

  2. pgAdmin é apenas uma GUI. Em grande parte irrelevante para esta questão. Acontece que uma ou mais sessões são vinculadas a uma janela do editor SQL e terminam quando a janela é fechada.

    Se você deseja manter a transação aberta, apenas não COMMIT(ou ROLLBACK) ainda.

    Se você realmente deseja "manter" o conjunto de resultados, escreva-o em uma table- possivelmente uma tabela TEMPORARYouUNLOGGED se você não precisar persistir permanentemente. Uma tabela temporária vive e morre com a sessão por padrão.

    SQL e PL/pgSQL são bastante rígidos com seu sistema de tipos e algumas coisas que parecem possíveis não foram implementadas (ainda). Mas o que você está tentando fazer provavelmente pode ser resolvido sem cursores. Se você precisar fornecer um nome de tabela para uma função dinamicamente, use um tipo de retorno polimórfico encadeado a um parâmetro de entrada:

    CREATE OR REPLACE FUNCTION f_dynamic_select(_tbl anyelement)
 RETURNS SETOF anyelement AS
$func$
BEGIN

RETURN QUERY EXECUTE
'SELECT * FROM ' || pg_typeof(_tbl);

END
$func$ LANGUAGE plpgsql;

    Ligar:

    SELECT * FROM  f_dynamic_select(NULL::my_schema.my_table)

    Este formulário é automaticamente seguro contra injeção de SQL, pois pg_typeof()retorna um regtypevalor que é escapado automaticamente (se necessário) quando é convertido automaticamente textdurante a concatenação de strings.

    Eu escrevi uma resposta intimamente relacionada lidando com tipos polimórficos ontem. Tem mais explicações e links:
    Inserir valores de uma variável de registro em uma tabela

    Normalmente , um simples e simples SELECTfaria o trabalho. É uma condição rara que os nomes das tabelas sejam fornecidos dinamicamente.

    SELECT * FROM my_schema.my_table
    • 4

relate perguntas