sequelize-xa-plugin v1.1.1

sequelize-XA-plugin

sequelize XA plugin

support sequelize for xa distribute protocol

Usage

1. Prepare Environment,support postgres only,edit postgresql.conf set max_prepared_transactions = 10

2. Init sequelize

   let xaPlugin = require('sequelize-xa-plugin');
   let sequelize = new Sequelize('database', 'user', 'pwd', {
     dialect: 'postgres',
     host: 'localhost',
     port: 5432,
     timezone: '+00:00',
     logging: undefined,
     pool: {
         maxConnections: 10
     }
   });
   sequelize = xaPlugin(sequelize);

3. XATransaction function

   yield db.XATransaction({
       transactionManager: 'TM URL',
       xid: 'TM ID',
       name: 'child service name',
       callback: 'child transaction callback',
       isolationLevel: Sequelize.Transaction.ISOLATION_LEVELS.READ_UNCOMMITTED
     }, function(t) {
       return co(function*() {
         //...do something to database
       });
     });

4. XA callback to commit or roolback prepared transaction

   yield sequelize.finishPrepared(transactionId, action);