分享一個MySQL ReplicationDriver類代碼

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");  ?????.......  ??}