MYSQL实现主从insert和query分开操作

<?php
/**
 * gMysql MySQL数据库的驱动支持
 */
class gMysql {
   /**
    * 数据库链接句柄
    */
   public $conn;// 当前使用的连接
   /**
    * 执行的SQL语句记录
    */
   public $arrSql;

   // 当前连接ID
   public $m_link_id = null; // 主库连接
   public $s_link_id = null; // 从库连接
        
   // 是否多库
   public $multi_server = false;
        
   // 数据库连接参数配置
   public $dbConfig = array ();
    public $dbCurrent = array ();

    /**
    * 构造函数
    *
    * @param dbConfig  数据库配置
    */
   public function __construct($dbConfig)
   {
            $this->dbConfig = $dbConfig;
            $this->multi_server = empty ( $this->dbConfig[‘slave‘] ) ? false : true;
   }
   /**
    * 连接数据库方法
    * @param type $dbConfig 
    */
   public function connect ($db) {
      $this->dbCurrent = $db;
      $linkfunction = ( TRUE == $db[‘persistent‘] ) ? ‘mysql_pconnect‘ : ‘mysql_connect‘;
      $this->conn = $linkfunction ( $db [‘host‘], $db [‘username‘], $db [‘password‘]);

      if (! $this->conn) {
            return false;
      }
      $re = mysql_select_db($db[‘dbname‘], $this->conn);
      if(!$re) {
         return false;
      }
      mysql_query ( "SET NAMES ‘" . $db [‘charset‘] . "‘", $this->conn );            
   }
   
   /**
    * 初始化数据库连接
    * @param type $master 
    */
   public function initConnect ($master = true) {
      if ($master || !$this->multi_server) {
            if($this->m_link_id){
                  $this->conn = $this->m_link_id;
                  $this->ping($master);
            } else {
                  $this->connect ( $this->dbConfig [‘master‘] );
                  $this->m_link_id = $this->conn;
            }
      } else {
            if($this->s_link_id){
                  $this->conn = $this->s_link_id;
                  $this->ping($master);
            } else {
                  $rand = rand(0, count($this->dbConfig [‘slave‘]) - 1);
                  $this->connect ( $this->dbConfig [‘slave‘][$rand] );
                  $this->s_link_id = $this->conn;
            }
      }
    }

    /**
    * 按SQL语句获取记录结果,返回数组
    *
    * @param sql  执行的SQL语句
    */
   public function getArray($sql)
   {
      if( ! $result = $this->query($sql) )return FALSE;
      if( ! mysql_num_rows($result) ) return FALSE;
      $rows = array();
      while($rows[] = mysql_fetch_array($result,MYSQL_ASSOC)){}
      mysql_free_result($result);
      array_pop($rows);
      return $rows;
   }

   /**
    * 返回当前插入记录的主键ID
    */
   public function newinsertid()
   {
      return mysql_insert_id($this->conn);
   }

   /**
    * 格式化带limit的SQL语句
    */
   public function setlimit($sql, $limit)
   {
      return $sql. " LIMIT {$limit}";
   }

   /**
    * 执行一个SQL语句
    *
    * @param sql 需要执行的SQL语句
    */
   public function exec($sql)
   {
      $this->arrSql[] = $sql;
        $this->initConnect ( true );
      
      return mysql_query($sql, $this->conn);
   }
    /**
     * 执行一个SQL语句,主要用于查询
     * @param type $sql
     * @param type $master default:false 为true:强制读主库;为false:在有从库的的情况下优先读从库,否则读主库
     */
    public function query ($sql, $master = false) {
        $this->arrSql[] = $sql;
        $this->initConnect ( $master );
        return mysql_query($sql, $this->conn);
    }

   /**
    * 返回影响行数
    */
   public function affected_rows()
   {
      return mysql_affected_rows($this->conn);
   }

   /**
    * 获取数据表结构
    *
    * @param tbl_name  表名称
    */
   public function getTable($tbl_name)
   {
      return $this->getArray("DESCRIBE {$tbl_name}");
   }
    
   //防止mysql gone away
    public function ping($master) {
       if([email protected]_ping($this->conn)){
         @mysql_close($this->conn); //注意:一定要先执行数据库关闭,这是关键
         if($master || !$this->multi_server) {
            unset($this->m_link_id);
         } else {
            unset($this->s_link_id);
         }
         $this->initConnect($master);
      }
    }
    
   /**
    * 对特殊字符进行过滤
    *
    * @param value  值
    */
   public function __val_escape($value) {
      if(is_null($value))return ‘NULL‘;
      if(is_bool($value))return $value ? 1 : 0;
      if(is_int($value))return (int)$value;
      if(is_float($value))return (float)$value;
      if(@get_magic_quotes_gpc())$value = stripslashes($value);
        $this->conn || $this->initConnect();
      return ‘\‘‘.mysql_real_escape_string($value, $this->conn).‘\‘‘;
   }

