耀极客论坛

 找回密码
 立即注册
查看: 511|回复: 0

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

[复制链接]

336

主题

318

帖子

22万

积分

管理员

Rank: 9Rank: 9Rank: 9

积分
220555
发表于 2022-5-8 01:33:35 | 显示全部楼层 |阅读模式
  本文主要介绍了Node连接MySQL并封装其增删改查的实现代码,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

Node连接Mysql

  说到node,可能大家会想到MOngoDB作为数据库,这里将会介绍node与mysql的连接,并分享了封装好的实例代码,在项目开发中可直接使用。

安装Mysql模块
  1. npm install mysql
复制代码
连接Mysql
  1.     const mysql = require('mysql');
  2.    
  3.     let connection = mysql.createConnection({
  4.         host : 'localhost',
  5.         user : 'root',
  6.         password : 'password',
  7.         database : 'test'
  8.     });
  9. connection.connect(function(err) {
  10.   if (err) {
  11.     console.error('连接失败: ' + err.stack);
  12.     return;
  13.   }
  14.   console.log('连接成功 id ' + connection.threadId);
  15. });
复制代码
       
  • host:连接的服务器   
  • user:数据库用户名   
  • password:设置的MySQL密码   
  • database: 要连接的数据库名

常用的SQL语句

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

Node操作Mysql

  查询
  1. connection.query('SELECT * FROM t_user WHERE username = "whg"', (err, results, fields) => {
  2.     if(err){
  3.         console.log(err);
  4.     }
  5.     console.log(results);
  6. })
复制代码
  添加
  1. connection.query('INSERT INTO t_user(username, pass) VALUES(?, ?)',['whg', '123'], (err, results) => {
  2.     if(err){
  3.         console.log(err);
  4.     }
  5.     console.log(results);
  6. })
复制代码
  删除
  1. connection.query('DELETE FROM t_user  WHERE id = 1', (err, results) => {
  2.     if(err){
  3.         console.log(err);
  4.     }
  5.     console.log(results);
  6. })
复制代码
  更新
  1. connection.query('UPDATE t_user SET pass = "321" WHERE username = "whg"', (err, results) => {
  2.     if(err){
  3.         console.log(err);
  4.     }
  5.     console.log(results);
  6. })
复制代码
  结束连接
  1. connection.end(function(err) {
  2.   
  3. });
  4. connection.destroy();
复制代码
  这两种都行,第二种是强制结束。

封装

  说了这么多,感觉操作起来还是挺简单的。在实际开发中,我们想要操作起来更方便,那就让我们自己封装一下来使用。直接上代码:
  封装好的代码
  1.数据库配置文件
  1. //配置链接数据库参数
  2. module.exports = {
  3.     host : 'localhost',
  4.     port : 3306,//端口号
  5.     database : 'nodetest',//数据库名
  6.     user : 'root',//数据库用户名
  7.     password : '123456'//数据库密码
  8. };
复制代码
  2.封装、暴露方法
  1. let mysql = require('mysql');//引入mysql模块
  2. var databaseConfig = require('./mysql.config');  //引入数据库配置模块中的数据
  3. //向外暴露方法
  4. module.exports = {
  5.     query : function(sql,params,callback){
  6.         //每次使用的时候需要创建链接,数据操作完成之后要关闭连接
  7.         var connection = mysql.createConnection(databaseConfig);        
  8.         connection.connect(function(err){
  9.             if(err){
  10.                 console.log('数据库链接失败');
  11.                 throw err;
  12.             }
  13.          //开始数据操作
  14.          //传入三个参数,第一个参数sql语句,第二个参数sql语句中需要的数据,第三个参数回调函数
  15.         connection.query( sql, params, function(err,results,fields ){
  16.            if(err){
  17.                 console.log('数据操作失败');
  18.                 throw err;
  19.             }
  20.             //将查询出来的数据返回给回调函数
  21.             callback && callback(results, fields);
  22.             //results作为数据操作后的结果,fields作为数据库连接的一些字段
  23.             //停止链接数据库,必须再查询语句后,要不然一调用这个方法,就直接停止链接,数据操作就会失败
  24.              connection.end(function(err){
  25.                   if(err){
  26.                       console.log('关闭数据库连接失败!');
  27.                       throw err;
  28.                   }
  29.               });
  30.            });
  31.        });
  32.     }
  33. };
复制代码
  3.演示实例
  1. var db=require('../model/mysql.js');
  2. // 查询实例
  3. db.query('select * from t_user', [],function(result,fields){
  4.     console.log('查询结果:');
  5.     console.log(result);
  6. });
  7. //添加实例
  8. var  addSql = 'INSERT INTO websites(username,password) VALUES(?,?)';
  9. var  addSqlParams =['咕噜先森', '666'];
  10. db.query(addSql,addSqlParams,function(result,fields){
  11.     console.log('添加成功')
  12. })
复制代码
结束

  想要使用的朋友,可以直接把封装好的两个文件copy到项目中,改一下配置就可以使用了,大大提高开发效率。
  到此这篇关于Node连接MySQL并封装其增删改查的实现代码的文章就介绍到这了,更多相关Node连接MySQL增删改查内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!


回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

Archiver|手机版|小黑屋|耀极客论坛 ( 粤ICP备2022052845号-2 )|网站地图

GMT+8, 2022-12-7 12:36 , Processed in 0.069509 second(s), 20 queries .

Powered by Discuz! X3.4

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表