Infrastructure/ghost
0
Fork 0
mirror of https://github.com/TryGhost/Ghost.git synced 2025-01-20 22:42:53 -05:00
Code Issues Activity

Caching db config in migration utils

Browse source
This commit is contained in:
Hannah Wolfe 2014-07-21 11:50:00 +01:00
parent cf9839c71d
commit 44cfcb6b01
1 changed files with 21 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
core/server/data/utils/index.js
View file

@ -2,7 +2,9 @@ var _ = require('lodash'),
when = require('when'), when = require('when'),
config = require('../../config'), config = require('../../config'),
schema = require('../schema').tables, schema = require('../schema').tables,
clients = require('./clients'); clients = require('./clients'),
dbConfig;
function addTableColumn(tablename, table, columnname) { function addTableColumn(tablename, table, columnname) {
@ -42,25 +44,29 @@ function addTableColumn(tablename, table, columnname) {
} }
function addColumn(table, column) { function addColumn(table, column) {
return config().database.knex.schema.table(table, function (t) { dbConfig = dbConfig || config().database;
return dbConfig.knex.schema.table(table, function (t) {
addTableColumn(table, t, column); addTableColumn(table, t, column);
}); });
} }
function addUnique(table, column) { function addUnique(table, column) {
return config().database.knex.schema.table(table, function (table) { dbConfig = dbConfig || config().database;
return dbConfig.knex.schema.table(table, function (table) {
table.unique(column); table.unique(column);
}); });
} }
function dropUnique(table, column) { function dropUnique(table, column) {
return config().database.knex.schema.table(table, function (table) { dbConfig = dbConfig || config().database;
return dbConfig.knex.schema.table(table, function (table) {
table.dropUnique(column); table.dropUnique(column);
}); });
} }
function createTable(table) { function createTable(table) {
return config().database.knex.schema.createTable(table, function (t) { dbConfig = dbConfig || config().database;
return dbConfig.knex.schema.createTable(table, function (t) {
var columnKeys = _.keys(schema[table]); var columnKeys = _.keys(schema[table]);
_.each(columnKeys, function (column) { _.each(columnKeys, function (column) {
return addTableColumn(table, t, column); return addTableColumn(table, t, column);
@ -69,11 +75,13 @@ function createTable(table) {
} }
function deleteTable(table) { function deleteTable(table) {
return config().database.knex.schema.dropTableIfExists(table); dbConfig = dbConfig || config().database;
return dbConfig.knex.schema.dropTableIfExists(table);
} }
function getTables() { function getTables() {
var client = config().database.client; dbConfig = dbConfig || config().database;
var client = dbConfig.client;
if (_.contains(_.keys(clients), client)) { if (_.contains(_.keys(clients), client)) {
return clients[client].getTables(); return clients[client].getTables();
@ -83,7 +91,8 @@ function getTables() {
} }
function getIndexes(table) { function getIndexes(table) {
var client = config().database.client; dbConfig = dbConfig || config().database;
var client = dbConfig.client;
if (_.contains(_.keys(clients), client)) { if (_.contains(_.keys(clients), client)) {
return clients[client].getIndexes(table); return clients[client].getIndexes(table);
@ -93,7 +102,8 @@ function getIndexes(table) {
} }
function getColumns(table) { function getColumns(table) {
var client = config().database.client; dbConfig = dbConfig || config().database;
var client = dbConfig.client;
if (_.contains(_.keys(clients), client)) { if (_.contains(_.keys(clients), client)) {
return clients[client].getColumns(table); return clients[client].getColumns(table);
@ -103,7 +113,8 @@ function getColumns(table) {
} }
function checkTables() { function checkTables() {
var client = config().database.client; dbConfig = dbConfig || config().database;
var client = dbConfig.client;
if (client === 'mysql') { if (client === 'mysql') {
return clients[client].checkPostTable(); return clients[client].checkPostTable();