一、前言
這裡記錄一次將MySQL資料庫中的表數據遷移到Oracle資料庫中的全過程 ,使用工具 Navicat,版本 12.0.11
操作環境及所用工具:
- mysql5.7
- oracle18c
- windows
- Navicat12.0.11
- idea

二、開始移植
點擊 工具 -> 數據傳輸

左邊 源 標識mysql資料庫 , 右邊 目標 標識要移植到的oracle資料庫

高級選項中勾選大寫
溫馨小提示:
如果欄位名和表名都為小寫,oracle操作數據的時候將會出現找不到表或視圖的錯誤,解決方法是必須加上雙引號才能查詢到, 這樣的話我們通過程序操作數據的時候必須加上雙引號,即大大加重了遷移資料庫後的工作量,因此這裡需勾選轉換對象名為大寫 ,同時在轉換過程中如果欄位名出現oracle關鍵字的話,它會自動給我們加上雙引號解決關鍵字的困擾!!!
【 ex: user -> “USER” number -> “NUMBER” desc -> “DESC” level -> “LEVEL” 】

選擇需要移植的表,這裡我一把梭全選了~

然後等待數據傳輸完成

如果最後遇到如下情況,可暫不管,直接關閉即可~

然後查看oracle,如下,數據導入成功

溫馨小提示:傳輸過程中可能會存在有部分幾張表不成功,手動導一下就好了~~
三、問題
1、解決oracle自增主鍵
oracle設置自增主鍵的幾種方式:
- 序列 + 觸發器
- 序列 + Hibernate配置 (註:此方式僅適用於通過Hibernate連接資料庫的方式)
- oracle12c版本之後新增 自增列語法 GENERATED BY DEFAULT AS IDENTITY
解決思路:
在ddl 創建表sql中添加自增主鍵的命令,重新創建一次表結構,然後再將oracle中的數據單獨導入這裡由於小編oracle版本為18c 因此在創建表的時候加上自增主鍵語法即可完成!
① 備份數據 -> 數據泵方式
數據泵 -> 數據泵導出



② idea中如下查看ddl

然後將ddl拷貝到一個txt文本文件中保存

