node.js中對 mysql 進行增刪改查等操做和async，await處理

時間  2019-12-17
標籤 node.js node mysql 進行 增刪 async await 處理 欄目 Node.js 简体版
原文   原文鏈接

要對mysql進行操做，咱們須要安裝一個mysql的庫。php

1、安裝mysql庫node

npm install mysql --save

　　

2、對mysql進行簡單查詢操做mysql

const mysql = require('mysql');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//鏈接數據庫
conn.connect(function (err) {
    if (err) {
        throw err;
    }
    console.log('鏈接成功');
});

//查詢數據庫
conn.query('select * from tb_user', function (err, data, field) {
    if (err) {
        throw err;
    }
    //data表示結果集數據，是一個數組
    console.log(data);
    data.forEach(function (value) {
        console.log(value.id, value.user_name, value.addr);
    });
    //表字段的詳細信息
    console.log(field);
});

//關閉數據庫鏈接
conn.end();

　　

2、對mysql進行增刪改操做sql

const mysql = require('mysql');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//鏈接數據庫
conn.connect(function (err) {
    if (err) {
        throw err;
    }
    console.log('鏈接成功');
});

//插入數據，query()方法能夠對sql語句進行參數綁定，用?號做爲佔位符。
conn.query('insert into tb_user values(null, ?, ?)', ['xxx', 'xxx'], function (err, data) {
    if (err) {
        throw err;
    }
    if (data && data.affectedRows) {
        console.log('插入數據成功，id爲', data.insertId);
    }
});

//修改數據
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('修改數據成功');
    }
});

//刪除數據
conn.query('delete from tb_user where id = ?', [5], function (err, data) {
    if (err) {
        throw err;
    }
    if (data && data.affectedRows) {
        console.log('刪除數據成功');
    }
});

//關閉數據庫鏈接
conn.end();

　　

3、使用mysql鏈接池來優化對數據庫的操做數據庫

頻繁的鏈接和斷開mysql是比較消耗資源的，咱們能夠建立一個鏈接池，複用鏈接池中的鏈接，提升效率。npm

const mysql = require('mysql');

//建立數據庫鏈接池
let pool = mysql.createPool({
    //鏈接數量，默認是10
    connectionLimit: 20,
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    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();
    });
});

//從鏈接池中獲取鏈接時，將觸發該事件
pool.on('acquire', function (conn) {
    console.log('獲取鏈接', conn.threadId);
});

//在鏈接池中創建新鏈接時，將觸發該事件
pool.on('connection', function (conn) {
    console.log('創建新鏈接', conn.threadId);
});

//等待可用鏈接時，將觸發該事件
pool.on('enqueue', function () {
    console.log('等待可用鏈接');
});

//當鏈接釋放回池中時，觸發該事件
pool.on('release', function (conn) {
    console.log('鏈接被釋放回池中', conn.threadId);
});

//結束池中全部的鏈接，否則node.js的事件循環會一直保持
setTimeout(function () {
    pool.end(function (err) {
        console.log('關閉鏈接池');
        console.log(err);
    });
}, 3000);

　　

4、按流的方式進行查詢數組

const mysql = require('mysql');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

let query = conn.query('select * from tb_user');
//Query類繼承自Sequence，而Sequence繼承自EventEmitter
//因此Query類的實例是能夠監聽事件

//發生錯誤時
query.on('error', function (err) {
    console.log(err);
});

//獲取查詢字段信息
query.on('fields', function (fields) {
    console.log(fields);
});

//獲取查詢結果
query.on('result', function (result) {
    //暫停獲取結果
    conn.pause();
    //跟流的pause()和resume()很相似，控制獲取數據的頻率。
    setTimeout(function () {
        console.log(result);
        //恢復獲取結果
        conn.resume();
    }, 1000);
});

//查詢結束
query.on('end', function () {
    console.log('查詢結束');
});

conn.end();

經過query.stream()方法返回一個可讀流來獲取數據promise

const mysql = require('mysql');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    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('查詢結束');
    console.log(result);
});

conn.end();

　　

5、mysql的事務處理async

const mysql = require('mysql');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//鏈接數據庫
conn.connect(function (err) {
    if (err) {
        throw err;
    }
    console.log('鏈接成功');
});

//開啓一個事務
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;
                });
            }
            //提交事務
            conn.commit(function (err) {
                if (err) {
                    //若是有錯誤則回滾
                    return conn.rollback(function () {
                        throw err;
                    });
                }
                console.log('處理成功');
                conn.end();
            });
        });
    });
});

　　

6、解決mysql嵌套回調的問題函數

有些時候咱們的操做須要上一個操做的結果，這樣會致使比較深的嵌套問題，爲了解決可使用async和await來解決，而async和await又是基於promise的。

const mysql = require('mysql');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    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');

//建立數據庫鏈接
let conn = mysql.createConnection({
    //主機地址
    host: '127.0.0.1',
    //用戶名
    user: 'root',
    //密碼
    password: '123456',
    //數據庫
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//注意經過util.promisify進行包裝的函數，必須知足
//一、函數的最後一個參數是回調函數
//二、回調函數的參數爲(err, result)，前者是錯誤，後者是正常結果
//注意這裏不要從新建立一個變量，否則會報錯。
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();
})();
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程