## 1. 环境准备
– 安装PostgreSQL：
$ sudo dnf install -y postgresql18-server postgresql18-contrib

– 初始化数据库：
$ sudo /postgresql/fgapp/bin/postgresql-18-setup –initdb

– 启动PostgreSQL服务：
$ sudo systemctl start postgresql-18
$ sudo systemctl enable postgresql-18

– 安装pgloader：
$ sudo dnf install -y pgloader

## 2. 架构迁移
– 导出MySQL架构：
$ mysqldump -u root -p –no-data fgedudb > mysql_schema.sql

– 转换架构：
# 使用pgloader转换架构
$ pgloader mysql://root:password@localfgedu.net.cn/fgedudb pgsql://pgsql: password@localfgedu.net.cn/fgedudb

– 手动调整架构：
# 调整数据类型
# 调整索引
# 调整约束

## 3. 数据迁移
– 使用pgloader迁移数据：
$ pgloader mysql://root:password@localfgedu.net.cn/fgedudb pgsql://pgsql: password@localfgedu.net.cn/fgedudb

– 验证数据：
# 比较迁移前后的数据量
# 检查关键数据
# 验证数据一致性

## 4. 应用迁移
– 修改应用连接配置：
# 修改数据库连接字符串
# 修改SQL语句
# 调整应用代码

– 测试应用：
# 功能测试
# 性能测试
# 兼容性测试

## 5. 切换操作
– 停止MySQL写入：
# 停止应用
# 禁止新的写入操作

– 执行最终增量迁移：
# 迁移最新数据
# 验证数据一致性

– 切换到PostgreSQL：
# 修改应用连接配置
# 启动应用
# 监控系统状态

## 6. 后续优化
– 优化PostgreSQL参数：
# 调整shared_buffers
# 调整work_mem
# 调整maintenance_work_mem

– 优化索引：
# 创建合适的索引
# 重建碎片索引

– 优化查询：
# 优化慢查询
# 使用EXPLAIN ANALYZE分析查询计划

## 1. 分析MySQL架构
– 查看MySQL表结构：
$ mysql -u root -p -e “USE fgedudb; SHOW CREATE TABLE fgedu_fgedus;”

– 查看MySQL索引：
$ mysql -u root -p -e “USE fgedudb; SHOW INDEX FROM fgedu_fgedus;”

– 查看MySQL约束：
$ mysql -u root -p -e “USE fgedudb; SHOW CREATE TABLE fgedu_fgedus;”

## 2. 转换表结构
– 数据类型映射：
MySQL类型 → PostgreSQL类型
INT → INTEGER
BIGINT → BIGINT
VARCHAR → VARCHAR
TEXT → TEXT
DATETIME → TIMESTAMP
DATE → DATE
TIME → TIME
BOOLEAN → BOOLEAN
DECIMAL → DECIMAL

– 自增字段：
MySQL: AUTO_INCREMENT
PostgreSQL: SERIAL或BIGSERIAL

– 主键约束：
MySQL: PRIMARY KEY
PostgreSQL: PRIMARY KEY

– 外键约束：
MySQL: FOREIGN KEY
PostgreSQL: FOREIGN KEY

## 3. 转换索引
– 普通索引：
MySQL: CREATE INDEX idx_name ON table (column);
PostgreSQL: CREATE INDEX idx_name ON table (column);

– 唯一索引：
MySQL: CREATE UNIQUE INDEX idx_name ON table (column);
PostgreSQL: CREATE UNIQUE INDEX idx_name ON table (column);

– 复合索引：
MySQL: CREATE INDEX idx_name ON table (column1, column2);
PostgreSQL: CREATE INDEX idx_name ON table (column1, column2);

## 4. 转换存储过程和函数
– MySQL存储过程：
DELIMITER //
CREATE PROCEDURE sp_get_fgedus()
BEGIN
SELECT * FROM fgedu_fgedus;
END //
DELIMITER ;

– PostgreSQL函数：
CREATE OR REPLACE FUNCTION sp_get_fgedus()
RETURNS SETOF fgedu_fgedus AS $$
BEGIN
RETURN QUERY SELECT * FROM fgedu_fgedus;
END;
$$ LANGUAGE plpgsql;

## 5. 转换触发器
– MySQL触发器：
DELIMITER //
CREATE TRIGGER trg_before_insert_fgedus
BEFORE INSERT ON fgedu_fgedus
FOR EACH ROW
BEGIN
SET NEW.created_at = NOW();
END //
DELIMITER ;

– PostgreSQL触发器：
CREATE OR REPLACE FUNCTION trg_before_insert_fgedus()
RETURNS TRIGGER AS $$
BEGIN
NEW.created_at = NOW();
RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_before_insert_fgedus
BEFORE INSERT ON fgedu_fgedus
FOR EACH ROW
EXECUTE FUNCTION trg_before_insert_fgedus();

## 6. 转换视图
– MySQL视图：
CREATE VIEW v_fgedus AS
SELECT id, name, email FROM fgedu_fgedus;

– PostgreSQL视图：
CREATE OR REPLACE VIEW v_fgedus AS
SELECT id, name, email FROM fgedu_fgedus;

