zoukankan      html  css  js  c++  java
  • spring Multiple MongoTemplate

        <!-- 数据环境配置 -->
    
        <mongo:repositories base-package="com.my9yu.manager.module.server.repository" />
    
        <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}"></mongo:mongo>
        <mongo:db-factory id="mongoDbFactory" dbname="${mongo.dbname}"
            mongo-ref="mongo" username="${mongo.username}" password="${mongo.password}" />
    
        
        <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
             <constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />
        </bean>
    
    
        <!-- 数据环境配置2 -->
        <mongo:mongo id="mongo2" host="${cpmongo.host}" port="${cpmongo.port}"></mongo:mongo>
        <mongo:db-factory id="mongoDbFactory2" dbname="${cpmongo.dbname}"
            mongo-ref="mongo2" username="${cpmongo.username}" password="${cpmongo.password}" />
    
        <bean id="mongoTemplate2" name="mongoTemplate2" class="org.springframework.data.mongodb.core.MongoTemplate">
             <constructor-arg name="mongoDbFactory" ref="mongoDbFactory2" />
        </bean>
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(locations = { "copy.xml" })
    public class MongoCopyData {
    
        @Autowired
        private MongoTemplate mongoTemplate;
        @Autowired
        @Qualifier("mongoTemplate2")
        private MongoTemplate mongoTemplate2;
    
        @Autowired
        private OperatorRepository operatorRepository;
    
        @Test
        public void test() {
    
            List<Operator> ops = mongoTemplate.find(new Query(), Operator.class);
            List<Operator> ops2 = mongoTemplate2.find(new Query(), Operator.class);
    
            System.out.println("start++++++++++++++++++++++++++++++");
            System.out.println("1++++++++++++++++++++++++++++++" + JsonUtils.object2String(ops));
            System.out.println("2++++++++++++++++++++++++++++++" + JsonUtils.object2String(ops2));
    
            System.out.println("1++++++++++++++++++++++++++++++" + mongoTemplate.getDb().getName());
            System.out.println("2++++++++++++++++++++++++++++++" + mongoTemplate2.getDb().getName());
            long start = System.currentTimeMillis();
            for (final Operator op : ops) {
                operatorRepository.save(op);
            }
            long end = System.currentTimeMillis();
    
        }
    
    }
  • 相关阅读:
    为什么要使用Handler
    使用Java中的Timer和TimerTask
    Top子句对查询计划的影响
    一个单表死锁的示例
    tracer token 追踪标记
    DDL Trigger
    事物复制的troubleshooting 1
    在分发服务器上查看信息
    将windows 2003 sp2的cluster升级到windows 2008 r2
    DistributionDB过大的原因
  • 原文地址:https://www.cnblogs.com/solq/p/3656977.html
Copyright © 2011-2022 走看看