node+mysql事務回滾及批量更新數據

//封裝事務回滾函數
var mysql = require('mysql');
var async = require("async");

var pool = mysql.createPool({
    host: "localhost",
    user: "root",
    password: "123456",
    database: "test",
    connectionLimit: 10,
    port: "3306",
    waitForConnections: false
});

function execTrans(sqlparamsEntities, callback) {
    pool.getConnection(function (err, connection) {
        if (err) {
            return callback(err, null);
        }
        connection.beginTransaction(function (err) {
            if (err) {
                return callback(err, null);
            }
            //console.log("開始執行transaction，共執行" + sqlparamsEntities.length + "條數據");
            var funcAry = [];
            sqlparamsEntities.forEach(function (sql_param) {
                var temp = function (cb) {
                    var sql = sql_param.sql;
                    var param = sql_param.params;
                    connection.query(sql, param, function (tErr, rows, fields) {
                        if (tErr) {
                            connection.rollback(function () {
                                console.log("事務失敗，" + sql_param + "，ERROR：" + tErr);
                                throw tErr;
                            });
                        } else {
                            return cb(null, 'ok');
                        }
                    })
                };
                funcAry.push(temp);
            });

            async.series(funcAry, function (err, result) {
                if (err) {
                    connection.rollback(function (err) {
                        console.log("transaction error: " + err);
                        connection.release();
                        return callback(err, null);
                    });
                } else {
                    connection.commit(function (err, info) {
                        //console.log("transaction info: " + JSON.stringify(info));
                        if (err) {
                            console.log("執行事務失敗，" + err);
                            connection.rollback(function (err) {
                                console.log("transaction error: " + err);
                                connection.release();
                                return callback(err, null);
                            });
                        } else {
                            connection.release();
                            return callback(null, info);
                        }
                    })
                }
            })
        });
    });
}

module.exports = {
    execTrans: execTrans,
}

const express=require('express');
const huigun=require('./dbHelper.js')

//初始化sql & params：
function _getNewSqlParamEntity(sql, params, callback) {
    if (callback) {
        return callback(null, {
            sql: sql,
            params: params
        });
    }
    return {
        sql: sql,
        params: params
    };
}

//如果你要執行多條sql語句，則需要：
var sqlParamsEntity = [];
//var sql1 = "insert table set a=?, b=? where 1=1";
//var param1 = {a:1, b:2};
//sqlParamsEntity.push(_getNewSqlParamEntity(sql1, param1));
var sql1 = `insert table1 (name,age) VALUES('burt',19)`;
sqlParamsEntity.push(_getNewSqlParamEntity(sql1));
sql1 = `insert table1 (name,age) VALUES('burt',23)`;
sqlParamsEntity.push(_getNewSqlParamEntity(sql1))
sql1 = `insert table1 (name,age) VALUES('jing',20)`;
sqlParamsEntity.push(_getNewSqlParamEntity(sql1))


var ret;
huigun.execTrans(sqlParamsEntity, function(err, info){
    if(err){
       console.error("事務執行失敗");
    }else{
       console.log("done.");
       console.log(info);
       ret = info;
    }
});


//創建服務器
const server=express();

//監聽端口號8081,移到台北服務器要改成8080端口，mysql的鏈接也要更改
server.listen(8082,(err)=>{
    if(err)
        throw new err;
    else 
        console.log('成功監聽8082端口。');
});

server.use('/',(req,res)=>{
   console.log(ret);
   res.send(ret);
});

 

mysql批量更新記錄

UPDATE categories

SET display_order = CASE id

WHEN 1 THEN 3

WHEN 2 THEN 4

WHEN 3 THEN 5

END

WHERE id IN (1,2,3)
這里使用了case when 這個小技巧來實現批量更新。
    這句sql的意思是，更新display_order 字段，如果id=1 則display_order 的值為3，如果id=2 則 display_order 的值為4，如果id=3 則 display_order 的值為5。
    這里的where部分不影響代碼的執行，但是會提高sql執行的效率。確保sql語句僅執行需要修改的行數，這里只有3條數據進行更新，而where子句確保只有3行數據執行。

UPDATE categories

SET display_order = CASE id

WHEN 1 THEN 3

WHEN 2 THEN 4

WHEN 3 THEN 5

END,

title = CASE id

WHEN 1 THEN ‘New Title 1’

WHEN 2 THEN ‘New Title 2’

WHEN 3 THEN ‘New Title 3’

END

WHERE id IN (1,2,3)
到這里，已經完成一條mysql語句更新多條記錄了。

性能分析

當我使用上萬條記錄利用mysql批量更新，發現使用最原始的批量update發現性能很差，將網上看到的總結一下一共有以下三種辦法：
1.批量update，一條記錄update一次，性能很差

復制代碼 代碼如下:

update test_tbl set dr=’2’ where id=1;

2.replace into 或者insert into …on duplicate key update

復制代碼 代碼如下:

replace into test_tbl (id,dr) values (1,’2’),(2,’3’),…(x,’y’);

或者使用

復制代碼 代碼如下:

insert into test_tbl (id,dr) values (1,’2’),(2,’3’),…(x,’y’) on duplicate key update dr=values(dr);
3.創建臨時表，先更新臨時表，然后從臨時表中update

代碼如下 復制代碼

create temporary table tmp(id int(4) primary key,dr varchar(50));

insert into tmp values (0,’gone’), (1,’xx’),…(m,’yy’);

update test_tbl, tmp set test_tbl.dr=tmp.dr where test_tbl.id=tmp.id;

注意：這種方法需要用戶有temporary 表的create 權限。
就測試結果來看，測試當時使用replace into性能較好。

replace into 和insert into on duplicate key update的不同在於：

replace into　操作本質是對重復的記錄先delete 后insert，如果更新的字段不全會將缺失的字段置為缺省值

insert into 則是只update重復記錄，不會改變其它字段。

1 replace into 跟 insert 功能類似，不同點在於：replace into 首先嘗試插入數據到表中。
2 1、如果發現表中已經有此行數據（根據主鍵或者唯一索引判斷）則先刪除此行數據，然后插入新的數據。
3 2、 否則，直接插入新數據。
4 
5 要注意的是：插入數據的表必須有主鍵或者是唯一索引！否則的話，replace into 會直接插入數據，這將導致表中出現重復的數據。