1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
|
#
# Query the DPM database and updates the 's_uid' and 'protocol' fields
#
package UpdateDpmDatabase;
use DBI;
use Common;
use strict;
use warnings;
sub find_and_update_s_uid_field($$) {
my ($dbh_dpns, $dbh_dpm) = @_;
my $select;
my $count = 0;
my ($userid, $username);
$select = $dbh_dpns->prepare("
SELECT userid, username
FROM Cns_userinfo");
$select->execute();
while(($userid, $username) = $select->fetchrow_array()) {
Common::updateFieldInDpmWhereString($dbh_dpm, "dpm_space_reserv", "s_uid", $userid, "client_dn", $username);
$count = $count+1;
}
$select->finish;
$dbh_dpm->commit;
return $count;
}
sub find_and_update_protocol_field($) {
my ($dbh_dpm) = @_;
my ($select1, $select2, $select3);
my $count = 0;
my ($r_token, $r_type, $protocol);
# in dpm_req, "get" requests
$select1 = $dbh_dpm->prepare("
SELECT r_token, protocol
FROM dpm_req
WHERE r_type = 'G' OR r_type = 'B'");
$select1->execute();
while (($r_token, $protocol) = $select1->fetchrow_array()) {
Common::updateFieldInDpmWhereString($dbh_dpm, "dpm_get_filereq", "protocol", $protocol, "r_token", $r_token);
$count = $count+1;
}
$select1->finish;
$dbh_dpm->commit;
# in dpm_req, "put" requests
$select2 = $dbh_dpm->prepare("
SELECT r_token, protocol
FROM dpm_req
WHERE r_type = 'P'");
$select2->execute();
$dbh_dpm->commit;
while (($r_token, $protocol) = $select2->fetchrow_array()) {
Common::updateFieldInDpmWhereString($dbh_dpm, "dpm_put_filereq", "protocol", $protocol, "r_token", $r_token);
$count = $count+1;
}
$select2->finish;
$dbh_dpm->commit;
# in dpm_pending_req
$select3 = $dbh_dpm->prepare("
SELECT r_token, protocol
FROM dpm_pending_req");
$select3->execute();
while (($r_token, $protocol) = $select3->fetchrow_array()) {
Common::updateFieldInDpmWhereString($dbh_dpm, "dpm_get_filereq", "protocol", $protocol, "r_token", $r_token);
Common::updateFieldInDpmWhereString($dbh_dpm, "dpm_put_filereq", "protocol", $protocol, "r_token", $r_token);
$count = $count+1;
}
$select3->finish;
$dbh_dpm->commit;
return ($count);
}
sub update_defpintime($) {
my ($dbh_dpm) = @_;
my $select;
my $count = 0;
my ($defpintime, $poolname, $new_defpintime);
$select = $dbh_dpm->prepare("
SELECT defpintime, poolname
FROM dpm_pool");
$select->execute();
while (($defpintime, $poolname) = $select->fetchrow_array()) {
if ($defpintime == 0) {
$new_defpintime = 7200;
Common::updateNumberInDpmWhereString($dbh_dpm, "dpm_pool", "defpintime", $new_defpintime, "poolname", $poolname);
$count = $count+1;
}
}
$select->finish;
$dbh_dpm->commit;
return ($count);
}
sub modify_dpm_db_before_updating_fields_mysql($$) {
my ($dbh_dpm, $lifetime) = @_;
# dpm_pool table
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD def_lifetime INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD max_lifetime INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD maxpintime INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD mig_policy VARCHAR(15) BINARY");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD ret_policy CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_pool SET def_lifetime=604800, max_lifetime=2592000, maxpintime=43200");
$dbh_dpm->do ("UPDATE dpm_pool SET mig_policy='none', ret_policy='R'");
# dpm_get_filereq table
$dbh_dpm->do ("ALTER TABLE dpm_get_filereq ADD protocol VARCHAR(7) BINARY");
$dbh_dpm->do ("ALTER TABLE dpm_get_filereq ADD ret_policy CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_get_filereq SET ret_policy='_'");
# dpm_put_filereq table
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD protocol VARCHAR(7) BINARY");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD f_lifetime INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD ret_policy CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD ac_latency CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET ret_policy='_', ac_latency='O'");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=86400");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=2147483647 WHERE f_type = 'P'");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=$lifetime WHERE f_type = 'V' AND status=4096"); # DPM_DONE status
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=$lifetime WHERE f_type = 'D' AND status=4096"); # DPM_DONE status
# dpm_req
$dbh_dpm->do ("DELETE FROM dpm_req WHERE r_type = 'C'");
# dpm_pending_req
$dbh_dpm->do ("DELETE FROM dpm_pending_req WHERE r_type = 'C'");
# dpm_copy_filereq table
$dbh_dpm->do ("DELETE FROM dpm_copy_filereq"); # as copy is not supported yet, delete all copy requests
$dbh_dpm->do ("ALTER TABLE dpm_copy_filereq CHANGE lifetime f_lifetime INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_copy_filereq ADD ret_policy CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_copy_filereq ADD ac_latency CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_copy_filereq SET ret_policy='_', ac_latency='O'");
# dpm_space_reserv table
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv MODIFY u_space BIGINT");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD s_uid INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD s_gid INTEGER");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD ret_policy CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD ac_latency CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD poolname VARCHAR(15)");
$dbh_dpm->do ("UPDATE dpm_space_reserv SET s_gid=0, ret_policy='R', ac_latency='O'");
$dbh_dpm->commit;
}
sub modify_cns_db_mysql($$) {
my ($dbh_dpns, $lifetime) = @_;
$dbh_dpns->do ("ALTER TABLE Cns_file_metadata MODIFY name VARCHAR(255) BINARY");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD ctime INTEGER");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD ltime INTEGER");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD r_type CHAR(1) BINARY");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD setname VARCHAR(36) BINARY");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD INDEX (host)");
$dbh_dpns->do ("UPDATE Cns_file_replica SET ltime=0x7FFFFFFF WHERE f_type = 'P'");
$dbh_dpns->do ("UPDATE Cns_file_replica SET ltime=$lifetime WHERE f_type = 'V'");
$dbh_dpns->do ("UPDATE Cns_file_replica SET ltime=$lifetime WHERE f_type = 'D'");
$dbh_dpns->commit;
}
sub modify_cns_db_oracle($$) {
my ($dbh_dpns, $lifetime) = @_;
$dbh_dpns->do ("ALTER TABLE Cns_file_metadata MODIFY name VARCHAR2(255)");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD ctime NUMBER(10)");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD ltime NUMBER(10)");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD r_type CHAR(1)");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD setname VARCHAR2(36)");
$dbh_dpns->do ("CREATE INDEX replica_host ON Cns_file_replica(host)");
$dbh_dpns->do ("UPDATE Cns_file_replica SET ltime=2147483647 WHERE f_type = 'P'");
$dbh_dpns->do ("UPDATE Cns_file_replica SET ltime=$lifetime WHERE f_type = 'V'");
$dbh_dpns->do ("UPDATE Cns_file_replica SET ltime=$lifetime WHERE f_type = 'D'");
$dbh_dpns->commit;
}
sub modify_dpm_db_before_updating_fields_oracle($$) {
my ($dbh_dpm, $lifetime) = @_;
# dpm_pool table
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD def_lifetime NUMBER(10)");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD max_lifetime NUMBER(10)");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD maxpintime NUMBER(10)");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD mig_policy VARCHAR2(15)");
$dbh_dpm->do ("ALTER TABLE dpm_pool ADD ret_policy CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_pool SET def_lifetime=604800, max_lifetime=2592000, maxpintime=43200");
$dbh_dpm->do ("UPDATE dpm_pool SET mig_policy='none', ret_policy='R'");
# dpm_get_filereq table
$dbh_dpm->do ("ALTER TABLE dpm_get_filereq ADD protocol VARCHAR2(7)");
$dbh_dpm->do ("ALTER TABLE dpm_get_filereq ADD ret_policy CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_get_filereq SET ret_policy='-'");
# dpm_put_filereq table
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD protocol VARCHAR2(7)");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD f_lifetime NUMBER(10)");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD ret_policy CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq ADD ac_latency CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET ret_policy='_', ac_latency='O'");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=86400");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=2147483647 WHERE f_type = 'P'");
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=$lifetime WHERE f_type = 'V' and status=4096"); # DPM_DONE status
$dbh_dpm->do ("UPDATE dpm_put_filereq SET f_lifetime=$lifetime WHERE f_type = 'D' and status=4096"); # DPM_DONE status
# dpm_req
$dbh_dpm->do ("DELETE FROM dpm_req WHERE r_type = 'C'");
# dpm_pending_req
$dbh_dpm->do ("DELETE FROM dpm_pending_req WHERE r_type = 'C'");
# dpm_copy_filereq table
$dbh_dpm->do ("DELETE FROM dpm_copy_filereq"); # as copy is not supported yet, delete all copy requests
$dbh_dpm->do ("ALTER TABLE dpm_copy_filereq RENAME COLUMN lifetime TO f_lifetime");
$dbh_dpm->do ("ALTER TABLE dpm_copy_filereq ADD ret_policy CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_copy_filereq ADD ac_latency CHAR(1)");
$dbh_dpm->do ("UPDATE dpm_copy_filereq SET ret_policy='_', ac_latency='O'");
# dpm_space_reserv table
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD s_uid NUMBER(10)");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD s_gid NUMBER(10)");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD ret_policy CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD ac_latency CHAR(1)");
$dbh_dpm->do ("ALTER TABLE dpm_space_reserv ADD poolname VARCHAR2(15)");
$dbh_dpm->do ("UPDATE dpm_space_reserv SET s_gid=0, ret_policy='R', ac_latency='O'");
$dbh_dpm->commit;
}
sub modify_db_after_updating_fields_mysql($$) {
my ($dbh_dpns, $dbh_dpm) = @_;
$dbh_dpm->do ("ALTER TABLE dpm_pending_req DROP protocol");
$dbh_dpm->do ("ALTER TABLE dpm_req DROP protocol");
$dbh_dpm->do ("ALTER TABLE dpm_pool DROP put_retenp");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq DROP sr_expiretime");
$dbh_dpm->do ("DELETE FROM schema_version");
$dbh_dpm->do ("INSERT INTO schema_version VALUES(3, 0, 0)");
$dbh_dpm->commit; # first commit before the indexes, in case the indexes already exist
$dbh_dpns->do ("DELETE FROM schema_version");
$dbh_dpns->do ("INSERT INTO schema_version VALUES(3, 0, 0)");
$dbh_dpns->do ("ALTER TABLE Cns_file_replica DROP INDEX sfn"); # drop unique constraint
$dbh_dpns->do ("ALTER TABLE Cns_file_replica ADD INDEX (sfn(255))"); # and replace it with an index
$dbh_dpns->commit;
$dbh_dpm->do ("CREATE INDEX G_PFN_IDX ON dpm_get_filereq(pfn(255))");
$dbh_dpm->do ("CREATE INDEX P_PFN_IDX ON dpm_put_filereq(pfn(255))");
$dbh_dpm->commit;
}
sub modify_db_after_updating_fields_oracle($$) {
my ($dbh_dpns, $dbh_dpm) = @_;
$dbh_dpm->do ("ALTER TABLE dpm_pending_req DROP COLUMN protocol");
$dbh_dpm->do ("ALTER TABLE dpm_req DROP COLUMN protocol");
$dbh_dpm->do ("ALTER TABLE dpm_pool DROP COLUMN put_retenp");
$dbh_dpm->do ("ALTER TABLE dpm_put_filereq DROP COLUMN sr_expiretime");
$dbh_dpm->do ("CREATE INDEX G_PFN_IDX ON dpm_get_filereq(pfn)");
$dbh_dpm->do ("CREATE INDEX P_PFN_IDX ON dpm_put_filereq(pfn)");
$dbh_dpm->do ("DELETE FROM schema_version");
$dbh_dpm->do ("INSERT INTO schema_version VALUES(3, 0, 0)");
$dbh_dpm->commit; # first commit before the indexes, in case the indexes already exist
$dbh_dpns->do ("DELETE FROM schema_version");
$dbh_dpns->do ("INSERT INTO schema_version VALUES(3, 0, 0)");
$dbh_dpns->commit;
$dbh_dpm->do ("CREATE INDEX G_PFN_IDX ON dpm_get_filereq(pfn)");
$dbh_dpm->do ("CREATE INDEX P_PFN_IDX ON dpm_put_filereq(pfn)");
$dbh_dpm->commit;
}
1;
|
