n8n/packages/cli/test/teardown.ts
Tomi Turtiainen 39df0d5ff1
chore(core): Remove mysql and mariadb specfic code (#24908)
Co-authored-by: Danny Martini <danny@n8n.io>
Co-authored-by: Claude <noreply@anthropic.com>
2026-01-29 15:57:33 +00:00

26 lines
914 B
TypeScript

import 'tsconfig-paths/register';
import { testDb } from '@n8n/backend-test-utils';
import { GlobalConfig } from '@n8n/config';
import { Container } from '@n8n/di';
import { DataSource as Connection } from '@n8n/typeorm';
export default async () => {
const { type: dbType } = Container.get(GlobalConfig).database;
if (dbType !== 'postgresdb') return;
const connection = new Connection(testDb.getBootstrapDBOptions());
await connection.initialize();
const query = 'SELECT datname as "Database" FROM pg_database';
const results: Array<{ Database: string }> = await connection.query(query);
const databases = results
.filter(({ Database: dbName }) => dbName.startsWith(testDb.testDbPrefix))
.map(({ Database: dbName }) => dbName);
const promises = databases.map(
async (dbName) => await connection.query(`DROP DATABASE ${dbName};`),
);
await Promise.all(promises);
await connection.destroy();
};