MySQL读写分离又一好办法 使用 com.mysql.jdbc.ReplicationDriver
在用过Amoeba 和 Cobar,还有dbware 等读写分离组件后,今天我的一个好朋友跟我讲,MySQL自身的也是可以读写分离的,因为他们提供了一个新的驱动,叫 com.mysql.jdbc.ReplicationDriver
说明文档:http://dev.mysql.com/doc/refman/5.1/en/connector-j-reference-replication-connection.html
代码例子:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
import java.sql. Connection ;
import java.sql.ResultSet;
import java.util.Properties;
import com.mysql.jdbc.ReplicationDriver;
public class ReplicationDriverDemo {
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 =
props);
//
// Perform read /write work on the master
// by setting the read - only flag to "false"
//
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" );
.......
}
}
|
感谢阅读,希望能帮助到大家,谢谢大对本站的支持!
原文链接:http://www.cnblogs.com/taven/archive/2013/04/24/3040489.html