程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> 關於MYSQL數據庫 >> MySQL 讀寫分離實例詳解

MySQL 讀寫分離實例詳解

編輯:關於MYSQL數據庫

MySQL 讀寫分離

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

 代碼例子:

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

感謝閱讀,希望能幫助到大家,謝謝大對本站的支持!

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved