IT4Change/gradido
3
0
Fork 0
mirror of https://github.com/IT4Change/gradido.git synced 2026-03-01 12:44:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

use connection pool for drizzle orm

Browse Source
This commit is contained in:
einhornimmond 2025-12-20 13:26:42 +01:00
parent c03f1ecda7
commit b0e4981463
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
database/src/AppDatabase.ts
View File

@ -1,7 +1,7 @@
import { drizzle, MySql2Database } from 'drizzle-orm/mysql2'
import Redis from 'ioredis'
import { getLogger } from 'log4js'
import { Connection, createConnection } from 'mysql2/promise'
import { Connection, createConnection, createPool, Pool } from 'mysql2/promise'
import { DataSource as DBDataSource, FileLogger } from 'typeorm'
import { latestDbVersion } from '.'
import { CONFIG } from './config'
@ -14,7 +14,7 @@ export class AppDatabase {
private static instance: AppDatabase
private dataSource: DBDataSource | undefined
private drizzleDataSource: MySql2Database | undefined
private drizzleConnection: Connection | undefined
private drizzlePool: Pool | undefined
private redisClient: Redis | undefined
/**
@ -48,10 +48,10 @@ export class AppDatabase {
}
public getDrizzleDataSource(): MySql2Database {
if (!this.drizzleDataSource) {
throw new Error('Drizzle connection not initialized')
if (!this.drizzlePool) {
throw new Error('Drizzle connection pool not initialized')
}
return this.drizzleDataSource
return drizzle({ client: this.drizzlePool })
}
// create database connection, initialize with automatic retry and check for correct database version
@ -106,22 +106,25 @@ export class AppDatabase {
logger.info('Redis status=', this.redisClient.status)
if (!this.drizzleDataSource) {
this.drizzleConnection = await createConnection({
this.drizzlePool = createPool({
host: CONFIG.DB_HOST,
user: CONFIG.DB_USER,
password: CONFIG.DB_PASSWORD,
database: CONFIG.DB_DATABASE,
port: CONFIG.DB_PORT,
waitForConnections: true,
connectionLimit: 20,
queueLimit: 100,
enableKeepAlive: true,
keepAliveInitialDelay: 10000,
})
this.drizzleDataSource = drizzle({ client: this.drizzleConnection })
}
}
public async destroy(): Promise<void> {
await Promise.all([this.dataSource?.destroy(), this.drizzleConnection?.end()])
await Promise.all([this.dataSource?.destroy(), this.drizzlePool?.end()])
this.dataSource = undefined
this.drizzleConnection = undefined
this.drizzleDataSource = undefined
this.drizzlePool = undefined
if (this.redisClient) {
await this.redisClient.quit()
this.redisClient = undefined