ViciDial/agc_2-X
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Small changes to nanpa populate and preload processes

Browse Source 
git-svn-id: svn://192.168.202.10@2029 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mattf
2013-09-28 12:18:48 +00:00
parent 4eea18c28a
commit d7911abee5
2 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bin/nanpa_type_populate.pl
+11 -10
View File
@@ -12,6 +12,7 @@
#
# CHANGES
# 130915-1345 - first build
# 130928-0747 - Force overwrite of unzipped files, more standard debug output
#
$PATHconf = '/etc/astguiclient.conf';
@@ -190,9 +191,9 @@ if ($skip_download < 1)
}
if ($DB > 0) {print "\n unzipping files... PrefixMasterList.zip\n";}
`/usr/bin/unzip -u /tmp/PrefixMasterList.zip -d /tmp`;
`/usr/bin/unzip -uo /tmp/PrefixMasterList.zip -d /tmp`;
if ($DB > 0) {print " unzipping files... neustar.zip\n";}
`/usr/bin/unzip -u /tmp/neustar.zip -d /tmp`;
`/usr/bin/unzip -uo /tmp/neustar.zip -d /tmp`;
##### END gather files from SFTP server and unzip #####
}
@@ -257,45 +258,45 @@ if ($nanpa_wireless_to_wired_count > 0)
{
$stmtN = "DELETE from nanpa_wireless_to_wired;";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records deleted| nanpa_wireless_to_wired\n";}
if($DB){print STDERR "|$affected_rows records deleted| nanpa_wireless_to_wired\n";}
}
$stmtN = "LOAD DATA LOCAL INFILE '/tmp/WIRELESS-TO-WIRELINE-NORANGE.TXT' into table nanpa_wireless_to_wired LINES terminated by '\n' (phone);";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records inserted| nanpa_wireless_to_wired\n";}
if($DB){print STDERR "|$affected_rows records inserted| nanpa_wireless_to_wired\n";}
if ($nanpa_wired_to_wireless_count > 0)
{
$stmtN = "DELETE from nanpa_wired_to_wireless;";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records deleted| nanpa_wired_to_wireless\n";}
if($DB){print STDERR "|$affected_rows records deleted| nanpa_wired_to_wireless\n";}
}
$stmtN = "LOAD DATA LOCAL INFILE '/tmp/WIRELINE-TO-WIRELESS-NORANGE.TXT' into table nanpa_wired_to_wireless LINES terminated by '\n' (phone);";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records inserted| nanpa_wired_to_wireless\n";}
if($DB){print STDERR "|$affected_rows records inserted| nanpa_wired_to_wireless\n";}
if ($nanpa_prefix_exchanges_master_count > 0)
{
$stmtN = "DELETE from nanpa_prefix_exchanges_master;";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records deleted| nanpa_prefix_exchanges_master\n";}
if($DB){print STDERR "|$affected_rows records deleted| nanpa_prefix_exchanges_master\n";}
}
$stmtN = "LOAD DATA LOCAL INFILE '/tmp/PrefixMasterList.csv' into table nanpa_prefix_exchanges_master FIELDS TERMINATED BY ',' LINES terminated by '\r\n' (areacode,prefix,source,type,tier,postal_code,new_areacode,tzcode,region);";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records inserted| nanpa_prefix_exchanges_master\n";}
if($DB){print STDERR "|$affected_rows records inserted| nanpa_prefix_exchanges_master\n";}
if ($nanpa_prefix_exchanges_fast_count > 0)
{
$stmtN = "DELETE from nanpa_prefix_exchanges_fast;";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records deleted| nanpa_prefix_exchanges_fast\n";}
if($DB){print STDERR "|$affected_rows records deleted| nanpa_prefix_exchanges_fast\n";}
}
$stmtN = "INSERT INTO nanpa_prefix_exchanges_fast (ac_prefix,type) SELECT CONCAT(areacode,prefix),type from nanpa_prefix_exchanges_master;";
$affected_rows = $dbhN->do($stmtN);
if($DBX){print STDERR "|$affected_rows records inserted| nanpa_prefix_exchanges_fast\n";}
if($DB){print STDERR "|$affected_rows records inserted| nanpa_prefix_exchanges_fast\n";}
if ($DB) {print "LEADS FOUND IN LIST $list_id: |$sthArows|\n";}
bin/nanpa_type_preload.pl
+2
View File
@@ -398,6 +398,7 @@ while ($sthArows > $rec_count)
if($DBX){print STDERR "|$affected_rows records changed|\n";}
}
$type_hash{$type}="";
if ($DB) {print STDERR "$rec_count / $sthArows\r";}
}
##################################################
@@ -436,6 +437,7 @@ foreach $type (keys %type_hash)
if($DBX){print STDERR "|$affected_rows records changed|\n";}
}
$type_hash{$type}="";
if ($DB) {print STDERR "$sthArows / $sthArows\r";}
}
}
#########################################################