0

0

聊聊node怎么操作MySQL数据库(增删改查)

青灯夜游

青灯夜游

发布时间:2023-02-28 19:52:02

|

2437人浏览过

|

来源于掘金社区

转载

node怎么操作mysql数据库?下面本篇文章带大家了解一下node项目中mysql数据库增删改查的方法,希望对大家有所帮助!

聊聊node怎么操作MySQL数据库(增删改查)

下载安装mysql,检查是否安装成功


image.png

net start mysql
  • 启动mysql
  • 可在桌面右键我的电脑进入计算机管理查看mysql是否已经成功运行 【相关教程推荐:nodejs视频教程

image.png

下载安装navicat


功能:为我们提供连接、操作mysql数据库的功能

下载

www.navicat.com.cn/products#na…

安装

双击,一路next

使用

找到应用程序,点击启动

image.png

如果 连接测试通过,接下来就可以点击确定按钮,正式连入mysql了。image.png

连入后的效果如下:

image.png

数据库简介


什么是数据库

英文: database 保存和管理数据的仓库就是数据库。

什么是数据? 文件,图片,视频,订单,用户名,密码等等。

这些数据都需要有专门的地方来保存和管理。

在我们没有学习数据库技术之前,我们使用的数据都是以文件系统(db.json)的方式保存的。我们需要一个专门的软件来管理我们的数据, 这就是数据库。

image.png

两大阵营-数据库分类

  • 关系型数据库,代表产品:

    • MySQL
    • Oracle
    • Sql server
    • DB2
  • 非关系型数据库

    • redis 键值存储数据库
    • HBaise列存储数据库
    • mongodb 面向文档数据库
    • neo4j 图形数据库
    • Elasticsearch 搜索引擎存储

参考:数据库使用排名 db-engines.com/en/ranking

image.png

理解关系型数据库

在关系型数据库中,存在三级关系:

  • 数据库
  • 数据表
  • 字段

类比excel

image.png

  • 每一列都是一类数据 --- 字段
  • 每一行代表一条数据 --- 记录
数据库 excel文件
数据库 excel文件
数据表 excel文件中的某一个sheet
表结构:字段 sheet中的表头:列

MySQL简介

image.pngMySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,目前属于 Oracle 旗下产品 。MySQL所使用的 SQL 语言是用于访问数据库的最常用标准化语言。

  • 体积小、速度快、总体拥有成本低,一般中小型网站的开发都选择 MySQL 作为网站数据库。
  • 搭配 PHPApache 可组成良好的开发环境。

3p技术:php,asp,jsp

操作数据库-用navicat


新建数据库

image.png

在弹出的窗口中填写数据库名即可。

image.png点击确定之后,会在左侧的数据库列中看到上面创建成功的数据库。

新建数据表

image.png

点击 "新建表", 然后在开始设置字段

image.png

主键: 作用是区别一条数据和其它数据。(它相当于人的身份证号)

设置字段完成之后,点击上图左上角所示的保存按钮,就会进一步弹出对话框,让填写表的名字。

我们填入user

image.png

编辑字段

image.png

添加数据

image.png

一条内容输入完成后,按下tab,会自动进入下一条记录的输入

学习使用SQL语句


结构化查询语言(Structured Query Language)简称SQL,用来操作关系型数据库:

喵记多
喵记多

喵记多 - 自带助理的 AI 笔记

下载
  • 是一种数据库查询和程序设计语言,用来存取数据以及查询、更新、和管理关系型数据库。
  • .sql是数据库脚本文件的扩展名。

最常用的用于数据操作的sql语句有四类,分别对应对数据的四种操作:

  • 增(create)(例如:用户注册)
  • 删(delete) (例如:删除订单)
  • 改(update) (例如:修改密码)
  • 查(select , read) (例如:信息搜索)

在navicat中运行sql - 添加数据


打开sql编辑区

image.png

然后:

image.png

学习 sql中的insert into 命令

格式:

 insert into 表名(字段名1,字段名2,....)  values (值1,值2,....)

