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实现数据库的增删改查的详细内容。