在用过Amoeba 和 Cobar，还有dbware 等读写分离组件后，今天我的一个好朋友跟我讲，MySQL自身的也是可以读写分离的，因为他们提供了一个新的驱动，叫 com.mysql.jdbc.ReplicationDriver
说明文档：http://dev.mysql.com/doc/refman/5.1/en/connector-j-reference-replication-connection.html
代码例子：
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 =
driver.connect(
"jdbc:mysql:replication://master,slave1,slave2,slave3/test"
,
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，如需转载请自行联系原作者
|
