node.js操作mysql简单实例

上篇文章介绍了node.js操作redis的简单实例，这里介绍如何操作mysql。

安装

安装mysql模块

cnpm install mysql

一个例子

新建一个mysql.js的文件，代码如下：

连接配置

1.host：主机地址 （默认：localhost）
2.user：用户名
3.password：密码
4.port：端口号 （默认：3306）
5.database：数据库名
6.charset：连接字符集（默认：'utf8_general_ci'，注意字符集的字母都要大写）
7.localaddress：此ip用于tcp连接（可选）
8.socketpath：连接到unix域路径，当使用 host 和 port 时会被忽略
9.timezone：时区（默认：'local'）
10.connecttimeout：连接超时（默认：不限制；单位：毫秒）
11.stringifyobjects：是否序列化对象（默认：'false' ；与安全相关https://github.com/felixge/node-mysql/issues/501）
12.typecast：是否将列值转化为本地javascript类型值 （默认：true）
13.queryformat：自定义query语句格式化方法 https://github.com/felixge/node-mysql#custom-format
14.supportbignumbers：数据库支持bigint或decimal类型列时，需要设此option为true （默认：false）
15.bignumberstrings：supportbignumbers和bignumberstrings启用 强制bigint或decimal列以javascript字符串类型返回（默认：false）
16.datestrings：强制timestamp,datetime,data类型以字符串类型返回，而不是javascript date类型（默认：false）
17.debug：开启调试（默认：false）
18.multiplestatements：是否许一个query中有多个mysql语句 （默认：false）
19.flags：用于修改连接标志，更多详情：https://github.com/felixge/node-mysql#connection-flags
20.ssl：使用ssl参数（与crypto.createcredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只捆绑amazon rds的配置文件

创建数据表

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语句相似。不再一一举例。