[TOC]
# 安装
`$ npm install mysql`
# 更新&修复
`$ npm install felixge/node-mysql`
# 引用
code
~~~
//引用
var mysql = require('mysql');
~~~
# 建立连接
code
~~~
//创建连接
var connection = mysql.createConnection({
host: 'localhost', //主机名称
user: 'root', //用户名
password: 'root', //密码
database: 'xj2014' //数据库
});
~~~
# 操作数据
code
~~~
//执行操作
connection.query('SELECT * from userinfo limit 0,1', function(err, rows, fields) {
console.log(err);
console.info(rows);
console.log(fields);
});
~~~
# 完整示例
~~~
//引用
var mysql = require('mysql');
//创建连接
var connection = mysql.createConnection({
host: 'localhost', //主机名称
user: 'root', //用户名
password: 'root', //密码
database: 'xj2014' //数据库
});
//连接
connection.connect();
//执行操作
connection.query('SELECT * from userinfo limit 0,1', function(err, rows, fields) {
console.log(err);
console.info(rows);
console.log(fields);
});
//关闭连接
connection.end();
~~~
# 高级部分
## 查询
带参数查询
~~~
//引用
var mysql = require('mysql');
//创建连接
var connection = mysql.createConnection({
host: 'localhost', //主机名称
user: 'root', //用户名
password: 'root', //密码
database: 'xj2014' //数据库
});
//连接
connection.connect();
//执行操作
connection.query('SELECT * from userinfo where name=?', ["小银银"], function(err, rows) {
if (err == null) {
console.info(rows);
} else {
console.log("error info:" + err);
}
});
//关闭连接
connection.end();
~~~
## 其他操作
修改 ,删除 ,添加 第二个参数会包含相关的操作信息
~~~
//引用
var mysql = require('mysql');
//创建连接
var connection = mysql.createConnection({
host: 'localhost', //主机名称
user: 'root', //用户名
password: 'root', //密码
database: 'xj2014' //数据库
});
//连接
connection.connect();
//执行操作
connection.query('update userinfo set name=? where id=93', ["小银银"], function(err, rows) {
if (err == null) {
console.info(rows); //包含相关信息
} else {
console.log("error info:" + err);
}
});
//关闭连接
connection.end();
~~~
结果:
> D:\ZW\xj2014\教案\data>node mysql.js
> OkPacket {
> fieldCount: 0,
> affectedRows: 1,
> insertId: 0,
> serverStatus: 2,
> warningCount: 0,
> message: '(Rows matched: 1 Changed: 1 Warnings: 0',
> protocol41: true,
> changedRows: 1 }
> D:\ZW\xj2014\教案\data>