search
HomeDatabaseMysql Tutorial秒杀MYSQL单双向同步_MySQL
秒杀MYSQL单双向同步_MySQLJun 01, 2016 pm 01:47 PM
masterdatabaseDownload Document

bitsCN.com

 

简介 :

采用脚本直接配置,请事先安装好MYSQL,附件中脚本包里有4个文件分别为mysqlsa.py(主程序)、mysqldb(数据库模块)、master(参数)、slave(参数)

程序文件下载地址:http://down.51cto.com/data/229410

Sever info:

Master:192.168.1.3

Slave:192.168.1.4

脚本使用教程:

Master:192.168.1.3

1、解压TAR包

[root@SQL1 down]# tar -zxf mysql-master-slave.tar.gz

2、进入目录设置权限

[root@SQL1 down]# cd mysql-master-slave

[root@SQL1 mysql-master-slave]# chmod 777 mysqlsa.py

3、打开master文件,设置你需要同步的库

[root@SQL1 mysql-master-slave]# vi master

log-bin=/var/log/mysql/mysql-bin

binlog-ignore-db=mysql,test

binlog-do-db=wgdb

log-bin=/var/log/mysql/updatelog

4、运行脚本程序(这里注意如果你的MYSQL默认安装路经不是‘/usr/local/mysql'在此脚本程序的10~11行把成“export LD_LIBRARY_PATH=your path '你自己路经地址,否则有可能程序里面MySQLdb模块报错

[root@SQL1 mysql-master-slave]# ./mysqlsa.py    

----------------------------------------------------------------------

                                1)Installation MySQL Master

 

                                2)Installation MySQL Slave

 

                                Q)Quit Installation

 

----------------------------------------------------------------------

                                Plase,Enter your option:

1:配置安装MYSQL主库

2:配置安装MYSQL从库

Q:退出

 

5、我们选择“1”配置MYSQL主库

[root@SQL1 mysql-master-slave]# ./mysqlsa.py   

----------------------------------------------------------------------

                                1)Installation MySQL Master

 

                                2)Installation MySQL Slave

 

                                Q)Quit Installation

 

----------------------------------------------------------------------

                                Plase,Enter your option:1

6、提示要求输入SLAVE服务器IP,这步是创建访问帐号用的,我们输入SLAVE的IP:192.168.1.4,注意:千万别输错,不然SLAVE访问就会出错

                             Plase,Enter your option:1

Please,input your slave server ip:192.168.1.4

7、OK,执行完成以后程序不会给你任何提示!我们直接安Q退出,查看/etc/my.cnf的57行下面内容是否成功写入

54 # required unique id between 1 and 2^32 - 1

55 # defaults to 1 if master-host is not set

56 # but will not function as a master if omitted

57 server-id             = 1

58 log-bin=/var/log/mysql/mysql-bin

59 binlog-ignore-db=mysql,test

60 binlog-do-db=wgdb

61 log-bin=/var/log/mysql/updatelog

 8、重启MYSQL

 

[root@SQL1 down]# service mysqld restart

 

 

 

Slave:192.168.1.4

1、解压TAR包

[root@SQL2 down]# tar -zxf mysql-master-slave.tar.gz

2、进入目录设置权限

[root@SQL2 down]# cd mysql-master-slave

[root@SQL2 mysql-master-slave]#

3、打开slave文件,设置你需要同步的库和master的IP

master-host = 192.168.1.3

master-user = replication

master-password = *.asDICf.1KD

master-port = 3306

master-connect-retry = 60

replicate-ignore-db = mysql,test

replicate-do-db = wgdb

relay-log=/var/log/mysql/slave-relay-bin

slave-skip-errors=all

4、运行脚本程序(这里注意如果你的MYSQL默认安装路经不是‘/usr/local/mysql'在此脚本程序的10~11行把成“export LD_LIBRARY_PATH=your path '你自己路经地址,否则有可能程序里面MySQLdb模块报错

[root@SQL2 mysql-master-slave]# ./mysqlsa.py   

----------------------------------------------------------------------

                                1)Installation MySQL Master

 

                                2)Installation MySQL Slave

 

                                Q)Quit Installation

 

