polylines tooltip content

pages/api/talas5/webserviceMap/GisStationsStatusDistrict.js

@@ -1,47 +1,42 @@
+// /pages/api/talas5/webserviceMap/gisStationsMeasurementsSQL.js
 import mysql from "mysql2/promise";
 
-const dbConfig = {
+// 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,
+});
 
 export default async function handler(req, res) {
   const { idMap, idUser } = req.query;
 
   if (!idMap || !idUser) {
-    res.status(400).json({ error: "idMap and idUser are required" });
-    return;
+    return res.status(400).json({ error: "idMap and idUser are required" });
   }
 
-  let connection;
   try {
-    connection = await mysql.createConnection(dbConfig);
-
     let onlySystem = -1;
     let districtCounter = 0;
 
     // Get onlySystem
-    const [mapResult] = await connection.execute(
-      "SELECT idsystem_typ FROM maps WHERE id = ?",
-      [idMap]
-    );
+    const [mapResult] = await pool.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 connection.execute(
-        "SELECT count(*) as count FROM user_User_layer1 WHERE iduser = ?",
-        [idUser]
-      );
+      const [userLayerResult] = await pool.query("SELECT count(*) as count FROM user_User_layer1 WHERE iduser = ?", [idUser]);
       districtCounter = userLayerResult[0].count;
     }
 
-    // Get GisStatusStations
+    // Building the query
     let query = `
       SELECT ld.idLD, dc.message, p.level, p.name, p.color, ld.idDevice, de.isService, dc.idIcon
       FROM location as l
@@ -55,25 +50,18 @@ export default async function handler(req, res) {
       WHERE p.level < 100 AND co.X > 0
     `;
 
-    if (districtCounter > 0) {
-      query += ` AND a.iddistrict IN (SELECT iddistrict FROM user_user_layer1 WHERE iduser = ?)`;
-    }
-
-    if (onlySystem >= 0) {
-      query += ` AND de.idsystem_typ = ?`;
-    }
-
-    query += ` ORDER BY p.level desc`;
-
     const queryParams = [idMap];
     if (districtCounter > 0) {
+      query += ` AND a.iddistrict IN (SELECT iddistrict FROM user_user_layer1 WHERE iduser = ?)`;
       queryParams.push(idUser);
     }
     if (onlySystem >= 0) {
+      query += ` AND de.idsystem_typ = ?`;
       queryParams.push(onlySystem);
     }
+    query += ` ORDER BY p.level desc`;
 
-    const [results] = await connection.execute(query, queryParams);
+    const [results] = await pool.query(query, queryParams);
 
     const mpss = {
       IdMap: idMap.toString(),
@@ -92,9 +80,5 @@ 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 {
-    if (connection) {
-      await connection.end();
-    }
   }
 }