Node 连接 mysql

在这篇笔记中，将会介绍node与mysql的连接，并且会分享封装好的代码，在项目中是可以直接使用。

安装 mysql 模块

npm install mysql

连接 mysql

const mysql = require('mysql');

let connection = mysql.createConnection({
    host : 'localhost',
    user : 'root', 
    password : 'password',
    database : 'test'
});

connection.connect(function(err) {
    if (err) {
        console.error('连接失败: ' + err.stack);
        return;
    }
    
    console.log('连接成功 id ' + connection.threadId);
});

host：连接的服务器

user：数据库用户名

password：设置的MySQL密码

database： 要连接的数据库名

常用的SQL语句

具体的使用这里不做详细说明，包括select、insert、update、delete等语句。

Node操作Mysql

查询

connection.query('SELECT * FROM t_user WHERE username = "whg"', (err, results, fields) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

添加

connection.query('INSERT INTO t_user(username, pass) VALUES(?, ?)',['whg', '123'], (err, results) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

删除

connection.query('DELETE FROM t_user  WHERE id = 1', (err, results) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

更新

connection.query('UPDATE t_user SET pass = "321" WHERE username = "whg"', (err, results) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

结束连接

connection.end(function(err) {
  
});
connection.destroy();

这两种都行，第二种是强制结束。

封装

封装好的代码

1.数据库配置文件

//配置链接数据库参数
module.exports = {
    host : 'localhost',
    port : 3306,//端口号
    database : 'nodetest',//数据库名
    user : 'root',//数据库用户名
    password : '123456'//数据库密码
};

2.封装、暴露方法

let mysql = require('mysql');//引入mysql模块
var databaseConfig = require('./mysql.config');  //引入数据库配置模块中的数据

//向外暴露方法
module.exports = {
    query : function(sql,params,callback){
        //每次使用的时候需要创建链接，数据操作完成之后要关闭连接
        var connection = mysql.createConnection(databaseConfig);        
        connection.connect(function(err){
            if(err){
                console.log('数据库链接失败');
                throw err;
            }
         //开始数据操作
         //传入三个参数，第一个参数sql语句，第二个参数sql语句中需要的数据，第三个参数回调函数
        connection.query( sql, params, function(err,results,fields ){
           if(err){
                console.log('数据操作失败');
                throw err;
            }
            //将查询出来的数据返回给回调函数
            callback && callback(results, fields);
            //results作为数据操作后的结果，fields作为数据库连接的一些字段
            //停止链接数据库，必须再查询语句后，要不然一调用这个方法，就直接停止链接，数据操作就会失败
             connection.end(function(err){
                  if(err){
                      console.log('关闭数据库连接失败！');
                      throw err;
                  }
              });
           });
       });
    }
};

3.演示实例

var db=require('../model/mysql.js');
// 查询实例
db.query('select * from t_user', [],function(result,fields){
    console.log('查询结果：');
    console.log(result);
});
//添加实例
var  addSql = 'INSERT INTO websites(username,password) VALUES(?,?)';
var  addSqlParams =['咕噜先森', '666'];
db.query(addSql,addSqlParams,function(result,fields){
    console.log('添加成功')
})

结束

使用的时候直接将封装好的方法copy到项目中，修改一下实例就行了。在下一篇我会继续介绍node+mysql连接池的使用。