PostgreSQL：将表作为函数中的参数传递

Question

我TYPE在 PostgreSQL 中发现。我有一个TABLE TYPE某些表必须尊重的（接口）。例如：

CREATE TYPE dataset AS(
    ChannelId INTEGER
   ,GranulityIdIn INTEGER
   ,GranulityId INTEGER
   ,TimeValue TIMESTAMP
   ,FloatValue FLOAT
   ,Status BIGINT
   ,QualityCodeId INTEGER
   ,DataArray FLOAT[]
   ,DataCount BIGINT
   ,Performance FLOAT
   ,StepCount INTEGER
   ,TableRegClass regclass
   ,Tags TEXT[]
   ,WeightedMean FLOAT
   ,MeanData FLOAT
   ,StdData FLOAT
   ,MinData FLOAT
   ,MaxData FLOAT
   ,MedianData FLOAT
   ,Percentiles FLOAT[]
);

我可以使用此模板创建表：

CREATE TABLE test OF dataset;

我在API 中看到了很多选项，但我有点迷茫。我想知道是否可以将此类型分配给函数INPUT/OUTPUT参数。

假设我有一个FUNCTION调用process，它从数据集中接收记录样本TABLE source，处理它们，然后返回TABLE sink具有相同TYPE.

那就是我想知道是否有可能创建一个TYPE这样的行为：

CREATE FUNCTION process(
    input dataset
) RETURNS dataset
AS ...

可以这样调用：

SELECT
    *
FROM
    source, process(input := source) AS sink;

我想知道 PostgreSQL 是否可行，并询问如何做到这一点。你们有人知道吗？

---

这是我正在尝试做的 MWE：

DROP TABLE IF EXISTS source;
DROP FUNCTION IF EXISTS process(dataset);
DROP TYPE dataset;

CREATE TYPE dataset AS (
    id INTEGER
   ,t  TIMESTAMP
   ,x  FLOAT
);


CREATE TABLE source OF dataset;
ALTER TABLE source ADD PRIMARY KEY(Id);
INSERT INTO source VALUES
    (1, '2016-01-01 00:00:00', 10.0)
   ,(2, '2016-01-01 00:30:00', 11.0)
   ,(3, '2016-01-01 01:00:00', 12.0)
   ,(4, '2016-01-01 01:30:00',  9.0)
   ;

CREATE OR REPLACE FUNCTION process(
    _source dataset
)
RETURNS SETOF dataset
AS
$BODY$
SELECT * FROM source;
$BODY$
LANGUAGE SQL;

SELECT * FROM process(source);

但它没有成功，就像 source 被视为一列而不是SETOF RECORDS具有数据集类型的列。

Answer 1

_sourceMWE（最小工作示例）中的参数未在任何地方引用。source函数体中的标识符没有前导下划线，独立解释为常量表名。

但无论如何它不会像这样工作。SQL 只允许参数化DML 语句中的值。看：

• 使用 plpgsql 变量设置 n_distinct 时出错

解决方案

您仍然可以EXECUTE在 plpgsql 函数中使用动态 SQL 使其工作：

CREATE TYPE dataset AS (id integer, t timestamp, x float);

CREATE TABLE source OF dataset (PRIMARY KEY(Id));  -- add constraints in same command

INSERT INTO source VALUES
    (1, '2016-01-01 00:00:00', 10.0)
   ,(2, '2016-01-01 00:30:00', 11.0);

CREATE OR REPLACE FUNCTION process(_tbl regclass)
  RETURNS SETOF dataset AS
$func$
BEGIN
RETURN QUERY EXECUTE 'SELECT * FROM ' || _tbl;
END
$func$  LANGUAGE plpgsql;

SELECT * FROM process('source');  -- table name as string literal 

看：

• 表名作为 PostgreSQL 函数参数

或在网站上搜索相关问题和答案。

要使其适用于任何给定的表：

CREATE OR REPLACE FUNCTION process2(_tbl anyelement)
  RETURNS SETOF anyelement AS
$func$
BEGIN
RETURN QUERY EXECUTE 'SELECT * FROM ' || pg_typeof(_tbl);
END
$func$  LANGUAGE plpgsql;

SELECT * FROM process2(NULL::source);  -- note the call syntax!!

详细解释：

• 重构一个 PL/pgSQL 函数以返回各种 SELECT 查询的输出

Answer 2

这将做你想做的事，而不需要任何动态 SQL：

drop table if exists source cascade;
drop function if exists process(dataset) cascade;
drop type if exists dataset cascade;

create type dataset as (
    id integer
   ,t  timestamp
   ,x  float
);

create table source of dataset;
alter table source add primary key(id);
insert into source values
   (1, '2016-01-01 00:00:00', 10.0)
 , (2, '2016-01-01 00:30:00', 11.0)
;

create or replace function process(
    x_source dataset[]
)
returns setof dataset
as
$body$
select * from unnest(x_source);
$body$
language sql;

select *
from
  process(
    array(
      select
        row(id, t, x)::dataset
      from source
    )
  );

据我所知（在广泛搜索之后，因为我遇到了同样的问题）你不能将表直接传递给函数。

但是，如图所示，您可以将表转换为由[]多个基本类型组成的自定义类型的数组（类似于表定义）。

然后，您可以传递该数组，并在进入函数后将其取消嵌套回表中。