package com.iplatform.gather.config;
|
|
import com.iplatform.gather.support.DefaultMetaDataEngine;
|
import com.walker.connector.LocalAddress;
|
import com.walker.db.DatabaseType;
|
import com.walker.dbmeta.DatabaseMetaEngine;
|
import com.walker.dbmeta.support.MySQLMetaEngine;
|
import com.walker.dbmeta.support.OracleMetaEngine;
|
import com.walker.jdbc.JdbcInspector;
|
import com.walker.store.AbstractMetaDataEngine;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
|
@Configuration
|
@ConditionalOnProperty(prefix = "iplatform.gather", name = "enabled", havingValue = "true", matchIfMissing = false)
|
public class GatherConfig {
|
|
private final transient Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
@Bean
|
public GatherProperties gatherProperties(){
|
return new GatherProperties();
|
}
|
|
@Bean
|
public LocalAddress localAddress(JdbcInspector jdbcInspector){
|
LocalAddress localAddress = new LocalAddress(jdbcInspector.getPrimaryDataSourceMeta());
|
logger.info("localAddress.serviceName = " + localAddress.getServiceName());
|
// logger.info("localAddress.service = " + localAddress.getService());
|
return localAddress;
|
}
|
|
@Bean
|
public AbstractMetaDataEngine metaDataEngine(JdbcInspector jdbcInspector){
|
DatabaseMetaEngine databaseMetaEngine = null;
|
DatabaseType databaseType = jdbcInspector.getPrimaryDatabaseType();
|
if(databaseType == DatabaseType.MYSQL){
|
databaseMetaEngine = new MySQLMetaEngine();
|
} else if(databaseType == DatabaseType.ORACLE){
|
databaseMetaEngine = new OracleMetaEngine();
|
} else {
|
throw new UnsupportedOperationException("暂不支持其他数据库 DatabaseMetaEngine 创建: " + databaseType.toString());
|
}
|
|
// AbstractMetaDataEngine metaDataEngine = new TestMetaDataEngine();
|
AbstractMetaDataEngine metaDataEngine = new DefaultMetaDataEngine();
|
metaDataEngine.setDatabaseMetaEngine(databaseMetaEngine);
|
logger.info("创建了对象: AbstractMetaDataEngine");
|
return metaDataEngine;
|
}
|
}
|