## 1. 使用pgloader迁移数据
– 创建迁移配置文件：
$ vi mysql_to_pg.load

LOAD DATABASE
FROM mysql://root:password@localfgedu.net.cn/fgedudb
INTO pgsql://pgsql: password@localfgedu.net.cn/fgedudb

WITH include drop, create tables, create indexes, reset sequences
SET work_mem to ’16MB’, maintenance_work_mem to ‘512MB’

CAST type datetime to timestamp
CAST type timestamp to timestamp
CAST type tinyint to boolean
CAST type bigint to bigint
CAST type int to integer
CAST type varchar to varchar
CAST type text to text
CAST type decimal to decimal
CAST type date to date
CAST type time to time

– 执行迁移：
$ pgloader mysql_to_pg.load

## 2. 验证数据
– 比较数据量：
# MySQL
$ mysql -u root -p -e “USE fgedudb; SELECT COUNT(*) FROM fgedu_fgedus;”

# PostgreSQL
$ psql -U pgsql -d fgedudb -c “SELECT COUNT(*) FROM fgedu_fgedus;”

– 检查关键数据：
# MySQL
$ mysql -u root -p -e “USE fgedudb; SELECT * FROM fgedu_fgedus LIMIT 10;”

# PostgreSQL
$ psql -U pgsql -d fgedudb -c “SELECT * FROM fgedu_fgedus LIMIT 10;”

– 验证数据一致性：
# 比较sum值
$ mysql -u root -p -e “USE fgedudb; SELECT SUM(id) FROM fgedu_fgedus;”
$ psql -U pgsql -d fgedudb -c “SELECT SUM(id) FROM fgedu_fgedus;”

## 3. 处理特殊数据类型
– JSON数据：
# MySQL
SELECT JSON_EXTRACT(data, ‘$.name’) FROM fgedu_fgedus;

# PostgreSQL
SELECT data->>’name’ FROM fgedu_fgedus;

– 时间戳数据：
# MySQL
SELECT FROM_UNIXTIME(timestamp) FROM fgedu_fgedus;

# PostgreSQL
SELECT to_timestamp(timestamp) FROM fgedu_fgedus;

## 4. 增量数据迁移
– 记录迁移时间：
$ migration_time=$(date +”%Y-%m-%d %H:%M:%S”)

– 迁移增量数据：
# MySQL
$ mysql -u root -p -e “USE fgedudb; SELECT * FROM fgedu_fgedus WHERE updated_at > ‘$migration_time’;”

# PostgreSQL
$ psql -U pgsql -d fgedudb -c “INSERT INTO fgedu_fgedus SELECT * FROM mysql_fgedu_fgedus WHERE updated_at > ‘$migration_time’;”

## 1. 修改连接配置
– Java应用：
# 修改fgapplication.properties
spring.datasource.url=jdbc:postgresql://localfgedu.net.cn:5432/fgedudb
spring.datasource.fgeduname=pgsql spring.datasource.password=password
spring.datasource.driver-class-name=org.postgresql.Driver

– Python应用：
# 修改配置
import psycopg2
conn = psycopg2.connect(
fgedu.net.cn=”localfgedu.net.cn”,
fgedudb=”fgedudb”,
fgedu=”postgres”,
password=”password”
)

– PHP应用：
# 修改配置
$conn = pg_connect(“fgedu.net.cn=localfgedu.net.cn fgedudb=fgedudb fgedu=pgsql password=password”);

## 2. 修改SQL语句
– 自增字段：
# MySQL
INSERT INTO fgedu_fgedus (name, email) VALUES (‘test’, ‘test@fgedu.net.cn’);

# PostgreSQL
INSERT INTO fgedu_fgedus (name, email) VALUES (‘test’, ‘test@fgedu.net.cn’);

– LIMIT语句：
# MySQL
SELECT * FROM fgedu_fgedus LIMIT 10;

# PostgreSQL
SELECT * FROM fgedu_fgedus LIMIT 10;

– IFNULL函数：
# MySQL
SELECT IFNULL(name, ‘Unknown’) FROM fgedu_fgedus;

# PostgreSQL
SELECT COALESCE(name, ‘Unknown’) FROM fgedu_fgedus;

– 日期函数：
# MySQL
SELECT NOW();

# PostgreSQL
SELECT NOW();

– 字符串函数：
# MySQL
SELECT CONCAT(first_name, ‘ ‘, last_name) FROM fgedu_fgedus;

# PostgreSQL
SELECT first_name || ‘ ‘ || last_name FROM fgedu_fgedus;

## 3. 调整应用代码
– 处理异常：
# Java
try {
// 数据库操作
} catch (SQLException e) {
// 处理异常
}

– 处理事务：
# Java
Connection conn = dataSource.getConnection();
conn.setAutoCommit(false);
try {
// 数据库操作
conn.commit();
} catch (SQLException e) {
conn.rollback();
} finally {
conn.close();
}

## 4. 测试应用
– 功能测试：
# 测试CRUD操作
# 测试业务逻辑
# 测试边界情况

– 性能测试：
# 测试响应时间
# 测试并发性能
# 测试负载能力

– 兼容性测试：
# 测试不同浏览器
# 测试不同设备
# 测试不同网络环境