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 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 = {
|
2016-09-12 18:45:35 -04:00
|
|
|
'mariadb' : 'maria',
|
|
|
|
'mariasql' : 'maria',
|
|
|
|
'pg' : 'postgres',
|
|
|
|
'postgresql' : 'postgres',
|
|
|
|
'sqlite' : 'sqlite3'
|
2016-05-17 01:01:34 +10:00
|
|
|
};
|
|
|
|
|
|
|
|
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)) {
|
2016-09-13 08:15:58 -04:00
|
|
|
Dialect = Client
|
2016-05-19 13:20:45 +03:00
|
|
|
} else if (typeof config.client === 'function' && config.client.prototype instanceof Client) {
|
2016-09-13 08:15:58 -04:00
|
|
|
Dialect = 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
|
2016-09-13 08:15:58 -04:00
|
|
|
Dialect = 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
|
|
|
|
|
2016-09-13 08:19:47 -04:00
|
|
|
Object.defineProperties(Knex, {
|
|
|
|
VERSION: {
|
|
|
|
get() {
|
|
|
|
warn(
|
|
|
|
'Knex.VERSION is deprecated, you can get the module version' +
|
|
|
|
"by running require('knex/package').version"
|
|
|
|
)
|
2016-10-12 10:22:49 -04:00
|
|
|
return '0.12.5'
|
2016-09-13 08:19:47 -04:00
|
|
|
}
|
|
|
|
},
|
|
|
|
Promise: {
|
|
|
|
get() {
|
|
|
|
warn(`Knex.Promise is deprecated, either require bluebird or use the global Promise`)
|
|
|
|
return require('bluebird')
|
|
|
|
}
|
2016-09-12 18:11:56 -04:00
|
|
|
}
|
|
|
|
})
|
2016-05-19 11:42:08 +03:00
|
|
|
|
2016-03-02 17:07:05 +01:00
|
|
|
// Run a "raw" query, though we can't do anything with it other than put
|
|
|
|
// it in a query statement.
|
2016-09-12 18:01:47 -04:00
|
|
|
Knex.raw = (sql, bindings) => {
|
|
|
|
warn('global Knex.raw is deprecated, use knex.raw (chain off an initialized knex object)')
|
|
|
|
return new Raw().set(sql, bindings)
|
2016-03-02 17:07:05 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
// 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')
|
|
|
|
}
|