TiDB 最佳实践系列（五）Java 数据库应用开发指南

• 网络协议：客户端通过标准 MySQL 协议 和 TiDB 进行网络交互。
• JDBC API 及实现：Java 应用通常使用 JDBC (Java Database Connectivity) 来访问数据库。JDBC 定义了访问数据库 API，而 JDBC 实现完成标准 API 到 MySQL 协议的转换，常见的 JDBC 实现是 MySQL Connector/J，此外有些用户可能使用 MariaDB Connector/J。
• 数据库连接池：为了避免每次创建连接，通常应用会选择使用数据库连接池来复用连接，JDBC DataSource 定义了连接池 API，开发者可根据实际需求选择使用某种开源连接池实现。
• 数据访问框架：应用通常选择通过数据访问框架（MyBatis、Hibernate）的封装来进一步简化和管理数据库访问操作。
• 业务实现：业务逻辑控制着何时发送和发送什么指令到数据库，其中有些业务会使用 Spring Transaction 切面来控制管理事务的开始和提交逻辑。

注意：

对于 MySQL Connector/J 实现，默认 Batch 只是将多次 addBatch
 的 SQL 发送时机延迟到调用 executeBatch
 的时候，但实际网络发送还是会一条条的发送，通常不会降低与数据库服务器的网络交互次数。

如果希望 Batch 网络发送批量插入，需要在 JDBC 连接参数中配置 rewriteBatchedStatements=true
（下面参数配置章节有详细介绍）。

• 设置 FetchSize
   为 Integer.MIN_VALUE
   让客户端不缓存，客户端通过 StreamingResult
   的方式从网络连接上流式读取执行结果。
• 使用 Cursor Fetch 首先需 设置 FetchSize
   为正整数且在 JDBC URL 中配置 useCursorFetch=true
  。

• useServerPrepStmts

• cachePrepStmts

• prepStmtCacheSqlLimit

• prepStmtCacheSize

pstmt = prepare(“insert into t (a) values(?)”);
pstmt.setInt(1, 10);
pstmt.addBatch();
pstmt.setInt(1, 11);
pstmt.addBatch();
pstmt.setInt(1, 12);
pstmt.executeBatch();

insert into t(a) values(10);
insert into t(a) values(11);
insert into t(a) values(12);

insert into t(a) values(10),(11),(12);

insert into t (a) values (10) on duplicate key update a = 10;
insert into t (a) values (11) on duplicate key update a = 11;
insert into t (a) values (12) on duplicate key update a = 12;

insert into t (a) values (10) on duplicate key update a = values(a);
insert into t (a) values (11) on duplicate key update a = values(a);
insert into t (a) values (12) on duplicate key update a = values(a);

insert into t (a) values (10), (11), (12) on duplicate key update a = values(a);

update t set a = 10 where id = 1; update t set a = 11 where id = 2; update t set a = 12 where id = 3;

cacheServerConfiguration=true
useLocalSessionState=true
elideSetAutoCommits=true
alwaysSendSetIsolation=false
enableQueryTimeouts=false

• maximumPoolSize
  ：连接池最大连接数，配置过大会导致 TiDB 消耗资源维护无用连接，配置过小则会导致应用获取连接变慢，所以需根据应用自身特点配置合适的值，可参考 这篇文章。
• minimumIdle
  ：连接池最大空闲连接数，主要用于在应用空闲时存留一些连接以应对突发请求，同样是需要根据业务情况进行配置。

The last packet sent successfully to the server was 3600000 milliseconds ago. The driver has not received any packets from the server. com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

• 每次使用连接前检查连接是否可用。
• 使用单独线程定期检查连接是否可用。
• 定期发送 test query 保活连接。

• select 1 from t where id = #{param1}
   会作为 prepare 语句转换为 select 1 from t where id = ?
   进行 prepare， 并使用实际参数来复用执行，通过配合前面的 Prepare 连接参数能获得最佳性能。
• select 1 from t where id = ${param2}
   会做文本替换为 select 1 from t where id = 1
   执行，如果这条语句被 prepare 成了不同参数，可能会导致 TiDB 缓存大量的 prepare 语句，并且这种方式执行 SQL 有注入安全风险。

<insert id="insertTestBatch" parameterType="java.util.List" fetchSize="1">
  insert into test
   (id, v1, v2)
  values
  <foreach item="item" index="index" collection="list" separator=",">
  (
   #{item.id}, #{item.v1}, #{item.v2}
  )
  </foreach>
  on duplicate key update v2 = v1 + values(v1)
</insert>

1.3 Streaming 结果

• 可以通过在 mapper 配置中对单独一条 SQL 设置 fetchSize
  （见上一段代码段），效果等同于调用 JDBC setFetchSize。
• 可以使用带 ResultHandler 的查询接口来避免一次获取整个结果集。
• 可以使用 Cursor 类来进行流式读取。

<select id="getAll" resultMap="postResultMap" fetchSize="-2147483648">
  select * from post;
</select>

@Select("select * from post")
@Options(fetchSize = Integer.MIN_VALUE)
Cursor<Post> queryAllPost();

• Simple
  ：每次执行都会向 JDBC 进行 prepare 语句的调用（如果 JDBC 配置有开启 cachePrepStmts
  ，重复的 prepare 语句会复用）。

• Reuse
  ：在 executor 中缓存 prepare 语句，这样不用 JDBC 的 cachePrepStmts
   也能减少重复 prepare 语句的调用。
• Batch
  ：每次更新只有在 addBatch
   到 query 或 commit 时才会调用 executeBatch
   执行，如果 JDBC 层开启了 rewriteBatchStatements
  ，则会尝试改写，没有开启则会一条条发送。