nodejs 操作mysql数据库（最新版本）

362 阅读 0 评论 239 点赞

我是靠谱客的博主高高雪糕，最近开发中收集的这篇文章主要介绍nodejs 操作mysql数据库（最新版本），觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

1、把Mysql Module装到NodeJS中：

$npm install Mysql

2、JS脚本 mysqlTest.js

// mysqlTest.js
//加载mysql Module
var Client = require(‘mysql').Client,
client = new Client(),
//要创建的数据库名
TEST_DATABASE = ‘nodejs_mysql_test',
//要创建的表名
TEST_TABLE = ‘test';
//用户名
client.user = ‘root';
//密码
client.password = ‘root';
//创建连接
client.connect();
client.query(‘CREATE DATABASE ‘+TEST_DATABASE, function(err) {
if (err && err.number != Client.ERROR_DB_CREATE_EXISTS) {
throw err;
}
});
// If no callback is provided, any errors will be emitted as `'error'`
// events by the client
client.query(‘USE ‘+TEST_DATABASE);
client.query(
‘CREATE TABLE ‘+TEST_TABLE+
‘(id INT(11) AUTO_INCREMENT, ‘+
‘title VARCHAR(255), ‘+
‘text TEXT, ‘+
‘created DATETIME, ‘+
‘PRIMARY KEY (id))'
);
client.query(
‘INSERT INTO ‘+TEST_TABLE+' ‘+
‘SET title = ?, text = ?, created = ?',
['super cool', 'this is a nice text', '2010-08-16 10:00:23']
);
var query = client.query(
‘INSERT INTO ‘+TEST_TABLE+' ‘+
‘SET title = ?, text = ?, created = ?',
['another entry', 'because 2 entries make a better test', '2010-08-16 12:42:15']
);
client.query(
‘SELECT * FROM ‘+TEST_TABLE,
function selectCb(err, results, fields) {
if (err) {
throw err;
}
console.log(results);
console.log(fields);
client.end();
}
);

3、执行脚本

node mysqlTest.js

效果如下:

注：对于老版本的mysql模块，上面的代码是可以运行的；如果npm最新的mysql模块，需要按照下面的方式

1、最新版模块安装：

npm install mysql

2、操作代码：

var mysql = require('mysql');  
      
var TEST_DATABASE = 'ceshi';  
var TEST_TABLE = 'user';  
  
//创建连接  
var client = mysql.createConnection({  
  user: 'root',  
  password: '',  
});  

client.connect();
client.query("use " + TEST_DATABASE);

client.query(  
  'SELECT * FROM '+TEST_TABLE,  
  function selectCb(err, results, fields) {  
    if (err) {  
      throw err;  
    }  
      
      if(results)
      {
          for(var i = 0; i < results.length; i++)
          {
              console.log("%dt%st%s", results[i].id, results[i].name, results[i].age);
          }
      }    
    client.end();  
  }  
);