注意:

  • 字段的顺序要和值的顺序是完全匹配的

  • 字段列表可以不与真实数据表中的字段完全相等,

    • 可以省略一些不必要的字段
    • 顺序与不需要与定义表时的顺序一致
  • 如果是字符串类型的字段,其值要加"",如果是数值类型的字符串,其值不需要加“”

示例:

insert into stu (sex, weight, name) values ('男', 60, '庞凯')

sql-delete语句-删除数据


格式

 delete  from 表名  where 删除条件复制代码

注意:不指定条件将删除所有数据

示例

-- 删除id为14的同学
delete from stu where id=14

-- 删除的时候,不加条件,将删除stu表中的全部记录
delete from stu

sql-update语句-修改数据


格式

update 表名 set 字段1=值1, 字段2=值2,...  where 修改条件

注意:

- 要修改的值使用键值对来表示 
- 多个字段用,分隔
- 不指定条件,将修改当前表中全部的记录

示例

-- 修改id为1的同学的年龄为53
update stu set age=53 where id = 1

-- 修改id为1的同学的年龄为35,身高为160
update stu set age=35,height=160 where id = 1

-- 如果修改的时候,不加条件,则会修改全部的数据
update stu set weight = 60

sql-select-语句-数据查询


作用

把数据从数据库查出来

格式

SELECT  字段名1, 字段名2, .....  FROM 表名  WHERE <条件表达式>

示例

# 查询部分字段SELECT id,name,age FROM stu
# 查询所有字段SELECT * FROM stu
# 带条件的查询SELECT * FROM 表名 WHERE 条件1 and 条件2

where子句


select field1, field2... from 表名 查询表中的所有数据

where 可以使用条件来筛选查询出的结果

-- 查询所有的学生
select * from stu

-- 查询所有学生的id,name,height
select id,name,height from stu

-- 带条件的查询
select * from stu where 条件

-- 查询所有的男同学
select * from stu where sex='男'

-- 查询id为2的男同学
select * from stu where id=2

-- 查询年龄大于50的同学
select * from stu where age > 50

-- 查询年龄大于50岁的男同学
select * from stu where age>50 and sex='男'

-- 查询年龄在30~60之间的同学,包括30和60
select * from stu where age>=30 and age<=60
select * from stu where age between 30 and 60

node.js操作mysql


通过mysql这个包来操作mysql数据库。

安装包

mysql模块是一个第三方模块,专门用来操作MySQL数据库。

# 安装
npm i mysql

参考:www.npmjs.com/package/mys…

使用步骤

要想用这个包连接数据库,首先要确保在电脑有mysql(phpstudy 还要启动mysql服务)

一共需要4个步骤:

  • 加载 MySQL 模块

  • 创建 MySQL 连接对象

  • 连接 MySQL 服务器

  • 执行SQL语句

var mysql = require('mysql');

var connection = mysql.createConnection({
  host     : 'localhost',   // 你要连接的数据库服务器的地址
  port     : 3306,// 端口号
  user     : 'root',        // 连接数据库服务器需要的用户名
  password : 'root',        // 连接数据库服务器需要的密码
  database : 'gz61'      //你要连接的数据库的名字
});

connection.connect((err) => {
  // 如果有错误对象,表示连接失败
  if (err) return console.log('数据库连接失败')
  // 没有错误对象提示连接成功
  console.log('mysql数据库连接成功')
});

参考地址: www.npmjs.com/package/mys…

node操作mysql-查询操作


执行查询类型的SQL语句,查询结果(result)是一个数组,每个单元是对象,对象的属性是数据表的字段名。

// 1. 加载mysql
const mysql = require('mysql');
// 2. 创建连接对象
const conn = mysql.createConnection({
    // 对象的属性名字不能改变
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'root',
    database: 'gz61'
});
// 3. 连接到MySQL服务器
connection.connect((err) => {
  // 如果有错误对象,表示连接失败
  if (err) return console.log('数据库连接失败')
  // 没有错误对象提示连接成功
  console.log('mysql数据库连接成功')
});
// 4. 执行SQL语句
let sql = 'select id,name,age from stu';
connection.query(sql, (err, result, fields) => {
    if (err) throw err; // throw err 相当于 return console.log(err);
    console.log(result); // result就是查询结果
});

