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_testSET 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:Usermyappejs4>npm install mysqlmysql@2.5.4 node_modulesmysql├── 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 %s %s", results[i].id, results[i].name, results[i].age）; } } client.end（）; }）;3、运行结果D:Usermyappejs4>node mysqltest.js1 admin 322 dans88 453 张三 354 ABCDEF 885 李小二 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];//增 addconnection.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:Usermyappejs4>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];//改 upconnection.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:Usermyappejs4>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";//查 queryconnection.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:Usermyappejs4>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:Usermyappejs4>node mysqltest_del.js-------------DELETE--------------DELETE affectedRows 1&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&增、删、改、查操作应会部完成了！下面关于Node.js的内容你可能也喜欢：在 Ubuntu 14.04/15.04 上安装配置 Node.js v4.0.0 http://www.linuxidc.com/Linux/2015-10/123951.htm如何在CentOS 7安装Node.js http://www.linuxidc.com/Linux/2015-02/113554.htmUbuntu 14.04下搭建Node.js开发环境 http://www.linuxidc.com/Linux/2014-12/110983.htmUbunru 12.04 下Node.js开发环境的安装配置 http://www.linuxidc.com/Linux/2014-05/101418.htmNode.Js入门[PDF+相关代码] http://www.linuxidc.com/Linux/2013-06/85462.htmNode.js开发指南高清PDF中文版 +源码 http://www.linuxidc.com/Linux/2014-09/106494.htmNode.js入门开发指南中文版 http://www.linuxidc.com/Linux/2012-11/73363.htmUbuntu 编译安装Node.js http://www.linuxidc.com/Linux/2013-10/91321.htmUbuntu 16.04 64位搭建 Node.js NodeJS 环境 http://www.linuxidc.com/Linux/2016-09/135487.htmNode.js 的详细介绍：请点这里
Node.js 的下载地址：请点这里本文永久更新链接地址