Node.js(Node)是一个基于Chrome V8 引擎构建的JavaScript 运行时环境。它可以使JavaScript运行在服务器端,具有高效、轻量、跨平台等特点。目前,Node已经成为一个相当重要的后端开发语言。
本文旨在介绍如何使用Node.js实现数据库的增删改查,特别是操作关系型数据库。这里我们以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的表,并在表中插入了三条数据。
Node.js官方提供了mysql模块,可以方便地操作MySQL数据库。在使用mysql模块之前,需要安装它,使用以下命令安装:
$ npm install mysql --save
连接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实现常见的数据操作。
使用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中获取影响的行数。
查询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返回的查询结果,它是一个数组,包含了所有查询结果。可以使用循环遍历该数组来获取查询结果的详细信息。
在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('#######################'); });
这里的字段名都需要用反引号包裹起来。
在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中文网其他相关文章!