nodejs连接mysql数据库

连接数据库

//数据库连接
global.db = require('mysql').createConnection({
    host: 'localhost',
    user: 'root',
    password: '***********',
    database: 'dataname',
    port: 3306
});
try {
    db.connect();
} catch (e) {
}
var sql = "SELECT * from kl_kefu where username='" + username + "' and password='" + password + "'";
//查询数据库中的用户名密码
db.query(sql, function(err, rows, fields) {
    if (err) throw err;
    if (rows.length > 0) {
        request.session['islogin'] = true;
        request.session['username'] = rows[0]['username'];
        request.session['nickname'] = rows[0]['name'];
        request.session['kefu_id'] = rows[0]['kefu_id'];
        request.session['room_id'] = rows[0]['room_id'];
    } else {
    }
});
db.end();

实际使用中可能会遇到连接关闭等错误

对于每次的请求都要连接数据库，要不然mysql就是超时而关闭，下面封装成一个模块使用

db.js

var mysql = require('mysql');
var db = {};
db.query = function sqlback(sql, callback) {
    var connection = require('mysql').createConnection({
        host: 'crm369.hemeids.com',
        user: 'hmcrm',
        password: 'mimajiushizhe',
        database: 'hmcrm',
        port: 3306
    });
    connection.connect(function(err) {
        if (err) {
            console.log(err);
            return;
        }
    });
    if (!sql) return;
    connection.query(sql, function(err, rows, fields) {
        if (err) {
            console.log(err);
            return;
        }
        callback(rows);
    });
    connection.end(function(err) {
        if (err) {
            return;
        } else {
            console.log('mysql connection closed!');
        }
    });
};
module.exports = db;

使用方法

mysql.query("select * from user where user_id=1", function(rows) {
    console.log(rows);
});