node-sqlite3的事务执行方法

2015年12月28日

直接传入执行事务的所有SQL语句不可行。

上午不知道为什么，使用navicat直接执行sql语句的时候，运行事务都不会成功。下午运行成功了，遂放心开始使用node.js开始编程。

后台处理函数：

//新增内容
function addTableInfo(res, data) {
    var data = JSON.parse(data);
    var sql = '';
    var returnMsg = '';
    rowSql = 'INSERT INTO ' + data.tableName + ' ' + data.tableRows + ' VALUES ';
    db.serialize(function() {
        db.run('BEGIN TRANSACTION;');
        for(var i = 0; i < data.vals.length; i++) {
            sql = rowSql + data.vals[i] + '; ';
            console.log(sql); 
            var k = 0;
            db.run(sql, function(err, rows) {
                if(!err) {
                    k++;
                    //当所有的回调都执行完成时，返回错误
                    if(k == (data.vals.length)) {
                        console.log('returnMsg返回错误' + returnMsg);
                        if(returnMsg) {
                            res.end(returnMsg);
                        } else {
                            res.end('新增成功！');
                        };
                        
                    };
                } else {
                    returnMsg = returnMsg + '【数据：' + data.vals[k] + '新增失败，' + err + '】';
                    k++;
                    if(k == (data.vals.length)) {     
                        if(returnMsg) {
                            console.log('returnMsg返回错误：' + returnMsg);
                            res.end(returnMsg);
                        } else {
                            res.end('新增成功！');
                        };
                    };
                };    
            });
        };       
        db.run('COMMIT TRANSACTION;');
    });  
};

如果data的内容是：

{"tableName":"eqpt_info","tableRows":"(eqpt_code, eqpt_name, eqpt_ty
pe, eqpt_address, create_time)","vals":["(1,2,2,2,2)","(1,3,2,2,2,)","(1,4,2,2,2
)","(1,5,2,2,2,4)"]}

那么返回的returnMsg数据是：

returnMsg返回错误【数据：(1,3,2,2,2,)新增失败，Error: SQLITE_ERROR: near ")": sy
ntax error】【数据：(1,5,2,2,2,4)新增失败，Error: SQLITE_ERROR: 6 values for 5 c
olumns】

需要使用node-sqlite3的流程控制函数 

也从别人写的IOS的sqlite3事务执行方法中得到了灵感。

sqlite3的事务执行方法和其它的数据库不太相同。

使用sqlite3的事务的时候，直接传入：

BEGIN TRANSACTION;
INSERT INTO eqpt_info (eqpt_code, eqpt_name, eqpt_type, eqpt_address, create_time) VALUES (1,2,2,2,2);
INSERT INTO eqpt_info (eqpt_code, eqpt_name, eqpt_type, eqpt_address, create_time) VALUES (1,2,2,2,2);
INSERT INTO eqpt_info (eqpt_code, eqpt_name, eqpt_type, eqpt_address, create_time) VALUES (1,2,2,2,2);
INSERT INTO eqpt_info (eqpt_code, eqpt_name, eqpt_type, eqpt_address, create_time) VALUES (1,2,2,2,2); 
COMMIT TRANSACTION;

这样的SQL语句，不会执行成功。