123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170 |
- 'use strict';
- exports.__esModule = true;
- var _defineProperties = require('babel-runtime/core-js/object/define-properties');
- var _defineProperties2 = _interopRequireDefault(_defineProperties);
- var _assign2 = require('lodash/assign');
- var _assign3 = _interopRequireDefault(_assign2);
- exports.default = makeKnex;
- var _events = require('events');
- var _migrate = require('../migrate');
- var _migrate2 = _interopRequireDefault(_migrate);
- var _seed = require('../seed');
- var _seed2 = _interopRequireDefault(_seed);
- var _functionhelper = require('../functionhelper');
- var _functionhelper2 = _interopRequireDefault(_functionhelper);
- var _methods = require('../query/methods');
- var _methods2 = _interopRequireDefault(_methods);
- var _helpers = require('../helpers');
- var helpers = _interopRequireWildcard(_helpers);
- var _batchInsert = require('./batchInsert');
- var _batchInsert2 = _interopRequireDefault(_batchInsert);
- function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- function makeKnex(client) {
- // The object we're potentially using to kick off an initial chain.
- function knex(tableName, options) {
- var qb = knex.queryBuilder();
- if (!tableName) helpers.warn('calling knex without a tableName is deprecated. Use knex.queryBuilder() instead.');
- return tableName ? qb.table(tableName, options) : qb;
- }
- (0, _assign3.default)(knex, {
- Promise: require('bluebird'),
- // A new query builder instance.
- queryBuilder: function queryBuilder() {
- return client.queryBuilder();
- },
- raw: function raw() {
- return client.raw.apply(client, arguments);
- },
- batchInsert: function batchInsert(table, batch) {
- var chunkSize = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : 1000;
- return new _batchInsert2.default(this, table, batch, chunkSize);
- },
- // Runs a new transaction, taking a container and returning a promise
- // for when the transaction is resolved.
- transaction: function transaction(container, config) {
- return client.transaction(container, config);
- },
- // Typically never needed, initializes the pool for a knex client.
- initialize: function initialize(config) {
- return client.initialize(config);
- },
- // Convenience method for tearing down the pool.
- destroy: function destroy(callback) {
- return client.destroy(callback);
- }
- });
- // Hook up the "knex" object as an EventEmitter.
- var ee = new _events.EventEmitter();
- for (var key in ee) {
- knex[key] = ee[key];
- }
- // Allow chaining methods from the root object, before
- // any other information is specified.
- _methods2.default.forEach(function (method) {
- knex[method] = function () {
- var builder = knex.queryBuilder();
- return builder[method].apply(builder, arguments);
- };
- });
- knex.client = client;
- var VERSION = '0.12.6';
- (0, _defineProperties2.default)(knex, {
- __knex__: {
- get: function get() {
- helpers.warn('knex.__knex__ is deprecated, you can get the module version' + "by running require('knex/package').version");
- return VERSION;
- }
- },
- VERSION: {
- get: function get() {
- helpers.warn('knex.VERSION is deprecated, you can get the module version' + "by running require('knex/package').version");
- return VERSION;
- }
- },
- schema: {
- get: function get() {
- return client.schemaBuilder();
- }
- },
- migrate: {
- get: function get() {
- return new _migrate2.default(knex);
- }
- },
- seed: {
- get: function get() {
- return new _seed2.default(knex);
- }
- },
- fn: {
- get: function get() {
- return new _functionhelper2.default(client);
- }
- }
- });
- // Passthrough all "start" and "query" events to the knex object.
- client.on('start', function (obj) {
- knex.emit('start', obj);
- });
- client.on('query', function (obj) {
- knex.emit('query', obj);
- });
- client.on('query-error', function (err, obj) {
- knex.emit('query-error', err, obj);
- });
- client.on('query-response', function (response, obj, builder) {
- knex.emit('query-response', response, obj, builder);
- });
- client.makeKnex = makeKnex;
- return knex;
- }
- module.exports = exports['default'];
|