2016-03-02 17:07:05 +01:00
|
|
|
|
2016-05-17 01:01:34 +10:00
|
|
|
import Raw from './raw';
|
|
|
|
import { warn } from './helpers';
|
|
|
|
import Client from './client';
|
2016-03-02 17:07:05 +01:00
|
|
|
|
2016-05-17 01:01:34 +10:00
|
|
|
import makeClient from './util/make-client';
|
|
|
|
import makeKnex from './util/make-knex';
|
|
|
|
import parseConnection from './util/parse-connection';
|
2016-03-02 17:07:05 +01:00
|
|
|
|
2016-05-18 20:22:50 +10:00
|
|
|
import { assign } from 'lodash'
|
2016-03-02 17:07:05 +01:00
|
|
|
|
2016-05-17 01:01:34 +10:00
|
|
|
// The client names we'll allow in the `{name: lib}` pairing.
|
|
|
|
const aliases = {
|
|
|
|
'mariadb' : 'maria',
|
|
|
|
'mariasql' : 'maria',
|
|
|
|
'pg' : 'postgres',
|
|
|
|
'postgresql': 'postgres',
|
|
|
|
'sqlite' : 'sqlite3'
|
|
|
|
};
|
|
|
|
|
|
|
|
export default function Knex(config) {
|
2016-03-02 17:07:05 +01:00
|
|
|
if (typeof config === 'string') {
|
|
|
|
return new Knex(assign(parseConnection(config), arguments[2]))
|
|
|
|
}
|
2016-05-17 01:01:34 +10:00
|
|
|
let Dialect;
|
2016-03-02 17:07:05 +01:00
|
|
|
if (arguments.length === 0 || (!config.client && !config.dialect)) {
|
|
|
|
Dialect = makeClient(Client)
|
2016-05-19 12:18:11 +03:00
|
|
|
} else if (typeof config.client === 'object' && config.client.prototype instanceof Client) {
|
2016-05-19 08:49:07 +03:00
|
|
|
Dialect = makeClient(config.client)
|
2016-03-02 17:07:05 +01:00
|
|
|
} else {
|
2016-05-17 01:01:34 +10:00
|
|
|
const clientName = config.client || config.dialect
|
|
|
|
Dialect = makeClient(require(`./dialects/${aliases[clientName] || clientName}/index.js`))
|
2016-03-02 17:07:05 +01:00
|
|
|
}
|
|
|
|
if (typeof config.connection === 'string') {
|
|
|
|
config = assign({}, config, {connection: parseConnection(config.connection).connection})
|
|
|
|
}
|
|
|
|
return makeKnex(new Dialect(config))
|
|
|
|
}
|
|
|
|
|
|
|
|
// Expose Client on the main Knex namespace.
|
|
|
|
Knex.Client = Client
|
|
|
|
|
|
|
|
// Run a "raw" query, though we can't do anything with it other than put
|
|
|
|
// it in a query statement.
|
2016-05-17 01:01:34 +10:00
|
|
|
Knex.raw = (sql, bindings) => new Raw({}).set(sql, bindings)
|
2016-03-02 17:07:05 +01:00
|
|
|
|
|
|
|
// Create a new "knex" instance with the appropriate configured client.
|
|
|
|
Knex.initialize = function(config) {
|
|
|
|
warn('knex.initialize is deprecated, pass your config object directly to the knex module')
|
|
|
|
return new Knex(config)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Bluebird
|
|
|
|
Knex.Promise = require('./promise')
|
|
|
|
|
|
|
|
// Doing this ensures Browserify works. Still need to figure out
|
|
|
|
// the best way to do some of this.
|
|
|
|
if (process.browser) {
|
|
|
|
require('./dialects/websql/index.js')
|
|
|
|
}
|