0

我继承了一些我显然不知道它是如何工作的 node.js 代码。我遇到的问题是它正在打开数据库连接而不是关闭或重用它们。所以在某些时候我必须终止节点进程以释放连接，否则数据库将开始抱怨。我尝试自己关闭连接，但不能理解基于事件的逻辑，因为我要么在第二个查询运行之前关闭连接，要么根本不运行。我在 Ubuntu 12.04.2 LTS 上使用节点 0.6.12 和节点 mysql 模块 v0.9.6。下面是一个示例模型方法。

this.search = function(options, callback) {
    if (options.post) {
        var query;
        var param;
        var limit;
        var results_per_page = 10;
        var page = (options.post.hasOwnProperty('page') && parseInt(options.post.page)) ? options.post.page : 1;

        limit = ' LIMIT ' + ((page-1)*(results_per_page)) + ',' + results_per_page;
        if (options.post.term) {
                var escaped_term = options.database_client.escape('%' + options.post.term + '%');
                query = "Q" + limit;
        } else {
                query = "Q" + limit;

        }
        options.database_client.query(query, [], query_results);
        // Tried closing DB connection here
        function query_results(err, results, fields) {
            var all_results = {};
            all_results.total_results = 0;
            all_results.total_pages = 0;
            all_results.current_page = page;
            all_results.results = [];

            if (err) {
                console.log('You have an error: ' + err);
                throw err;
            } else {
                if(!results[0]) {
                    callback(undefined, all_results);
                    return;
                } else{
                    options.database_client.query("SELECT found_rows() AS total", [], function(err, results2, fields) {
                        if (err) {
                            console.log('You have an error: ' + err);
                            throw err;
                        } else {
                            if (!results2[0]) {
                                callback(undefined, all_results);
                                return;
                            } else {
                                var all_results = {};
                                all_results.total_results = results2[0].total;
                                all_results.total_pages = Math.ceil(all_results.total_results/results_per_page);
                                all_results.current_page = page;

                                for(var property in results) {
                                    if(results.hasOwnProperty(property)){
                                        if(results[property] == "" || results[property] == " "){
                                            results[property] = null;
                                        }
                                    }
                                }
                                all_results.results = results;

                            }
                            callback(undefined, all_results);
                            return;
                        }

                    }); // end query
                }
            }
            // I think here is only closing one connection
            options.database_client.end();
        }
    // Also tried here but total_pages, total_results end up being 0 in the results callback
    }
};

我正在使用options.database_client.end();根据 node.js mysql 模块文档关闭数据库连接。任何帮助将不胜感激。

4

1 回答 1

0

实际上你正在这样做 1. 查询并调用 query_results，当结果准备好时 2. 使用匿名函数再次查询（找到的行） 3. 结束数据库连接

但是，这有一个问题：在 anon 之前调用 end。我认为found_rows 结果的函数。

我认为您在该代码中有几点，应该调用 options.database_client.end() 1. 抛出错误时（2 个位置） 2. 在“回调（未定义，all_results）;”之间 和“返回；” （也有2个地方）

或更好：关闭数据库，在第一行中的回调从该方法外部调用之后，甚至更好：在外部请求结束时

于 2013-06-12T20:31:51.037 回答