您当前的位置:首页 > 网站建设 > javascript
| php | asp | css | H5 | javascript | Mysql | Dreamweaver | Delphi | 网站维护 | 帝国cms | React | 考试系统 | ajax | jQuery | 小程序 |

Node连接MySQL并封装其增删改查的实现代码

51自学网 2022-02-21 13:35:04
  javascript

Node连接Mysql

说到node,可能大家会想到MOngoDB作为数据库,这里将会介绍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并封装其增删改查的实现代码的文章就介绍到这了,更多相关Node连接MySQL增删改查内容请搜索51zixue.net以前的文章或继续浏览下面的相关文章希望大家以后多多支持51zixue.net!


下载地址:
一篇文章告诉你如何用事件委托实现JavaScript留言板功能
详解Vue返回值动态生成表单及提交数据的办法
万事OK自学网:51自学网_软件自学网_CAD自学网自学excel、自学PS、自学CAD、自学C语言、自学css3实例,是一个通过网络自主学习工作技能的自学平台,网友喜欢的软件自学网站。