// 實(shí)際網(wǎng)絡(luò)抓包的數(shù)據(jù)示例 (簡化)

// 客戶端發(fā)送: 
[0x03] [S E L E C T   *   F R O M   u s e r]

// 服務(wù)端響應(yīng):
// 第一個包: 列數(shù)
[0x1c 0x00 0x00 0x00]  // 28字節(jié)長度的包
[0x03]                 // 結(jié)果集標(biāo)志
[0x02]                 // 2列

// 第二個包: 列定義 "id"
[0x18 0x00 0x00 0x00]  // 包長度
[0x04]                 // 列定義標(biāo)志
[0x03] [i d]           // 列名

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

// 第四包: 行數(shù)據(jù)
[0x10 0x00 0x00 0x00]
[0x00]                 // 行標(biāo)志
[0x01] [0x31]         // id=1
[0x05] [T o m]        // name='Tom'

// 第五包: EOF
[0x05 0x00 0x00 0x00]
[0xfe]                 // EOF 標(biāo)志

// PreparedStatement 內(nèi)部轉(zhuǎn)換流程
pstmt.setInt(1, 123);

// 實(shí)際轉(zhuǎn)換步驟:
// 1. Java int → JDBC Types.INTEGER
// 2. 根據(jù)驅(qū)動實(shí)現(xiàn)轉(zhuǎn)換為數(shù)據(jù)庫特定格式
// 3. 按照協(xié)議編碼為網(wǎng)絡(luò)字節(jié)流

// MySQL 驅(qū)動內(nèi)部簡化實(shí)現(xiàn) (Connector/J)
public void setInt(int parameterIndex, int x) throws SQLException {
    // 檢查參數(shù)位置有效性
    checkBounds(parameterIndex);
    
    // 存儲為參數(shù)對象，包含值和類型
    Parameter p = getParameter(parameterIndex);
    p.value = x;
    p.type = Types.INTEGER;
    p.isNull = false;
    
    // 實(shí)際寫入時調(diào)用編碼方法
    // byte[] encoded = encodeInteger(x, 4); // 4字節(jié)小端序
}

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

// MySQL 驅(qū)動內(nèi)部簡化實(shí)現(xiàn)
public int getInt(String columnLabel) throws SQLException {
    // 1. 找到列索引
    int columnIndex = findColumn(columnLabel);
    
    // 2. 獲取原始字節(jié)數(shù)據(jù)
    byte[] rawData = rowData.getColumnData(columnIndex);
    
    // 3. 根據(jù)協(xié)議格式解碼
    // MySQL 整數(shù)格式: 小端序，固定長度
    
    // 4. 類型轉(zhuǎn)換
    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;
}

// 即使數(shù)據(jù)庫是 VARCHAR，也可以讀取為 int
ResultSet rs = stmt.executeQuery("SELECT '123' AS num");
int num = rs.getInt("num");  // 自動轉(zhuǎn)換 123
// 內(nèi)部實(shí)現(xiàn): String → Integer.parseInt()

// 支持的類型轉(zhuǎn)換矩陣 (部分)
// getInt(): VARCHAR, CHAR, DECIMAL, BIGINT, SMALLINT, TINYINT
// getString(): 幾乎所有類型（會調(diào)用 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 協(xié)議層面的參數(shù)替換:
// 服務(wù)端收到的是帶占位符的預(yù)編譯語句
// 客戶端發(fā)送 COM_STMT_PREPARE
// 服務(wù)端返回 statement_id
// 客戶端發(fā)送 COM_STMT_EXECUTE(statement_id, params...)

// 流式傳輸，避免內(nèi)存溢出
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: 二進(jìn)制大對象  
    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");
    // 邊讀邊寫，不占用大量內(nèi)存
    byte[] buffer = new byte[8192];
    int len;
    while ((len = is.read(buffer)) != -1) {
        // 處理數(shù)據(jù)
    }
}

// 減少網(wǎng)絡(luò)往返次數(shù)
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();  // 一次發(fā)送100條
        conn.commit();
    }
}

// 協(xié)議層面: 批量發(fā)送多個命令包
// 服務(wù)端批量執(zhí)行，減少往返延遲

// 1. 使用連接池減少連接建立開銷
// 2. 批量操作減少網(wǎng)絡(luò)往返
// 3. 只查詢需要的列
String sql = "SELECT id, name FROM user";  // 好
String sql = "SELECT * FROM user";         // 差，傳輸冗余數(shù)據(jù)

// 4. 使用 fetchSize 控制內(nèi)存
Statement stmt = conn.createStatement();
stmt.setFetchSize(100);  // 每次從數(shù)據(jù)庫取100行
ResultSet rs = stmt.executeQuery("SELECT * FROM huge_table");

// 直接使用匹配的類型
int id = rs.getInt("id");        // 高效：直接解碼
String idStr = rs.getString("id"); // 低效：int→String 轉(zhuǎn)換

// 使用具體類型而非 Object
Object obj = rs.getObject("amount");  // 需要類型判斷和轉(zhuǎn)換
BigDecimal amount = rs.getBigDecimal("amount"); // 直接獲取

// 同一個 Connection 中的 PreparedStatement 可以被復(fù)用
// 某些驅(qū)動支持服務(wù)端預(yù)編譯緩存
// MySQL 需要配置: cachePrepStmts=true
String url = "jdbc:mysql://localhost:3306/db?cachePrepStmts=true&useServerPrepStmts=true";

// 核心類層次
com.mysql.cj.jdbc.ConnectionImpl
    └── com.mysql.cj.NativeSession  // 管理網(wǎng)絡(luò)會話
        └── com.mysql.cj.protocol.a.NativeProtocol  // 協(xié)議處理
            └── com.mysql.cj.protocol.a.SimplePacketReader  // 讀取包
            └── com.mysql.cj.protocol.a.TimeTrackingPacketWriter  // 寫入包

// 發(fā)送 SQL 的關(guān)鍵方法
protected ResultSetInternalMethods executeInternal(
    int maxRowsToRetrieve,
    Buffer queryPacket,
    boolean sendPacket,
    int maxRows,
    Catalog nor...
) throws SQLException {
    // 1. 發(fā)送命令包
    this.session.sendCommand(queryPacket, sendPacket);
    
    // 2. 讀取響應(yīng)
    this.protocol.readQueryResult(this.columnDefinitions, false, false, 
                                   this.session.getServerSession().getCapabilities());
    
    // 3. 解析結(jié)果集并轉(zhuǎn)換為 Java 對象
    return this.protocol.readAllResults(maxRowsToRetrieve, 
                                         true, 
                                         this.resultSetFactory, 
                                         this.columnDefinitions);
}