node.js连接数数据库及对数据库进行操作

为了安装速度快一些，可以使用淘宝定制的 cnpm (gzip 压缩支持) 命令行工具代替默认的 npm，之后就可以使用 cnpm 命令来安装模块了
（一）安装mysql驱动（cnpm install mysql）
(二)在工程下新建一个叫connect的javascript文件
文件编辑如下

var mysql      = require('mysql');
var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '123456',//mysql连接密码
    database : 'st_system'//数据库名字
});

connection.connect();

connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
    if (error) throw error;
    console.log('The solution is: ', results[0].solution);
});

在Webstorm中示例如下： （三）打开cmd运行connect文件，结果显示如下，数据库连接成功 （四）对数据库操作
（1）查询数据库

var mysql  = require('mysql');
var connection = mysql.createConnection({
    host     : 'localhost',//连接名
    user     : 'root',//用户名
    password : '123456',
    port: '3306',
    database: 'st_system'//数据库名
});
connection.connect();
var  sql = 'SELECT * FROM class_room';//表名
connection.query(sql,function (err, result) {
    if(err){
        console.log('[SELECT ERROR] - ',err.message);
        return;
    }
    console.log('--------------------------查询结果----------------------------');
    console.log(result);
    console.log('------------------------------------------------------------\n\n');
});

WebStorm中如图所示：

打开cmd运行connect.js,查询结果如下

向表中插入数据

var mysql  = require('mysql');
var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '123456',
    port: '3306',
    database: 'st_system'//数据库名
});
connection.connect();
var  addSql = 'INSERT INTO student(id,name,sex,room) VALUES(?,?,?,?)';//student是表名
var  addSqlParams = ['12', '李明','男', '501'];
connection.query(addSql,addSqlParams,function (err, result) {
    if(err){
        console.log('[INSERT ERROR] - ',err.message);
        return;
    }
    console.log('--------------------------插入----------------------------');
    console.log('INSERT ID:',result);
    console.log('-----------------------------------------------------------------\n\n');
});
connection.end();

cmd中运行connect.js文件，结果显示如下

添加成功后数据库表中可看到所添加的数据

删除表中数据

var mysql  = require('mysql');
var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '123456',
    port: '3306',
    database: 'st_system'
});
connection.connect();
var delSql = 'DELETE FROM class_room where idroom=102';
connection.query(delSql,function (err, result) {
    if(err){
        console.log('[DELETE ERROR] - ',err.message);
        return;
    }
    console.log('--------------------------删除----------------------------');
    console.log('DELETE affectedRows',result.affectedRows);
    console.log('-----------------------------------------------------------------\n\n');
});
connection.end();

cmd中显示如下

数据库删除前

数据库删除后

更改表中数据

var mysql  = require('mysql');  
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'st_system' 
}); 
connection.connect();
var modSql = 'UPDATE student  SET name =?WHERE Id = ?';//注意?和 //WHERE之间不能有逗号
var modSqlParams = ['王芳', '23'];
connection.query(modSql,modSqlParams,function (err, result) {
   if(err){
         console.log('[UPDATE ERROR] - ',err.message);
         return;
   }        
  console.log('--------------------------更改----------------------------');
  console.log('UPDATE affectedRows',result.affectedRows);
  console.log('-----------------------------------------------------------------\n\n');
});
connection.end();

更改后的数据库

以上完成了对数据库的增删改查操作，当然增删改操作可以在同一个文件中同时完成。