{"type":"doc","content":[{"type":"paragraph","content":[{"text":"Table of Contents:","type":"text","marks":[{"type":"strong"}]}]},{"type":"extension","attrs":{"layout":"default","extensionType":"com.atlassian.confluence.macro.core","extensionKey":"toc","parameters":{"macroParams":{"minLevel":{"value":"1"},"maxLevel":{"value":"6"},"outline":{"value":"false"},"type":{"value":"list"},"printable":{"value":"false"}},"macroMetadata":{"macroId":{"value":"3eff9c76-e5e3-4a82-8f01-4c770bc2489f"},"schemaVersion":{"value":"1"},"title":"Table of Contents"}},"localId":"ed76bd1e-108f-4583-b31c-4d7eac9084d7"}},{"type":"heading","attrs":{"level":2},"content":[{"text":"Table management","type":"text"}]},{"type":"panel","attrs":{"panelType":"warning"},"content":[{"type":"paragraph","content":[{"text":"Both create and alter table procedures should only be called from SNP Glue™. Drop table procedure may be called on tables not created by SNP Glue™.","type":"text"}]}]},{"type":"paragraph","content":[{"text":"Create an SNP Glue™ table in the specified database, source, name, and table definition.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.create_glue_table(, , ,

);","type":"text"}]},{"type":"paragraph","content":[{"text":"Alter an SNP Glue™ table in the specified database, source, name, and table definition.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.alter_glue_table(,,

);","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"Table definition formatting:\n{\n-- Example of column definition, each column should have said definition\n{\"fieldname\": \"\", \"type\": , \"key\": , \"comment\": \"\" }\n}\n-- Fieldname = Name of the column\n-- Type = Data type of the column\n-- Key = If the column is part of the primary key or not\n-- Comment = Column comment ","type":"text"}]},{"type":"paragraph","content":[{"text":"Drop an SNP Glue™ table by specifying the database and source where it is located and its name. Its merge-related artifacts are dropped as well → stream, view, task, and historical table. Before the historical table is deleted it is backed up as

_BAK_ e.g. ","type":"text"},{"text":"ZZVBAK_BAK_20230606084229","type":"text","marks":[{"type":"strong"}]},{"text":".","type":"text"}]},{"type":"panel","attrs":{"panelIconId":"atlassian-warning","panelIcon":":warning:","panelIconText":":warning:","panelColor":"#FFEBE6","panelType":"custom"},"content":[{"type":"paragraph","content":[{"text":"This action may lead to data loss! Use with caution.","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.drop_glue_table(, ,

);","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Merge","type":"text"}]},{"type":"paragraph","content":[{"text":"Resumes all merges inside a source. This only applies to MERGE_

tasks.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.resume_merge(, ); ","type":"text"}]},{"type":"paragraph","content":[{"text":"Resumes merge on a specific table.","type":"text"}]},{"type":"panel","attrs":{"panelIconId":"atlassian-warning","panelIcon":":warning:","panelIconText":":warning:","panelColor":"#FFEBE6","panelType":"custom"},"content":[{"type":"paragraph","content":[{"text":"Do not call in a loop! In need of resuming multiple merges, provide an array of tables instead of calling the stored procedure one by one.","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.resume_merge(, ,

);","type":"text"}]},{"type":"paragraph","content":[{"text":"Resumes merge on an array of tables.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.resume_merge(, , );","type":"text"}]},{"type":"paragraph","content":[{"text":"Suspends all merges inside a source. This only applies to MERGE_

tasks and not the ","type":"text"},{"text":"START_CONTROL","type":"text","marks":[{"type":"strong"}]},{"text":" task. Call ","type":"text"},{"text":"CORE.SUSPEND_CONTROL","type":"text","marks":[{"type":"strong"}]},{"text":" for suspending the ","type":"text"},{"text":"START_CONTROL","type":"text","marks":[{"type":"strong"}]},{"text":" task.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.suspend_merge(, );","type":"text"}]},{"type":"paragraph","content":[{"text":"Suspends merge on a specific table.","type":"text"}]},{"type":"panel","attrs":{"panelIconId":"atlassian-warning","panelIcon":":warning:","panelIconText":":warning:","panelColor":"#FFEBE6","panelType":"custom"},"content":[{"type":"paragraph","content":[{"text":"Do not call in a loop! In need of suspending multiple merges, provide an array of tables instead of calling the stored procedure one by one.","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.suspend_merge(, ,

);","type":"text"}]},{"type":"paragraph","content":[{"text":"Suspend merge on an array of tables.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.suspend_merge(, , );","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Settings","type":"text"}]},{"type":"paragraph","content":[{"text":"Get settings of specified scope → ","type":"text"},{"text":"APP ","type":"text","marks":[{"type":"strong"}]},{"text":"for application settings, ","type":"text"},{"text":"DEFAULT ","type":"text","marks":[{"type":"strong"}]},{"text":"for default (template) source settings, for specific source settings.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.get_settings();","type":"text"}]},{"type":"paragraph","content":[{"text":"Update settings overwrite existing settings with the same key and appended new ones.","type":"text"}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.update_merge(, to_variant(parse_json('')));\n\nExample: call core.update_settings('', to_variant(parse_json('\n {\"warehouse\": \"\",\n \"merge_schedule_time\": \"\"})));","type":"text"}]},{"type":"paragraph","content":[{"text":"Set settings completely overwrite all existing values.","type":"text"}]},{"type":"panel","attrs":{"panelType":"warning"},"content":[{"type":"paragraph","content":[{"text":"Not specified settings already present for the scope will be lost!","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.set_settings(, to_variant(parse_json('')));\n\nExample: call core.set_settings('','{\"warehouse\": \"\",\n \"merge_schedule_time\": \"\"});","type":"text"}]},{"type":"paragraph","content":[{"text":"List of all source settings:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"warehouse: Warehouse under which merge task runs.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"historical_tab_suffix: Suffix of the table the replicated table is going to be merged into.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"merge_schedule_time: Defines a period of how often merge tasks should run.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"merge_schedule_type: Defines the time unit for the ","type":"text"},{"text":"merge_schedule_time","type":"text","marks":[{"type":"strong"}]},{"text":".","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"insert_flag: Defines what identifier in metadata should represent inserts, can insert multiple values if they are separated by a comma, use '' placeholder for space","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"update_flag: Defines what identifier in metadata should represent updates, can insert multiple values if they are separated by a comma, use '' placeholder for space","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"delete_flag: Defines what identifier in metadata should represent deletes, can insert multiple values if they are separated by a comma","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"retention_period: Retention period for backups created after table deactivation in days","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"metadata_timestamp_field: Name of the field used to determine the last record of a specific key","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"metadata_change_field: Type of change of specific field","type":"text"}]}]}]},{"type":"paragraph","content":[{"text":"Application settings:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"app_name: Name of the application.","type":"text"}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Source management","type":"text"}]},{"type":"paragraph","content":[{"text":"Register a new source. It creates a new schema if it does not already exist and ","type":"text"},{"text":"sets default","type":"text","marks":[{"type":"strong"}]},{"text":" source settings.","type":"text"}]},{"type":"panel","attrs":{"panelType":"warning"},"content":[{"type":"paragraph","content":[{"text":"In case an already existing source is registered again, its settings will be overwritten, and objects inside it will not be affected.","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.register_source(, )","type":"text"}]},{"type":"paragraph","content":[{"text":"Remove source drops source, its schema, if it exists. ","type":"text"}]},{"type":"panel","attrs":{"panelIconId":"atlassian-warning","panelIcon":":warning:","panelIconText":":warning:","panelColor":"#FFEBE6","panelType":"custom"},"content":[{"type":"paragraph","content":[{"text":"This action may lead to data loss! Use with caution.","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.remove_source(, );","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Cleanup","type":"text"}]},{"type":"paragraph","content":[{"text":"Drop an SNP Glue™ by specifying its source, type (view, stream, or task), and name.","type":"text"}]},{"type":"panel","attrs":{"panelType":"info"},"content":[{"type":"paragraph","content":[{"text":"This stored procedure cannot drop tables. Use ","type":"text"},{"text":"CORE.DROP_GLUE_TABLE","type":"text","marks":[{"type":"strong"}]},{"text":" for dropping tables.","type":"text"}]}]},{"type":"codeBlock","attrs":{"language":"sql"},"content":[{"text":"call core.drop_glue_object(, , ,

Browser not supported