浅析JDBC与数据库如何进行数据交互及类型转换

// 实际网络抓包的数据示例 (简化)

// 客户端发送: 
[0x03] [S E L E C T   *   F R O M   u s e r]

// 服务端响应:
// 第一个包: 列数
[0x1c 0x00 0x00 0x00]  // 28字节长度的包
[0x03]                 // 结果集标志
[0x02]                 // 2列

// 第二个包: 列定义 "id"
[0x18 0x00 0x00 0x00]  // 包长度
[0x04]                 // 列定义标志
[0x03] [i d]           // 列名

// 第三个包: 列定义 "name"  
[0x1a 0x00 0x00 0x00]
[0x04]                 
[0x05] [n a m e]

// 第四包: 行数据
[0x10 0x00 0x00 0x00]
[0x00]                 // 行标志
[0x01] [0x31]         // id=1
[0x05] [T o m]        // name='Tom'

// 第五包: EOF
[0x05 0x00 0x00 0x00]
[0xfe]                 // EOF 标志

// PreparedStatement 内部转换流程
pstmt.setInt(1, 123);

// 实际转换步骤:
// 1. Java int → JDBC Types.INTEGER
// 2. 根据驱动实现转换为数据库特定格式
// 3. 按照协议编码为网络字节流

// MySQL 驱动内部简化实现 (Connector/J)
public void setInt(int parameterIndex, int x) throws SQLException {
    // 检查参数位置有效性
    checkBounds(parameterIndex);
    
    // 存储为参数对象，包含值和类型
    Parameter p = getParameter(parameterIndex);
    p.value = x;
    p.type = Types.INTEGER;
    p.isNull = false;
    
    // 实际写入时调用编码方法
    // byte[] encoded = encodeInteger(x, 4); // 4字节小端序
}

int id = rs.getInt("id");

// MySQL 驱动内部简化实现
public int getInt(String columnLabel) throws SQLException {
    // 1. 找到列索引
    int columnIndex = findColumn(columnLabel);
    
    // 2. 获取原始字节数据
    byte[] rawData = rowData.getColumnData(columnIndex);
    
    // 3. 根据协议格式解码
    // MySQL 整数格式: 小端序，固定长度
    
    // 4. 类型转换
    if (rawData == null) return 0;  // SQL NULL 返回 0
    
    // 解码为 int
    int value = (rawData[0] & 0xff) |
                ((rawData[1] & 0xff) << 8) |
                ((rawData[2] & 0xff) << 16) |
                ((rawData[3] & 0xff) << 24);
    
    return value;
}

// 即使数据库是 VARCHAR，也可以读取为 int
ResultSet rs = stmt.executeQuery("SELECT '123' AS num");
int num = rs.getInt("num");  // 自动转换 123
// 内部实现: String → Integer.parseInt()

// 支持的类型转换矩阵 (部分)
// getInt(): VARCHAR, CHAR, DECIMAL, BIGINT, SMALLINT, TINYINT
// getString(): 几乎所有类型（会调用 toString()）
// getTimestamp(): DATE, TIME, VARCHAR(符合日期格式)

PreparedStatement pstmt = conn.prepareStatement(
    "INSERT INTO user(id, name, salary) VALUES(?, ?, ?)"
);

pstmt.setInt(1, 100);           // int → Types.INTEGER
pstmt.setString(2, "张三");      // String → Types.VARCHAR
pstmt.setBigDecimal(3, new BigDecimal("9999.99"));

pstmt.executeUpdate();

// MySQL 协议层面的参数替换:
// 服务端收到的是带占位符的预编译语句
// 客户端发送 COM_STMT_PREPARE
// 服务端返回 statement_id
// 客户端发送 COM_STMT_EXECUTE(statement_id, params...)

// 流式传输，避免内存溢出
try (PreparedStatement pstmt = conn.prepareStatement(
        "INSERT INTO files(id, content) VALUES(?, ?)")) {
    
    pstmt.setInt(1, 1);
    
    // CLOB: 字符大对象
    Reader reader = new FileReader("large.txt");
    pstmt.setCharacterStream(2, reader);
    
    // BLOB: 二进制大对象  
    InputStream is = new FileInputStream("large.pdf");
    pstmt.setBinaryStream(2, is);
    
    pstmt.executeUpdate();
}

// 读取时也使用流式
ResultSet rs = stmt.executeQuery("SELECT content FROM files WHERE id=1");
if (rs.next()) {
    InputStream is = rs.getBinaryStream("content");
    // 边读边写，不占用大量内存
    byte[] buffer = new byte[8192];
    int len;
    while ((len = is.read(buffer)) != -1) {
        // 处理数据
    }
}

// 减少网络往返次数
PreparedStatement pstmt = conn.prepareStatement(
    "INSERT INTO user(name) VALUES(?)"
);

conn.setAutoCommit(false);

for (int i = 0; i < 1000; i++) {
    pstmt.setString(1, "user" + i);
    pstmt.addBatch();  // 累积到批次中
    
    if (i % 100 == 0) {
        int[] results = pstmt.executeBatch();  // 一次发送100条
        conn.commit();
    }
}

// 协议层面: 批量发送多个命令包
// 服务端批量执行，减少往返延迟

// 1. 使用连接池减少连接建立开销
// 2. 批量操作减少网络往返
// 3. 只查询需要的列
String sql = "SELECT id, name FROM user";  // 好
String sql = "SELECT * FROM user";         // 差，传输冗余数据

// 4. 使用 fetchSize 控制内存
Statement stmt = conn.createStatement();
stmt.setFetchSize(100);  // 每次从数据库取100行
ResultSet rs = stmt.executeQuery("SELECT * FROM huge_table");

// 直接使用匹配的类型
int id = rs.getInt("id");        // 高效：直接解码
String idStr = rs.getString("id"); // 低效：int→String 转换

// 使用具体类型而非 Object
Object obj = rs.getObject("amount");  // 需要类型判断和转换
BigDecimal amount = rs.getBigDecimal("amount"); // 直接获取

// 同一个 Connection 中的 PreparedStatement 可以被复用
// 某些驱动支持服务端预编译缓存
// MySQL 需要配置: cachePrepStmts=true
String url = "jdbc:mysql://localhost:3306/db?cachePrepStmts=true&useServerPrepStmts=true";

// 核心类层次
com.mysql.cj.jdbc.ConnectionImpl
    └── com.mysql.cj.NativeSession  // 管理网络会话
        └── com.mysql.cj.protocol.a.NativeProtocol  // 协议处理
            └── com.mysql.cj.protocol.a.SimplePacketReader  // 读取包
            └── com.mysql.cj.protocol.a.TimeTrackingPacketWriter  // 写入包

// 发送 SQL 的关键方法
protected ResultSetInternalMethods executeInternal(
    int maxRowsToRetrieve,
    Buffer queryPacket,
    boolean sendPacket,
    int maxRows,
    Catalog nor...
) throws SQLException {
    // 1. 发送命令包
    this.session.sendCommand(queryPacket, sendPacket);
    
    // 2. 读取响应
    this.protocol.readQueryResult(this.columnDefinitions, false, false, 
                                   this.session.getServerSession().getCapabilities());
    
    // 3. 解析结果集并转换为 Java 对象
    return this.protocol.readAllResults(maxRowsToRetrieve, 
                                         true, 
                                         this.resultSetFactory, 
                                         this.columnDefinitions);
}