content: package com.alibaba.otter.canal.client.adapter.es6x.test;
  
  import java.util.Map;
  
  import org.junit.Assert;
  import org.junit.Before;
  import org.junit.Ignore;
  import org.junit.Test;
  
  import com.alibaba.otter.canal.client.adapter.es.core.config.ESSyncConfig;
  import com.alibaba.otter.canal.client.adapter.es.core.config.ESSyncConfigLoader;
  import com.alibaba.otter.canal.client.adapter.support.DatasourceConfig;
  
  @Ignore
  public class ConfigLoadTest {
  
      @Before
      public void before() {
          // AdapterConfigs.put("es", "mytest_user.yml");
          // 加载数据源连接池
          DatasourceConfig.DATA_SOURCES.put("defaultDS", TestConstant.dataSource);
      }
  
      @Test
      public void testLoad() {
          Map<String, ESSyncConfig> configMap = ESSyncConfigLoader.load(null);
          ESSyncConfig config = configMap.get("mytest_user.yml");
          config.validate();
          Assert.assertNotNull(config);
          Assert.assertEquals("defaultDS", config.getDataSourceKey());
          ESSyncConfig.ESMapping esMapping = config.getEsMapping();
          Assert.assertEquals("mytest_user", esMapping.getIndex());
          Assert.assertEquals("_doc", esMapping.getType());
          Assert.assertEquals("id", esMapping.getId());
          Assert.assertNotNull(esMapping.getSql());
  
          // Map<String, List<ESSyncConfig>> dbTableEsSyncConfig =
          // ESSyncConfigLoader.getDbTableEsSyncConfig();
          // Assert.assertFalse(dbTableEsSyncConfig.isEmpty());
      }
  }
  