Node连接Mysql
说到node，可能大家会想到MOngoDB作为数据库，这里将会介绍node与mysql的连接，并分享了封装好的实例代码，在项目开发中可直接使用。下一篇博客将会讲node连接MongoDB。
安装Mysql模块
1复制代码 | npm install mysql复制代码 |
连接Mysql
1234567891011121314151617复制代码 | 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
查询
123456复制代码 | connection.query('SELECT * FROM t_user WHERE username = "whg"', (err, results, fields) => { if(err){ console.log(err); } console.log(results);})复制代码 |
添加
123456复制代码 | connection.query('INSERT INTO t_user(username, pass) VALUES(?, ?)',['whg', '123'], (err, results) => { if(err){ console.log(err); } console.log(results);})复制代码 |
删除
123456复制代码 | connection.query('DELETE FROM t_user WHERE id = 1', (err, results) => { if(err){ console.log(err); } console.log(results);})复制代码 |
更新
123456复制代码 | connection.query('UPDATE t_user SET pass = "321" WHERE username = "whg"', (err, results) => { if(err){ console.log(err); } console.log(results);})复制代码 |
结束连接
1234复制代码 | connection.end(function(err) { });connection.destroy();复制代码 |
这两种都行，第二种是强制结束。
封装
说了这么多，感觉操作起来还是挺简单的。在实际开发中，我们想要操作起来更方便，那就让我们自己封装一下来使用。直接上代码：
封装好的代码
1.数据库配置文件
12345678复制代码 | //配置链接数据库参数module.exports = { host : 'localhost', port : 3306,//端口号 database : 'nodetest',//数据库名 user : 'root',//数据库用户名 password : '123456'//数据库密码};复制代码 |
2.封装、暴露方法
12345678910111213141516171819202122232425262728293031323334复制代码 | 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.演示实例
123456789101112复制代码 | 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连接MongoDB。