通过SPI方式定制druid filter

1. 通过@AutoLoad方式实现自己的Druid Filter

比如，Cat这个监控：

package com.wlqq.loan.rule.config;import com.alibaba.druid.filter.AutoLoad;
import com.alibaba.druid.filter.FilterAdapter;
import com.alibaba.druid.filter.FilterChain;
import com.alibaba.druid.proxy.jdbc.DataSourceProxy;
import com.alibaba.druid.proxy.jdbc.PreparedStatementProxy;
import com.alibaba.druid.proxy.jdbc.ResultSetProxy;
import com.alibaba.druid.proxy.jdbc.StatementProxy;
import com.dianping.cat.Cat;
import com.dianping.cat.CatConstants;
import com.dianping.cat.message.Message;
import com.dianping.cat.message.Transaction;import java.sql.SQLException;/*** cat监控drui连接池** @author flowkr90@gmail.com*/
@AutoLoad
public class DruidCatFilter extends FilterAdapter {private String dbType;private String url;@Overridepublic void init(DataSourceProxy dataSource) {dbType = dataSource.getDbType();url = dataSource.getUrl();}@Overridepublic boolean statement_execute(FilterChain chain, StatementProxy statement, String sql) throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);boolean result;try {result = super.statement_execute(chain, statement, sql);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic boolean statement_execute(FilterChain chain, StatementProxy statement, String sql, int autoGeneratedKeys)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);boolean result;try {result = super.statement_execute(chain, statement, sql, autoGeneratedKeys);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic boolean statement_execute(FilterChain chain, StatementProxy statement, String sql, int[] columnIndexes)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);boolean result;try {result = super.statement_execute(chain, statement, sql, columnIndexes);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic boolean statement_execute(FilterChain chain, StatementProxy statement, String sql, String[] columnNames)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);boolean result;try {result = super.statement_execute(chain, statement, sql, columnNames);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic int[] statement_executeBatch(FilterChain chain, StatementProxy statement) throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", statement.getBatchSql());int[] result;try {result = super.statement_executeBatch(chain, statement);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic ResultSetProxy statement_executeQuery(FilterChain chain, StatementProxy statement, String sql)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);ResultSetProxy result;try {result = super.statement_executeQuery(chain, statement, sql);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic int statement_executeUpdate(FilterChain chain, StatementProxy statement, String sql) throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);int result;try {result = super.statement_executeUpdate(chain, statement, sql);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic int statement_executeUpdate(FilterChain chain, StatementProxy statement, String sql, int autoGeneratedKeys)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);int result;try {result = super.statement_executeUpdate(chain, statement, sql, autoGeneratedKeys);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic int statement_executeUpdate(FilterChain chain, StatementProxy statement, String sql, int[] columnIndexes)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);int result;try {result = super.statement_executeUpdate(chain, statement, sql, columnIndexes);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic int statement_executeUpdate(FilterChain chain, StatementProxy statement, String sql, String[] columnNames)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", sql);int result;try {result = super.statement_executeUpdate(chain, statement, sql, columnNames);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic boolean preparedStatement_execute(FilterChain chain, PreparedStatementProxy statement) throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", statement.getSql());boolean result;try {result = super.preparedStatement_execute(chain, statement);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic ResultSetProxy preparedStatement_executeQuery(FilterChain chain, PreparedStatementProxy statement)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", statement.getSql());ResultSetProxy result;try {result = super.preparedStatement_executeQuery(chain, statement);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}@Overridepublic int preparedStatement_executeUpdate(FilterChain chain, PreparedStatementProxy statement)throws SQLException {Transaction transaction = Cat.newTransaction(CatConstants.TYPE_SQL, url);Cat.logEvent("SQL.DbType", dbType);Cat.logEvent("SQL.Database", url);Cat.logEvent("SQL.sql", statement.getSql());int result;try {result = super.preparedStatement_executeUpdate(chain, statement);transaction.setStatus(Message.SUCCESS);} catch (SQLException e) {Cat.logError(e);transaction.setStatus(e);throw e;} finally {transaction.complete();}return result;}}

配置SPI

在 src/main/resources/META-INF/services 目录下创建 com.alibaba.druid.filter.Filter这个文件

文件内容为 filter 的全路径

com.wlqq.loan.rule.config.DruidCatFilter

通过SPI方式定制druid filter相关推荐

niosii spi 外部_NIOS II SPI详解如何使用SPI方式传输
NIOS II SPI 详解如何使用 SPI 方式传输 1 .说明本文是依据笔者阅读< Embedded Peripherals (ver 9.0, Mar 2009, 4 MB).pdf ...
台式机安装EXSI，通过官方方式定制安装包
台式机安装EXSI,通过官方方式定制安装包需要使用第三方工具 ESXi-Customizer-PS 对安装镜像进行修改,加载我们想要的驱动. 下载和安装 PowerShell: https://do ...
STM32使用SPI方式读写SD 卡
掌握SD卡协议原理,用STM32F103 完成对SD卡的数据读取(FAT文件模式). 文章目录一.前言 1.SD卡 2.FATFS 二.工程分析 1.代码分析 2.连线 3.编译工程并烧录 4.验证 ...
② ESP8266 开发学习笔记_By_GYC 【ESP8266 驱动 ws2812 三原色灯（spi方式稳定灯光）】
目录 ② ESP8266 开发学习笔记_By_GYC [ESP8266 驱动 ws2812 三原色灯(spi方式稳定灯光)] 一.驱动ws2812遇到的问题二.可能的方案三.具体实现四.测试程 ...
stm32 4线SPI方式驱动CH452A数码管驱动芯片
stm32 采用的是4线SPI方式连接.操作命令是12位的数据,采用的是io模拟的方式驱动.试过使用硬件SPI驱动,但是命令只支持12位,硬件SPI发送的是8位或者16位,是驱动不起来的. 常用指令如 ...
基于GCCAVR的TLC2543读写程序----模拟SPI方式实现
TLC2453的操作也比较简单,通过模拟的方式实现只需要看一下时序图把时序搞对即可. 在硬件SPI中,读和写实可以通过硬件同步进行的,因此在写入本次命令字时可以同时读取上一次命令的数据,在模拟SPI的 ...
基于SPI方式实现OLED屏显
文章目录一.SPI简介 1.1物理层 1.2协议层二.OLED 2.1定义 2.2优势 2.3模块工作模式选择 2.4模块特点三.实验过程 3.1实验准备 3.2硬件连接 3.3程序烧录 3.3 ...
基于Xilinx平台MicroBlaze的SPI方式FatFs移植
FatFs是面向小型嵌入式系统的一种通用的FAT文件系统.它完全是由AISI C语言编写并且完全独立于底层的I/O介质.因此它可以很容易地不加修改地移植到其他的处理器当中,如8051.PIC.AVR. ...
SPI方式读写SD卡速度有多快？
很久没有写公众号了,一方面忙,另一方面也不知道写些什么内容,大家如果有想了解的(前提是我也懂),可以后台发送给我. 今天主要来测试一下SPI读写SD卡的速度.SD卡是一个嵌入式中非常常用的外设,可以用 ...

通过SPI方式定制druid filter

1. 通过@AutoLoad方式实现自己的Druid Filter

配置SPI

通过SPI方式定制druid filter相关推荐

最新文章

热门文章