安装

$ 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();