快捷導(dǎo)航

node.js如何操作MySQL數(shù)據(jù)庫(kù)

更新時(shí)間：2020年10月29日 14:34:04 作者：青城同學(xué)

這篇文章主要介紹了node.js如何操作MySQL數(shù)據(jù)庫(kù)，幫助大家更好的進(jìn)行web開發(fā)，感興趣的朋友可以了解下

MySQL數(shù)據(jù)庫(kù)作為最流行的開源數(shù)據(jù)庫(kù)?；旧鲜敲總€(gè)web開發(fā)者必須要掌握的數(shù)據(jù)庫(kù)程序之一了。

基本使用

node.js上，最受歡迎的mysql包就是mysql模塊。

npm install mysql

然后在js腳本里面直接引用進(jìn)來

var mysql   = require('mysql');

配置mysql的數(shù)據(jù)庫(kù)連接。

var connection = mysql.createConnection({
 host   : 'ip',
 user   : '用戶名',
 password : '密碼',
 database : 'dbname'
});
connection.connect();

這樣就拿到了一個(gè)連接。

然后就可以愉快的進(jìn)行各種curd操作了。

node.js對(duì)數(shù)據(jù)庫(kù)的curd都在query這個(gè)方法里面。這點(diǎn)和ado.net有很大的區(qū)別。

你的所有的操作，都從query的回調(diào)函數(shù)里面獲得結(jié)果

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

連接池操作

在單機(jī)軟件中，我們之間使用簡(jiǎn)單獲得一個(gè)連接，然后就行了。

但是在面向互聯(lián)網(wǎng)的web服務(wù)里面，頻繁的創(chuàng)建和關(guān)閉連接，是很消耗服務(wù)器性能的。

于是我們的前輩們發(fā)明了各種池子。比如多線程操作中的線程池，游戲開發(fā)中的對(duì)象池，當(dāng)然還包括數(shù)據(jù)庫(kù)操作的連接池。

創(chuàng)建連接池：

var mysql = require('mysql');
var pool = mysql.createPool({
 connectionLimit : 連接池?cái)?shù)量,
 host      : 'ip地址',
 user      : '賬號(hào)',
 password    : '密碼',
 database    : '數(shù)據(jù)庫(kù)名稱'
});

然后就是和上文一樣的curd操作

//從連接池中獲取一個(gè)連接
pool.getConnection(function(err, connection) {
  if (err) throw err; // not connected!
 
  // 使用這個(gè)連接curd
  connection.query('SELECT something FROM sometable', function (error, results, fields) {
    // 使用完之后，記得把這個(gè)連接放到連接池里面去
    connection.release();
 
    // Handle error after the release.
    if (error) throw error;
 
  });
});

如果你的程序要退出，請(qǐng)把調(diào)用連接池的end()方法。不然程序會(huì)卡在后臺(tái)，一直退出失敗。

封裝成Promise

在ES6中，可以直接用和C#的await一樣的語(yǔ)法去調(diào)用js的異步函數(shù)。

但是要求這個(gè)函數(shù)必須是async聲明和返回值是Promise對(duì)象。

query = function (sql, arr, callback) {
  console.log('獲取一個(gè)連接');
  return new Promise(function (resolve, reject) {
    pool.getConnection(function (err, connection) {
      if (err) {
        reject(err);// not connected!
      } else {
        console.log('開始查詢');
        connection.query(sql, arr, function (error, results, fields) {
          connection.release();
          console.log('連接已經(jīng)釋放，返回結(jié)果');

          if (error) reject(error);
          // callback && callback(results, fields)
          resolve({
            rows: results,
            fields: fields
          })
        });
      }


    });
  })


}

簡(jiǎn)單的用法到這里就結(jié)束了。當(dāng)然還有更高級(jí)的用法，比如MySQL的Cluster操作等。有興趣的話，可以去研究，因?yàn)槲夷壳坝貌坏竭@種功能，所有就不往后去深究了。

以上就是node.js如何操作MySQL數(shù)據(jù)庫(kù)的詳細(xì)內(nèi)容，更多關(guān)于node.js 操作數(shù)據(jù)庫(kù)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: