mysql 读写分离出现的问题~~请教

ghewqqq

最近由于数据库的压力比较大，所以想使用户的对数据库的读写操作经行分离。
具体实施是 判断sql 语句
如果是匹配 select 开头的 就用 mysql_connect 连接到两台从数据库中。否则就连接主数据库。
但是期间发生过即使是写的时候也可能是停留在 从数据中 并经行写操作，使sql有误。
所以我查看了mysql手册后，相应的改进。当sql 语句中有写操作的时候，先用mysql_close关闭数据库的连接。
然后再连接到 主数据库中。经行写操作。
但是问题依然存在。写操作的时候还是有时停留在从数据库。
请教 怎样才能让写操作的时候在写数据库经行操作呢。

sunnyfun

理想的情况是先将数据库操作用类封装，然后类里建两个连接，一个读，一个写，根据情况对不同的连接操作。为以防万一，可以让从库帐号只读。

yueliangdao0608

不知道你具体的代码，无从下手。

ghewqqq

我是经行了封装的
具体代码

1. 
   
2. function &getDb($query=''){
   
3.         $db;
   
4.                 $username  = $fileConfig->getValue( "db_username" );
   
5.                 $password  = $fileConfig->getValue( "db_password" );
   
6.                 //$host      = $fileConfig->getValue( "db_host" );
   
7.                 $dbname    = $fileConfig->getValue( "db_database" );
   
8.                 $dbcharset = $fileConfig->getValue( "db_character_set" );
   
9.                 $dbpersistent   = $fileConfig->getValue( "db_persistent" );
   
10. 
    
11.                                
    
12.         if (preg_match ("/^select/i",ltrim($query))){
    
13.                                        
    
14.                 $host_array=$fileConfig->getValue( "db_host_array" );
    
15.                 $host  = $host_array[array_rand ($host_array, 1)];
    
16.         else{
    
17.        
    
18.                 $db->Close();
    
19.                 $host  = $fileConfig->getValue( "db_host" );
    
20.         }
    
21. 
    
22.                 if($dbpersistent == true) {
    
23.                             if( !$db->PConnect( $host, $username, $password, $dbname, $dbcharset )) {
    
24.                                 $message = "Fatal error: could not connect to the database!".
    
25.                                            " Error: ".$db->ErrorMsg();
    
26.                                     throw( new Exception( $message ));
    
27.                                     die();
    
28.                             }
    
29.                     }
    
30.                     else {
    
31.                             if( !$db->Connect( $host, $username, $password, $dbname, $dbcharset )) {
    
32.                                 $message = "Fatal error: could not connect to the database!".
    
33.                                            " Error: ".$db->ErrorMsg();
    
34.                                     throw( new Exception( $message ));
    
35.                                     die();
    
36.                             }
    
37.                     }
    
38. }

复制代码

然后还有一个执行数据库操作的函数

1. function Execute( $query,
   
2.                           $page = DEFAULT_PAGING_ENABLED,
   
3.                           $itemsPerPage = DEFAULT_ITEMS_PER_PAGE )
   
4.         {
   
5.             // initialize the db when we have to execute the first query,
   
6.             // not earlier.
   
7.             $this->_initializeDb($query);
   
8.         //这里初始话的时候区分sql语句是读还是写，然后掉用上班的连接数据库的类经行读写区分
   
9.             // see PDbDriverBase (or one of its drivers like PDbMySQLDriver
   
10.             // for details)
    
11.             $result = $this->_db->Execute( $query, $page, $itemsPerPage );
    
12.                        
    
13.             // if the query generated an error, write a message to the sql
    
14.             // error log file
    
15.             if( !$result ) {
    
16.                 $this->_lastError = $this->_db->ErrorMsg();
    
17.                 lt_include( PLOG_CLASS_PATH . "class/logger/loggermanager.class.php" );
    
18. 
    
19.                 $log =& LoggerManager::getLogger( "sqlerr" );
    
20.                 $error = $this->DbError();
    
21.                 $log->error( "The following query = \n" .
    
22.                               $query .
    
23.                              "generated the following error message = \n" .
    
24.                               $error );
    
25.             }
    
26.               
    
27.             return( $result );
    
28.         }

复制代码

sql语句执行都通过这个execute 函数执行

请帮忙看看，写的时候为什么还会连接着从数据库

[ 本帖最后由 ghewqqq 于 2008-12-3 15:14 编辑 ]

sunnyfun

代码不全没看到实际操作数据库的逻辑，但可以肯定的是确实有漏洞。且不说存储过程的情况，如果往你那个Execute里一次塞两句sql的话，整个就乱套了。

忍者5482

大家有没有试过amoeba啊,支持读写分离,分表操作.阿里巴巴的工程师开发的.似乎性能不错.

ghewqqq

MySQL Proxy 不知道性能和稳定行怎么样。一直都不敢再生产线上使用。

枫影谁用了

mysql-proxy 你要是懂lua的话还是可以用到生产的。不错的东西。

willko

只从这段代码比较难找到问题～～
不过，我估计可能先读从服务器，这时写的话就是写在从DB上了
你可以试下。整个程序只写的话会不会写在从DB上。。