mirror of
https://github.com/directus/directus.git
synced 2026-04-03 03:00:39 -04:00
Add validateDBConnection function
This commit is contained in:
@@ -3,10 +3,11 @@ import bodyParser from 'body-parser';
|
||||
import logger from 'express-pino-logger';
|
||||
import path from 'path';
|
||||
import cors from 'cors';
|
||||
|
||||
import env, { validateEnv } from './env';
|
||||
import { validateDBConnection } from './database';
|
||||
|
||||
validateEnv();
|
||||
validateDBConnection();
|
||||
|
||||
import errorHandler from './middleware/error-handler';
|
||||
|
||||
|
||||
@@ -2,6 +2,7 @@ import knex, { Config } from 'knex';
|
||||
import dotenv from 'dotenv';
|
||||
import camelCase from 'camelcase';
|
||||
import path from 'path';
|
||||
import logger from '../logger';
|
||||
import env from '../env';
|
||||
|
||||
import SchemaInspector from 'knex-schema-inspector';
|
||||
@@ -31,6 +32,15 @@ if (env.DB_CLIENT === 'sqlite3') {
|
||||
|
||||
const database = knex(knexConfig);
|
||||
|
||||
export const schemaInspector = SchemaInspector(database);
|
||||
export async function validateDBConnection() {
|
||||
try {
|
||||
await database.raw('select 1+1 as result');
|
||||
} catch (error) {
|
||||
logger.fatal(`Can't connect to the database.`);
|
||||
logger.fatal(error);
|
||||
process.exit(1);
|
||||
}
|
||||
}
|
||||
|
||||
export const schemaInspector = SchemaInspector(database);
|
||||
export default database;
|
||||
|
||||
Reference in New Issue
Block a user