   public function escape($value) {
      if(is_null($value))return ‘NULL‘;
      if(is_bool($value))return $value ? 1 : 0;
      if(is_int($value))return (int)$value;
      if(is_float($value))return (float)$value;
      if(@get_magic_quotes_gpc())$value = stripslashes($value);
        $this->conn || $this->initConnect();
      return mysql_real_escape_string($value, $this->conn);
   }
   
   /**
    * 析构函数
    */
   public function __destruct()
   {
        if( TRUE != @$this->dbCurrent[‘persistent‘] )@mysql_close($this->conn);
   }
}

重点在 initConnect($master)方法里,这里决定加载的配置文件中是连接到主库还是从库

时间: 2024-10-02 00:21:11

MYSQL实现主从insert和query分开操作的相关文章

如何快速解决MySQL 1032 主从错误

3分钟解决MySQL 1032主从错误 Part1:写在最前1032错误----现在生产库中好多数据,在从库误删了,生产库更新后找不到了,现在主从不同步了,再跳过错误也没用,因为没这条,再更新还会报错 解决方案 Part1:临时方案 mysql> stop slave;Query OK, 0 rowsaffected (0.00 sec) mysql> set global sql_slave_skip_counter=1;Query OK, 0 rowsaffected (0.00 sec)

MySQL互为主从模型实现基于SSL复制

一.MySQL复制 1.MySQL复制过程描述 MySQL主服务器上每一次发生的有可能产生修改或者产生修改的操作都会在主服务器上基于语句或基于行写入二进制日志,从服务器会在此期间启用一个IO线程不断的向主服务器发送请求,主服务器的二进制日志一但有更新,则会启用binlog dump线程,把数据发送给对方,从服务器接收到数据后则会将二进制日志的内容同步至本地的中继日志保存,而后启用SQL线程,将日志中的操作语句写入本地从服务器数据库: 2.mysql复制的同步和异步 同步:客户端向主服务器执行一条

Mysql数据库主从心得整理

一.mysql主从的原理 1.Replication 线程 Mysql的 Replication 是一个异步的复制过程(mysql5.1.7以上版本分为异步复制和半同步两种模式),从一个 Mysql instace(我们称之为 Master)复制到另一个 Mysql instance(我们称之 Slave).在 Master 与 Slave 之间的实现整个复制过程主要由三个线程来完成,其中两个线程(Sql线程和IO线程)在 Slave 端,另外一个线程(IO线程)在 Master 端. 要实现

谈谈Mysql数据库主从同步延迟分析及解决方案

一.MySQL的数据库主从复制原理 MySQL主从复制实际上基于二进制日志,原理可以用一张图来表示: 分为四步走: 1. 主库对所有DDL和DML产生的日志写进binlog: 2. 主库生成一个 log dump 线程,用来给从库I/O线程读取binlog: 3. 从库的I/O Thread去请求主库的binlog,并将得到的binlog日志写到relay log文件中: 4. 从库的SQL Thread会读取relay log文件中的日志解析成具体操作,将主库的DDL和DML操作事件重放. 关

Mysql互为主从问题

我搭建的是mysql 互为主从 复制 两台机器的mysql环境完全相同 第一部分测试: B为master  A为slave的同步测试 在B上创建表lian,并插入数据mysql> create table lian (a int,b char(10)); mysql> insert into lian (a,b)values(22,'hahah'); mysql> show tables;+------+| Tables_in_test |+------+| lian          

3分钟解决MySQL 1032 主从错误(转)

转自  https://blog.51cto.com/suifu/1845457 3分钟解决MySQL 1032主从错误 Part1:写在最前 1032错误----现在生产库中好多数据,在从库误删了,生产库更新后找不到了,现在主从不同步了,再跳过错误也没用,因为没这条,再更新还会报错 解决方案 Part1:临时方案 mysql> stop slave; Query OK, 0 rows affected (0.00 sec) mysql> set global sql_slave_skip_c

MySQL数据库(7)_用户操作与权限管理、视图、存储过程、触发器、基本函数

用户操作与权限管理 MySQL用户操作 创建用户 方法一: CREATE USER语句创建 CREATE USER "用户名"@"IP地址" IDENTIFIED BY "密码"; 方法二: INSERT语句创建 INSERT INTO mysql.user(user,host, password,ssl_cipher,x509_issuer,x509_subject) VALUES('用户名','IP地址',password('密码'),'',

mysql数据库主从同步

环境: Mater:   CentOS7.1  5.5.52-MariaDB  192.168.108.133 Slave:   CentOS7.1  5.5.52-MariaDB  192.168.108.140 1.导出主服务数据,将主备初始数据同步 master: //从master上导出需要同步的数据库信息 mysqldump -u*** -p*** --database test > test.sql //将master上的备份信息传输到slave上 scp /root/test.sq

mysql 设置主从

mysql 设置主从 Table of Contents 主从 扩展升级 读写分离: 主主复制: 互为主从, 也叫双主 数据分片, 分区 (高级, 难) 主从 主从: 异步实现 slave 的 IO thread 当有数据需要同步的时候, master 的 bin log dump 会传给 slave 的 IO thread, 否则 slave 会睡眠 slave 的 sql thread 负责将 bin log 从 master 下载到 slave mysql 二进制日志文件 statemen