CREATE SOURCE
IF NOT EXISTS
src_name
IN CLUSTER
cluster_name
FROM
POSTGRES
CONNECTION
connection_name
(
PUBLICATION
publication_name
,
TEXT COLUMNS
(
column_name
,
)
)
FOR ALL TABLES
FOR TABLES
(
table_name
AS
subsrc_name
,
FOR SCHEMAS
(
schema_name
,
)
EXPOSE
PROGRESS
AS
progress_subsource_name
with_options