From 2555414e1175e49a17d6075e12c6e7bdc6b6d118 Mon Sep 17 00:00:00 2001
From: gaofy <1014893517@qq.com>
Date: Mon, 27 Nov 2023 18:28:07 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E8=BF=9E=E6=8E=A5?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E5=90=8E=E5=85=B3=E9=97=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 node-server/core/common.js |  6 +++---
 node-server/index.js       | 19 +++++++++++--------
 2 files changed, 14 insertions(+), 11 deletions(-)

diff --git a/node-server/core/common.js b/node-server/core/common.js
index ce08b24..cedeae6 100644
--- a/node-server/core/common.js
+++ b/node-server/core/common.js
@@ -94,15 +94,15 @@ const getDatabases = () => app.post('/getdatabases', function (req, res) {
 const mysqlQuery = (res, database, sql) => {
     if (!database) return res.status(500).send('database is ' + database);
     try {
-        // connection(database).connect();
+        connection(database).connect();
         connection(database).query(sql, (error, results, fields) => {
             if (error) {
-                // console.log(`${nowTime()} 错误：${JSON.stringify(error)}`);
+                console.log(`${nowTime()} 错误：${JSON.stringify(error)}`);
                 return res.status(500).send(error);
             } else {
                 res.send(results);
-                // connection(database).end();
             }
+            connection(database).end();
         });
         
     } catch (error) {
diff --git a/node-server/index.js b/node-server/index.js
index 3399bd8..dafffb3 100644
--- a/node-server/index.js
+++ b/node-server/index.js
@@ -22,14 +22,17 @@ app.use(bodyParser.json());
 
 app.listen(3001, () => console.log('服务启动! ' + nowTime()));
 
-common.con.connect();
-common.con.query("SHOW DATABASES", function (error, results, fields) {
-    if (error) {
-        console.log(`${nowTime()} 错误：${JSON.stringify(error)}`);
-    } else {
-        common.connection(results[results.length-1].Database).connect();
-    }
-});
+common.con.connect()
+setInterval(() => {
+    common.con.connect()
+}, 1000 * 60 * 60)
+// common.con.query("SHOW DATABASES", function (error, results, fields) {
+//     if (error) {
+//         console.log(`${nowTime()} 错误：${JSON.stringify(error)}`);
+//     } else {
+//         common.connection(results[results.length-1].Database).connect();
+//     }
+// });
 
 common.getDatabases();
 featureTable.getTable();