import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
@Bean
public DataSource definitionDataSource() throws Exception {
    StatFilter statFilter = new StatFilter();

    Properties config = new Properties();
    config.setProperty("url", dataSourceProperties.getUrl());
    config.setProperty("username", dataSourceProperties.getUsername());
    config.setProperty("password", dataSourceProperties.getPassword());
    config.setProperty("driverClassName", dataSourceProperties.getDriverClassName());

    config.setProperty("filters", "slf4j");
    DruidDataSource dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(config);
    dataSource.setProxyFilters(Collections.singletonList(statFilter));

    return dataSource;
}
 

import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
@Bean
@ConditionalOnProperty(prefix = DRUID_STAT_FILTER_PREFIX, name = "enabled", havingValue = "true", matchIfMissing = true)
@ConfigurationProperties(DRUID_STAT_FILTER_PREFIX)
public StatFilter statFilter() {
    log.debug("druid stat-filter init...");
    return new StatFilter();
}
 

import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
public AutoGen init(String configPath) throws IOException {
    if(configPath == null || configPath.length() == 0){
        configPath = PathKit.getRootClassPath() + "/defaultRule.json" ;
    }
    config = getConfig(configPath) ;
    if(config == null){
        throw new NullPointerException("No Config.");
    }
    JSONObject dataSourceConfig = config.getJSONObject("dataSource") ;
    dp = new DruidPlugin(
            dataSourceConfig.getString("url"),
            dataSourceConfig.getString("user"),
            dataSourceConfig.getString("pwd")
    );
    dp.addFilter(new StatFilter());
    WallFilter wall = new WallFilter();
    wall.setDbType("mysql");
    WallConfig wallConfig = new WallConfig();
    wallConfig.setFunctionCheck(false);
    wallConfig.setCreateTableAllow(true);
    wallConfig.setCommentAllow(true);
    wallConfig.setMultiStatementAllow(true);
    wall.setConfig(wallConfig);
    dp.addFilter(wall);
    arp = new ActiveRecordPlugin(dp);
    arp.setContainerFactory(new CaseInsensitiveContainerFactory(true));// 大小写不敏感
    arp.setDialect(new MysqlDialect());
    dp.start();
    arp.start();
    resourceLoader = new FileResourceLoader(config.getString("baseTemplatePath"),"utf-8");
    cfg = Configuration.defaultConfiguration();
    gt = new GroupTemplate(resourceLoader, cfg);
    System.out.println("-- init success .");
    return this ;
}
 

import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
/**
 * 创建数据源，有前缀
 *
 * @param dataSourceMap
 * @param prefix
 * @return
 * @throws SQLException
 */
private DruidDataSource buildDruidDataSource(Map<String, Object> dataSourceMap, String prefix) throws SQLException {
    DruidDataSource dataSource = new DruidDataSource();
    dataSource.setName(MapUtils.getString(dataSourceMap, prefix + "name"));
    dataSource.setDriverClassName(MapUtils.getString(dataSourceMap, prefix + "driverClass"));
    dataSource.setUrl(MapUtils.getString(dataSourceMap, prefix + "url"));
    dataSource.setUsername(MapUtils.getString(dataSourceMap, prefix + "username"));
    dataSource.setPassword(MapUtils.getString(dataSourceMap, prefix + "password"));

    // 配置过滤器
    WallFilter wallFilter = new WallFilter();
    StatFilter statFilter = new StatFilter();
    statFilter.setSlowSqlMillis(5000);
    statFilter.setLogSlowSql(true);
    statFilter.setMergeSql(true);
    Slf4jLogFilter slf4jLogFilter = new Slf4jLogFilter();
    slf4jLogFilter.setDataSourceLogEnabled(false);
    slf4jLogFilter.setConnectionLogEnabled(false);
    slf4jLogFilter.setConnectionLogErrorEnabled(true);
    slf4jLogFilter.setResultSetLogEnabled(false);
    slf4jLogFilter.setResultSetLogErrorEnabled(true);
    slf4jLogFilter.setStatementLogEnabled(false);
    slf4jLogFilter.setStatementExecutableSqlLogEnable(true);
    slf4jLogFilter.setStatementSqlFormatOption(new SQLUtils.FormatOption(false, false));

    List filterList = new ArrayList();
    filterList.add(wallFilter);
    filterList.add(statFilter);
    filterList.add(slf4jLogFilter);
    dataSource.setProxyFilters(filterList);

    return dataSource;
}
 

