TT#30501 sync_db(): add sync_db_timezones

* sync_db_timezones use 'mysql_tzinfo_to_sql'
      to load timezone info from /usr/share/zoneinfo into
      MariaDB.
    * tzdata package version is checked and the timezone data
      sync is skipped if the version in ngcp.tzinfo_version
      is already up to date.

Change-Id: I92c87fb52fea20df0366c93c2e3568c25833b9bb

debian/control

@@ -9,6 +9,7 @@ Build-Depends:
  debhelper (>= 10),
  docbook-xsl,
  git,
+ libcapture-tiny-perl,
  libclone-perl,
  libconfig-tiny-perl,
  libdata-validate-ip-perl,
@@ -39,6 +40,7 @@ Depends:
  etckeeper,
  file,
  git (>= 1:1.7.2.5-3~),
+ libcapture-tiny-perl,
  libclone-perl,
  libconfig-tiny-perl,
  libdata-validate-ip-perl,

helper/sync-db

@@ -9,6 +9,7 @@ use YAML::XS qw(LoadFile);
 use Template;
 use Hash::Merge qw(merge);
 use DBI;
+use Capture::Tiny qw(capture);
 
 sub sync_extra_sockets;
 sub db_connect;
@@ -64,6 +65,8 @@ exit 1 unless(sync_rtp_interfaces($dbh,
 exit 1 unless(sync_general_timezone($dbh,
   $config->{general}->{timezone}));
 
+exit 1 unless(sync_db_timezones($dbh));
+
 $dbh->disconnect;
 
 exit 0;
@@ -163,5 +166,73 @@ SQL
     return 1;
 }
 
+## /usr/share/zoneinfo into MariaDB ##############################
+sub sync_db_timezones {
+    my $dbh = shift;
+
+    my ($out, $err, $rc) = capture {
+        system('/usr/bin/mysql_tzinfo_to_sql /usr/share/zoneinfo');
+    };
+
+    if ($rc) {
+        print "Error: $err\n";
+        return;
+    }
+
+    my ($tzinfo_version, undef, undef) = capture {
+        system('dpkg -s tzdata | grep Version:');
+    };
+
+    unless ($tzinfo_version && $tzinfo_version =~ /Version:\s*(\S+)/) {
+        print "Error: Could not retreive tzdata package version\n";
+        return;
+    }
+    $tzinfo_version = $1;
+
+    my $pe = $dbh->{PrintError};
+    $dbh->{PrintError} = 0;
+    my $sql = '';
+    my $p_rs = $RS;
+    eval {
+        $dbh->begin_work() or die "Cannot start tx: ".$DBI::errstr;
+        my ($cur_tzinfo_version) = $dbh->selectrow_array(<<SQL)
+SELECT version
+  FROM ngcp.tzinfo_version
+SQL
+            or die "Cannot select from ngcp.tzinfo_version: $DBI::errstr\n";
+        if ($cur_tzinfo_version eq $tzinfo_version) {
+            return;
+        }
+        open(my $sql_stream, "<", \$out)
+            or die "Cannot open sql stream: $ERRNO\n";
+        binmode($sql_stream);
+        local $RS = ";\n";
+        $dbh->do('USE mysql')
+            or die "Cannot use mysql database: $DBI::errstr\n";
+        while ($sql = <$sql_stream>) {
+            map {
+                $dbh->do($_) or die "Cannot insert timezone data: $DBI::errstr\n";
+            } split /;\s+/, $sql; # multiple one line statements
+        }
+        close $sql_stream;
+        $dbh->do(<<SQL, undef, $tzinfo_version, $tzinfo_version)
+INSERT INTO ngcp.tzinfo_version SET version = ?
+    ON DUPLICATE KEY UPDATE version = ?, modified_at = CURRENT_TIMESTAMP
+SQL
+            or die "Cannot insert into ngcp.tzinfo_version: $DBI::errstr\n";
+    };
+    local $RS = $p_rs;
+    $err = $EVAL_ERROR;
+    $dbh->{PrintError} = $pe;
+    if ($err) {
+        print $err,"sql: $sql\n";
+        $dbh->rollback();
+        return;
+    }
+    $dbh->commit();
+
+    return 1;
+}
+
 
 ## END OF FILE #################################################################