Oracle国产化迁移全流程实战：从评估到上线的完整指南（附实操代码）

-- Oracle建表语句（可直接在目标库兼容模式下执行）
CREATE TABLE power_station (
    station_id NUMBER(10) PRIMARY KEY,
    station_name VARCHAR2(100) NOT NULL,
    build_date DATE,
    run_status CHAR(1) DEFAULT '1',
    ext_info INTERVAL DAY TO SECOND,
    location SDO_GEOMETRY  -- 空间类型，兼容Oracle空间数据
);

-- 目标库兼容Oracle SEQUENCE序列（转换为自增列）
CREATE TABLE order_info (
    order_id INT PRIMARY KEY IDENTITY(1,1),  -- 替代Oracle SEQUENCE
    order_no VARCHAR2(32) NOT NULL,
    create_time DATE DEFAULT SYSDATE
);

-- Oracle PL/SQL存储过程（目标库兼容模式下零修改执行）
CREATE OR REPLACE PROCEDURE get_station_info(
    p_station_id IN NUMBER,
    p_station_name OUT VARCHAR2,
    p_run_status OUT CHAR
) AS
    TYPE station_rec IS RECORD (  -- RECORD复合类型，兼容支持
        name VARCHAR2(100),
        status CHAR(1)
    );
    v_station station_rec;
BEGIN
    SELECT station_name, run_status INTO v_station
    FROM power_station WHERE station_id = p_station_id;
    
    p_station_name := v_station.name;
    p_run_status := v_station.status;
EXCEPTION
    WHEN NO_DATA_FOUND THEN
        p_station_name := '未知场站';
        p_run_status := '0';
END;
/

-- Oracle特有函数（目标库兼容模式下正常执行）
SELECT 
    station_id,
    DECODE(run_status, '1', '运行中', '0', '停用', '异常') AS status_desc,  -- DECODE函数兼容
    NVL2(build_date, TO_CHAR(build_date, 'YYYY-MM-DD'), '未录入') AS build_desc  -- NVL2函数兼容
FROM power_station;

# 1. 部署麒麟V10操作系统（鲲鹏920平台）
# 查看系统信息，确认环境适配
cat /etc/os-release
uname -a

# 2. 部署目标库主备集群（4套，每套2节点）
# 集群初始化命令（简化示例）
kes_install --cluster --mode=primary --host=192.168.1.10 --port=54321 --dbname=power_db
kes_install --cluster --mode=standby --host=192.168.1.11 --port=54321 --master=192.168.1.10

# 3. 部署配套工具
# 图形化管理工具（KStudio）
yum install kstudio -y
# 性能监控平台（KMonitor）
systemctl start kmonitor
systemctl enable kmonitor

# 1. 异构迁移工具（KDTS）配置，用于历史数据批量迁移
kdts_config --source=oracle --host=192.168.2.10 --port=1521 --sid=orcl --user=sys --password=xxx
kdts_config --target=kingbase --host=192.168.1.10 --port=54321 --dbname=power_db --user=db_user --password=xxx

# 2. 增量同步工具（KFS）配置，捕获Oracle Redo Log变更
kfs_config --source=oracle --redo_log_path=/u01/app/oracle/oradata/orcl/redo01.log
kfs_config --target=kingbase --host=192.168.1.10 --port=54321 --dbname=power_db
kfs_start --job=oracle_to_kingbase --delay=1  # 秒级延迟同步

# 使用KDTS工具导出Oracle全量数据
kdts_export --source=oracle --schema=power_schema --file=/data/backup/full_data.dmp --compression=gzip

# 导入目标库
kdts_import --target=kingbase --file=/data/backup/full_data.dmp --schema=power_schema --ignore_error=false

# 启动KFS增量同步任务，持续捕获Oracle端变更
kfs_start --job=oracle_to_kingbase --log=/var/log/kfs_sync.log

# 查看同步状态，确保延迟≤1秒
kfs_status --job=oracle_to_kingbase

# Python脚本：全表MD5比对，确保迁移前后数据零差异
import psycopg2
import cx_Oracle

def compare_md5(oracle_conn, kingbase_conn, table_name):
    # Oracle查询MD5
    oracle_cursor = oracle_conn.cursor()
    oracle_cursor.execute(f"SELECT MD5(TO_CHAR(ROWID) || TO_CHAR(ROWNUM)) FROM {table_name}")
    oracle_md5 = set([row[0] for row in oracle_cursor.fetchall()])
    
    # 目标库查询MD5（兼容Oracle ROWID，替换为CTID）
    kb_cursor = kingbase_conn.cursor()
    kb_cursor.execute(f"SELECT MD5(TO_CHAR(CTID) || TO_CHAR(ROWNUM)) FROM {table_name}")
    kb_md5 = set([row[0] for row in kb_cursor.fetchall()])
    
    # 比对差异
    diff = oracle_md5.symmetric_difference(kb_md5)
    if diff:
        print(f"表{table_name}存在{len(diff)}条数据差异")
    else:
        print(f"表{table_name}数据一致性校验通过")
    
    oracle_cursor.close()
    kb_cursor.close()

