db.queryAsync = Binding.fromStandard(db.query);
db.endAsync = Binding.fromStandard(db.end);
sql = 'select * from '+opt.db_name+'.'+tb_name+' limit 10';
//db.query(sql,function(err,data){
// console.log(err,data);
// db.end();
//})
var testAsync = eval(Jscex.compile("async",function(){
sql = 'select * from '+opt.db_name+'.'+tb_name+' limit 1';
var data = $await(db.queryAsync(sql));
$await(db.endAsync());
console.log(data);
}));
testAsync().start();
"version": "0.9.6","homepage": "https://github.com/felixge/node-mysql",
--
db = mysql.createClient({
host:opt.db_host,
port:opt.db_port,
user: opt.db_user,
password: opt.db_pass,
debug:false
});
db.queryAsync = Binding.fromStandard(db.query);
sql = 'select * from '+opt.db_name+'.'+tb_name+' limit 10';
//db.query(sql,function(err,data){
// console.log(err,data);
// db.end();
//})
var testAsync = eval(Jscex.compile("async",function(){
sql = 'select * from '+opt.db_name+'.'+tb_name+' limit 1';
var data = $await(db.queryAsync(sql));
db.end();
--
db.queryAsync = Binding.fromStandard(db.query);
sql = 'select * from '+opt.db_name+'.'+tb_name+' limit 10';
//db.query(sql,function(err,data){
// console.log(err,data);
// db.end();
//})
db.queryAsync2 = function(sql){
return Task.create(function(t){
db.query(sql,function(err,data){
t.complete("success",data);
});
})
}
var testAsync = eval(Jscex.compile("async",function(){
var sql = 'select * from '+opt.db_name+'.'+tb_name+' limit 1';
var data = $await(db.queryAsync2(sql));
db.end();
console.log(data);
}));
ret = testAsync().start();
console.log(ret);
嗯,但是还是没有完成,我打出ret = testAsync().start(); console.log(ret);
结果是{ id: 1,_delegate: [Function],_listeners: {},status: 'running' }方法里面的data还是没有输出
--
ret = testAsync().start();
console.log(ret);
{ id: 1,_delegate: [Function],_listeners: {},status: 'running' }
--
console.log(data);
这个输出结果在console.log(ret);
--
--