欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

node.js中 mysql 增刪改查操作及async,await處理實例分析

 更新時間:2020年02月11日 09:37:00   作者:懷素真  
這篇文章主要介紹了node.js中 mysql 增刪改查操作及async,await處理,結(jié)合實例形式分析了node.js中 mysql庫安裝、增刪改查操作及async,await處理相關(guān)實現(xiàn)技巧,需要的朋友可以參考下

本文實例講述了node.js中 mysql 增刪改查操作及async,await處理。分享給大家供大家參考,具體如下:

要對mysql進行操作,我們需要安裝一個mysql的庫。

一、安裝mysql庫

npm install mysql --save

二、對mysql進行簡單查詢操作

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//連接數(shù)據(jù)庫
conn.connect(function (err) {
  if (err) {
    throw err;
  }
  console.log('連接成功');
});
//查詢數(shù)據(jù)庫
conn.query('select * from tb_user', function (err, data, field) {
  if (err) {
    throw err;
  }
  //data表示結(jié)果集數(shù)據(jù),是一個數(shù)組
  console.log(data);
  data.forEach(function (value) {
    console.log(value.id, value.user_name, value.addr);
  });
  //表字段的詳細信息
  console.log(field);
});
//關(guān)閉數(shù)據(jù)庫連接
conn.end();

二、對mysql進行增刪改操作

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//連接數(shù)據(jù)庫
conn.connect(function (err) {
  if (err) {
    throw err;
  }
  console.log('連接成功');
});
//插入數(shù)據(jù),query()方法可以對sql語句進行參數(shù)綁定,用?號作為占位符。
conn.query('insert into tb_user values(null, ?, ?)', ['xxx', 'xxx'], function (err, data) {
  if (err) {
    throw err;
  }
  if (data && data.affectedRows) {
    console.log('插入數(shù)據(jù)成功,id為', data.insertId);
  }
});
//修改數(shù)據(jù)
conn.query('update tb_user set user_name = ? where id = ?', ['ggg', 7], function (err, data) {
  if (err) {
    throw err;
  }
  if (data && data.affectedRows) {
    console.log('修改數(shù)據(jù)成功');
  }
});
//刪除數(shù)據(jù)
conn.query('delete from tb_user where id = ?', [5], function (err, data) {
  if (err) {
    throw err;
  }
  if (data && data.affectedRows) {
    console.log('刪除數(shù)據(jù)成功');
  }
});
//關(guān)閉數(shù)據(jù)庫連接
conn.end();

三、使用mysql連接池來優(yōu)化對數(shù)據(jù)庫的操作

