chore: Add database create & drop commands

This commit is contained in:
Faruk AYDIN
2021-10-05 18:37:57 +02:00
committed by Ali BARIN
parent c41d938f9e
commit 908f156a45
7 changed files with 193 additions and 2 deletions

View File

@@ -0,0 +1,9 @@
import { Client } from 'pg';
const client = new Client({
host: 'localhost',
user: 'postgres',
port: 5432,
})
export default client;

View File

@@ -0,0 +1,42 @@
import appConfig from '../../src/config/app';
import logger from '../../src/helpers/logger';
import client from './client';
const createDatabaseAndUser = async () => {
if(appConfig.appEnv !== 'development' && appConfig.appEnv !== 'test') {
const errorMessage = 'Database creation can be used only with development or test environments!'
logger.error(errorMessage)
return;
}
await client.connect();
await createDatabase();
await createDatabaseUser();
await grantPrivileges();
await client.end();
}
const createDatabase = async () => {
await client.query(`CREATE DATABASE ${appConfig.postgresDatabase}`);
logger.info(`Database: ${appConfig.postgresDatabase} created!`);
}
const createDatabaseUser = async () => {
await client.query(`CREATE USER ${appConfig.postgresUsername}`);
logger.info(`Database User: ${appConfig.postgresUsername} created!`);
}
const grantPrivileges = async () => {
await client.query(
`GRANT ALL PRIVILEGES ON DATABASE ${appConfig.postgresDatabase} TO ${appConfig.postgresUsername};`
);
logger.info(
`${appConfig.postgresUsername} has granted all privileges on ${appConfig.postgresDatabase}!`
);
}
createDatabaseAndUser();

View File

@@ -0,0 +1,29 @@
import appConfig from '../../src/config/app';
import logger from '../../src/helpers/logger';
import client from './client';
const dropDatabase = async () => {
if (appConfig.appEnv != 'development' && appConfig.appEnv != 'test') {
const errorMessage = 'Drop database command can be used only with development or test environments!'
logger.error(errorMessage)
return;
}
await client.connect();
await dropDatabaseAndUser();
await client.end();
}
const dropDatabaseAndUser = async() => {
await client.query(`DROP DATABASE IF EXISTS ${appConfig.postgresDatabase}`);
logger.info(`Database: ${appConfig.postgresDatabase} removed!`);
await client.query(`DROP USER IF EXISTS ${appConfig.postgresUsername}`);
logger.info(`Database User: ${appConfig.postgresUsername} removed!`);
}
dropDatabase();