diff --git a/backend/pricing-engine/src/db/connection.ts b/backend/pricing-engine/src/db/connection.ts
index 4bcbd616..3e8771e9 100644
--- a/backend/pricing-engine/src/db/connection.ts
+++ b/backend/pricing-engine/src/db/connection.ts
@@ -39,11 +39,11 @@ let mysqlPool: mysql.Pool | null = null;
 export async function getMySQL(): Promise<mysql.Pool> {
   if (!mysqlPool) {
     mysqlPool = mysql.createPool({
-      host: process.env.DB_HOST || '127.0.0.1',
+      host: process.env.DB_PRIMARY_HOST_V2 || process.env.DB_HOST || '127.0.0.1',
       port: parseInt(process.env.DB_PORT || '3306'),
-      database: process.env.DB_NAME || 'siro',
-      user: process.env.DB_USER || 'root',
-      password: process.env.DB_PASS || '',
+      database: process.env.DB_PRIMARY_NAME_V2 || process.env.DB_NAME || 'siro',
+      user: process.env.DB_PRIMARY_USER_V2 || process.env.DB_USER || 'root',
+      password: process.env.DB_PRIMARY_PASS_V2 || process.env.DB_PASS || '',
       waitForConnections: true,
       connectionLimit: 5,
       queueLimit: 0,