匿名通过本文主要向大家介绍了MySQL，ReplicationDriver 等相关知识,希望本文的分享对您有所帮助
在 MySQL 复制的环境中，要通过 JDBC 连接这个 MySQL 集群，就必须使用 ReplicationDriver 这个类来替换原有的 com.mysql.jdbc.Driver 。不过该 Driver 在连接池环境下无效，要通过连接池连接 MySQL 集群可使用 lbpool。
public static void main(String[] args) throws Exception {
ReplicationDriver driver = new ReplicationDriver();
Properties props = new Properties();
// We want this for failover on the slaves
props.put("autoReconnect", "true");
// We want to load balance between the slaves
props.put("roundRobinLoadBalance", "true");
props.put("user", "foo");
props.put("password", "bar");
//
// Looks like a normal MySQL JDBC url, with a
// comma-separated list of hosts, the first
// being the 'master', the rest being any number
// of slaves that the driver will load balance against
//
Connection conn =
driver.connect("jdbc:mysql://master,slave1,slave2,slave3/test",
props);
//
// Perform read/write work on the master
// by setting the read-only flag to "false"
//
//这个节点应该是通过spring的事务管理来设置，同时这个conn对象应该不是一个真正的connection，
//而是一个代理类，通过设置readonly，代理类会去使用不同的connection，
//那么问题是它该代理类使用的connection是哪里取的，抑或说难道它每次都会新开一个connection？，需要看源代码
conn.setReadOnly(false);
conn.setAutoCommit(false);
conn.createStatement().executeUpdate("UPDATE some_table ....");
conn.commit();
//
// Now, do a query from a slave, the driver automatically picks one
// from the list
//
conn.setReadOnly(true);
ResultSet rs =
conn.createStatement().executeQuery("SELECT a,b FROM alt_table");
.......
}以上就是分享一个MySQL ReplicationDriver类代码的详细内容，更多请关注微课江湖其它相关文章！