Nodejs连接mysql并实现增、删、改、查操作的方法详解
更新时间：2018年01月04日 11:57:32 作者：浪友dans
这篇文章主要介绍了Nodejs连接mysql并实现增、删、改、查操作的方法,结合实例形式详细分析了nodejs针对mysql数据库的的连接、mysql数据库的创建及nodejs针对mysql增删改查等相关操作具体实现技巧,需要的朋友可以参考下
本文实例讲述了Nodejs连接mysql并实现增、删、改、查操作的方法。分享给大家供大家参考，具体如下：
一、准备
nodejs的教程，大多以操作mongodb为示例。但是mongodb有一些局限性，具体官网上有说。我打算用MySQL，因为多少还有点使用经验。先以研究为主。node-mysql，是目前最火的node下的mysql驱动。初步了用了一下，因为异步回调的这种方式，果然好多坑。
下面这个项目的package name是 mysql，版本是mysql@ 2.5.4
先说明下面的所示代码，均已以下代码开头，后面不在说明
var connection = mysql.createConnection({
host : '127.0.0.1',
user : 'root',
password : 'root123',
port: '3306',
database: 'my_news_test',
});
代码什么意思很直白，如果想深入，可以去上面的官网查。像host，user之类的配置，写过MySQL数据库应用程序的，应该都很清楚，请自行修改相应参数。后面的代码，假定数据库”my_news_test”中有一个叫node_use的表，表有3个属性
id: 自增主键
name：名字，有unique的限制
age：年龄
测试MySQL MySQL版本：5.5
二、建库并插入5条记录
Source Database : my_news_test
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for node_user
-- ----------------------------
DROP TABLE IF EXISTS `node_user`;
CREATE TABLE `node_user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(30) DEFAULT NULL,
`age` int(8) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of node_user
-- ----------------------------
INSERT INTO `node_user` VALUES ('1', 'admin', '32');
INSERT INTO `node_user` VALUES ('2', 'dans88', '45');
INSERT INTO `node_user` VALUES ('3', '张三', '35');
INSERT INTO `node_user` VALUES ('4', 'ABCDEF', '88');
INSERT INTO `node_user` VALUES ('5', '李小二', '65');
三、先测试一下环境
1、 首先需要安装nodejs 的mysql包
D:\User\myappejs4>npm install mysql mysql@2.5.4 node_modules\mysql ├── require-all@0.0.8 ├── bignumber.js@1.4.1 └── readable-stream@1.1.13 (inherits@2.0.1, string_decoder@0.10.31, isarray@0 .0.1, core-util-is@1.0.1)
2、编写nodejs与mysql交互的代码
//mysql.js
//首先需要安装nodejs 的mysql包
//npm install mysql
//编写nodejs与mysql交互的代码
var mysql = require('mysql');
var TEST_DATABASE = 'my_news_test';
var TEST_TABLE = 'node_user';
//创建连接
var client = mysql.createConnection({
user: 'root',
password: 'root123',
});
client.connect();
client.query("use " + TEST_DATABASE);
client.query(
'SELECT * FROM '+TEST_TABLE,
function selectCb(err, results, fields) {
if (err) {
throw err;
}
if(results)
{
for(var i = 0; i < results.length; i++)
{
console.log("%d\t%s\t%s", results[i].id, results[i].name, results[i].age);
}
}
client.end();
}
);
3、运行结果
D:\User\myappejs4>node mysqltest.js 1 admin 32 2 dans88 45 3 张三 35 4 ABCDEF 88 5 李小二 65
四、Node.js结合MySQL的增、删、改、查操作
1、增
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '127.0.0.1',
user : 'root',
password : 'root123',
port: '3306',
database: 'my_news_test',
});
connection.connect();
var userAddSql = 'INSERT INTO node_user(id,name,age) VALUES(0,?,?)';
var userAddSql_Params = ['Wilson', 55];
//增 add
connection.query(userAddSql,userAddSql_Params,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);
console.log('#######################');
});
connection.end();
运行如下
D:\User\myappejs4>node mysqltestadd.js
-------INSERT----------
INSERT ID: { fieldCount: 0,
affectedRows: 1,
insertId: 6,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0 }
#######################
2、改
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '127.0.0.1',
user : 'root',
password : 'root123',
port: '3306',
database: 'my_news_test',
});
connection.connect();
var userModSql = 'UPDATE node_user SET name = ?,age = ? WHERE id = ?';
var userModSql_Params = ['Hello World',99,7];
//改 up
connection.query(userModSql,userModSql_Params,function (err, result) {
if(err){
console.log('[UPDATE ERROR] - ',err.message);
return;
}
console.log('----------UPDATE-------------');
console.log('UPDATE affectedRows',result.affectedRows);
console.log('******************************');
});
connection.end();
运行结果如下
D:\User\myappejs4>node mysqltest_up.js ----------UPDATE------------- UPDATE affectedRows 1 ******************************
3、查操作
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '127.0.0.1',
user : 'root',
password : 'root123',
port: '3306',
database: 'my_news_test',
});
connection.connect();
var userGetSql = 'SELECT * FROM node_user';
//查 query
connection.query(userGetSql,function (err, result) {
if(err){
console.log('[SELECT ERROR] - ',err.message);
return;
}
console.log('---------------SELECT----------------');
console.log(result);
console.log('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$');
});
connection.end();
运行的结果如下
D:\User\myappejs4>node mysqltest_query.js
---------------SELECT----------------
[ { id: 1, name: 'admin', age: 32 },
{ id: 2, name: 'dans88', age: 45 },
{ id: 3, name: '张三', age: 35 },
{ id: 4, name: 'ABCDEF', age: 88 },
{ id: 5, name: '李小二', age: 65 },
{ id: 6, name: 'Wilson', age: 55 } ]
$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$
4、删除操作
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '127.0.0.1',
user : 'root',
password : 'root123',
port: '3306',
database: 'my_news_test',
});
connection.connect();
var userDelSql = 'DELETE FROM node_user WHERE id = 7';
//ɾ
connection.query(userDelSql,function (err, result) {
if(err){
console.log('[DELETE ERROR] - ',err.message);
return;
}
console.log('-------------DELETE--------------');
console.log('DELETE affectedRows',result.affectedRows);
console.log('&&&&&&&&&&&&&&&&&');
});
connection.end();
运行的结果如下
D:\User\myappejs4>node mysqltest_del.js
-------------DELETE--------------
DELETE affectedRows 1
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&
增、删、改、查操作应会部完成了！
希望本文所述对大家nodejs程序设计有所帮助。
您可能感兴趣的文章:
- 使用nodejs连接mySQL写接口全过程(增删改查)
- nodejs+mysql实现用户相关的增删改查的详细操作
- 三分钟教会你用nodejs操作mysql数据库
- Nodejs 连接 mysql时报Error: Cannot enqueue Query after fatal error错误的处理办法
- NodeJs操作MYSQL方法详细介绍
- nodejs中关于mysql数据库的操作
- Nodejs中koa2连接mysql的实现示例
- NodeJs+MySQL实现注册登录功能
- nodejs连接mysql数据库及基本知识点详解
- nodejs实现的连接MySQL数据库功能示例
- NodeJS连接MySQL数据库并进行增删改查操作详解
相关文章
这篇文章主要介绍了nodejs的请求路由概述,需要的朋友可以参考下2014-07-07
npm run dev和npm run serve的区别小结
npm run serve和npm run dev是在开发阶段使用npm运行脚本的两种常见命令,本文就来介绍一下这两者的区别,具有一定的参考价值,感兴趣的可以了解一下2024-03-03
Multer是Node.js中的一个第三方包,或者说是第三方中间件,主要用于是实现文件上传的功能,本文小编讲给大家详细介绍一下基于Express+multer来实现文件上传功能,文章通过代码示例和图文介绍的非常详细,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了Node.js中使用事件发射器模式实现事件绑定详解,本文一并讲解了回调模式、发射器模式、事件类型等基础知识做了补充,需要的朋友可以参考下2014-08-08
Node.js发送HTTP客户端请求并显示响应结果的方法示例
这篇文章主要介绍了Node.js发送HTTP客户端请求并显示响应结果的方法,结合完整实例形式分析了nodejs发送http请求及响应的相关操作技巧,需要的朋友可以参考下2017-04-04
这篇文章主要介绍了使用socket.io实现简单聊天室案例，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-01-01
这篇文章主要介绍了Node.js中使用计时器定时执行函数详解,本文使用了Node.js中的setTimeout和setInterval函数,需要的朋友可以参考下2014-08-08
这篇文章主要为大家展现了express结合nodejs开启服务的代码示例模版，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职加薪2022-04-04
这篇文章主要介绍了Node.js pipe实现源码解析，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-08-08
nodeJS最大的特点就是其异步操作，下面这篇文章主要给大家介绍了关于NodeJS如何实现同步的方法的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧2018-08-08
最新评论