Jack a montré la voie à suivre. Cependant, je pense qu'il y a place à amélioration.
Je place tout dans le schéma x
pour des tests pratiques. Configuration de test:
DROP SCHEMA x CASCADE;
CREATE SCHEMA x;
-- meta tables for schema and table name
CREATE TABLE x.schma(schma_id int, schma text);
INSERT INTO x.schma VALUES (1, 'x');
CREATE TABLE x.tbl(tbl_id int, tbl text);
INSERT INTO x.tbl VALUES (1, 't1'), (2, 't2');
-- dummy tables to be used in example query:
CREATE TABLE x.t1(id int);
INSERT INTO x.t1 VALUES (1),(2);
CREATE TABLE x.t2(foo text);
INSERT INTO x.t2 VALUES ('some text'), ('some more text');
Ancienne fonction (réponse originale):
CREATE OR REPLACE FUNCTION x.f_dynaquery_old(int, int, _col text, _type anyelement, OUT col anyelement)
RETURNS SETOF anyelement AS
$func$
BEGIN
RETURN QUERY EXECUTE '
SELECT ' || quote_ident(_col) || '
FROM ' || (
(SELECT schma FROM schma WHERE schma_id = $1) || '.' ||
(SELECT tbl FROM tbl WHERE tbl_id = $2))::regclass;
END
$func$ LANGUAGE plpgsql;
Version plus propre avec format()
(mise à jour 2017):
CREATE OR REPLACE FUNCTION x.f_dynaquery(_schma_id int, _tbl_id int
, _col text, _type anyelement)
RETURNS TABLE(col anyelement) AS
$func$
BEGIN
RETURN QUERY EXECUTE format(
'SELECT %I FROM %I.%I'
, _col
, (SELECT schma FROM schma WHERE schma_id = _schma_id)
, (SELECT tbl FROM tbl WHERE tbl_id = _tbl_id)
);
END
$func$ LANGUAGE plpgsql;
COMMENT ON FUNCTION x.f_dynaquery(int, int, text, anyelement)
IS 'Query any column from a dynamically assembled tablename.
$1 .. id of schema
$2 .. id of table
$3 .. name of column
$4 .. type of column (only data type matters, not the value)';
Appel:
SELECT col FROM x.f_dynaquery(1, 1, 'id', NULL::int);
col
-----
1
2
SELECT col FROM x.f_dynaquery(1, 2, 'foo', NULL::text);
col
----------------
some text
some more text
Points majeurs
La fonction peut renvoyer n'importe quelle colonne de n'importe quel type . Lisez le manuel sur les types polymorphes et la déclaration des paramètres de fonction .
Défendez-vous contre l'injection SQL en utilisant quote_ident()
et en transtypantregclass
dans l'ancienne version ou format()
dans la nouvelle. En relation:
Récupérez le nom de la table par requête comme l'OP l'a demandé. L'exemple est requête par id
mais tout est possible.
Nommez la colonne retournée, afin qu'elle soit plus facile à référencer.
Vous avez besoin de SQL dynamique - peut-être quelque chose comme ceci:
Je suppose que chaque table est présente dans chaque schéma comme la question l'indique
la source