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

feat: テーブルのカラムID変更に伴う修正

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2022-10-21 18:55:27 +09:00
parent dda511a663
commit cc1d234d29
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
rds_mysql/stored_procedure/crm_data_sync.sql
View File

@ -28,11 +28,11 @@ BEGIN
tt.end_datetime = "9999-12-31 00:00:00"
AND NOT EXISTS (
SELECT
tta.id
tta.Id
FROM
$$target_table_all$$ tta
WHERE
tt.id = tta.id
tt.Id = tta.Id
AND tt.$$target_column$$ = tta.$$target_column$$
)
';

8
rds_mysql/stored_procedure/crm_history.sql
View File

@ -49,7 +49,7 @@ BEGIN
SET @make_history_tmp_create = '
CREATE TEMPORARY TABLE $$target_table$$_make_history_tmp
SELECT
id
Id
, MIN($$target_column$$) AS min_start_datetime
, MAX(start_datetime) AS max_start_datetime
FROM
@ -57,9 +57,9 @@ BEGIN
WHERE
end_datetime = "9999-12-31 00:00:00"
GROUP BY
id
Id
HAVING
count(id) = 2
count(Id) = 2
';
SET @make_history_tmp_create = REPLACE(@make_history_tmp_create, "$$target_table$$", target_table);
SET @make_history_tmp_create = REPLACE(@make_history_tmp_create, "$$target_column$$", target_column);
@ -71,7 +71,7 @@ BEGIN
SET @update_end_datetime = '
UPDATE $$target_table$$ tt
INNER JOIN $$target_table$$_make_history_tmp mht
ON tt.id = mht.id
ON tt.Id = mht.Id
AND tt.start_datetime = mht.min_start_datetime
SET
end_datetime = mht.max_start_datetime - INTERVAL 1 SECOND