Node.js连接mysql

一、安装Node.js mysql驱动库

　　Node.js里面没有mysql模块的，我们需要安装mysql模块。我们可以使用npm(Node package manager)进行安装。这里使用到的版本为："2.0.0-rc2。安装步骤如下：

　　1、打开cmd输入命令：npm install -g mysql 回车，下载完成之后效果图如下：

　　mysql下载的目录为C:UsersuserAppDataRoaming pm ode_modules。

　　2、将C:UsersuserAppDataRoaming pm ode_modules目录下的mysql目录拷贝到D:Program Files odejs ode_modules pm ode_modules这个目录下。D:Program Files为Nodejs的安装目录。这样就安装完成。

二、编写连接mysql代码

　　1、在D盘新建文本文件重命名为，testmysql.js。内容如下：

var mysql = require('mysql');
var TEST_DATABASE = 'nodejs_mysql_test';//数据库名
var TEST_TABLE = 'user';//表名
var client = mysql.createConnection({  
    host : 'localhost',  
    user : 'root',  
    password : '123456'
}); 

//创建数据库
client.query('create database '+TEST_DATABASE, function(err) {
  if (err && err.number != mysql.ERROR_DB_CREATE_EXISTS) {
    throw err;
  }
});

client.query('USE '+TEST_DATABASE);//使用该数据库

//创建表
client.query(
  'CREATE TABLE '+TEST_TABLE+
  '(id INT(11) AUTO_INCREMENT, '+
  'username VARCHAR(255), '+
  'password VARCHAR(255), '+
  'created DATETIME, '+
  'PRIMARY KEY (id))'
);


 //查询数据   
var query = client.query('select * from  '+TEST_TABLE+' where id = ?', [2],function(err, results){ //查询id为2的数据
    console.log(results[0].id);//返回记录id
        console.log(results[0].username);//返回记录id
            console.log(results[0].password);//返回记录id
                console.log(results[0].created);//返回记录id
  }
); 

 //添加数据
var query = client.query('INSERT INTO '+TEST_TABLE+' SET username = ?, password = ?, created = ?',
  ['zhangsan', '1234', '2010-08-16 12:42:15'],function(err, results){
    console.log(results.insertId);//返回记录id
  }
);


//修改数据
client.query("update user set password = ? where id = ?", [ "123456", 1 ], function(err, results) {//修改id为1的记录的password
  console.log(results);  
  /** result 为格式如下的信息
      {   fieldCount: 0,
          affectedRows: 1,
          insertId: 0,
          serverStatus: 2,
          warningCount: 0,
          message: '(Rows matched: 1  Changed: 1  Warnings: 0',
          protocol41: true,
          changedRows: 1 
      }
   */
}); 

//删除数据
client.query("delete from user where id = ?", [ 1 ], function(err, results) {//删除id为1的记录
  console.log(results);  
  /** result 为格式如下的信息
      {
          fieldCount: 0,
          affectedRows: 1,
          insertId: 0,
          serverStatus: 2,
          warningCount: 0,
          message: '',
          protocol41: true,
          changedRows: 0 
      }
  */
});

client.end();//关闭连接

　　cmd进入D盘 运行命令 node testmysql.js 回车即可运行。