頻繁的連接和斷開mysql是比較消耗資源的,我們可以創(chuàng)建一個連接池,復用連接池中的連接,提高效率。

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接池
let pool = mysql.createPool({
  //連接數(shù)量,默認是10
  connectionLimit: 20,
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//pool.query()方法可以自動的幫我們在連接池中獲取可用連接
pool.query('select * from tb_user', function (err, data) {
  if (err) {
    throw err;
  }
  data.forEach(function (value) {
    console.log(value.id, value.user_name, value.addr);
  });
});
//當然我們也可以手動獲取可用連接
pool.getConnection(function (err, conn) {
  if (err) {
    throw err;
  }
  conn.query('select * from `order`', function (err, data) {
    if (err) {
      throw err;
    }
    data.forEach(function (value) {
      console.log(value.id, value.order_id, value.user_id);
    });
    //連接用完之后,需要釋放,重新放回連接池中。
    //注意這里并沒有銷毀該連接,該連接仍然可用,但需要重新獲取
    conn.release();
  });
});
//從連接池中獲取連接時,將觸發(fā)該事件
pool.on('acquire', function (conn) {
  console.log('獲取連接', conn.threadId);
});
//在連接池中建立新連接時,將觸發(fā)該事件
pool.on('connection', function (conn) {
  console.log('建立新連接', conn.threadId);
});
//等待可用連接時,將觸發(fā)該事件
pool.on('enqueue', function () {
  console.log('等待可用連接');
});
//當連接釋放回池中時,觸發(fā)該事件
pool.on('release', function (conn) {
  console.log('連接被釋放回池中', conn.threadId);
});
//結(jié)束池中所有的連接,不然node.js的事件循環(huán)會一直保持
setTimeout(function () {
  pool.end(function (err) {
    console.log('關(guān)閉連接池');
    console.log(err);
  });
}, 3000);

四、按流的方式進行查詢

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
let query = conn.query('select * from tb_user');
//Query類繼承自Sequence,而Sequence繼承自EventEmitter
//所以Query類的實例是可以監(jiān)聽事件
//發(fā)生錯誤時
query.on('error', function (err) {
  console.log(err);
});
//獲取查詢字段信息
query.on('fields', function (fields) {
  console.log(fields);
});
//獲取查詢結(jié)果
query.on('result', function (result) {
  //暫停獲取結(jié)果
  conn.pause();
  //跟流的pause()和resume()很類似,控制獲取數(shù)據(jù)的頻率。
  setTimeout(function () {
    console.log(result);
    //恢復獲取結(jié)果
    conn.resume();
  }, 1000);
});
//查詢結(jié)束
query.on('end', function () {
  console.log('查詢結(jié)束');
});
conn.end();

通過query.stream()方法返回一個可讀流來獲取數(shù)據(jù)

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//從一個查詢中獲取一個可讀流
let qs = conn.query('select * from tb_user').stream({highWaterMark: 2});
let result = [];
qs.on('data', function (data) {
  result.push(data);
});
qs.on('end', function () {
  console.log('查詢結(jié)束');
  console.log(result);
});
conn.end();

五、mysql的事務(wù)處理

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//連接數(shù)據(jù)庫
conn.connect(function (err) {
  if (err) {
    throw err;
  }
  console.log('連接成功');
});
//開啟一個事務(wù)
conn.beginTransaction(function (err) {
  if (err) {
    throw err;
  }
  conn.query('update account set money = money - 50 where name = ?', ['A'], function (err, data) {
    if (err) {
      //如果有錯誤則回滾
      return conn.rollback(function () {
        throw err;
      });
    }
    conn.query('update account set money = money + 50 where name = ?', ['B'], function (err, data) {
      if (err) {
        //如果有錯誤則回滾
        return conn.rollback(function () {
          throw err;
        });
      }
      //提交事務(wù)
      conn.commit(function (err) {
        if (err) {
          //如果有錯誤則回滾
          return conn.rollback(function () {
            throw err;
          });
        }
        console.log('處理成功');
        conn.end();
      });
    });
  });
});

六、解決mysql嵌套回調(diào)的問題

有些時候我們的操作需要上一個操作的結(jié)果,這樣會導致比較深的嵌套問題,為了解決可以使用async和await來解決,而async和await又是基于promise的。

const mysql = require('mysql');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
function query(conn, sql, params = []) {
  if (!conn) {
    return;
  }
  return new Promise(function (resolve, reject) {
    conn.query(sql, params, function (err, data) {
      if (err) {
        reject(err);
      } else {
        resolve(data);
      }
    });
  });
}
(async function () {
  let result = await query(conn, 'select * from tb_user');
  console.log(result);
  let row = await query(conn, 'select * from tb_user where id = ?', [result[0].id]);
  console.log(row);
  conn.end();
})();

當然我們還可以使用 util.promiseify() 進行包裝。

const mysql = require('mysql');
const util = require('util');
//創(chuàng)建數(shù)據(jù)庫連接
let conn = mysql.createConnection({
  //主機地址
  host: '127.0.0.1',
  //用戶名
  user: 'root',
  //密碼
  password: '123456',
  //數(shù)據(jù)庫
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//注意通過util.promisify進行包裝的函數(shù),必須滿足
//1、函數(shù)的最后一個參數(shù)是回調(diào)函數(shù)
//2、回調(diào)函數(shù)的參數(shù)為(err, result),前者是錯誤,后者是正常結(jié)果
//注意這里不要重新創(chuàng)建一個變量,不然會報錯。
conn.query = util.promisify(conn.query);
(async function () {
  let result = await conn.query('select * from tb_user');
  console.log(result);
  let row = await conn.query('select * from tb_user where id = ?', [result[0].id]);
  console.log(row);
  conn.end();
})();

希望本文所述對大家node.js程序設(shè)計有所幫助。

相關(guān)文章

  • 教你如何用node連接redis的示例代碼

    教你如何用node連接redis的示例代碼

    這篇文章主要介紹了教你如何用node連接redis的示例代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-07-07
  • node使用promise替代回調(diào)函數(shù)

    node使用promise替代回調(diào)函數(shù)

    這篇文章主要介紹了node使用promise替代回調(diào)函數(shù),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-05-05
  • 詳解基于Vue+Koa的pm2配置

    詳解基于Vue+Koa的pm2配置

    這篇文章主要介紹了詳解基于Vue+Koa的pm2配置,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-10-10
  • node.js中的console.timeEnd方法使用說明

    node.js中的console.timeEnd方法使用說明

    這篇文章主要介紹了node.js中的console.timeEnd方法使用說明,本文介紹了console.timeEnd的方法說明、語法、使用實例和實現(xiàn)源碼,需要的朋友可以參考下
    2014-12-12
  • nodejs中函數(shù)的調(diào)用實例詳解

    nodejs中函數(shù)的調(diào)用實例詳解

    本文通過實例代碼給大家介紹了nodejs函數(shù)的調(diào)用,代碼簡單易懂,非常不錯,具有一定的參考借鑒價值,需要的朋友可以參考下
    2018-10-10
  • node+axios實現(xiàn)服務(wù)端文件上傳示例

    node+axios實現(xiàn)服務(wù)端文件上傳示例

    這篇文章主要介紹了node+axios實現(xiàn)服務(wù)端文件上傳示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-06-06
  • node.js中process進程的概念和child_process子進程模塊的使用方法示例

    node.js中process進程的概念和child_process子進程模塊的使用方法示例

    這篇文章主要介紹了node.js中process進程的概念和child_process子進程模塊的使用方法,結(jié)合實例形式分析了node.js中process進程和child_process子進程模塊相關(guān)概念、原理、使用方法及操作注意事項,需要的朋友可以參考下
    2020-02-02
  • nodejs插件及用法整理

    nodejs插件及用法整理

    在本篇文章里小編給大家整理的是一篇關(guān)于nodejs插件及用法相關(guān)內(nèi)容,有興趣的朋友們可以跟著學習參考下。
    2021-11-11
  • nodejs如何獲取時間戳與時間差

    nodejs如何獲取時間戳與時間差

    本文詳細介紹了nodejs獲取時間戳與時間差的多種方法,對平時nodejs的使用很有幫助,下面一起來看看吧。
    2016-08-08
  • npm?install常見報錯以及問題詳解

    npm?install常見報錯以及問題詳解

    npm?install總是一言難盡,下面這篇文章主要給大家介紹了關(guān)于npm?install常見報錯以及問題的相關(guān)資料,文中通過圖文以及實例代碼介紹的非常詳細,需要的朋友可以參考下
    2023-02-02

最新評論