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
|
%dbx = (
epoch_to_timestamp_fn => 'FROM_UNIXTIME',
to_hex_string => sub {
my ($bin) = @_;
return "X'" . unpack("H*", $bin) . "'";
},
column_info_type_col => 'mysql_type_name',
tables => {
"report" => {
column_definitions => [
"serial" , "int" , "unsigned NOT NULL AUTO_INCREMENT",
"mindate" , "timestamp" , "NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP",
"maxdate" , "timestamp" , "NULL",
"domain" , "varchar(255)" , "NOT NULL",
"org" , "varchar(255)" , "NOT NULL",
"reportid" , "varchar(255)" , "NOT NULL",
"email" , "varchar(255)" , "NULL",
"extra_contact_info" , "varchar(255)" , "NULL",
"policy_adkim" , "varchar(20)" , "NULL",
"policy_aspf" , "varchar(20)" , "NULL",
"policy_p" , "varchar(20)" , "NULL",
"policy_sp" , "varchar(20)" , "NULL",
"policy_pct" , "tinyint" , "unsigned",
"raw_xml" , "mediumtext" , "",
],
additional_definitions => "PRIMARY KEY (serial), UNIQUE KEY domain (domain, reportid)",
table_options => "ROW_FORMAT=COMPRESSED",
indexes => [],
},
"rptrecord" => {
column_definitions => [
"id" , "int" , "unsigned NOT NULL AUTO_INCREMENT PRIMARY KEY",
"serial" , "int" , "unsigned NOT NULL",
"ip" , "int" , "unsigned",
"ip6" , "binary(16)" , "",
"rcount" , "int" , "unsigned NOT NULL",
"disposition" , "enum('" . join("','", ALLOWED_DISPOSITION) . "')" , "",
"reason" , "varchar(255)" , "",
"dkimdomain" , "varchar(255)" , "",
"dkimresult" , "enum('" . join("','", ALLOWED_DKIMRESULT) . "')" , "",
"spfdomain" , "varchar(255)" , "",
"spfresult" , "enum('" . join("','", ALLOWED_SPFRESULT) . "')" , "",
"spf_align" , "enum('" . join("','", ALLOWED_SPF_ALIGN) . "')" , "NOT NULL",
"dkim_align" , "enum('" . join("','", ALLOWED_DKIM_ALIGN) . "')" , "NOT NULL",
"identifier_hfrom" , "varchar(255)" , ""
],
additional_definitions => "KEY serial (serial, ip), KEY serial6 (serial, ip6)",
table_options => "",
indexes => [],
},
},
add_column => sub {
my ($table, $col_name, $col_type, $col_opts, $after_col) = @_;
my $insert_pos = "FIRST";
if ($after_col) {
$insert_pos = "AFTER $after_col";
}
return "ALTER TABLE $table ADD $col_name $col_type $col_opts $insert_pos;"
},
modify_column => sub {
my ($table, $col_name, $col_type, $col_opts) = @_;
return "ALTER TABLE $table MODIFY COLUMN $col_name $col_type $col_opts;"
},
);
1;
|
