36 lines
1.3 KiB
TypeScript
36 lines
1.3 KiB
TypeScript
import { EntityManager, MikroORM } from '@mikro-orm/core';
|
|
import config from './mikro-orm.config.js';
|
|
import { EnvVars, getEnvVar } from './util/envvars.js';
|
|
import { getLogger, Logger } from './logging/initalize.js';
|
|
|
|
let orm: MikroORM | undefined;
|
|
export async function initORM(testingMode: boolean = false) {
|
|
const logger: Logger = getLogger();
|
|
|
|
logger.info('Initializing ORM');
|
|
logger.debug('MikroORM config is', config);
|
|
|
|
orm = await MikroORM.init(config(testingMode));
|
|
// Update the database scheme if necessary and enabled.
|
|
if (getEnvVar(EnvVars.DbUpdate)) {
|
|
await orm.schema.updateSchema();
|
|
} else {
|
|
const diff = await orm.schema.getUpdateSchemaSQL();
|
|
if (diff) {
|
|
throw Error(
|
|
'The database structure needs to be updated in order to fit the new database structure ' +
|
|
'of the app. In order to do so automatically, set the environment variable DWENGO_DB_UPDATE to true. ' +
|
|
'The following queries will then be executed:\n' +
|
|
diff
|
|
);
|
|
}
|
|
}
|
|
}
|
|
export function forkEntityManager(): EntityManager {
|
|
if (!orm) {
|
|
throw Error(
|
|
'Accessing the Entity Manager before the ORM is fully initialized.'
|
|
);
|
|
}
|
|
return orm.em.fork();
|
|
}
|