MySQL使用Federate引擎

1. 查看Mysql数据库是否已经安装Federate引擎

  FEDERATES Support NO表示未开启。

2.开启federated引擎

  windows下在my.ini中加入federated,即可开启;

  linux中,需要编译时加入选项,再在my.ini中加入federated,方可开启.

  3.建立远程数据表链接

  假如:在ServerA上有一个数据库dbtestA,在ServerB上有数据库dbtestB,要在ServerB的数据库dbtestB上建立 ServerA的数据库dbtestA上的表的数据表链接remote_tabletestA,语句如下:

以下是代码片段:

  create table remote_tabletestA ... ... engine=federated connection = ‘MySQL://root:[email protected]:3306/dbtestA/tabletestA‘;

  4.使用远程数据表链接

  如上例,直接在ServerB的数据库dbtestB上对表remote_tabletestA进行操作,即是操作ServerA上数据库dbtestA的表tabletestA.

  5.MySQL使用Federate引擎实现操作本地表映射远程操作表

  

考虑这样一个场景,存在多台agent系统(每台均拥有自己的数据库)各自做完操作后,将会触发各自数据库的存储过程进行复杂运算,各自完成后均需要向远程某Master机器的数据库的表中擦入一条信息,以通知操作完成。初步设想有两个方案来实现。

  1. 在agent系统里面通过java代码调用存储过程,直到存储过程执行完成后,再将执结束信息写入到Master系统的数据库中。
  2. 通过为每一个agent系统中的数据库建立一个远程映射表,从而实现agent系统存储过程执行完成后,通过存储过程再将信息写入本地的映射表中,由mysql自动同步数据到Master上。(此处也凸显出mysql一个短板,本地存储过程不能调用远程数据库的存储过程,不能操作远程数据库的表,貌似Oracle,sqlserver等都可以,不然就不用这么麻烦了╮(╯▽╰)╭)

因为在实际项目中,第一种方式的会因为存储过程的运行时间过长(半个小时甚至更久),会导致agent系统的性能有影响,迫于无赖才使用第二种方案。

首先需确保已经打开federated引擎,可通过show engines命令查看是否安装。然后具体步骤如下:

首先在Master机器上建立projects表,我们只需要将每个agent数据库中建立映射表projects

CREATE TABLE `projects` (
    `project_id` INT(11) NOT NULL AUTO_INCREMENT,
    `project_code` VARCHAR(50) NOT NULL,
    `test_code` VARCHAR(50) NOT NULL,
    `create_time` BIGINT(11) NULL DEFAULT NULL,
    `result` VARCHAR(255) NULL DEFAULT NULL,
    `ts` BIGINT(11) NOT NULL,
    PRIMARY KEY (`id`)
)
COLLATE=‘utf8_general_ci‘
ENGINE=FEDERATED
CONNECTION=‘mysql://user:[email protected]:3306/testdb/tb_projects_tests‘;

注意connection语句的设置,需要远程Master数据库的用户名,密码以及映射表的相应信息,中然后在每一个存储过程执行完成后对本地的projects执行一条insert语句即可。

PS:需要注意的是,此种方式不适合大数据量的同步操作。

 

时间: 2024-10-11 04:06:43

MySQL使用Federate引擎的相关文章

查看并修改mysql的默认引擎

1.mysql存储引擎: a)mysql服务器采用了模块化风格,各部分之间保持相对独立,尤其体现在存储架构上.存储引擎负责管理数据存储,以及mysql的索引管理.通过定义的API,mysql服务器能够与存储引擎进行通信.目前使用最多的是MyISAM和InnoDB.InnoDB被Oracle收购后,mysql自行开发的新存储引擎Falcon将在mysql6.0版本引进. b)MyISAM引擎是一种非事务性的引擎,提供高速存储和检索,以及全文搜索能力,适合数据仓库等查询频繁的应用.MyISAM中,一

mysql 的存储引擎介绍

在数据库中存的就是一张张有着千丝万缕关系的表,所以表设计的好坏,将直接影响着整个数据库.而在设计表的时候,我们都会关注一个问题,使用什么存储引擎.等一下,存储引擎?什么是存储引擎? 什么是存储引擎? MySQL中的数据用各种不同的技术存储在文件(或者内存)中.这些技术中的每一种技术都使用不同的存储机制.索引技巧.锁定水平并且最终提供广泛的不同的功能和能力.通过选择不同的技术,你能够获得额外的速度或者功能,从而改善你的应用的整体功能. 例如,如果你在研究大量的临时数据,你也许需要使用内存MySQL

