mysql connector 执行 select 和 shardingshpere-proxy 的处理过程

use java mysql connector

// fake mysql select code
// ... datasource init
Connection conn = datasource.getConnection();
PreparedStatement pst = conn.prepareStatement("select id, task_name from t_task where id = ?");
pst.setLong(1, 31);
pst.executeQuery();

按照直觉, 既然用了 preparedStatement, 执行过一次后会在服务端缓存好预编译的语句, 之后就能省去这个解析过程,直接提交参数执行就好了

  1. 但是, mysql connector 默认创建的是 ClientPreparedStatement
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
        try {
            synchronized(this.getConnectionMutex()) {
                this.checkClosed();
                ClientPreparedStatement pStmt = null;
                boolean canServerPrepare = true;
                String nativeSql = (Boolean)this.processEscapeCodesForPrepStmts.getValue() ? this.nativeSQL(sql) : sql;
                if ((Boolean)this.useServerPrepStmts.getValue() && (Boolean)this.emulateUnsupportedPstmts.getValue()) {
                    canServerPrepare = this.canHandleAsServerPreparedStatement(nativeSql);
                }
              // useServerPrepStmts = false
                if ((Boolean)this.useServerPrepStmts.getValue() && canServerPrepare) {
                      // ... 省略一些代码
                    } else {
                    	//... 省略一些代码
                            pStmt = (ClientPreparedStatement)this.clientPrepareStatement(nativeSql, resultSetType, resultSetConcurrency, false);
                        }
                    }
                } else {
                    pStmt = (ClientPreparedStatement)this.clientPrepareStatement(nativeSql, resultSetType, resultSetConcurrency, false);
                }

                return (PreparedStatement)pStmt;
            }
        } catch (CJException var17) {
            throw SQLExceptionsMapping.translateException(var17, this.getExceptionInterceptor());
        }
    }

因为默认并没有设置 useServerPrepStmts = true, 默认是false 去指定要求服务端缓存 创建的 clientPrepareStatement 客户端语句

  1. 是不是 ClientPreparedStatement 看着客户端侧进行一些元数据的缓存?
    pst.executeQuery(); 代码中有一段逻辑, 如果cacheResultSetMetadata=true的话,会缓存元数据,但是并没有
                  boolean cacheResultSetMetadata = (Boolean)locallyScopedConn.getPropertySet().getBooleanProperty(PropertyKey.cacheResultSetMetadata).getValue();
                    String origSql = ((PreparedQuery)this.query).getOriginalSql();
                    if (cacheResultSetMetadata) {
                        cachedMetadata = locallyScopedConn.getCachedMetaData(origSql);
                    }

所以,虽然每次还是从服务端拿返回 参数 和 resultSet 的一些元数据

  1. 最终发往服务端(这边场景是proxy) 的 sql 其实是非参数化的 com_query 命令
    image

  2. proxy 接收到 com_query 交由 MySQLComQueryPacketExecutor 处理

   public Collection<DatabasePacket<?>> execute() throws SQLException {
        ResponseHeader responseHeader = proxyBackendHandler.execute();
        if (responseHeader instanceof QueryResponseHeader) {
            return processQuery((QueryResponseHeader) responseHeader);
        }
        responseType = ResponseType.UPDATE;
        return processUpdate((UpdateResponseHeader) responseHeader);
    }

MySQLComQueryPacketExecutor 常规文本查询,在 proxy frontend 处理过程较为的简单,直接交给 backend 执行,后续就和 sharding-jdbc 核心处理逻辑一致了,比如 分库分表、读写分离、单库单表直接执行

扩展:

原文链接:https://www.cnblogs.com/mushishi/p/17329876.html

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:mysql connector 执行 select 和 shardingshpere-proxy 的处理过程 - Python技术站

(0)
上一篇 2023年4月18日
下一篇 2023年4月19日

