sql >> Databáze >  >> RDS >> PostgreSQL

Použití dynamického dotazu + uživatelsky definovaný datový typ v Postgresu

Základní UPDATE

Nahraďte první dotaz tímto mnohem kratším a účinnějším jediným UPDATE příkaz:

UPDATE features
SET   (x1,x2,x3,x4,x5,x6, y)   
    = ((x1 - g.avg1) / g.range1
     , (x2 - g.avg2) / g.range2
 --  , (x3 - ...
     , (y  - g.avgy) / g.rangey)
FROM (
   SELECT avg(x1) AS avg1, max(x1) - min(x1) AS range1
        , avg(x2) AS avg2, max(x2) - min(x2) AS range2
     -- , avg(x3) ...
        , avg(y) AS avgy, max(y) - min(y) AS rangey
   FROM   features
   ) g;

O krátkém UPDATE syntaxe:

Dynamická funkce

Na základě jednoduššího dotazu je zde dynamická funkce pro libovolný počet sloupců:

CREATE OR REPLACE FUNCTION scale_function_dyn()
  RETURNS void AS
$func$
DECLARE
   cols text;  -- list of target columns
   vals text;  -- list of values to insert
   aggs text;  -- column list for aggregate query
BEGIN
   SELECT INTO cols, vals, aggs
          string_agg(quote_ident(attname), ', ')
        , string_agg(format('(%I - g.%I) / g.%I'
                          , attname, 'avg_' || attname, 'range_' || attname), ', ')
        , string_agg(format('avg(%1$I) AS %2$I, max(%1$I) - min(%1$I) AS %3$I'
                          , attname, 'avg_' || attname, 'range_' || attname), ', ')
   FROM   pg_attribute
   WHERE  attrelid = 'features'::regclass
   AND    attname NOT IN ('n', 'x0')  -- exclude columns from update
   AND    NOT attisdropped            -- no dropped (dead) columns
   AND    attnum > 0;                 -- no system columns

   EXECUTE format('UPDATE features
                   SET   (%s) = (%s)
                   FROM  (SELECT %s FROM features) g'
                 , cols, vals, aggs);

END
$func$  LANGUAGE plpgsql;

Související odpověď s podrobnějším vysvětlením:

SQL Fiddle.




  1. Jak mám vyřešit tuto chybu? Zastaralé:mysql_escape_string():Tato funkce je zastaralá; místo toho použijte mysql_real_escape_string().

  2. Připojte se z PHP k Oracle DB pomocí Oracle Wallet

  3. Jak zacházet s připojením MySQL pomocí multithreadingu Pythonu

  4. Jak obejít MySQL Chyba tabulky nelze znovu otevřít