MySQL数据库存储引擎

MySQL数据库存储引擎 MySQL数据库是一种关系型数据库,数据时存放在数据库中的一张一张的表中的,各个表之间或有关联,表中的每行相关,每列是不相关.这是关系型数据库的基本存储方式. MySQL存储引擎是为了在各种不同的条件下对数据存放的可靠性.关联性.读写等方面做出的一个可供选择的存储模式. 当前使用较多的MySQL存储引擎主要有以下几个,MyISAM,InnoDB,BdB,Memory等,这些存储引擎主要在以下几个方面有所区分,锁定水平.处理方式.存储方式和索引技巧方面有所不同. mysq

MySQL中innodb引擎分析(初始化)

MySQL的存储引擎是以插件形式工作的,这应该是MySQL的一大特色了吧! 依据<深入理解MySQL>的内容,5.1版本号时存储引擎的插件化都还不是彻底,确切的说是刚加入的特性.为MySQL加入一个存储引擎时,须要更改一些上层代码,零散的更改本来就有点麻烦,同一时候project也要又一次编译一次.我听别人说,已经能够不改C/C++代码就直接加入引擎了.这种话,折腾存储引擎的话就更方便了! 这段代码来自ha_innodb.cc,这是MySQL中申明存储引擎插件的标准过程.这段代码利用了宏.在p

mysql innodb存储引擎的聚集索引

InnoDB聚集索引 MySQL有没有支持聚集索引,取决于采用哪种存储引擎. MySQL InnoDB一定会建立聚集索引,所谓聚集,指实际数据行和相关的键值保存在一块,这也决定了一个表只能有一个聚集索引,即MySQL不会一次把数据行保存在二个地方.InnoDB通常根据主键值(primary key)进行聚集,但是当一个表没有PK怎么办?InnoDB选取聚集索引参照列的顺序是: 1.如果声明了主键(primary key),则这个列会被做为聚集索引2.如果没有声明主键,则会用一个唯一且不为空的索引

mysql的常用引擎

在MySQL数据库中,常用的引擎主要就是2个:Innodb和MyIASM. 首先: 1.简单介绍这两种引擎,以及该如何去选择.2.这两种引擎所使用的数据结构是什么. 1. a.Innodb引擎,Innodb引擎提供了对数据库ACID事务的支持.并且还提供了行级锁和外键的约束.它的设计的目标就是处理大数据容量的数据库系统.它本身实际上是基于Mysql后台的完整的系统.Mysql运行的时候,Innodb会在内存中建立缓冲池,用于缓冲数据和索引.但是,该引擎是不支持全文搜索的.同时,启动也比较的慢,它

Mysql的存储引擎介绍

下面主要介绍InnoDB.MyISAM和MEMEORY三种存储引擎. InnoDB存储引擎 InnoDB遵循CNU通用公开许可(GPL)发行.InnoDB已经被一些重量级互联网公司所采用,如雅虎.Slashdot和Google,为用户操作非常大的数据库提供了一个强大的解决方案.InnoDB给MySQL的表提供了事务.回滚.崩溃修复能力和多版本并发控制的事务安全.MySQL从3.23.34a开始包含InnoDB存储引擎.InnoDB是MySQL上第一个提供外键约束的表引擎,而且InnoDB对事务处

MySQL的数据库引擎

Mysql的数据库引擎有很多,最重要的就是MyISAM.InnoDB.heap(memory),此外还有BDB.archive数据表.csv.ndb.federated InnoDB 优点: 1.对数据库事务支持,支持四种事务级别(read uncommitted.read committed.repeatable read.serializable) 2.提供行级锁(内建的)和外键,目的是处理大量数据库系统,行级锁锁定的只是一次事务中的记录,不会锁定数据表,所以其他的用户都可以去访问操作数据库

如何批量修改mysql表的引擎

工作需要,要将所有的mysql表的引擎改为innodb 执行如下SQL SET @DATABASE_NAME = 'name_of_your_db';SELECT  CONCAT('ALTER TABLE `', table_name, '` ENGINE=InnoDB;') AS sql_statementsFROM    information_schema.tables AS tbWHERE   table_schema = @DATABASE_NAMEAND     `ENGINE` =