2014-04-04 39 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 
相关问题