use strict;
use warnings;
use DBI;
my $t   = "pm1083865_ivo2"; # table name
my $date_string ;
my @hdr = ();
my @val = ();
while (<>) {  # reading STDIN
  chomp;
  $date_string = $_;
  last;
}
while (<>) {  # reading STDIN
  next if (/^\s*$/);
  chomp;
  if ( /^([^:]+):\s*(\d+)\s*$/ ) {
	push(@hdr, $1); push(@val, $2); 
  }
  elsif ( /^([^:]+):\s*(\d+)\s*([^:]+):\s*(\d+)\s*$/ ) {
	push(@hdr, $1); push(@val, $2); 
	push(@hdr, $3); push(@val, $4); 
  }
  else {
    print ">>>", $_ ,"<<<\n";
    die "oops - unprocessed line!\n";
  }
}
# clean up header names for database use:
for (my$i=0;$i<scalar(@hdr);$i++) {
	$hdr[$i] = lc($hdr[$i]);  #  lower case
	$hdr[$i] =~ s{[-]}{_}g;   #  change dash to underscore
	$hdr[$i] =~ s{[ ]}{_}g;   #  change space to underscore
	$hdr[$i] =~ s{_[_]+}{_}g; #
}
my @all_hdrs = (); push(@all_hdrs, "date_line" ); push(@all_hdrs, @hdr);
my @all_vals = (); push(@all_vals, $date_string); push(@all_vals, @val);
# use only this line to get a output csv
# print join("\t", @all_hdrs), "\n", join("\t", @all_vals), "\n";
# exit;
my $dbh = DBI->connect or die "no database connection - $!\n ";
$dbh->{AutoCommit} = 0;
$dbh->{RaiseError} = 1;
my $arf = $dbh->selectrow_arrayref("
   select count(*) from information_schema.tables
   where table_schema = 'public' and table_name = '$t'");
if ($arf->[0] == 0) {
    my $sql_create = join("\n"
      , "create table $t ("
      ,  " date_line timestamptz\n, "
      ,  join ("\n, ", map { $_ .= ' integer' } @hdr )
      , ");"
    );
    $dbh->do( $sql_create );
}
my $sql_insert = join("\n"
      , "insert into $t values ("
      ,  join( ", ", map {'?'} @all_hdrs)
      , ");"
);
my $sth = $dbh->prepare($sql_insert);
my $rc  = $sth->execute(@all_vals);
$dbh->commit;
$dbh->disconnect;