У меня уже есть что-то вроде этого ... Не совсем то, что вы требовали, но очень близко к этому я обобщил основную часть и вот code..Hope это поможет ....
var mysql = require('mysql');
var con = mysql.createConnection({
host:"yourHostName",
user:"yourUserName",
password:"yourPassword"
});
con.query("use databaseName");
function getCustomerDetails(custId){
con.query("select * from customer where custId = "+custId,function(err,result,fields){
if(!err)
return result;
else
console.log(err);
});
}
function updateCustomerDetails(custId,fieldName,fieldValue){
con.query("update customer set "+fieldName+" = "+fieldValue+" where custId = "+custId,function(err,result,fields){
if(!err)
return true;
else
console.log(err);
return false;
});
}
exports.getCustomerDetails = getCustomerDetails;
exports.updateCustomerDetails = updateCustomerDetails;
И тогда предположим, что вы сохранили модуль как dbAccessModule.js затем вы можете использовать функции как этот
var C = require('./dbAccessModule');
result = C.getCustomerDetails(1);
console.log(result.fieldName);
var success = C.updateCustomerDetails(1,'name','sumit');
if(success)
console.log('Table Updated successfully....');
else
// take necessary action according to your application
Одна вещь, вы должны позаботиться о том, что если вы обновляете любое поле со значением строки то пожалуйста не забывайте окружать значение fieldValue одинарными кавычками.
Если это не то, что вы просили, пожалуйста, игнорируйте его ....