今天，给大家带来一段JDBC实现Master Slave的代码，好了，不多说了，我们直接上代码吧。

具体代码如下：

package com.lyz.test;import java.beans.PropertyVetoException;import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import com.mchange.v2.c3p0.ComboPooledDataSource;public class ReplicationDriverTest {private static final String URL = "jdbc:mysql://127.0.0.1:3306/test1?useUnicode=true&characterEncoding=utf8";private static final String DRIVER = "com.mysql.jdbc.Driver";private static final String replicationURL = "jdbc:mysql:replication://localhost:3306,10.2.15.123:3306/test?useUnicode=true&characterEncoding=utf8";private static final String loadBalanceURL = "jdbc:mysql:loadbalance://localhost:3306,10.2.15.123:3306/test?useUnicode=true&characterEncoding=utf8";private static final String REPLICATION_DRIVER = "com.mysql.jdbc.ReplicationDriver";public static void main(String[] args) throws SQLException {// oneDB();// replicationDB(URL);// replicationDB(replicationURL);replicationDB(loadBalanceURL);}public static void replicationDB(String url) throws SQLException {ComboPooledDataSource dataSource = new ComboPooledDataSource();try {dataSource.setDriverClass(REPLICATION_DRIVER);} catch (PropertyVetoException e1) {e1.printStackTrace();}dataSource.setJdbcUrl(url);dataSource.setMaxPoolSize(10);dataSource.setMinPoolSize(10);dataSource.setUser("kevin");dataSource.setPassword("123456");dataSource.setCheckoutTimeout(1000);dataSource.setDataSourceName("datasource");dataSource.setInitialPoolSize(10);try {Connection connection = dataSource.getConnection();connection.setReadonly(true);//设置为只读，代理类将会获取Slave数据库连接，否则设置Master连接java.sql.PreparedStatement pStatement_ = connection.prepareStatement("SELECT user_id, username, PASSWORD, email  FROM account_0 LIMIT 0,3;");ResultSet rs = pStatement_.executeQuery();while (rs.next()) {System.out.println(rs.getInt(1) + "\t" + rs.getString(2) + "\t" + rs.getString(3) + "\t" + rs.getString(4));}rs.close();pStatement_.close();connection.close();} catch (SQLException e) {e.printStackTrace();}Connection connection = dataSource.getConnection();connection.setReadonly(false);//设置为只读，代理类将会获取Slave数据库连接，否则设置Master连接java.sql.PreparedStatement pStatement_ = connection.prepareStatement("UPDATE account_0 SET  username = 'kevin' ,PASSWORD = 'password' ,email = 'xxxx' WHERE user_id = '1001' ;");int row = pStatement_.executeUpdate();System.out.println(row);pStatement_.close();connection.close();}public static void oneDB() throws SQLException {ComboPooledDataSource dataSource = new ComboPooledDataSource();try {dataSource.setDriverClass(DRIVER);} catch (PropertyVetoException e1) {e1.printStackTrace();}dataSource.setJdbcUrl(URL);dataSource.setMaxPoolSize(10);dataSource.setMinPoolSize(10);dataSource.setUser("root");dataSource.setPassword("123456");dataSource.setCheckoutTimeout(1000);dataSource.setDataSourceName("datasource00");dataSource.setInitialPoolSize(10);try {Connection connection = dataSource.getConnection();java.sql.PreparedStatement pStatement_ = connection.prepareStatement("SELECT * FROM user limit 1");ResultSet rs = pStatement_.executeQuery();while (rs.next()) {System.out.println(rs.getInt(1) + "\t" + rs.getString(2) + "\t" + rs.getString(3) + "\t" + rs.getString(4));}rs.close();pStatement_.close();connection.close();} catch (SQLException e) {e.printStackTrace();}Connection connection = dataSource.getConnection();java.sql.PreparedStatement pStatement_ = connection.prepareStatement("UPDATE user SETNAME = 'KEVIN-LUAN' , sex = '1' , age = '89' WHERE id = 16 ;");int row = pStatement_.executeUpdate();System.out.println(row);pStatement_.close();connection.close();}}