首页 > web前端 > 前端问答 > 讲解nodejs实现数据库的增删改查

讲解nodejs实现数据库的增删改查

PHPz
发布: 2023-04-05 10:14:43
原创
1887 人浏览过

Node.js(Node)是一个基于Chrome V8 引擎构建的JavaScript 运行时环境。它可以使JavaScript运行在服务器端,具有高效、轻量、跨平台等特点。目前,Node已经成为一个相当重要的后端开发语言。

本文旨在介绍如何使用Node.js实现数据库的增删改查,特别是操作关系型数据库。这里我们以MySQL为例进行讲解。

1. MySQL安装和导入数据

首先,我们需要安装MySQL数据库并创建一些测试数据。

在安装MySQL之后,需要登录到MySQL服务器,我们可以使用MySQL命令行工具或者图形化工具如phpMyAdmin,Navicat等。在命令行下使用以下命令,进入MySQL:

$ mysql -u root -p
登录后复制

它会提示输入密码,输入之后回车即可。

然后在MySQL命令行中执行以下命令,创建一个名为test的数据库和一个名为user的表:

mysql> create database test;
mysql> use test;
mysql> create table user(id int not null auto_increment, name varchar(255), age int, primary key (id));
mysql> insert into user(name, age) values('Tom', 18);
mysql> insert into user(name, age) values('Jack', 25);
mysql> insert into user(name, age) values('Lucy', 27);
登录后复制

这里我们创建了一个名为test的数据库,然后在该数据库中创建了一个名为user的表,并在表中插入了三条数据。

2. 安装MySQL模块

Node.js官方提供了mysql模块,可以方便地操作MySQL数据库。在使用mysql模块之前,需要安装它,使用以下命令安装:

$ npm install mysql --save
登录后复制

3. 连接数据库

连接MySQL数据库并进行操作之前,需要创建一个连接。

可以使用下面的方法连接到MySQL数据库:

var mysql = require('mysql');
var connection = mysql.createConnection({
    host: 'localhost', // 数据库IP地址
    user: 'root',      // 数据库用户名
    password: '123456',// 数据库密码
    database: 'test'   // 数据库名称
});

connection.connect(function(err) {
    if (err) {
        console.error('error: ' + err.stack);
        return;
    }

    console.log('connected as id ' + connection.threadId);
});

//断开连接
connection.end();
登录后复制

这里我们创建了一个connection对象,并传入了数据库连接参数。通过调用connection.connect()函数,我们可以尝试连接数据库。如果连接不上,会输出错误信息,否则会输出连接成功的消息。最后一行connection.end()是用来断开与数据库的连接。

接下来,我们来看看如何用Node.js实现常见的数据操作。

4. 插入数据

使用MySQL插入数据的方法是INSERT,在Node.js中使用mysql模块插入数据的方法是:

var insertSql = 'insert into user(name, age) values (?,?)';
var insertParams = ['Tom', 20];
connection.query(insertSql, insertParams, function(err, result) {
    if (err) {
        console.log('[INSERT ERROR] - ', err.message);
        return;
    }

    console.log('-------INSERT----------');
    console.log('INSERT ID:', result.insertId);
    console.log('INSERT ID:', result.affectedRows);
    console.log('#######################');
});
登录后复制

这里的?是语句占位符,后面的insertParams是插入的参数。在回调函数中,如果出错,则输出错误信息。如果插入成功,则可以从result.resultId中获取插入的数据的ID,从result.affectedRows中获取影响的行数。

5. 查询数据

查询MySQL数据的方法是SELECT,在Node.js中查询的示例代码如下:

var selectSql = 'SELECT * FROM user';
connection.query(selectSql, function(err, rows) {
    if (err) {
        console.log('[SELECT ERROR] - ', err.message);
        return;
    }

    console.log('-------SELECT----------');
    console.log(rows);
    console.log('#######################');
});
登录后复制

这里的*是通配符,表示返回所有列。rows是MySQL返回的查询结果,它是一个数组,包含了所有查询结果。可以使用循环遍历该数组来获取查询结果的详细信息。

6. 更新数据

在MySQL中更新数据的方法是UPDATE,在Node.js中使用mysql模块的代码如下:

var updateSql = 'UPDATE user SET age = ? WHERE name = ?';
var updateParams = [22, 'Tom'];
connection.query(updateSql, updateParams, function(err, result) {
    if (err) {
        console.log('[UPDATE ERROR] - ', err.message);
        return;
    }

    console.log('-------UPDATE----------');
    console.log('UPDATE affectedRows', result.affectedRows);
    console.log('#######################');
});
登录后复制

这里的字段名都需要用反引号包裹起来。

7. 删除数据

在MySQL中删除数据的方法是DELETE,在Node.js中使用的示例代码如下:

var deleteSql = 'DELETE FROM user WHERE name = ?';
var deleteParams = ['Tom'];
connection.query(deleteSql, deleteParams, function(err, result) {
    if (err) {
        console.log('[DELETE ERROR] - ', err.message);
        return;
    }

    console.log('-------DELETE----------');
    console.log('DELETE affectedRows', result.affectedRows);
    console.log('#######################');
});
登录后复制

总结

Node.js提供了非常方便的操作MySQL数据库的功能,相信本文对于想要学习Node.js的朋友们会有所帮助。实际应用中,需要结合自身的业务需求进行开发,仅供参考。

以上是讲解nodejs实现数据库的增删改查的详细内容。更多信息请关注PHP中文网其他相关文章!

来源:php.cn
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板