nodejs için gerekli eklentileri yükleme;
npm install mysql
npm install request
gerekli düzenlemeleri yaparsın,
var mysql = require('mysql'), sql;
var request = require('request');
var connect= function() {
sql = mysql.createConnection({ host: 'localhost', user: 'db_username', password: 'db_pass', database: 'db_name', insecureAuth: true });
sql.connect(function(err) {if(err) { setTimeout(connect, 2000); }});
}
var cekgonder= function() {
sql.query("SELECT * FROM ....", function(e,r) {
if(!e) {
if(r.length > 0) {
// gelen veri "r" değeri ile array olarak geliyor, r[0] 1. veriyi ifade eder.
request.post({url:'http://site.com/a.php', form: {key:'value'}}, function(err,httpResponse,body){ /* ... */ })
}
}
});
}
connect(); // sql bağlantısı
setInterval(cekgonder, 5000);