2015-05-09 13:58:18 -04:00
|
|
|
|
2015-06-01 07:55:04 -04:00
|
|
|
import url from 'url'
|
|
|
|
import {parse as parsePG} from 'pg-connection-string'
|
2015-05-09 13:58:18 -04:00
|
|
|
|
2015-06-01 07:55:04 -04:00
|
|
|
export default function parseConnectionString(str) {
|
2015-05-09 13:58:18 -04:00
|
|
|
var parsed = url.parse(str)
|
|
|
|
var protocol = parsed.protocol
|
|
|
|
if (protocol && protocol.indexOf('maria') === 0) {
|
|
|
|
protocol = 'maria'
|
|
|
|
}
|
|
|
|
if (protocol === null) {
|
|
|
|
return {
|
|
|
|
client: 'sqlite3',
|
|
|
|
connection: {
|
|
|
|
filename: str
|
|
|
|
}
|
2016-03-08 08:41:13 +01:00
|
|
|
}
|
2015-05-09 13:58:18 -04:00
|
|
|
}
|
|
|
|
if (protocol.slice(-1) === ':') {
|
|
|
|
protocol = protocol.slice(0, -1);
|
|
|
|
}
|
|
|
|
return {
|
|
|
|
client: protocol,
|
2015-06-01 07:55:04 -04:00
|
|
|
connection: protocol === 'postgres' ? parsePG(str) : connectionObject(parsed)
|
2016-03-08 08:41:13 +01:00
|
|
|
}
|
2015-05-09 13:58:18 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
function connectionObject(parsed) {
|
|
|
|
var connection = {};
|
|
|
|
var db = parsed.pathname;
|
|
|
|
if (db[0] === '/') {
|
|
|
|
db = db.slice(1)
|
|
|
|
}
|
|
|
|
if (parsed.protocol.indexOf('maria') === 0) {
|
|
|
|
connection.db = db
|
|
|
|
} else {
|
|
|
|
connection.database = db
|
|
|
|
}
|
|
|
|
if (parsed.hostname) {
|
|
|
|
connection.host = parsed.hostname;
|
|
|
|
}
|
|
|
|
if (parsed.port) {
|
|
|
|
connection.port = parsed.port;
|
|
|
|
}
|
|
|
|
if (parsed.auth) {
|
|
|
|
var idx = parsed.auth.indexOf(':');
|
|
|
|
if (idx !== -1) {
|
|
|
|
connection.user = parsed.auth.slice(0, idx);
|
|
|
|
if (idx < parsed.auth.length - 1) {
|
|
|
|
connection.password = parsed.auth.slice(idx + 1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return connection
|
|
|
|
}
|