这篇文章主要介绍Nodejs怎么操作数据库，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！
// 导包 const express = require("express"); var mysql = require("mysql"); // 创建一个和数据库的连接 var connection = mysql.createConnection({ host: "localhost", // 数据库服务器的地址 user: "root", // 账号 password: "lijiazhao123", // 密码 database: "maxiaoyu", // 数据库名 }); // 打开连接 connection.connect(); let name = "伟健"; let miaoshu = "哈哈哈很开心"; // 执行sql语句 connection.query( `insert into user(username,description) values("${name}","${miaoshu}")`, function (error, results) { if (error == null) { console.log(results); // 返回结果是一个对象 console.log(results.affectedRows); // 受影响的行数，如果大于0，说明新增成功 console.log(results.insertId); // 插入的这条数据的id } } ); // 关闭连接 connection.end();// 导包 const express = require("express"); var mysql = require("mysql"); // 创建一个和数据库的连接 var connection = mysql.createConnection({ host: "localhost", // 数据库服务器的地址 user: "root", // 账号 password: "lijiazhao123", // 密码 database: "maxiaoyu", // 数据库名 }); // 打开连接 connection.connect(); let id = 3; let name = "千里jack"; let miaoshu = "新一代世界首富"; // 执行sql语句 connection.query(`delete from user where id = ${id}`, function ( error, results ) { if (error == null) { console.log(results); // 返回结果是一个对象 console.log(results.affectedRows); // 受影响的行数，如果大于0，说明新增成功 } }); // 关闭连接 connection.end();// 导包 const express = require("express"); var mysql = require("mysql"); // 创建一个和数据库的连接 var connection = mysql.createConnection({ host: "localhost", // 数据库服务器的地址 user: "root", // 账号 password: "lijiazhao123", // 密码 database: "maxiaoyu", // 数据库名 }); // 打开连接 connection.connect(); let id = 3; let name = "千里jack"; let miaoshu = "新一代世界首富"; // 执行sql语句 connection.query( `update user set username="${name}",description="${miaoshu}" where id=${id}`, function (error, results) { if (error == null) { console.log(results); // 返回结果是一个对象 console.log(results.affectedRows); // 受影响的行数，如果大于0，说明新增成功 } } ); // 关闭连接 connection.end();// 导包 const express = require("express"); var mysql = require("mysql"); // 创建一个和数据库的连接 var connection = mysql.createConnection({ host: "localhost", // 数据库服务器的地址 user: "root", // 账号 password: "lijiazhao123", // 密码 database: "maxiaoyu", // 数据库名 }); // 打开连接 // 其实这里这句代码可以不写，这个插件内部在你调用query执行sql语句的时候会自动的帮你打开连接 connection.connect(); // 执行sql语句 connection.query("select * from user", function (error, results, fields) { // 错误对象，如果没有错误就返回null // console.log(error); // 执行sql语句得到的结果集，有错的话就是undefined console.log(results); // console.log(results[4].username); // 拿到的是字段的信息 // console.log(fields); }); // 关闭连接 // 其实也可以不写，也是会自动关闭连接 connection.end();// 导包 const express = require("express"); const multer = require("multer"); const bodyParser = require("body-parser"); const mysql = require("mysql"); // 创建一个和数据库的连接 var connection = mysql.createConnection({ host: "localhost", // 数据库服务器的地址 user: "root", // 账号 password: "lijiazhao123", // 密码 database: "maxiaoyu", // 数据库名 }); // 创建一个uploads文件 var upload = multer({ dest: "uploads/" }); // 创建服务器 const app = express(); // 将uploads文件夹暴露出去，使得此文件夹内的文件可以直接被访问到 app.use(express.static("uploads")); // 写路由 // 1. 写一个新增接口 // 参数：heroName,heroSkill,heroIcon(文件), 使用multer从前端接收 app.post("/hero/add", upload.single("heroIcon"), (req, res) => { let heroIcon = "http://127.0.0.1:4399/" + req.file.filename; let { heroName, heroSkill } = req.body; // 执行sql语句 connection.query( `insert into hero(heroName,heroSkill,heroIcon) values("${heroName}","${heroSkill}","${heroIcon}")`, function (error, results) { if (error == null) { // 如果没有错则响应一个code为200的json对象 res.send({ code: 200, msg: "新增成功", }); } else { res.send({ code: 500, msg: "新增失败", }); } } ); }); // 2. 写一个查询所有的英雄接口 // 参数：无 app.get("/hero/all", (req, res) => { // 直接读取数据库表中的所有的英雄，返回 // 执行sql语句 connection.query( `select id,heroName,heroSkill,heroIcon from hero where isDelete="false"`, function (error, results) { if (error == null) { // 如果没有错则响应一个code为200的json对象 res.send({ code: 200, msg: "查询成功", data: results, }); } else { res.send({ code: 500, msg: "服务器内部错误", }); } } ); }); // 开启服务器 app.listen(4399, () => { console.log("服务器开启成功..."); });我们自己写的模块
// 变量 // let foodName = "红烧肉"; // // 把foodName暴露出去，为了使其可以被其他js文件导入 // module.exports = foodName; // 函数 // function test() { // console.log("我是test函数"); // } // module.exports = test; // 对象 let db = { baseUrl: "http://127.0.0.1:4399", insert() { console.log("我是插入的方法"); }, delete() { console.log("我是删除的方法"); }, }; module.exports = db;使用我们自己写的模块
// 导包 const path = require("path"); const myMoudle = require(path.join(__dirname, "01-我们自己写的模块.js")); // console.log(myMoudle); // myMoudle(); console.log(myMoudle.baseUrl); myMoudle.insert(); myMoudle.delete();我们自己写的一个mysql模块
const mysql = require("mysql"); // 创建一个和数据库的连接 var connection = mysql.createConnection({ host: "localhost", // 数据库服务器的地址 user: "root", // 账号 password: "lijiazhao123", // 密码 database: "maxiaoyu", // 数据库名 }); module.exports = { // connection: connection // 简写 connection, };使用我们自己写的mysql模块
// 导包 const express = require("express"); const path = require("path"); // 导入我们自己写的mysql模块 const db = require(path.join(__dirname, "03-我们自己写一个mysql的模块.js")); // 创建服务器 const app = express(); // 写一个查询所有英雄接口 app.get("/hero/all", (req, res) => { // 这里使用我们自己写的mysql模块，来操作数据库 // 这里的db,就相当于是03那个文件里面暴露出来的对象 // 这个对象里面又connection这个连接 db.connection.query( `select id,heroName,heroSkill,heroIcon from hero where isDelete="false"`, (error, results) => { if (error == null) { res.send({ code: 200, msg: "查询成功", data: results, }); } else { res.send({ code: 500, msg: "服务器内部错误", }); } } ); }); // 开启服务器 app.listen(4399, () => { console.log("服务器开启了"); });//导入模块 const hm = require("mysql-ithm"); //2.连接数据库 //如果数据库存在则连接，不存在则会自动创建数据库 hm.connect({ host: "localhost", //数据库地址 port: "3306", user: "root", //用户名，没有可不填 password: "lijiazhao123", //密码，没有可不填 database: "hm", //数据库名称 }); //3.创建Model(表格模型：负责增删改查) //如果table表格存在则连接，不存在则自动创建 let heroModel = hm.model("hero", { heroName: String, heroSkill: String, }); // 4. 调用api // 4.1 添加单个数据 // heroModel.insert( // { heroName: "波波", heroSkill: "骚的一批" }, // (err, results) => { // console.log(err); // console.log(results); // if (!err) console.log("增加成功"); // } // ); // 4.2 批量添加数据 // let arr = [ // { // heroName: "李白", // heroSkill: "一片诗意的酒，一曲长歌。一剑天涯，但愿长醉不复醒。", // }, // { // heroName: "孙悟空", // heroSkill: "取经之路就在脚下，超脱三界之外，不在五行之中。", // }, // { heroName: "貂蝉", heroSkill: "华丽又漂亮的生存到最后。" }, // ]; // heroModel.insert(arr, (err, results) => { // console.log(err); // console.log(results); // if (!err) console.log("增加成功"); // }); // 4.3 查询所有数据 // heroModel.find((err, results) => { // console.log(results); // }); // 4.4 根据数据库字段查询部分数据 // ['name'] : 将要查询的字段放入数组中 // heroModel.find(["heroName", "heroSkill"], (err, results) => { // console.log(results); // }); // 4.5 根据条件查询数据 // 'id=1' : 查询id为1的数据 (查询条件可以参考sql语句) //例如 'age>10' : 查询age超过10的数据 //例如 'name>"张三"' : 查询名字为张三的数据，注意字符串添加引号 // heroModel.find("id>2", (err, results) => { // console.log(results); // }); // 4.6 将数据库中 id = 1 的数据，age修改为30 // heroModel.update( // "id=2", // { // heroName: "千年之狐", // heroSkill: "青丘之灵的灵魂不会永远漂泊,因为我在这里", // }, // (err, results) => { // console.log(results); // } // ); //4.1 删除所有 id>3 的数据 // 这里删除是真正的把数据删掉 // 实际开发的时候不会用这个，因为开放的时候一般是软删除（使用更新） heroModel.delete("id>3", (err, results) => { console.log(results); });抓包
用到以下第三方库
crewler
功能介绍：
服务器端 DOM 和自动 jQuery 插入，使用 Cheerio（默认）或 JSDOM
可配置的池大小和重做
控制速率限制
请求的优先级队列
强制 8 模式， 让爬网程序处理与字符集检测和转换
兼容 4.x 或较新版本
// 1. 抓包：用爬虫crawler插件来爬网页上的数据 // 1. 抓包 // 导包 var Crawler = require("crawler"); // 创建一个爬虫实例 var c = new Crawler({ maxConnections: 10, // This will be called for each crawled page callback: function (error, res, done) { if (error) { console.log(error); } else { var $ = res.$; // $ is Cheerio by default //a lean implementation of core jQuery designed specifically for the server // console.log(JSON.parse(res.body)); // 所有的英雄，这是一个包含了很多对象的数组 // 所有的英雄 都要去获取他的头像和技能 // 所以要遍历出每一个英雄的ename,凭借一个详情页路径重新发请求 JSON.parse(res.body).forEach((v) => { // console.log(`https://pvp.qq.com/web201605/herodetail/${v.ename}.shtml`); // Queue just one URL, with default callback xq.queue(`https://pvp.qq.com/web201605/herodetail/${v.ename}.shtml`); }); } done(); }, }); // 声明一个全局遍历heros数组，用来存放所有的英雄的 let heros = []; // Queue just one URL, with default callback c.queue("https://pvp.qq.com/web201605/js/herolist.json"); // 创建一个请求详情的爬虫实例 var xq = new Crawler({ maxConnections: 10, // This will be called for each crawled page callback: function (error, res, done) { if (error) { console.log(error); } else { var $ = res.$; // $ is Cheerio by default //a lean implementation of core jQuery designed specifically for the server // 英雄名字 英雄技能 英雄头像 // console.log($(".cover-name").text(), $(".skill-name>b").first().text()); // console.log("https:" + $(".ico-play").prev("img").attr("src")); // 把获取到的英雄名字 英雄技能 英雄头像都添加到这个数组中 heros.push({ heroName: $(".cover-name").text(), heroSkill: $(".skill-name>b").first().text(), heroIcon: "https:" + $(".ico-play").prev("img").attr("src"), isDelete: false, }); } done(); }, }); // 要等待所有的请求全部做完之后，才入库 xq.on("drain", function () { // For example, release a connection to database. // 调用API：添加数据 heroModel.insert(heros, (err, results) => { console.log(err); console.log(results); if (!err) console.log("增加成功"); }); });入库
用到以下第三方库
就是用来操作MySQL的
// 2. 入库：用mysql-ithm插件把爬到的数据装进数据库中 //1.导入模块 const hm = require("mysql-ithm"); //2.连接数据库 //如果数据库存在则连接，不存在则会自动创建数据库 hm.connect({ host: "localhost", //数据库地址 port: "3306", user: "root", //用户名，没有可不填 password: "lijiazhao123", //密码，没有可不填 database: "wzry", //数据库名称 }); //3.创建Model(表格模型：负责增删改查) //如果table表格存在则连接，不存在则自动创建 let heroModel = hm.model("hero", { heroName: String, heroSkill: String, heroIcon: String, isDelete: String, });以上是“Nodejs怎么操作数据库”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注亿速云行业资讯频道！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