# 连接数据库
oracle_conn = cx_Oracle.connect("sys/xxx@192.168.2.10:1521/orcl")
kingbase_conn = psycopg2.connect(host="192.168.1.10", port=54321, user="db_user", password="xxx", dbname="power_db")

# 校验核心表
core_tables = ["power_station", "order_info", "monitor_data"]
for table in core_tables:
    compare_md5(oracle_conn, kingbase_conn, table)

# 关闭连接
oracle_conn.close()
kingbase_conn.close()

// 原Oracle JDBC连接配置
// String url = "jdbc:oracle:thin:@192.168.2.10:1521:orcl";
// Class.forName("oracle.jdbc.driver.OracleDriver");

// 目标库JDBC连接配置（替换驱动与URL）
String url = "jdbc:kingbase8://192.168.1.10:54321/power_db?oracle_compat=true";
Class.forName("com.kingbase8.Driver");

// 连接池配置（增加故障转移参数，支持主备切换）
BasicDataSource dataSource = new BasicDataSource();
dataSource.setUrl(url);
dataSource.setUsername("db_user");
dataSource.setPassword("xxx");
dataSource.setConnectionProperties("failoverMode=auto");  // 自动故障转移

-- 原Oracle SQL（含专有提示符）
-- SELECT /*+ INDEX(power_station idx_station_id) */ * FROM power_station WHERE station_id = 100;

-- 目标库适配后SQL（替换为标准提示符）
SELECT /*+ INDEX(power_station idx_station_id) */ * FROM power_station WHERE station_id = 100;

// 原Oracle UTL_FILE文件操作（读取场站配置文件）
// UTL_FILE.FOPEN('DATA_DIR', 'station_config.txt', 'R');

// 目标库替代实现（使用Java IO+目标库文件接口）
File file = new File("/data/config/station_config.txt");
BufferedReader br = new BufferedReader(new FileReader(file));
String line;
while ((line = br.readLine()) != null) {
    // 读取配置并写入数据库
    String sql = "INSERT INTO station_config (config_key, config_value) VALUES (?, ?)";
    preparedStatement.executeUpdate(sql, new Object[]{line.split("=")[0], line.split("=")[1]});
}
br.close();

# 第一阶段：单个场站试点（72小时验证）
# 切换脚本：将单个场站数据采集地址指向目标库
sed -i 's/oracle_host=192.168.2.10/kingbase_host=192.168.1.10/' /data/config/station_config.conf
systemctl restart data_collect_service

# 第二阶段：3个区域集群（7×24小时稳定性监测）
# 批量切换命令
for station in $(cat /data/station_list_3.txt); do
    sed -i "s/oracle_host=192.168.2.10/kingbase_host=192.168.1.10/" /data/config/${station}_config.conf
done
systemctl restart data_collect_service

# 后续阶段：逐步扩展至全域，每阶段配置回滚机制
# 回滚命令（紧急情况下恢复Oracle连接）
sed -i 's/kingbase_host=192.168.1.10/oracle_host=192.168.2.10/' /data/config/*.conf
systemctl restart data_collect_service

# Python监控脚本：实时采集核心指标，异常告警
import requests
import time
from datetime import datetime

def monitor_cluster():
    monitor_url = "http://192.168.1.10:8080/kmonitor/api/metrics"
    headers = {"Authorization": "Bearer xxx"}
    while True:
        response = requests.get(monitor_url, headers=headers).json()
        # 提取核心指标
        cpu_usage = response["metrics"]["cpu_usage"]
        io_wait = response["metrics"]["io_wait"]
        slow_sql_count = response["metrics"]["slow_sql_count"]
        lock_wait = response["metrics"]["lock_wait"]
        
        # 异常告警（CPU>80%、慢SQL>5条、锁等待>10s）
        alerts = []
        if cpu_usage > 80:
            alerts.append(f"CPU使用率过高：{cpu_usage}%")
        if slow_sql_count > 5:
            alerts.append(f"慢SQL数量超标：{slow_sql_count}条")
        if lock_wait > 10:
            alerts.append(f"锁等待超时：{lock_wait}s")
        
        if alerts:
            print(f"【{datetime.now()}】告警：{'; '.join(alerts)}")
        time.sleep(60)  # 每分钟采集一次

if __name__ == "__main__":
    monitor_cluster()