nodejs連接mysql數據庫簡單封裝示例-mysql模塊

2019-11-19 16:52:22

字體：大中小

來源：轉載

供稿：網友

本人最近在學習研究nodejs,下面我來記錄一下,有需要了解nodejs連接mysql數據庫簡單封裝的朋友可參考。希望此文章對各位有所幫助。

安裝mysql模塊

npm install mysql

測試是否連接成功

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

結果 : 連接成功

封裝連接數據庫代碼

支持連接池,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;

測試封裝

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('用戶數量 : ', rows[0].count); });

運行結果