//mysql事務(wù)測(cè)試
const mysqlUtil = require('./mysql/mysql-util');

//開(kāi)啟事務(wù)
function tranOpen(conn) {
    return new Promise((resolve, reject) => {
        conn.beginTransaction(err => {
            if (err) {
                reject(err);
            } else {
                resolve();
            }
        });
    });
}
//關(guān)閉事務(wù)
function tranShut(conn) {
    return new Promise((resolve, reject) => {
        conn.commit(err => {
            if (err) {
                reject(err);
            } else {
                resolve();
            }
        });
    });
}

router.get('/', async function (req, res, next) {
    let conn = await mysqlUtil();
    let sqlStr = 'select * from music_info ';
    let sqlParam = [];
    // 開(kāi)啟事務(wù)
    await tranOpen(conn);
    // 開(kāi)始查詢?nèi)蝿?wù)
    let result1 = await new Promise((resolve, reject) => {
        conn.query(sqlStr, sqlParam, (err, ret) => {
            //如果錯(cuò)誤，回滾直到碰到beginTransaction
            if (err) {
                return conn.rollback(() => {
                    resolve(err);
                });
            }
            resolve(ret);
        })
    });
    console.log(result1);
    // 關(guān)閉事務(wù)
    await tranShut(conn);
    conn.release();
    res.send();
});