----------------------------------------------------------------------

                                Plase,Enter your option:

5、我们选择‘2’安装从库

[root@SQL2 mysql-master-slave]# ./mysqlsa.py   

----------------------------------------------------------------------

                                1)Installation MySQL Master

 

                                2)Installation MySQL Slave

 

                                Q)Quit Installation

 

----------------------------------------------------------------------

                                Plase,Enter your option:2

6、检查下‘/etc/my.cnf' 57行内容是否写入

# required unique id between 1 and 2^32 - 1

# defaults to 1 if master-host is not set

# but will not function as a master if omitted

server-id             = 2

master-host = 192.168.1.3

master-user = replication

master-password = *.asDICf.1KD

master-port = 3307

master-connect-retry = 60

replicate-ignore-db = mysql,test

replicate-do-db = wgdb

relay-log=/var/log/mysql/slave-relay-bin

slave-skip-errors=all

7、重起MYSQL

[root@SQL2 mysql-master-slave]# service mysqld restart

最后一步

1、进入Master 调整参数

[root@SQL1 down]# mysql -uroot -p

Enter password:   

Welcome to the MySQL monitor.    Commands end with ; or /g.

Your MySQL connection id is 2

Server version: 5.1.57-log Source distribution

 

Copyright (c) 2000, 2010, Oracle and/or its affiliates. All rights reserved.

This software comes with ABSOLUTELY NO WARRANTY. This is free software,

and you are welcome to modify and redistribute it under the GPL v2 license

 

Type 'help;' or '/h' for help. Type '/c' to clear the current input statement.

 

mysql> slave stop;

Query OK, 0 rows affected, 1 warning (0.00 sec)

 

mysql>    show master status;

+------------------+----------+--------------+------------------+

| File                         | Position | Binlog_Do_DB | Binlog_Ignore_DB |

+------------------+----------+--------------+------------------+

| updatelog.000001 |            106 | wgdb                 | mysql,test             |

+------------------+----------+--------------+------------------+

1 row in set (0.00 sec)

2、进入slave 调整参数

[root@SQL2 mysql-master-slave]# mysql -uroot -p

Enter password:    

Welcome to the MySQL monitor.    Commands end with ; or /g.

Your MySQL connection id is 4

Server version: 5.1.57-log Source distribution

 

Copyright (c) 2000, 2010, Oracle and/or its affiliates. All rights reserved.

This software comes with ABSOLUTELY NO WARRANTY. This is free software,

and you are welcome to modify and redistribute it under the GPL v2 license

 

Type 'help;' or '/h' for help. Type '/c' to clear the current input statement.

 

mysql> slave stop;

Query OK, 0 rows affected (0.00 sec)

 

mysql> CHANGE MASTER TO MASTER_LOG_FILE='updatelog.000001',MASTER_LOG_POS=106;

Query OK, 0 rows affected (0.02 sec)

 

mysql> slave start;

Query OK, 0 rows affected (0.01 sec)

3、检查是否成功

Slave_IO_Running:    Yes

Slave_SQL_Running: Yes

以上配置已经全部完成,很多朋友可能会问,这只是单向同步吗?

答:只要把两个操作反向做下就OK

脚本程序问题在哪里?

答:http://down.51cto.com/data/229410

 

以下是主程序的代码

#!/usr/bin/python

#

#This is a mysql reversed sync    and data pool script.

import os,MySQLdb

import sys

import re

#Check that Mysql exists

if os.path.isfile('/etc/my.cnf'):

        b=os.system('python mysqldb.py')

        profile = open('/etc/profile','r+')

        if re.search('export LD_LIBRARY_PATH=/usr/local/mysql/lib/mysql/',profile.read()) is None:

                profile.write('export LD_LIBRARY_PATH=/usr/local/mysql/lib/mysql/')

        profile.close

                

