let sql=require("mssql");

//sql.trustedConnection = true;
let sqlConfig = {
    user: 'casdbuser',
    password:'4KcLao2016!',
    server: 'ustww2063\\CCE',
    database: 'CAS110',
    port: 1433
}

let sourceTag="CCERpsLog";
let processingType="casrpslog";
let maxPKey="";

sql.connect(sqlConfig,err => {
    console.log("JOE" , err);
    const request = new sql.Request();
    request.stream = true;


    setInterval(_=>{
        request.query('select top 1 *,getdate() from rpslog where pkey > \'' + maxPKey + '\' order by pkey');
    },5000)



    

    request.on('row',row=>{
            //console.log(row);
            if (row.PKey > maxPKey) {
                maxPKey=row.PKey;
               // console.log("MaxPKey:",maxPKey)
            }
            outData={sourceTag:sourceTag,processingType:processingType,data:row};
            console.log(outData);
    });

    request.on('done', result=>{
        console.log("Done");
    });
})