我应该在什么时候关闭数据库连接？

社区

Lliuj0225发布于 14 年前最后回复 14 年前

1788590

首先向到来的各位表示感谢！

我的程序大概是这样子的，我现在应该在哪里db.end()呢：

var mysql = require('mysql');
var db = mysql.createClient();

fn1();
fn2();

function fn1(){
  db.query('select * fro table1', function(error, rows){
    rows.forEach(function(row){
      db.query('update table set field=? where id=?', [value, row.id]);
    });
  });
}

function fn2(){
  db.query('select * from table2', function(error, rows){
    rows.forEach(function(row){
      db.query('update table2 set field=? where id=?', [value, row.id]);
    });
  });
}

查看回复

liuj0225#1714 年前

引用 iamsur123最近一直在用Async，蛮好用的

确实不错

liuj0225#1614 年前

引用 oldhu//函数改成支持回调的方式 var f1 = function (callback) { setTimeout(function () { console.log('1') callback(...

多谢，帮我解决了问题

iamsur123#1514 年前

最近一直在用Async，蛮好用的

hades#1414 年前

用wind.js吧，还是用传统思想去写程序吧

oldhu#1314 年前

//函数改成支持回调的方式
var f1 = function  (callback) {
	setTimeout(function () {
		console.log('1')
		callback()
	},1000)
}

var f2 = function  (callback) {
	setTimeout(function () {
		console.log('2')
		callback()
	},1000)
}

//用一个类 管理函数队列 
//一个简单的实现 有个叫Async的库就是干这个的
function Async (fns) {
	this._fns = fns
}
Async.prototype.next = function() {
	if(fn = this._fns.shift()){
		fn (this.next.bind(this))
	}else{
		console.log('搞完了')
	}
};


async = new Async([f1,f2])
async.next()

ubuntuus#1214 年前

设置一个标志，在多个回调中检测标志后再判断是否关闭

chloe#1114 年前

引用 chloe我觉得你这样写sql 是有问题的，你为什么不写一个查询，然后执行完之后关闭

@liuj0225 这样的话可以在fn1 fn2加一个callback告诉这个查询完成再进行相应的处理

liuj0225#1014 年前

引用 chloe我觉得你这样写sql 是有问题的，你为什么不写一个查询，然后执行完之后关闭

上面这个是我写的简单想表达是这个意思，实际业务比这个要复杂，必须要这样做的

chloe#914 年前

我觉得你这样写sql 是有问题的，你为什么不写一个查询，然后执行完之后关闭

dtrex#814 年前

引用 imzshh你要把fn1、fn2也写成异步的形式。