MySQL 存储引擎 FEDERATED使用方法

本地 MySQL 服务器          远程 MySQL 服务器
┌─────────────────┐      ┌─────────────────┐
│ FEDERATED 表     │─────>│ 实际数据表       │
│ (只存结构)       │      │ (存储真实数据)   │
└─────────────────┘      └─────────────────┘
       ↓                        ↓
   元数据                    数据存储
   (无数据)                  (真实数据)

-- 检查是否启用
SHOW ENGINES;
-- 如果未启用，在 my.cnf/my.ini 中添加
[mysqld]
federated
-- 或者动态加载（如果已编译）
INSTALL PLUGIN federated SONAME 'ha_federated.so';

-- 在远程服务器 (例如：192.168.1.100:3306) 
CREATE DATABASE remote_db;
USE remote_db;
CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50),
    email VARCHAR(100),
    created_at DATETIME
) ENGINE=InnoDB;

USE local_db;
CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50),
    email VARCHAR(100),
    created_at DATETIME
) ENGINE=FEDERATED
CONNECTION='mysql://username:password@192.168.1.100:3306/remote_db/users';

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50),
    email VARCHAR(100),
    created_at DATETIME
) ENGINE=FEDERATED
DATA DIRECTORY='mysql://user:pass@host:port/db/table';

-- 查询远程数据（和本地表一样使用）
SELECT * FROM users WHERE username = 'john';
-- 插入数据（实际插入到远程）
INSERT INTO users (username, email) VALUES ('alice', 'alice@example.com');
-- 更新操作
UPDATE users SET email = 'new@example.com' WHERE id = 1;
-- 删除操作
DELETE FROM users WHERE id = 1;
-- JOIN 本地表和 FEDERATED 表
SELECT l.*, f.* 
FROM local_table l 
INNER JOIN users f ON l.user_id = f.id;

# my.cnf / my.ini
[mysqld]
# 启用 FEDERATED
federated
# 可选配置
federated_max_connections=100        # 最大连接数
read_buffer_size=256K                # 读缓冲区
read_rnd_buffer_size=256K            # 随机读缓冲区

-- 在主库
CREATE VIEW all_users AS
SELECT * FROM db1.users
UNION ALL
SELECT * FROM db2.users;
-- 通过复制到从库，从库查询视图

// Java 示例
@Service
public class UserService {
    @Autowired
    private UserRepository localRepo;
    @Autowired
    @Qualifier("remoteUserRepository")
    private UserRepository remoteRepo;
    public List<User> getAllUsers() {
        List<User> all = new ArrayList<>();
        all.addAll(localRepo.findAll());
        all.addAll(remoteRepo.findAll());
        return all;
    }
}

# 使用 DataX 同步
{
  "job": {
    "content": [{
      "reader": {
        "name": "mysqlreader",
        "parameter": {
          "connection": [{
            "table": ["users"],
            "jdbcUrl": ["jdbc:mysql://remote:3306/db"]
          }]
        }
      },
      "writer": {
        "name": "mysqlwriter",
        "parameter": {
          "connection": [{
            "table": ["users"],
            "jdbcUrl": "jdbc:mysql://local:3306/db"
          }]
        }
      }
    }]
  }
}