node操作mysql-添加操作


执行添加类型的SQL语句,查询结果(result)是一个对象,该对象中有两个属性要关注:

  • affectedRows: 受影响行数
  • insertID: 查询数据的主键值
// 1. 加载mysql
const mysql = require('mysql');
// 2. 创建连接对象
const conn = mysql.createConnection({
    // 对象的属性名字不能改变
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'root',
    database: 'gz61'
});
// 3. 连接到MySQL服务器
connection.connect((err) => {
  // 如果有错误对象,表示连接失败
  if (err) return console.log('数据库连接失败')
  // 没有错误对象提示连接成功
  console.log('mysql数据库连接成功')
});

let sql = 'insert into users (name,password) values("小王","snv")'
connection.query(sql, (err, result) => {
    if (result.affectedRows > 0) {
        console.log('添加成功,新数据的id为:' + result.insertId);
    } else {
        console.log('添加失败');
    }
});

node操作mysql-修改操作


执行修改类型的SQL语句,查询结果(result)是一个对象,该对象中有 affectedRows 属性,表示本次修改操作影响到的行数。

// 1. 加载mysql
const mysql = require('mysql');
// 2. 创建连接对象
const conn = mysql.createConnection({
    // 对象的属性名字不能改变
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'root',
    database: 'gz61'
});
// 3. 连接到MySQL服务器
connection.connect((err) => {
  // 如果有错误对象,表示连接失败
  if (err) return console.log('数据库连接失败')
  // 没有错误对象提示连接成功
  console.log('mysql数据库连接成功')
});
// 更新
// update stu set 字段=值,字段=值 where id=11
let sql = 'update users set password="123" where name="小王"';

conn.query(sql, (err, result) => {
    if (err) throw err;
    if (result.affectedRows > 0) {
        console.log('修改成功');
    } else {
        console.log('修改失败');
    }
})

node操作mysql-删除操作


执行删除类型的SQL语句,查询结果(result)是一个对象,该对象中有 affectedRows 属性

// 1. 加载mysql
const mysql = require('mysql');
// 2. 创建连接对象
const conn = mysql.createConnection({
    // 对象的属性名字不能改变
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'root',
    database: 'gz61'
});
// 3. 连接到MySQL服务器
connection.connect((err) => {
  // 如果有错误对象,表示连接失败
  if (err) return console.log('数据库连接失败')
  // 没有错误对象提示连接成功
  console.log('mysql数据库连接成功')
});
// 删除
let sql = 'delete from stu where id=1';

connection.query(sql,(err, result) => {
    if (err) throw err;
    if (result.affectedRows > 0) {
        console.log('删除成功');
    } else {
        console.log('删除失败');
    }
});

了解一下软删除


做删除 : delete from 表名 条件 会把数据直接从数据库中删除掉!

思路:

  • 不是真的删除,而是设置一个特殊的字段表示当前的状态:正常还是已经删除

image.png

# 目标:把id=16的软删除掉
update stu set isDelete=1 where id=16

模块化封装


分析上面几个单独的功能点,它们基本的语法格式是一致的,只是要执行的sql语句不同而已,所以,我们可以对它们进行一个简单的封装。然后再写测试文件对其进行测试。

涉及两个文件:

  • sql.js
  • sqltest.js

封装模块

模块名:sql.js

// 由于四项(insert,delete,update,select)操作只是sql语句不同

// 1. 加载mysql
const mysql = require('mysql');
// 2. 创建连接对象
const conn = mysql.createConnection({
    // 对象的属性名字不能改变
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'root',
    database: 'gz61'
});
// 3. 连接到MySQL服务器
connection.connect((err) => {
  // 如果有错误对象,表示连接失败
  if (err) return console.log('数据库连接失败')
  // 没有错误对象提示连接成功
  console.log('mysql数据库连接成功')
});

