pubnub to mysql

/* ---------------------------------------------------------------------------

    Init PubNub and Get your PubNub API Keys:
    http://www.pubnub.com/account#api-keys ./node.js/pubnub.js

--------------------------------------------------------------------------- */

var pubnub = require("./node.js/pubnub.js").init({
    publish_key   : "pub-cxxxxxxxxxxxxx",
    subscribe_key : "sub-c-xxxxxxxxxxxxxxxxxxxx"
});
var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'pbss'
  //debug: false
});

/* ---------------------------------------------------------------------------
Listen for Messages
--------------------------------------------------------------------------- */



function subscribe(channel) {
    pubnub.subscribe({
        'channel' : channel,
        'connect' : function(c) {
            console.log('CONNECTED to ' + c);
        },
        'disconnect' : function(c) {
            console.log('CONNECTED to ' + c);
        },
        'reconnect' : function(c) {
            console.log('CONNECTED to ' + c);
        },
        'error' : function(e) {
            console.log('ERROR  ' + JSON.stringify(r));
        },
        'callback' : function(m,a,subscribed_channel,c,real_channel) {
            var dataku = JSON.stringify(m); ; //"ALERT!HYK0009-2121"
            console.log(dataku);
            var datamasuk=JSON.stringify(m); //"ALERT!HYK0009"
            console.log(datamasuk);
            var statusupd="";
            var datamasuk = datamasuk.substring(1, datamasuk.length-1); //ALERT!HYK0009
            console.log("datamasuk "+datamasuk);

            var isine = datamasuk.slice(0, 5); //ALERT
            console.log("isine "+isine);

            var pengirim = datamasuk.substring((datamasuk.search("!")+1), datamasuk.search("-")); //HYK0009
            console.log("pengirim "+pengirim);
            var d = new Date();
            var waktune = d.toLocaleString();


            connection.connect(function(err) {
             // if (err) throw err;
             // console.log("Connected!");

              var sql = "INSERT INTO inboxpub (pengirim, data) VALUES?";
              var values=[[pengirim, datamasuk]];
              connection.query(sql,[values], function (err, result) {
                if (err) throw err;
                 console.log("Number of array records inserted: " + result.affectedRows);
              });

              //var sql = "UPDATE client SET notelp = ? WHERE idclient=?";
              //var valuesnya=[[pengirim]];
              connection.query('UPDATE client SET status = ? WHERE idclient=?', [isine,pengirim],function (err, result){
                if (err) throw err;
                console.log(result.affectedRows + " record(s) updated");
              });

            });
            //connection.end();

        }
    })
    //console.log(process.argv.slice(2));

}
subscribe("Channel-YOGYA");