var Serialport = require('serialport');
var mysql = require('mysql');


var portName = 'COM5';
var distance = 0;
var time = 0;
var connected = false;

var sp = new Serialport(portName, {
    baudRate: 9600,
    dataBits: 8,
    parity: 'none',
    stopBits: 1,
    flowControl: false
});



sp.on('data', function(data) {
    time += 0.1;
    distance = parseInt(data.toString('utf8'));
    console.log(data.toString('utf-8'));
    if (connected){
        if(!isNaN(distance))
            insertIntoDb();
    }
});

function insertIntoDb(){
    var sql = "INSERT INTO inputdata (time, distance) VALUES (" + time + ", " + distance + ");";
    con.query(sql, function (err, result) {
        if (err) throw err;
        console.log("1 record inserted");
    });
}

var con = mysql.createConnection({
    host: 'localhost',
    user: "root",
    password: "",
    database: "ultrasonicReads"
});

con.connect(function(err){
    if (err) throw err;
    else{
        console.log("Connected to database!");
        connected = true;
    }
});