else:

        print 'Your mysql not installiation'

        sys.exit(1)

 

class msa:

        def sql(self):

                try:   

                        try:

                                conn = MySQLdb.connect(host = 'localhost',user='root',passwd='')

                        except:

                                pw = raw_input('Please,input your amdin of mysql passwd:')

                                conn = MySQLdb.connect(host = 'localhost',user='root',passwd='%s')%pw

                        IP = raw_input('Please,input your slave server ip:')

                        cursor = conn.cursor()

                        sql = "GRANT REPLICATION SLAVE,REPLICATION CLIENT,RELOAD,SUPER ON *.* TO    'replication'@'%s' identified by '*.asDICf.1KD'; Flush privileges; "%(IP)

                        cursor.execute(sql)

                except Exception,e:

                        print e

                        sys.exit()

        def mk(self):

                var='/var/log/mysql'

                if not os.path.isdir(var):

                        os.makedirs(var)

                        os.chmod(var,448|56)

                        os.chown(var,500,500)

        def master(self):

                my_conf = open('/etc/my.cnf','r')

                my_conf_read = my_conf.readlines()

                my_conf.close

                if re.search('binlog-do-db',str(my_conf_read)) is None:

                        master_file = open('master','r')

                        read = master_file.read()

                        my_conf_read.insert(57,read)

                        my_conf = open('/etc/my.cnf','w')

                        my_conf.writelines(my_conf_read)

                        master_file.close

                        my_conf.close

        def slave(self):

                my_conf = open('/etc/my.cnf','r')

                my_conf_read = my_conf.readlines()

                my_conf.close

                if re.search('replicate-do-db',str(my_conf_read)) is None:

                        master_file = open('slave','r')

                        read = master_file.read()

                        my_conf_read.insert(57,read)

                        my_conf = open('/etc/my.cnf','w')

                        my_conf.writelines(my_conf_read)

                        master_file.close

        def re(self):

                my_conf = open('/etc/my.cnf','r')

                #my_conf_read = my_conf.readlines()

                my_conf.close

                if info    == '1':

    = re.sub()    = re.sub('log-bin=mysql-bin','#log-bin=mysql-bin',my_conf.read())

                else:

                        if re.search('binlog-do-db',my_conf.read()) is None:

                                my_conf.seek(0)

    = re.sub()    = re.sub('server-id/t= 1/n','server-id/t= 2/n',my_conf.read())

                        else:

                                my_conf.seek(0)

= my_conf.read() = my_conf.read()

                my_conf = open('/etc/my.cnf','w')

                my_conf.writelines(sub)

                my_conf.close

 

                

 

m = msa()

while 1 > b:

        #os.system('clear')

        print '--' * 35

        print '/t/t1)Installation MySQL Master/n'

        print '/t/t2)Installation MySQL Slave/n'

        print '/t/tQ)Quit Installation/n'

        print '--' * 35

        if ('err' in dir()) is True:

                print err

                del err

        info = raw_input('/t/tPlase,Enter your option:')

        if info.lower() == 'q':

                sys.exit()

        elif info == '1':

                m.sql()

                m.mk()

                m.master()

                m.re()

        elif info == '2':

                m.mk()

                m.slave()

                m.re()

        else:

                err ='/t/t***You enter the option error***'

本文出自 “Intelligence” 博客

bitsCN.com
Statement
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
master和host的区别是什么master和host的区别是什么Sep 28, 2023 pm 01:34 PM

master和host的区别有:1、host可以扮演客户端或服务器的角色,而master是分布式系统中负责协调和管理其他从服务器的中央服务器;2、host是普通的计算机设备,而master通常具有更高的处理能力和资源,用于处理和分发任务、管理数据和维护整个系统的稳定性;3、host是网络中的一个节点,而master是在分布式系统中担任核心角色的服务器。

深入理解MySQL索引优化器工作原理深入理解MySQL索引优化器工作原理Nov 09, 2022 pm 02:05 PM

