Transactions

gistfile1.js

conn.beginTransaction(function(err) {
  if (err) {
    throw err;
  }
  conn.query('INSERT INTO gluer_topic SET ?', data, function(err, result) {
    if (err) {
      console.error(err);
      conn.rollback(function() {
        throw err;
      });
    }
    var data1 = {
      UID: uid,
      TID: result.insertId,
      UTAuthority: 'C',
      UTAccess: 'RWVC'
    };
    console.log('[createTopic] data:' + data1);
    conn.query('INSERT INTO gluer_ut SET ? ', data1, function(err, result1){
      if(err) {
        console.error(err);
        conn.rollback(function() {
          throw err;
        });
        return next(err, -1);
      }
      conn.commit(function(err) {
        if (err) {
          conn.rollback(function() {
            throw err;
          });
        }
        console.log('[createTopic] Create Topic OK');
        return next(false, result.insertId);
      });//Commit
    });//gluer_ut
  });//gluer_topic
});//Transaction