import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
@Override
public void initialize() throws SQLException {
    Prop prop = PropKit.use(DB_CONFIG);
    druidPlugin = new DruidPlugin(prop.get("jdbcUrl"), prop.get("user"), prop.get("password"));

    // StatFilter提供JDBC层的统计信息
    druidPlugin.addFilter(new StatFilter());
    // WallFilter的功能是防御SQL注入攻击
    WallFilter wallFilter = new WallFilter();
    wallFilter.setDbType("mysql");
    druidPlugin.addFilter(wallFilter);
    druidPlugin.start();
}
 

import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
/**
 * DruidPlugin
 * @param prop ： property
 * @return
 */
private DruidEncryptPlugin getDruidPlugin(String ds) {
	this.loadPropertyFile();
	String url = this.getProperty(String.format("db.%s.url", ds));
	url = String.format(URL_TEMPLATE, ds, url);
	String endsWith = "?characterEncoding=UTF8&zeroDateTimeBehavior=convertToNull";
	if (!url.endsWith(endsWith)) {
		url += endsWith;
	}
	DruidEncryptPlugin dp = new DruidEncryptPlugin(url,
			this.getProperty(String.format(USER_TEMPLATE, ds)),
			this.getProperty(String.format(PASSWORD_TEMPLATE, ds)));
	dp.setInitialSize(this.getPropertyToInt(String.format(INITSIZE_TEMPLATE, ds)));
	dp.setMaxActive(this.getPropertyToInt(String.format(MAXSIZE_TEMPLATE, ds)));
	dp.addFilter(new StatFilter());
	WallFilter wall = new WallFilter();
	wall.setDbType(ds);
	dp.addFilter(wall);
	
	if (this.geRuned) {
		dp.start();
		BaseModelGeneratorExt baseGe = new BaseModelGeneratorExt(this.getBaseModelPackage(), this.getBaseModelOutDir());
		baseGe.setGenerateTableNameInModel(this.getGeTableNameInModel());
		baseGe.setGenerateTableColumnNameInModel(this.getGeTableColumnName());
		ModelGenerator modelGe = new ModelGenerator(this.getModelPackage(), this.getBaseModelPackage(), this.getModelOutDir());
		modelGe.setGenerateDaoInModel(this.getGeDaoInModel());
		Generator ge = new Generator(dp.getDataSource(), baseGe, modelGe);
		MappingKitGeneratorExt mappingKitGe = new MappingKitGeneratorExt(this.getModelPackage(), this.getModelOutDir());
		if (!JFinalConfigExt.DEFAULT_MAPPINGKIT_CLASS_NAME.equals(this.getMappingKitClassName())) {
			mappingKitGe.setMappingKitClassName(this.getMappingKitClassName());
		}
		mappingKitGe.setGenerateMappingArpKit(this.getGeMappingArpKit());
		mappingKitGe.setGenerateTableMapping(this.getGeTableMapping());
		ge.setMappingKitGenerator(mappingKitGe);
		ge.setGenerateDataDictionary(this.getGeDictionary());
		ge.generate();
	}
	
	return dp;
}
 

import com.alibaba.druid.filter.stat.StatFilter; //导入依赖的package包/类
@Bean
@ConfigurationProperties(prefix = "spring.datasource.druid.stat-filter")
public Filter statFilter() {
    return new StatFilter();
}