相关文章

  • Java中的JUnit是什么?

    JUnit是Java中最受欢迎的测试框架之一,用于编写单元测试。在软件开发中,单元测试是用于测试小部分代码的实践,以确保它们能够按照预期进行工作,同时也是保证代码质量和可维护性的重要步骤。在本文中,我们将详细讲解JUnit的各个方面,从安装到使用。 安装 JUnit可以通过Maven在Java项目中安装,只需要在项目的pom.xml文件中添加以下依赖项即可:…

    Java 2023年4月27日
    00
  • Java最长公共子序列示例源码

    Java最长公共子序列示例源码可以用于找到两个字符串之间的最长公共子序列。以下是Java最长公共子序列示例源码的完整攻略: 1. 题目描述 给定两个字符串s1和s2,找到它们的最长公共子序列(LCS)。 2. 示例 示例1: 输入:s1 = "abcde", s2 = "ace" 输出:3 解释:最长公共子序列是 &q…

    Java 2023年5月27日
    00
  • 基于java ssm springboot+mybatis酒庄内部管理系统设计和实现

    基于Java SSM SpringBoot+Mybatis酒庄内部管理系统设计和实现 系统需求 管理员登录管理 酒庄员工管理 酒庄原材料和产品管理 酒庄生产线管理 酒庄生产流程管理 酒庄销售管理 技术选型 后端:Spring、SpringMVC、Mybatis、SpringBoot、MySQL 前端:Bootstrap、jQuery、Ajax 系统架构 使用…

    Java 2023年5月19日
    00
  • Spring Security入门demo案例

    下面是Spring Security入门demo案例的完整攻略。 一、前置知识 在开始学习Spring Security入门demo案例之前,你需要具备以下一些基础知识: 基本的Java编程语言和Spring框架的了解; 熟悉Spring MVC框架的开发以及相关的Maven工程构建方式。 二、Spring Security简介 Spring Securit…

    Java 2023年5月20日
    00
  • SpringBoot3整合MyBatis出现异常:Property ‘sqlSessionFactory’or ‘sqlSessionTemplate’ are required

    Spring Boot是目前非常受欢迎的开发框架,而MyBatis是一款优秀的数据库ORM框架,二者结合可以让我们开发高效率、高质量的Web应用。不过在整合Spring Boot和MyBatis的时候,有时候会遇到”Property ‘sqlSessionFactory’ or ‘sqlSessionTemplate’ are required”异常,那么该…

    Java 2023年5月20日
    00
  • SpringBoot使用ExceptionHandler做异常处理

    SpringBoot是一个非常流行的Java框架,其内置了大量的工具和库,可以大大地提升Java开发的效率。 在实际的应用开发中,异常处理是一个非常重要的问题。使用SpringBoot中的ExceptionHandler可以很方便地处理异常,本文将详细讲解如何实现这个功能。 实现步骤 下面是实现SpringBoot使用ExceptionHandler做异常处…

    Java 2023年5月27日
    00
  • 基于Java在netty中实现线程和CPU绑定

    基于Java在netty中实现线程和CPU绑定,可以提高系统的稳定性和性能。以下是具体的实现攻略。 一、绑定CPU 绑定CPU可以有效避免Java进程因为线程数量过多和线程切换而导致CPU资源繁忙,从而降低系统的性能。在Java中绑定CPU可以通过任务调度类java.util.concurrent.ScheduledThreadPoolExecutor中的s…

    Java 2023年5月19日
    00
  • hibernate框架环境搭建具体步骤(介绍)

    Hibernate是一个Java持久化框架,可以将Java应用程序中的对象映射到关系数据库中的表中。通过Hibernate,Java开发人员可以使用面向对象的方式操作数据库,而不必考虑数据的存取和处理细节。 下面是Hibernate框架环境搭建的具体步骤: 步骤一:引入Hibernate依赖 在项目的pom文件中添加Hibernate依赖,示例代码如下: &…

    Java 2023年5月19日
    00
合作推广
合作推广
分享本页
返回顶部