#! /usr/bin/perl -w

use strict;
use DBI;
use IO::Socket;

my $dbi_host='localhost';
my $dbi_name='revspace';
my $dbi_user='revspace';
my $dbi_pass='co2';

our $dbh_in;
our $sth_dbs;

# connect to data input table
sub conn_db {
        print "reconnect db\n";

        $dbh_in = DBI->connect("dbi:mysql:database=$dbi_name:host=$dbi_host", $dbi_user, $dbi_pass, { RaiseError => 0, AutoCommit => 1 });

        $dbh_in->{mysql_auto_reconnect} = 1;

        $sth_dbs = $dbh_in -> prepare('INSERT INTO co2(ts, value) VALUES(NOW(), ?)');
}

conn_db();

while(<>) {
        chomp;
        my $value = $_;

        $sth_dbs -> execute($value) or conn_db();

        print "$value\n";
}