③ ddl文件內容替換自增主鍵工具類
溫馨小提示:
這裡小編資料庫中的時間類型為 DATE 類型 需 改為 TIMESTAMP 類型 ,這個問題可以直接使用idea的替換功能完成修改~ ,其餘修改可根據個人實際情況來進行修改
public class MySQLToOracleTest {
public static void main(String[] args) {
try {
replaceDDLContent("D:UserszqDesktoporacle測試oracle_ddl.txt"); // TODO 這裡修改為自己的ddl文件存放位置
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 替換文本文件中的 自增主鍵ID
*
* @param path
* @throws IOException
*/
public static void replaceDDLContent(String path) throws IOException {
// 原有的內容
String srcStr = "not null";
// 要替換的內容
String replaceStr = "GENERATED BY DEFAULT AS IDENTITY";
// 讀
File file = new File(path);
FileReader in = new FileReader(file);
BufferedReader bufIn = new BufferedReader(in);
// 內存流, 作為臨時流
CharArrayWriter tempStream = new CharArrayWriter();
// 替換
String line = null;
// 需要替換的行
Map<Integer, Object> lineMap = new HashMap<>(104);
//定義順序變數
int count = 0;
while ((line = bufIn.readLine()) != null) {
count++;
if (line.contains("create table")) {
lineMap.put(count + 2, line);
}
//遍歷map中的鍵
for (Integer key : lineMap.keySet()) {
if (count == key && !line.contains("NVARCHAR2")) {
// TODO 在這裡這是自增主鍵哦
line = line.replaceAll(srcStr, replaceStr);
lineMap.put(count, line);
}
}
// 將該行寫入內存
tempStream.write(line);
// 添加換行符
tempStream.append(System.getProperty("line.separator"));
}
// 關閉 輸入流
bufIn.close();
// 將內存中的流 寫入 文件
FileWriter out = new FileWriter(file);
tempStream.writeTo(out);
out.close();
System.out.println("文件存放位置:" + path);
System.out.println(lineMap);
}
}
④ 將替換過後的ddl拷貝到idea中的一個新控制台中運行創建表
全選ddl,然後點擊左上角運行創建表 【 註:這裡需先清空該庫下所有表,因此步驟①要先備份一下從mysql遷移到oracle後的表數據,不要忘記哦!!】

等待表全部創建成功,如下所示:

⑤ 導入備份數據
數據泵 -> 數據泵導入



⑥ 最後查看數據導入成功!

這時候,數據有了,自增主鍵也有了,但是存在一個問題就是插入數據的時候主鍵自增ID都是從1開始自增,如果表中沒有數據都還ok,問題是如果表有數據,就會出現主鍵ID重複的問題!!!
2、解決自增主鍵ID無法從表數據ID最大值開始增值
思路:拼接出修改表自增ID從幾開始的sql即可!
SELECT
'SELECT ''ALTER TABLE SEWAGE_GY.' || t1.table_name || ' MODIFY(' || t1.Column_Name || ' Generated as Identity (START WITH '' || MAX( ' || t1.Column_Name || '+1 ) || ''));'' FROM ' || t1.table_name || ' UNION ALL' AS FINAL_SQL
FROM cols t1
LEFT JOIN user_col_comments t2 ON t1.Table_name = t2.Table_name AND t1.Column_Name = t2.Column_Name
LEFT JOIN user_tab_comments t3 ON t1.Table_name = t3.Table_name
WHERE
NOT EXISTS (
SELECT t4.Object_Name
FROM User_objects t4
WHERE
t4.Object_Type = 'TABLE'
AND t4.TEMPORARY = 'Y'
AND t4.Object_Name = t1.Table_Name
)
AND t1.IDENTITY_COLUMN = 'YES'
ORDER BY t1.Table_Name, t1.Column_ID
命令解析:
# 設置表主鍵ID從多少開始自增 ex:下面標識從10000開始自增
ALTER TABLE 資料庫名.表名 MODIFY(主鍵ID Generated as Identity (START WITH 10000));
# 查詢該庫下所有表名
SELECT table_name FROM user_tables;
# 查詢出指定表的主鍵ID欄位名
SELECT t1.table_name,t1.Column_Name
FROM cols t1
LEFT JOIN user_col_comments t2 ON t1.Table_name = t2.Table_name AND t1.Column_Name = t2.Column_Name
LEFT JOIN user_tab_comments t3 ON t1.Table_name = t3.Table_name
WHERE NOT EXISTS (
SELECT t4.Object_Name
FROM User_objects t4
WHERE t4.Object_Type = 'TABLE'
AND t4.TEMPORARY = 'Y'
AND t4.Object_Name = t1.Table_Name
)
AND t1.table_name = '表名'
AND t1.IDENTITY_COLUMN = 'YES'
ORDER BY t1.Table_Name, t1.Column_ID
# 查詢該庫下所有表名+表主鍵欄位名
SELECT t1.table_name,t1.Column_Name
FROM cols t1
LEFT JOIN user_col_comments t2 ON t1.Table_name = t2.Table_name AND t1.Column_Name = t2.Column_Name
LEFT JOIN user_tab_comments t3 ON t1.Table_name = t3.Table_name
WHERE NOT EXISTS (
SELECT t4.Object_Name
FROM User_objects t4
WHERE t4.Object_Type = 'TABLE'
AND t4.TEMPORARY = 'Y'
AND t4.Object_Name = t1.Table_Name
)
AND t1.IDENTITY_COLUMN = 'YES'
ORDER BY t1.Table_Name, t1.Column_ID

拷貝到新的控制台後注意刪除最後一個 UNION ALL 再運行哦!!!

最終完成自增主鍵ID從表數據最大值開始自增!

3、程序中的sql語句轉換
這裡結合個人語言實際操作…
原創文章,作者:投稿專員,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/250327.html