mirror of
https://github.com/timescale/timescaledb.git
synced 2025-05-16 18:43:18 +08:00
4dcbe6114d
This PR add support for primary-key, foreign-key, unique, and exclusion constraints. Previously supported are CHECK and NOT NULL constraints. Now, foreign key constraints where a hypertable references a plain table is support (while vice versa, with a plain table references a hypertable, is still not).
97 lines
3.1 KiB
PL/PgSQL
97 lines
3.1 KiB
PL/PgSQL
-- This file contains functions related to getting information about the
|
|
-- schema of a hypertable, including columns, their types, etc.
|
|
|
|
|
|
-- Check if a given table OID is a main table (i.e. the table a user
|
|
-- targets for SQL operations) for a hypertable
|
|
CREATE OR REPLACE FUNCTION _timescaledb_internal.is_main_table(
|
|
table_oid regclass
|
|
)
|
|
RETURNS bool LANGUAGE SQL STABLE AS
|
|
$BODY$
|
|
SELECT EXISTS(SELECT 1 FROM _timescaledb_catalog.hypertable WHERE table_name = relname AND schema_name = nspname)
|
|
FROM pg_class c
|
|
INNER JOIN pg_namespace n ON (n.OID = c.relnamespace)
|
|
WHERE c.OID = table_oid;
|
|
$BODY$;
|
|
|
|
-- Check if given table is a hypertable's main table
|
|
CREATE OR REPLACE FUNCTION _timescaledb_internal.is_main_table(
|
|
schema_name NAME,
|
|
table_name NAME
|
|
)
|
|
RETURNS BOOLEAN LANGUAGE SQL STABLE AS
|
|
$BODY$
|
|
SELECT EXISTS(
|
|
SELECT 1 FROM _timescaledb_catalog.hypertable h
|
|
WHERE h.schema_name = is_main_table.schema_name AND
|
|
h.table_name = is_main_table.table_name
|
|
);
|
|
$BODY$;
|
|
|
|
-- Get a hypertable given its main table OID
|
|
CREATE OR REPLACE FUNCTION _timescaledb_internal.hypertable_from_main_table(
|
|
table_oid regclass
|
|
)
|
|
RETURNS _timescaledb_catalog.hypertable LANGUAGE SQL STABLE AS
|
|
$BODY$
|
|
SELECT h.*
|
|
FROM pg_class c
|
|
INNER JOIN pg_namespace n ON (n.OID = c.relnamespace)
|
|
INNER JOIN _timescaledb_catalog.hypertable h ON (h.table_name = c.relname AND h.schema_name = n.nspname)
|
|
WHERE c.OID = table_oid;
|
|
$BODY$;
|
|
|
|
CREATE OR REPLACE FUNCTION _timescaledb_internal.main_table_from_hypertable(
|
|
hypertable_id int
|
|
)
|
|
RETURNS regclass LANGUAGE SQL STABLE AS
|
|
$BODY$
|
|
SELECT format('%I.%I',h.schema_name, h.table_name)::regclass
|
|
FROM _timescaledb_catalog.hypertable h
|
|
WHERE id = hypertable_id;
|
|
$BODY$;
|
|
|
|
|
|
-- Get the name of the time column for a chunk.
|
|
--
|
|
-- schema_name, table_name - name of the schema and table for the table represented by the crn.
|
|
CREATE OR REPLACE FUNCTION _timescaledb_internal.time_col_name_for_chunk(
|
|
schema_name NAME,
|
|
table_name NAME
|
|
)
|
|
RETURNS NAME LANGUAGE PLPGSQL STABLE AS
|
|
$BODY$
|
|
DECLARE
|
|
time_col_name NAME;
|
|
BEGIN
|
|
SELECT h.time_column_name INTO STRICT time_col_name
|
|
FROM _timescaledb_catalog.hypertable h
|
|
INNER JOIN _timescaledb_catalog.chunk c ON (c.hypertable_id = h.id)
|
|
WHERE c.schema_name = time_col_name_for_chunk.schema_name AND
|
|
c.table_name = time_col_name_for_chunk.table_name;
|
|
RETURN time_col_name;
|
|
END
|
|
$BODY$;
|
|
|
|
-- Get the type of the time column for a chunk.
|
|
--
|
|
-- schema_name, table_name - name of the schema and table for the table represented by the crn.
|
|
CREATE OR REPLACE FUNCTION _timescaledb_internal.time_col_type_for_chunk(
|
|
schema_name NAME,
|
|
table_name NAME
|
|
)
|
|
RETURNS REGTYPE LANGUAGE PLPGSQL STABLE AS
|
|
$BODY$
|
|
DECLARE
|
|
time_col_type REGTYPE;
|
|
BEGIN
|
|
SELECT h.time_column_type INTO STRICT time_col_type
|
|
FROM _timescaledb_catalog.hypertable h
|
|
INNER JOIN _timescaledb_catalog.chunk c ON (c.hypertable_id = h.id)
|
|
WHERE c.schema_name = time_col_type_for_chunk.schema_name AND
|
|
c.table_name = time_col_type_for_chunk.table_name;
|
|
RETURN time_col_type;
|
|
END
|
|
$BODY$;
|