nodejs连接mysql数据库

来源:赵克立 分类: nodejs 标签:nodejs发布时间:2018-01-05 11:38:52浏览:13
版权声明:
本文为博主原创文章,转载请声明原文链接...谢谢。o_0。
温馨提示:
技术类文章有它的时效性,请留意文章更新时间以及软件的版本
更新时间:
2018-01-15 10:29:32

连接数据库

//数据库连接
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);
});



微信号:mokuyu QQ群:215861553 紧急求助须知
留下一点心意, :)
点击更换验证码
留言