質問編集履歴
2
使い方が分からず、再修正しました。
test
CHANGED
File without changes
|
test
CHANGED
@@ -32,21 +32,15 @@
|
|
32
32
|
|
33
33
|
my $tbl_name2 = 'tbl_name2';
|
34
34
|
|
35
|
-
```
|
36
35
|
|
37
|
-
|
38
|
-
|
39
|
-
```
|
40
36
|
|
41
37
|
my %attr = (RaiseError=>1, PrintError=>0, mysql_enable_utf8=>1, AutoCommit=>0);
|
42
38
|
|
43
39
|
my ( $dsh_connect1, $dsh_connect2 );
|
44
40
|
|
45
|
-
```
|
46
41
|
|
47
42
|
|
48
43
|
|
49
|
-
```
|
50
44
|
|
51
45
|
# 1) DB1 へ接続
|
52
46
|
|
@@ -64,11 +58,7 @@
|
|
64
58
|
|
65
59
|
}
|
66
60
|
|
67
|
-
```
|
68
61
|
|
69
|
-
|
70
|
-
|
71
|
-
```
|
72
62
|
|
73
63
|
eval{
|
74
64
|
|
@@ -86,11 +76,9 @@
|
|
86
76
|
|
87
77
|
}
|
88
78
|
|
89
|
-
```
|
90
79
|
|
91
80
|
|
92
81
|
|
93
|
-
```
|
94
82
|
|
95
83
|
# 2) DB2 へ接続
|
96
84
|
|
@@ -110,11 +98,9 @@
|
|
110
98
|
|
111
99
|
}
|
112
100
|
|
113
|
-
```
|
114
101
|
|
115
102
|
|
116
103
|
|
117
|
-
```
|
118
104
|
|
119
105
|
eval{
|
120
106
|
|
@@ -140,25 +126,21 @@
|
|
140
126
|
|
141
127
|
}
|
142
128
|
|
143
|
-
```
|
144
129
|
|
145
130
|
|
146
131
|
|
147
|
-
```
|
148
132
|
|
149
133
|
$dsh_connect1->disconnect;
|
150
134
|
|
151
135
|
$dsh_connect2->disconnect;
|
152
136
|
|
153
|
-
```
|
154
137
|
|
155
|
-
|
138
|
+
|
139
|
+
|
156
140
|
|
157
141
|
exit;
|
158
142
|
|
159
143
|
```
|
160
|
-
|
161
|
-
|
162
144
|
|
163
145
|
|
164
146
|
|
1
ソースが見づらくなってしまい修正いたしました。
test
CHANGED
File without changes
|
test
CHANGED
@@ -26,83 +26,107 @@
|
|
26
26
|
|
27
27
|
|
28
28
|
|
29
|
+
```
|
30
|
+
|
29
31
|
my $tbl_name1 = 'tbl_name1';
|
30
32
|
|
31
|
-
my $tbl_name2 = 'tbl_name2';
|
33
|
+
my $tbl_name2 = 'tbl_name2';
|
34
|
+
|
35
|
+
```
|
32
36
|
|
33
37
|
|
34
38
|
|
39
|
+
```
|
40
|
+
|
35
41
|
my %attr = (RaiseError=>1, PrintError=>0, mysql_enable_utf8=>1, AutoCommit=>0);
|
36
42
|
|
37
|
-
my ( $dsh_connect1, $dsh_connect2 );
|
43
|
+
my ( $dsh_connect1, $dsh_connect2 );
|
44
|
+
|
45
|
+
```
|
38
46
|
|
39
47
|
|
48
|
+
|
49
|
+
```
|
40
50
|
|
41
51
|
# 1) DB1 へ接続
|
42
52
|
|
43
53
|
eval{
|
44
54
|
|
45
|
-
|
55
|
+
my $dsn = "DBI:mysql:$dbname1:$dbhost1:$dbport1";
|
46
56
|
|
47
|
-
|
57
|
+
$dsh_connect1 = DBI -> connect ( $dsn, $dbuser1, $dbpass1, \%attr );
|
48
58
|
|
49
|
-
};
|
59
|
+
};
|
50
60
|
|
51
|
-
# ERROR
|
52
|
-
|
53
|
-
if(!@){
|
61
|
+
if(!@){
|
54
62
|
|
55
63
|
# 接続1 エラー
|
56
64
|
|
57
65
|
}
|
58
66
|
|
67
|
+
```
|
68
|
+
|
69
|
+
|
70
|
+
|
71
|
+
```
|
72
|
+
|
59
73
|
eval{
|
60
74
|
|
75
|
+
# INSERT処理1
|
76
|
+
|
61
|
-
$sth = $dsh_connect1->prepare("INSERT INTO
|
77
|
+
$sth = $dsh_connect1->prepare("INSERT INTO $dbname1.$tbl_name1 VALUES ($tbl_query_value1)");
|
78
|
+
|
79
|
+
$sth->execute;
|
80
|
+
|
81
|
+
};
|
82
|
+
|
83
|
+
if($@){
|
84
|
+
|
85
|
+
# INSERT1 Error
|
86
|
+
|
87
|
+
}
|
88
|
+
|
89
|
+
```
|
90
|
+
|
91
|
+
|
92
|
+
|
93
|
+
```
|
94
|
+
|
95
|
+
# 2) DB2 へ接続
|
96
|
+
|
97
|
+
eval{
|
98
|
+
|
99
|
+
my $dsn = "DBI:mysql:$dbname2:$dbhost2:$dbport2";
|
100
|
+
|
101
|
+
$dsh_connect2 = DBI -> connect ( $dsn, $dbuser2, $dbpass2, \%attr );
|
102
|
+
|
103
|
+
};
|
104
|
+
|
105
|
+
if(!@){
|
106
|
+
|
107
|
+
# 接続2 エラー
|
108
|
+
|
109
|
+
$dsh_connect1->rollback;
|
110
|
+
|
111
|
+
}
|
112
|
+
|
113
|
+
```
|
114
|
+
|
115
|
+
|
116
|
+
|
117
|
+
```
|
118
|
+
|
119
|
+
eval{
|
120
|
+
|
121
|
+
# INSERT処理2
|
122
|
+
|
123
|
+
$sth = $dsh_connect2->prepare("INSERT INTO $dbname2.$tbl_name2 VALUES ($tbl_query_value2)");
|
62
124
|
|
63
125
|
$sth->execute;
|
64
126
|
|
65
127
|
};
|
66
128
|
|
67
|
-
if($@){
|
129
|
+
if($@){
|
68
|
-
|
69
|
-
# INSERT1 Error
|
70
|
-
|
71
|
-
}
|
72
|
-
|
73
|
-
|
74
|
-
|
75
|
-
# 2) DB2 へ接続
|
76
|
-
|
77
|
-
eval{
|
78
|
-
|
79
|
-
my $dsn = "DBI:mysql:$dbname2:$dbhost2:$dbport2";
|
80
|
-
|
81
|
-
$dsh_connect2 = DBI -> connect ( $dsn, $dbuser2, $dbpass2, \%attr );
|
82
|
-
|
83
|
-
};
|
84
|
-
|
85
|
-
# ERROR
|
86
|
-
|
87
|
-
if(!@){
|
88
|
-
|
89
|
-
# 接続2 エラー
|
90
|
-
|
91
|
-
$dsh_connect1->rollback;
|
92
|
-
|
93
|
-
}
|
94
|
-
|
95
|
-
|
96
|
-
|
97
|
-
eval{
|
98
|
-
|
99
|
-
$sth = $dsh_connect2->prepare("INSERT INTO `$dbname2`.`$tbl_name2` VALUES ($tbl_query_value2)");
|
100
|
-
|
101
|
-
$sth->execute;
|
102
|
-
|
103
|
-
};
|
104
|
-
|
105
|
-
if($@){
|
106
130
|
|
107
131
|
# INSERT2 Error
|
108
132
|
|
@@ -116,11 +140,25 @@
|
|
116
140
|
|
117
141
|
}
|
118
142
|
|
143
|
+
```
|
144
|
+
|
145
|
+
|
146
|
+
|
147
|
+
```
|
148
|
+
|
119
149
|
$dsh_connect1->disconnect;
|
120
150
|
|
121
151
|
$dsh_connect2->disconnect;
|
122
152
|
|
153
|
+
```
|
154
|
+
|
155
|
+
```
|
156
|
+
|
123
157
|
exit;
|
158
|
+
|
159
|
+
```
|
160
|
+
|
161
|
+
|
124
162
|
|
125
163
|
|
126
164
|
|