2014-04-04 49 views

回答

0

我決定用助力車這項任務。

require 'moped'  

def connect_mongo(config) 
    session = Moped::Session.new(["#{config['host']}:#{config['port']}"]) 
    session.use config['database'] 
    session.login config['username'],config['password'] 
    session 
end 

和保存用戶到另一個數據庫的代碼:

mongo = connect_mongo(config1) 
mongo_staging = connect_mongo(config2) 

users = mongo[:users].find.limit(limit) 
users.each do |user| 
    # some code here ... 
    mongo_staging[:users].insert(user) 
end 
相關問題