ClickHouse使用MySQL数据库引擎的实现

CREATE DATABASE mysql_db_alias -- ClickHouse 中的数据库别名
ENGINE = MySQL('mysql_host:port', 'mysql_database_name', 'mysql_user', 'mysql_password');

-- 查看 MySQL 数据库中的表
SHOW TABLES FROM mysql_db_alias;

-- 查询 MySQL 中的某个表
SELECT * FROM mysql_db_alias.some_mysql_table WHERE condition LIMIT 10;

-- 与 ClickHouse 本地表进行 JOIN
SELECT c.data, m.name
FROM clickhouse_local_table AS c
JOIN mysql_db_alias.users AS m ON c.user_id = m.id;

name: 'ch_mysql_demo'

services:
mysql-server:
image: mysql:8.0 # 使用 MySQL 8.0 镜像
container_name: mysql-server
hostname: mysql-server # 容器主机名，ClickHouse 将使用它连接
restart: always
environment:
MYSQL_ROOT_PASSWORD: TestPassword!@#$ # 设置 root 密码 (生产环境请使用更安全的方式)
MYSQL_DATABASE: demo_db # 创建一个名为 demo_db 的数据库
MYSQL_USER: demo_user # 创建一个用户
MYSQL_PASSWORD: UserPassword123 # 设置用户的密码 (生产环境请使用更安全的方式)
volumes:
- mysql_data:/var/lib/mysql # 持久化 MySQL 数据
- ./mysql_init:/docker-entrypoint-initdb.d # 挂载初始化脚本目录
ports:
- "3306:3306" # 将 MySQL 端口映射到宿主机，方便调试
networks:
- ch_mysql_network

clickhouse-server:
image: clickhouse/clickhouse-server:latest # 使用最新的 ClickHouse 镜像
container_name: clickhouse-server
hostname: clickhouse-server
restart: always
ports:
- "8123:8123" # ClickHouse HTTP 接口
- "9000:9000" # ClickHouse 原生 TCP 接口
volumes:
- clickhouse_data:/var/lib/clickhouse/ # 持久化 ClickHouse 数据
- clickhouse_logs:/var/log/clickhouse-server/ # 持久化 ClickHouse 日志
networks:
- ch_mysql_network
depends_on:
- mysql-server # 确保 MySQL 容器先启动
ulimits: # 推荐为 ClickHouse 提高文件描述符限制
nofile:
soft: 262144
hard: 262144

volumes:
mysql_data: # Docker 管理的数据卷
clickhouse_data:
clickhouse_logs:

networks:
ch_mysql_network: # 自定义桥接网络，让容器可以通过服务名通信
driver: bridge

-- 这个脚本会在 MySQL 容器第一次启动时自动执行
-- 使用我们通过环境变量创建的数据库
USE demo_db;

-- 创建一个示例表
CREATE TABLE products (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
price DECIMAL(10, 2),
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

-- 插入一些示例数据
INSERT INTO products (name, price) VALUES
('Laptop', 1200.50),
('Mouse', 25.00),
('Keyboard', 75.99),
('Monitor', 300.00);

-- 可以添加更多表和数据...

-- 确保 demo_user 对 demo_db 有权限 (通常环境变量创建用户时会自动授权，但显式添加更保险)
-- GRANT ALL PRIVILEGES ON demo_db.* TO 'demo_user'@'%'; -- 在某些 MySQL 镜像版本可能需要
-- FLUSH PRIVILEGES;