上篇文章介绍了node.js操作redis的简单实例,这里介绍如何操作mysql。
安装
安装mysql模块
cnpm install mysql
一个例子
新建一个mysql.js的文件,代码如下:
连接配置
创建数据表
SET FOREIGN_KEY_CHECKS=0;-- ------------------------------ Table structure for users-- ----------------------------DROP TABLE IF EXISTS `users`;CREATE TABLE `users` ( `Id` int(11) NOT NULL AUTO_INCREMENT, `CreateTime` datetime NOT NULL, `Header` varchar(255) DEFAULT NULL, `NickName` varchar(255) DEFAULT NULL, `Sex` int(11) NOT NULL, PRIMARY KEY (`Id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;
//引入mysql模块var mysql = require("mysql");//创建连接var connection = mysql.createConnection({ host: "localhost", port: "3306", user: "root", password: "abcd", database: "it_odd_o",});//开始连接connection.connect(function (err) { if (err) { console.log("[connect] - " + err); return; } else { console.log("connection connect successed!"); };});//执行sql语句connection.query("select 1+1 as result", function (err, rows, fields) { if (err) { console.log("[query] - " + err); } else { console.log("result is " + rows[0].result); };});//向user表中插入数据var userAddSql = "insert into users(createTime,header,nickName,sex) value(now(),?,?,1);";var userAddSql_params = ["1.jpg", "wolfy"];//执行sql语句connection.query(userAddSql, userAddSql_params, function (err, result) { if (err) { console.log("[insert] - " + err); } else { console.log(result); };});//断开连接connection.end();
改
//改var userUpdateSql="update users set header=? where id=?;";var userUpdateSql_params=["2.jpg",2];connection.query(userUpdateSql, userUpdateSql_params, function (err, result) { if (err) { console.log("[update] - " + err); } else { console.log(result); };});
通过上面的例子我们看到起主要作用还是sql语句以及参数化查询,其他的跟sql语句相似。不再一一举例。
新闻热点
疑难解答