nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:レビュー指摘対応。スキーマ名追加と修正

Browse Source
This commit is contained in:
daido 2023-10-18 11:36:22 +09:00
parent 8f522fca7d
commit 599da12f1e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
rds_mysql/stored_procedure/internal02/get_distribution_to_schema.sql
View File

@ -1,6 +1,6 @@
-- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する -- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する
-- $$から始まる文字は後からREPLACEする文字を示す独自ルール -- $$から始まる文字は後からREPLACEする文字を示す独自ルール
CREATE FUNCTION `get_distribution_to_schema`(target_table VARCHAR(100), target_column VARCHAR(100), target_column_value VARCHAR(100)) CREATE FUNCTION internal02.`get_distribution_to_schema`(target_table VARCHAR(100), target_column VARCHAR(100), target_column_value VARCHAR(100))
RETURNS VARCHAR(20) RETURNS VARCHAR(20)
DETERMINISTIC DETERMINISTIC
@ -20,7 +20,7 @@ BEGIN
-- カーソル -- カーソル
DECLARE cursor_crm_data_distribution_settings CURSOR FOR DECLARE cursor_crm_data_distribution_settings CURSOR FOR
SELECT `from_column_value`, `to_schema` SELECT `from_column_value`, `to_schema`
FROM intenal02.`crm_data_distribution_settings` FROM internal02.`crm_data_distribution_settings`
WHERE `table_id` = target_table WHERE `table_id` = target_table
AND `from_column_id` = target_column; AND `from_column_id` = target_column;