質問編集履歴
3
質問内容の更新
title
CHANGED
|
File without changes
|
body
CHANGED
|
@@ -23,4 +23,50 @@
|
|
|
23
23
|
|
|
24
24
|
➂embulkでBigQueryにバルクインサート
|
|
25
25
|
|
|
26
|
-
上記、方法論で実装可能か検討中となります
|
|
26
|
+
上記、方法論で実装可能か検討中となります
|
|
27
|
+
|
|
28
|
+
|
|
29
|
+
※開発中のpl/sql
|
|
30
|
+
|
|
31
|
+
```ここに言語を入力
|
|
32
|
+
DECLARE W_BANGOU varchar(50)
|
|
33
|
+
DECLARE W_NUM varchar(50)
|
|
34
|
+
DECLARE W_STR varchar(50)
|
|
35
|
+
|
|
36
|
+
DECLARE CUR_AAA CURSOR FOR
|
|
37
|
+
SELECT A1.BANGOU
|
|
38
|
+
,A1.NUM
|
|
39
|
+
,A1.STR
|
|
40
|
+
FROM INPUT_TEST_001 A1
|
|
41
|
+
INNER JOIN INPUT_TEST_002 B1
|
|
42
|
+
WHERE A1.NUM = B1.NUM
|
|
43
|
+
|
|
44
|
+
OPEN CUR_001;
|
|
45
|
+
|
|
46
|
+
FETCH NEXT FROM CUR_AAA
|
|
47
|
+
INTO W_BANGOU,W_NUM,W_STR;
|
|
48
|
+
|
|
49
|
+
WHILE @@FETCH_STATUS = 0
|
|
50
|
+
BEGIN
|
|
51
|
+
|
|
52
|
+
INSERT INTO INPUT_TEST_003
|
|
53
|
+
VALUES (
|
|
54
|
+
W_BANGOU
|
|
55
|
+
,W_NUM
|
|
56
|
+
,W_STR
|
|
57
|
+
)
|
|
58
|
+
|
|
59
|
+
|
|
60
|
+
FETCH NEXT FROM CUR_AAA
|
|
61
|
+
INTO W_BANGOU,W_NUM,W_STR;
|
|
62
|
+
|
|
63
|
+
END
|
|
64
|
+
|
|
65
|
+
CLOSE CUR_001;
|
|
66
|
+
DEALLOCATE CUR_001;
|
|
67
|
+
```
|
|
68
|
+
※実行結果
|
|
69
|
+
```ここに言語を入力
|
|
70
|
+
SQL> @C:\Users\xxxx\Desktop\embulk\CURSOR_test_002.sql
|
|
71
|
+
36
|
|
72
|
+
```
|
2
質問内容更新
title
CHANGED
|
File without changes
|
body
CHANGED
|
@@ -7,12 +7,15 @@
|
|
|
7
7
|
➀Oracleトリガーで2つのテーブルを特定条件で結合させて対象レコードを抽出
|
|
8
8
|
|
|
9
9
|
⇒以下のようなSQLを使ってみる
|
|
10
|
+
|
|
11
|
+
```ここに言語を入力
|
|
10
12
|
select
|
|
11
13
|
A1.BANGOU,A1.NUM,A1.STR,A1.DT
|
|
12
14
|
from
|
|
13
15
|
INPUT_TEST_001 A1,INPUT_TEST_002 B1
|
|
14
16
|
where
|
|
15
17
|
A1.NUM = B1.NUM;
|
|
18
|
+
```
|
|
16
19
|
|
|
17
20
|
➁スケジュールジョブでembulkを実行
|
|
18
21
|
|
1
質問内容更新
title
CHANGED
|
File without changes
|
body
CHANGED
|
@@ -18,4 +18,6 @@
|
|
|
18
18
|
|
|
19
19
|
⇒embulkのconfig.ymlに、➀で検索されたレコードだけを指定する
|
|
20
20
|
|
|
21
|
-
➂embulkでBigQueryにバルクインサート
|
|
21
|
+
➂embulkでBigQueryにバルクインサート
|
|
22
|
+
|
|
23
|
+
上記、方法論で実装可能か検討中となります
|