nodejs 连接mysql

db.js
/**
 * Created by niefengjun.cn on 13-12-5.
 */
var Config = require('../../config').config;
var mysqlClient = require('mysql');


var dbExecuteSql = function (Sql, callback) {

    var conn = mysqlClient.createConnection(Config.dbweixin_Log);

    conn.connect();
    conn.query(Sql, function (err, result, fields) {
        if (err) {

            conn.end();
            callback(err, undefined);
        }
        conn.end();
        callback(undefined, result);
    });
};

var tool = require('../../tool');
var db = require('./db');

function addLog(MsgType, Content, FromUserName, ToUserName, EventKey,account_source, callback)
 {
    var sql = 'INSERT INTO weixinUserLog (MsgType ,Content ,CreateTime , FromUserName ,ToUserName,EventKey,account_source) ';
    sql = sql   "VALUES (" tool.sqlstring(MsgType) "," tool.sqlstring(Content) ",now()," tool.sqlstring(FromUserName) ","   tool.sqlstring(ToUserName)
          "," tool.sqlstring(EventKey) "," tool.sqlstring(account_source) ")";

    db.dbExecuteSql(sql, function (err, value) {

            callback(err, value);
        }
    );

}

exports.addLog = addLog;