• 92795

    文章

  • 776

    评论

  • 17

    友链

  • 最近新加了换肤功能,大家多来逛逛吧~~~~
  • 喜欢这个网站的朋友可以加一下QQ群,我们一起交流技术。

JDBC - 使用 mysql-connector-java-5.1.13.jar 中的拦截器

撸了今年阿里、腾讯和美团的面试,我有一个重要发现.......>>

// 加载MySql的驱动类
try {
    Class.forName("com.mysql.jdbc.Driver"); // 注册驱动到DriverManager
} catch (ClassNotFoundException e) {
    System.out.println("找不到驱动程序类 ,加载驱动失败!");
    e.printStackTrace();
}
// 连接MySql数据库
String url = "jdbc:mysql://127.0.0.1:3306/test?useSSL=false&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true";
// 配置拦截器
url += "&statementInterceptors=cn.java.database.jdbc.mysql.interceptors.FooOneStatementInterceptor";
String username = "root";
String password = "123456";
try {
    connection = DriverManager.getConnection(url, username, password); // 连接数据库,并完成握手
    if (connection instanceof com.mysql.jdbc.ConnectionImpl){

    }
} catch (SQLException se) {
    System.out.println("数据库连接失败!");
    se.printStackTrace();
}

package cn.java.database.jdbc.mysql.interceptors;

import com.mysql.jdbc.*;

import java.sql.SQLException;
import java.util.Properties;

public class FooOneStatementInterceptor implements StatementInterceptor {

    private Connection connection;
    private Properties properties;

    /**
     * 初始化
     *
     * @param connection
     * @param properties
     * @throws SQLException
     */
    @Override
    public void init(Connection connection, Properties properties) throws SQLException {
        // Connection
        {
            if (connection instanceof com.mysql.jdbc.ConnectionImpl) {

            }
        }

        // Properties
        {
            System.out.println("properties.get(\"user\") = " + properties.get("user"));
            System.out.println("properties.get(\"password\") = " + properties.get("password"));
        }


        this.connection = connection;
        this.properties = properties;
    }

    /**
     * 只在顶级执行
     *
     * @return
     */
    @Override
    public boolean executeTopLevelOnly() {
        return false;
    }


    /**
     * 执行请求前
     * <p>
     * 可以在这里篡改执行的sql语句
     *
     * @param sql
     * @param interceptedStatement
     * @param connection
     * @return 如果返回的不是为null,那么不会发起远程的请求。而且不会执行"Interceptor链条"后面的Interceptor
     * @throws SQLException
     */
    @Override
    public ResultSetInternalMethods preProcess(String sql, Statement interceptedStatement, Connection connection) throws SQLException {
        System.out.println("--- cn.java.database.jdbc.mysql.interceptors.FooOneStatementInterceptor.preProcess ---");

        if (interceptedStatement instanceof com.mysql.jdbc.PreparedStatement) {
            String preparedSql = ((PreparedStatement) interceptedStatement).getPreparedSql();
            System.out.println("preparedSql = " + preparedSql);

            String asSql = ((PreparedStatement) interceptedStatement).asSql(true);
            System.out.println("asSql = " + asSql);
        } else if (interceptedStatement instanceof com.mysql.jdbc.StatementImpl) {
            if (interceptedStatement instanceof com.mysql.jdbc.Statement) {

            }
            System.out.println("sql = " + sql);
        }

        if (connection instanceof com.mysql.jdbc.ConnectionImpl) {
            if (connection instanceof com.mysql.jdbc.MySQLConnection) {

            }
        }
        return null;
    }


    /**
     * 执行请求后
     * <p>
     * 可以在这里篡改返回的结果集合
     *
     * @param sql
     * @param interceptedStatement
     * @param resultSetInternalMethods
     * @param connection
     * @return 返回的值会作为"后面的Interceptor"的入参
     * @throws SQLException
     */
    @Override
    public ResultSetInternalMethods postProcess(String sql, Statement interceptedStatement, ResultSetInternalMethods resultSetInternalMethods, Connection connection) throws SQLException {
        System.out.println("--- cn.java.database.jdbc.mysql.interceptors.FooOneStatementInterceptor.postProcess ---");
        if (interceptedStatement instanceof com.mysql.jdbc.PreparedStatement) {
            String preparedSql = ((PreparedStatement) interceptedStatement).getPreparedSql();
            System.out.println("preparedSql = " + preparedSql);

            String asSql = ((PreparedStatement) interceptedStatement).asSql(true);
            System.out.println("asSql = " + asSql);
        } else if (interceptedStatement instanceof com.mysql.jdbc.StatementImpl) {

            if (interceptedStatement instanceof com.mysql.jdbc.Statement) {

            }
            System.out.println("sql = " + sql);

        }

        if (connection instanceof com.mysql.jdbc.ConnectionImpl) {
            if (connection instanceof com.mysql.jdbc.MySQLConnection) {

            }
        }
        return resultSetInternalMethods;
    }


    /**
     * 销毁
     */
    @Override
    public void destroy() {
        this.connection = null;
        this.properties = null;
    }
}

 


695856371Web网页设计师②群 | 喜欢本站的朋友可以收藏本站,或者加入我们大家一起来交流技术!

欢迎来到梁钟霖个人博客网站。本个人博客网站提供最新的站长新闻,各种互联网资讯。 还提供个人博客模板,最新最全的java教程,java面试题。在此我将尽我最大所能将此个人博客网站做的最好! 谢谢大家,愿大家一起进步!

转载原创文章请注明出处,转载至: 梁钟霖个人博客www.liangzl.com

1条评论

Loading...
  • zxg938L

    你好,我想请问下在preProcess方法中,可以设置preparedStatement的参数吗?如果可以怎么设置呢?我使用setString方法后没有生效,望赐教,感谢!



发表评论

电子邮件地址不会被公开。 必填项已用*标注

自定义皮肤
注册梁钟霖个人博客