normal replication RS0 Region-A HLog-0 RS1 HLog-1 Peer Cluster RS0 HLog-0 RS1 HLog-1 Peer Cluster Region-A Region-A moved from RS0 to RS1 For region A, Both RS0’s HLog & RS1’s HLog will be replicated replicated to peer cluster in parallel. For region A, Only RS0’s HLog will be replicated to peer cluster. Normal replication - problem #1 Put K0, V0, t1 Put K0, V0, t2 t1 t2 Put K0, V0, t5 t4 of the serial peer. ❏ Barrier: Will store the region’s openNum as its barrier for each region when RS open it. ❏ Last Pushed Sequence ID VS WAL Position: ❏ Last Pushed Sequence ID is a sequence id for

ResultSet rs = stmt.executeQuery( "SELECT * FROM COMPANY;" ); while ( rs.next() ) { int id = rs.getInt("id"); String name = rs.getString("name"); int age = rs.getInt("age"); getInt("age"); String address = rs.getString("address"); float salary = rs.getFloat("salary"); System.out.println( "ID = " + id ); System.out.println( "NAME = " + name System.out.println( "SALARY = " + salary ); System.out.println(); } rs.close(); stmt.close(); c.close(); } catch ( Exception e ) { System.err.println(

from arrests") dbBegin(con) rs <- dbSendStatement(con, "DELETE from arrests WHERE Murder > 1") dbGetRowsAffected(rs) dbReadTable_SQLiteConnection_character 5 dbClearResult(rs) dbGetQuery(con, "select dbGetQuery(con, "select count(*) from arrests")[1, ] dbBegin(con) rs <- dbSendStatement(con, "DELETE FROM arrests WHERE Murder > 5") dbClearResult(rs) dbCommit(con) dbGetQuery(con, "SELECT count(*) FROM arrests")[1 13 # Or do it in batches rs <- dbSendQuery(con, "SELECT * FROM USArrests") d1 <- dbFetch(rs, n = 10) # extract data in chunks of 10 rows dbHasCompleted(rs) d2 <- dbFetch(rs, n = -1) # extract all remaining

within a try/with block so that they are automatically closed. Line 24 This while loop uses the rs.next() method to iterate through each row. As long as there is another row in the result set, the try/with block so that they are automatically closed. Page 40 of 43 Line 24 This while loop uses the rs.next() method to iterate through each row. As long as there is another row in the result set, the ResultSet rs = stmt.executeQuery(sql)) { while (rs.next()) { System.out.printf("%d\t%‐10s\t%‐10s\t%tD%n", rs.getInt(1), rs.getString(2), rs.getString(3), rs.getDate(4));

prepareStatement(sql)) { hintManager.setDatabaseShardingValue(3); try (ResultSet rs = pstmt.executeQuery()) { while (rs.next()) { //... } 3.1. Sharding 29 Apache ShardingSphere document, v5.0.0-beta conn.prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = ps.executeQuery()) { while(rs.next()) { // ... } } } 4.1. ShardingSphere-JDBC 151 Apache ShardingSphere document prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } 4.1. ShardingSphere-JDBC 153 Apache ShardingSphere

conn.prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = ps.executeQuery()) { while(rs.next()) { // ... } } } Use YAML Import Maven Dependency org prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } Use Spring Boot Starter Import Maven Dependency r", 1); hintManager.addTableShardingValue("t_order", 2); try (ResultSet rs = preparedStatement.executeQuery()) { while (rs.next()) { // ... } } } // Sharding database and one database route with

prepareStatement(sql)) { hintManager.setDatabaseShardingValue(3); try (ResultSet rs = pstmt.executeQuery()) { while (rs.next()) { //... } } } 3.1. 数据分片 27 Apache ShardingSphere document, v5.0.0-beta conn.prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = ps.executeQuery()) { while(rs.next()) { // ... } } } 使用 YAML 配置 引入 Maven 依赖 org.apache prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } 使用 Spring Boot Starter 引入 Maven 依赖

conn.prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = ps.executeQuery()) { while(rs.next()) { // ... } } } 使用 YAML 配置 引入 Maven 依赖 org.apache prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } 使用 Spring Boot Starter 引入 Maven 依赖 r", 1); hintManager.addTableShardingValue("t_order", 2); try (ResultSet rs = preparedStatement.executeQuery()) { while (rs.next()) { // ... } } } // Sharding database without sharding table and

Result-5 Cell-6 Cell-8 Cell-2 Result-2 Cell-3 RegionServer Row Data RPC Response Recieved from RS Results get from scanner.next() Cell-9 Size of cell-1 > 1MB scan.setCaching(2).setAllowPartialResults(true) Result-5 Cell-6 Cell-8 Cell-2 Result-2 Cell-3 RegionServer Row Data RPC Response Recieved from RS Results get from scanner.next() Cell-1 Cell-2 Result-1 Cell-3 Cell-4 Result-2 Cell-5 Result-3 Cell-7 Result-5 Cell-6 Cell-8 Cell-2 Result-2 Cell-3 Cell-9 RegionServer Row Data RPC Response Recieved from RS Results get from scanner.next() Cell-1 Result-1 Cell-4 Result-3 Cell-5 Result-4 Cell-7 Result-5

prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } Mode Configuration Root Configuration Class name: prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } Database Connection Pool Usage String driverClassName prepareStatement(sql)) { ps.setInt(1, 10); ps.setInt(2, 1000); try (ResultSet rs = preparedStatement.executeQuery()) { while(rs.next()) { // ... } } } 5.1. ShardingSphere-JDBC 99 Apache ShardingSphere