From 688aad2365a378422d3a38315cf7a1c943ac67de Mon Sep 17 00:00:00 2001 From: luchenqun Date: Tue, 18 Apr 2017 10:58:21 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E4=B8=AAtimer=E6=9F=A5=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E5=BA=93=EF=BC=8C=E5=8F=91=E7=8E=B0=E9=97=AE=E9=A2=98?= =?UTF-8?q?=E6=8C=82=E6=8E=89node,=E8=AE=A9forever=E5=B8=AE=E5=8A=A9?= =?UTF-8?q?=E9=87=8D=E5=90=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- database/db.js | 22 ++++++++++++---------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/database/db.js b/database/db.js index 00821c5..0074530 100644 --- a/database/db.js +++ b/database/db.js @@ -13,7 +13,7 @@ var client = {} var disconnect = 0; function handleDisconnect() { console.error("handleDisconnect, disconnect = ", disconnect++); - + client = mysql.createConnection(dbConfig); client.connect(function(err) { @@ -57,14 +57,17 @@ Date.prototype.format = function(fmt) { //author: meizz var db = { } -// var sql = "SELECT * FROM `users` WHERE `username` = 'luchenqun1'"; -// client.query(sql, (err, result) => { -// if (err) { -// console.log(err); -// } else { -// console.log(result); -// } -// }); + +// 每隔10秒查询一下,出现问题直接挂掉nodejs,让forever将其重启! +setInterval(function () { + var sql = "SELECT * FROM `users` WHERE `id` = '1'"; + client.query(sql, (err, result) => { + if (err) { + throw new Error("数据查询出问题了,直接挂掉程序,让forever重启应用,错误信息:" + JSON.stringify(err)); + } + }); +}, 10000); + db.getBookmarkbyUrl = function(user_id, url) { var sql = "SELECT * FROM `bookmarks` WHERE `user_id` = '" + user_id + "' AND `url` = '" + url + "'" @@ -899,7 +902,6 @@ db.getBookmarkWaitFavicon = function(today) { client.query(sql, (err, result) => { if (err) { reject(err); - handleDisconnect(); } else { resolve(result); }