import java.sql.*; public class TestCase { public static void main(String args[]) { try { Class.forName("com.mysql.jdbc.ReplicationDriver"); String url = "jdbc:mysql://192.168.0.1:3308,192.168.0.1:3306/database"; Connection conn = DriverManager.getConnection(url, "user", "password"); System.err.println("Switching to master"); conn.setReadOnly(false); System.err.println("Setting catalog to 'test'"); conn.setCatalog("test"); System.err.println("catalog='"+conn.getCatalog()+"'"); System.err.println("Switching to slave"); conn.setReadOnly(true); System.err.println("catalog='"+conn.getCatalog()+"'"); System.err.println("Setting catalog to 'mysql'"); conn.setCatalog("mysql"); System.err.println("catalog='"+conn.getCatalog()+"'"); System.err.println("Switching to slave"); conn.setReadOnly(true); System.err.println("catalog='"+conn.getCatalog()+"'"); conn.close(); }catch(Exception e){ e.printStackTrace(); } } }