本篇文章给大家带来了关于mysql的相关知识,其中主要介绍了关于索引优化器工作原理的相关内容,其中包括了MySQL Server的组成,MySQL优化器选择索引额原理以及SQL成本分析,最后通过 select 查询总结整个查询过程,下面一起来看一下,希望对大家有帮助。

sybase是什么数据库sybase是什么数据库Sep 22, 2021 am 11:39 AM

sybase是基于客户/服务器体系结构的数据库,是一个开放的、高性能的、可编程的数据库,可使用事件驱动的触发器、多线索化等来提高性能。

visual foxpro数据库文件是什么visual foxpro数据库文件是什么Jul 23, 2021 pm 04:53 PM

visual foxpro数据库文件是管理数据库对象的系统文件。在VFP中,用户数据是存放在“.DBF”表文件中;VFP的数据库文件(“.DBC”)中不存放用户数据,它只起将属于某一数据库的 数据库表与视图、连接、存储过程等关联起来的作用。

数据库系统的构成包括哪些数据库系统的构成包括哪些Jul 15, 2022 am 11:58 AM

数据库系统由4个部分构成:1、数据库,是指长期存储在计算机内的,有组织,可共享的数据的集合;2、硬件,是指构成计算机系统的各种物理设备,包括存储所需的外部设备;3、软件,包括操作系统、数据库管理系统及应用程序;4、人员,包括系统分析员和数据库设计人员、应用程序员(负责编写使用数据库的应用程序)、最终用户(利用接口或查询语言访问数据库)、数据库管理员(负责数据库的总体信息控制)。

数据库的什么是指数据的正确性和相容性数据库的什么是指数据的正确性和相容性Jul 04, 2022 pm 04:59 PM

数据库的“完整性”是指数据的正确性和相容性。完整性是指数据库中数据在逻辑上的一致性、正确性、有效性和相容性。完整性对于数据库系统的重要性:1、数据库完整性约束能够防止合法用户使用数据库时向数据库中添加不合语义的数据;2、合理的数据库完整性设计,能够同时兼顾数据库的完整性和系统的效能;3、完善的数据库完整性有助于尽早发现应用软件的错误。

mysql查询慢的因素除了索引,还有什么?mysql查询慢的因素除了索引,还有什么?Jul 19, 2022 pm 08:22 PM

mysql查询为什么会慢,关于这个问题,在实际开发经常会遇到,而面试中,也是个高频题。遇到这种问题,我们一般也会想到是因为索引。那除开索引之外,还有哪些因素会导致数据库查询变慢呢?

go语言可以写数据库么go语言可以写数据库么Jan 06, 2023 am 10:35 AM

go语言可以写数据库。Go语言和其他语言不同的地方是,Go官方没有提供数据库驱动,而是编写了开发数据库驱动的标准接口,开发者可以根据定义的接口来开发相应的数据库驱动;这样做的好处在于,只要是按照标准接口开发的代码,以后迁移数据库时,不需要做任何修改,极大方便了后期的架构调整。

See all articles

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

AI Hentai Generator

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

R.E.P.O. Energy Crystals Explained and What They Do (Yellow Crystal)
2 weeks agoBy尊渡假赌尊渡假赌尊渡假赌
Repo: How To Revive Teammates
1 months agoBy尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: How To Get Giant Seeds
4 weeks agoBy尊渡假赌尊渡假赌尊渡假赌

Hot Tools

SAP NetWeaver Server Adapter for Eclipse

SAP NetWeaver Server Adapter for Eclipse

Integrate Eclipse with SAP NetWeaver application server.

EditPlus Chinese cracked version

EditPlus Chinese cracked version

Small size, syntax highlighting, does not support code prompt function

Dreamweaver Mac version

Dreamweaver Mac version

Visual web development tools

Notepad++7.3.1

Notepad++7.3.1

Easy-to-use and free code editor

VSCode Windows 64-bit Download

VSCode Windows 64-bit Download

A free and powerful IDE editor launched by Microsoft