module.exports = connection

测试

sqltest.js

const conn = require('./sql');

conn.query('select * from users where username="小美1" and userpassword="666"', (err, data) => {
  console.log(err);
  console.log(data);
  if (data.length > 0) {
    console.log('用户名密码Ok');
  } else {
    console.log('用户名密码error');
  }
});

更多node相关知识,请访问:nodejs 教程

相关专题

更多
Golang gRPC 服务开发与Protobuf实战
Golang gRPC 服务开发与Protobuf实战

本专题系统讲解 Golang 在 gRPC 服务开发中的完整实践,涵盖 Protobuf 定义与代码生成、gRPC 服务端与客户端实现、流式 RPC(Unary/Server/Client/Bidirectional)、错误处理、拦截器、中间件以及与 HTTP/REST 的对接方案。通过实际案例,帮助学习者掌握 使用 Go 构建高性能、强类型、可扩展的 RPC 服务体系,适用于微服务与内部系统通信场景。

8

2026.01.15

公务员递补名单公布时间 公务员递补要求
公务员递补名单公布时间 公务员递补要求

公务员递补名单公布时间不固定,通常在面试前,由招录单位(如国家知识产权局、海关等)发布,依据是原入围考生放弃资格,会按笔试成绩从高到低递补,递补考生需按公告要求限时确认并提交材料,及时参加面试/体检等后续环节。要求核心是按招录单位公告及时响应、提交材料(确认书、资格复审材料)并准时参加面试。

44

2026.01.15

公务员调剂条件 2026调剂公告时间
公务员调剂条件 2026调剂公告时间

(一)符合拟调剂职位所要求的资格条件。 (二)公共科目笔试成绩同时达到拟调剂职位和原报考职位的合格分数线,且考试类别相同。 拟调剂职位设置了专业科目笔试条件的,专业科目笔试成绩还须同时达到合格分数线,且考试类别相同。 (三)未进入原报考职位面试人员名单。

58

2026.01.15

国考成绩查询入口 国考分数公布时间2026
国考成绩查询入口 国考分数公布时间2026

笔试成绩查询入口已开通,考生可登录国家公务员局中央机关及其直属机构2026年度考试录用公务员专题网站http://bm.scs.gov.cn/pp/gkweb/core/web/ui/business/examResult/written_result.html,查询笔试成绩和合格分数线,点击“笔试成绩查询”按钮,凭借身份证及准考证进行查询。

11

2026.01.15

Java 桌面应用开发(JavaFX 实战)
Java 桌面应用开发(JavaFX 实战)

本专题系统讲解 Java 在桌面应用开发领域的实战应用,重点围绕 JavaFX 框架,涵盖界面布局、控件使用、事件处理、FXML、样式美化(CSS)、多线程与UI响应优化,以及桌面应用的打包与发布。通过完整示例项目,帮助学习者掌握 使用 Java 构建现代化、跨平台桌面应用程序的核心能力。

65

2026.01.14

php与html混编教程大全
php与html混编教程大全

本专题整合了php和html混编相关教程,阅读专题下面的文章了解更多详细内容。

36

2026.01.13

PHP 高性能
PHP 高性能

本专题整合了PHP高性能相关教程大全,阅读专题下面的文章了解更多详细内容。

75

2026.01.13

MySQL数据库报错常见问题及解决方法大全
MySQL数据库报错常见问题及解决方法大全

本专题整合了MySQL数据库报错常见问题及解决方法,阅读专题下面的文章了解更多详细内容。

21

2026.01.13

PHP 文件上传
PHP 文件上传

本专题整合了PHP实现文件上传相关教程,阅读专题下面的文章了解更多详细内容。

35

2026.01.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PostgreSQL 教程
PostgreSQL 教程

共48课时 | 7.2万人学习

Django 教程
Django 教程

共28课时 | 3.1万人学习

Excel 教程
Excel 教程

共162课时 | 11.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号