ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / node_modules / knex-migrator / node_modules / knex / lib / dialects / oracle

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.default = void 0;

var _bluebird = _interopRequireDefault(require("bluebird"));

var _transaction = _interopRequireDefault(require("../../transaction"));

var _lodash = require("lodash");

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

const debugTx = require('debug')('knex:tx');

class Oracle_Transaction extends _transaction.default {
  // disable autocommit to allow correct behavior (default is true)
  begin() {
    return _bluebird.default.resolve();
  }

commit(conn, value) {
    this._completed = true;
    return conn.commitAsync().return(value).then(this._resolver, this._rejecter);
  }

release(conn, value) {
    return this._resolver(value);
  }

rollback(conn, err) {
    this._completed = true;
    debugTx('%s: rolling back', this.txid);
    return conn.rollbackAsync().throw(err).catch(error => {
      if ((0, _lodash.isUndefined)(error)) {
        error = new Error(`Transaction rejected with non-error: ${error}`);
      }

return this._rejecter(error);
    });
  }

acquireConnection(config) {
    const t = this;
    return _bluebird.default.try(() => config.connection || t.client.acquireConnection()).then(connection => {
      connection.__knexTxId = this.txid;
      return connection;
    }).tap(connection => {
      if (!t.outerTx) {
        connection.setAutoCommit(false);
      }
    }).disposer(connection => {
      debugTx('%s: releasing connection', t.txid);
      connection.setAutoCommit(true);

if (!config.connection) {
        t.client.releaseConnection(connection);
      } else {
        debugTx('%s: not releasing external connection', t.txid);
      }
    });
  }

}

exports.default = Oracle_Transaction;
module.exports = exports.default;

[-] utils.js [edit]
[+] ..
[+] schema
[-] index.js [edit]
[+] query
[-] transaction.js [edit]
[-] formatter.js [edit]