mysql createPool

pages/api/talas5/webserviceMap/GisStationsStatusDistrict.js

@@ -1,19 +1,10 @@
-// /pages/api/talas5/webserviceMap/gisStationsMeasurementsSQL.js
-import mysql from "mysql2/promise";
-
-// Erstellen eines Verbindungspools anstelle einer einzelnen Verbindung
-const pool = mysql.createPool({
-  host: process.env.DB_HOST,
-  user: process.env.DB_USER,
-  password: process.env.DB_PASSWORD,
-  database: process.env.DB_NAME,
-  port: process.env.DB_PORT,
-  waitForConnections: true,
-  connectionLimit: 10,
-  queueLimit: 0,
-});
+// /pages/api/talas5/webserviceMap/GisStationsStatusDistrict.js
+import getPool from "../../../../utils/mysqlPool"; // Singleton-Pool importieren
 
 export default async function handler(req, res) {
+  const pool = getPool(); // Singleton-Pool verwenden
+  let connection; // Verbindung deklarieren
+
   const { idMap, idUser } = req.query;
 
   if (!idMap || !idUser) {
@@ -21,22 +12,25 @@ export default async function handler(req, res) {
   }
 
   try {
+    // Verbindung aus dem Pool holen
+    connection = await pool.getConnection();
+
     let onlySystem = -1;
     let districtCounter = 0;
 
     // Get onlySystem
-    const [mapResult] = await pool.query("SELECT idsystem_typ FROM maps WHERE id = ?", [idMap]);
+    const [mapResult] = await connection.query("SELECT idsystem_typ FROM maps WHERE id = ?", [idMap]);
     if (mapResult.length > 0) {
       onlySystem = mapResult[0].idsystem_typ ?? -1;
     }
 
     // Get districtCounter
     if (idUser > 0) {
-      const [userLayerResult] = await pool.query("SELECT count(*) as count FROM user_User_layer1 WHERE iduser = ?", [idUser]);
+      const [userLayerResult] = await connection.query("SELECT count(*) as count FROM user_User_layer1 WHERE iduser = ?", [idUser]);
       districtCounter = userLayerResult[0].count;
     }
 
-    // Building the query
+    // Query erstellen
     let query = `
       SELECT ld.idLD, dc.message, p.level, p.name, p.color, ld.idDevice, de.isService, dc.idIcon
       FROM location as l
@@ -61,7 +55,7 @@ export default async function handler(req, res) {
     }
     query += ` ORDER BY p.level desc`;
 
-    const [results] = await pool.query(query, queryParams);
+    const [results] = await connection.query(query, queryParams);
 
     const mpss = {
       IdMap: idMap.toString(),
@@ -80,5 +74,8 @@ export default async function handler(req, res) {
   } catch (error) {
     console.error("Fehler beim Laden der Daten:", error);
     res.status(500).json({ error: "Interner Serverfehler" });
+  } finally {
+    // Stelle sicher, dass die Verbindung zurück in den Pool gegeben wird
+    if (connection) connection.release();
   }
 }

pages/api/talas5/webserviceMap/gisStationsMeasurementsSQL.js

@@ -1,27 +1,9 @@
 // /pages/api/talas5/webserviceMap/gisStationsMeasurementsSQL.js
-import mysql from "mysql2";
-
-// Erstellen eines Pools von Datenbankverbindungen
-const pool = mysql.createPool({
-  host: process.env.DB_HOST,
-  user: process.env.DB_USER,
-  password: process.env.DB_PASSWORD,
-  database: process.env.DB_NAME,
-  port: process.env.DB_PORT,
-  waitForConnections: true,
-  connectionLimit: 10,
-  queueLimit: 0,
-});
-
-pool.on("connection", function (connection) {
-  console.log("Database connected successfully.");
-});
-
-pool.on("error", function (err) {
-  console.error("Fehler beim Verbinden:", err);
-});
+import getPool from "../../../../utils/mysqlPool"; // Singleton-Pool importieren
 
 export default function handler(req, res) {
+  const pool = getPool(); // Singleton-Pool verwenden
+
   const idMap = req.query.idMap;
   if (req.method !== "GET") {
     return res.status(405).json({ error: "Nur GET Methode erlaubt" });