'use strict';
var co = require("co");
var cofy = require("cofy");
var redis = require('redis');
 
//enable redis to has a co ablitiy.
cofy.class(redis.RedisClient);
 
//now we can use mysql in co 
var client = redis.createClient(6379,'localhost');
co(function * () {
    //use class.$fn
    var r1 = yield client.$set('a' ,1);
    var r2 = yield client.$get('a');
    var r3 = yield client.$hmset('h' , {k1:'v1' , k2:'v2'});
    var r4 = yield client.$hget('h' ,'k1');
    console.log(r1,r2);
    console.log(r3,r4);
})();

'use strict';
var co = require("co");
var cofy = require("cofy");
var mysql = require('mysql');
 
//(felixge/node-mysql) has no extends entrance. so we can do this.
var PoolConnection = require('mysql/lib/PoolConnection.js');
var Pool = require('mysql/lib/Pool.js');
var PoolCluster = require('mysql/lib/PoolCluster.js');
 
//enable mysql to has a co ablitiy.
cofy.class(PoolConnection);
cofy.class(Pool);
cofy.class(PoolCluster);
 
var pool = mysql.createPool({
    host: "localhost",
    database: "db",
    user: "root",
    password: "pass",
});
//now we can use mysql in co 
co(function * () {
    var con = yield pool.$getConnection();
    //pay attention on precedence of operator! yield < [] .
    var result = (yield con.$query("select 1+1"))[0]; 
    console.log(result);
    con.release();
})();
 
 
//use it in transaction
co(function*(){
    var con ;
    try{
        con = yield pool.$getConnection();
        yield con.$beginTransaction();
        yield con.$query("select some");
        yield con.$query("insert some");
        yield con.$query("update some");
        yield con.$commit();
    }catch(e){
        yield con.$rollback();
        console.error(e);
        //to do 
    }finally{
        if(con){
            con.release();
        }
    }
})();

'use strict';
var request = require('request');
var cofy = require('cofy');
var co = require('co');
 
var $request = cofy.fn(request);
 
co(function*(){
    var r = yield $request({url:"http://www.google.com"});
    console.log(r);
})();