安裝mysql模塊

npm install mysql

測(cè)試是否連接成功

mysql.js代碼:

  var mysql      = require('mysql');  
  var connection = mysql.createConnection({  
  host     : 'localhost',  
  user     : 'root',  
  password : '123456',  
  database : 'nodejs'  
  });  

  connection.connect();  

  connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {  
  if (err) {  
  console.log(err);  
  return;  
  };  

  console.log('The solution is: ', rows[0].solution);  
  });  

  connection.end();  

結(jié)果 : 連接成功

image

封裝連接數(shù)據(jù)庫(kù)代碼

支持連接池,mysql.js:

  var db    = {};  
  var mysql = require('mysql');  
  var pool  = mysql.createPool({  
  connectionLimit : 10,  
  host            : 'localhost',  
  user            : 'root',  
  password        : '123456',  
  database        : 'nodejs'  
  });  

  db.query = function(sql, callback){  

  if (!sql) {  
  callback();  
  return;  
  }  
  pool.query(sql, function(err, rows, fields) {  
  if (err) {  
  console.log(err);  
  callback(err, null);  
  return;  
  };  

  callback(null, rows, fields);  
  });  
  }  
  module.exports = db;  

測(cè)試封裝

dbtest.js:

  var db = require('./mysql.js');  
  var sql = 'SELECT count(*) as count from user';  
  db.query(sql, function(err, rows, fields){  
    if (err) {  
      console.log(err);  
      return;  
    }  
    console.log('用戶數(shù)量 : ', rows[0].count);  
  });  

運(yùn)行結(jié)果

image

數(shù)據(jù)庫(kù)截圖:

image