sql >> Database >  >> RDS >> PostgreSQL

Creëer dynamische tabel van functie in PostgreSQL

Uw oplossing is een haalbare manier. Ik heb je plpgsql-functie grotendeels herschreven voor vereenvoudiging / prestatie / leesbaarheid / veiligheid.

CREATE OR REPLACE FUNCTION f_taxamount()
 RETURNS void AS
$BODY$
DECLARE
    rec record;
BEGIN

    DROP TABLE IF EXISTS tmptable;

    EXECUTE 'CREATE TABLE tmptable (invoiceid integer PRIMARY KEY, '
        || (
           SELECT string_agg(col || ' numeric(9,2) DEFAULT 0', ', ')
           FROM  (
              SELECT quote_ident(lower(replace(taxname,' ','_'))) AS col
              FROM   tbltaxamount
              GROUP  BY 1
              ORDER  BY 1
              ) x
           )
        || ')';

    EXECUTE '
        INSERT INTO tmptable (invoiceid)
        SELECT DISTINCT invoiceid FROM tbltaxamount';

    FOR rec IN
        SELECT taxname, taxamt, invoiceid FROM tbltaxamount ORDER BY invoiceid
    LOOP
        EXECUTE '
            UPDATE tmptable
            SET ' || quote_ident(lower(replace(rec.taxname,' ','_')))
                  || ' = '|| rec.taxamt || ' 
            WHERE invoiceid = ' || rec.invoiceid;
    END LOOP;

END;
$BODY$ LANGUAGE plpgsql;

Dit werkt voor PostgreSQL 9.1 of hoger.

Voor pagina 8.4 of later vervangen

SELECT string_agg(col || ' numeric(9,2) DEFAULT 0', ', ')

met:

SELECT array_to_string(array_agg(col || ' numeric(9,2) DEFAULT 0'), ', ')

Voor versies nog ouder maak dan een aggregatiefunctie als volgt:

CREATE OR REPLACE FUNCTION f_concat_comma(text, text)
  RETURNS text AS
$BODY$
BEGIN
RETURN ($1 || ', '::text) || $2;
END;
$BODY$
  LANGUAGE plpgsql IMMUTABLE;

CREATE AGGREGATE concat_comma(text) (
  SFUNC=f_concat_comma,
  STYPE=text
);

En schrijf dan:

SELECT concat_comma(col || ' numeric(9,2) DEFAULT 0')

Ook:

DROP TABLE IF EXISTS tmptable;

De clausule "IF EXISTS" is geïntroduceerd met versie 8.2 .
Als u een versie nog ouder zou moeten gebruiken dan zou je moeten kunnen:

IF EXISTS (
    SELECT *
    FROM   pg_catalog.pg_class
    WHERE  oid = 'tmptable'::regclass
    AND    relkind = 'r')
THEN
    DROP TABLE tmptable;
END IF;
*/

Upgrade!

Bekijk het versiebeleid van het PostgreSQL-project . Versie 8.0.1 is een bijzonder buggy-versie. Ik zou sterk adviseren om te upgraden. Als je niet kunt upgraden naar een nieuwere hoofdversie, upgrade dan in ieder geval om veiligheidsredenen naar de laatste punt-release, 8.0.26 in jouw geval. Dit kan ter plekke worden gedaan, zonder iets anders te veranderen.



  1. Verhoog mijn id in mijn invoegverzoek

  2. Hoe SQLite-queryresultaten op te maken in TCL-modus

  3. Beste manier om een ​​configuratiebestand te maken (config.php) php

  4. SQL Server Dynamic Pivot in UDF die tabel retourneert