1. 程式人生 > >MyBatis專案實戰 快速將MySQL轉換成Oracle語句

MyBatis專案實戰 快速將MySQL轉換成Oracle語句

一、前言

因專案需求,小編要將專案從mysql遷移到oracle中 ~

之前已經完成 資料遷移 (https://zhengqing.blog.csdn.net/article/details/103694901)

現在將完成 基於MyBatis-Plus將專案中的MySQL語句全部轉換Oracle語句

大概實現步驟:
  1. 將專案改成支援雙庫配置(因專案基於mysql資料庫已經全部完成,也不想直接替換掉,於是新增oracle庫,讓整個專案可支援多個數據庫,這裡不是多資料來源哦!)
  2. Oracle中建立常用函式
  3. 遍歷專案中的xxxMapper.xml檔案,找到mysql與oracle語句的區別,然後替換絕大部分SQL
  4. 最後將一些特殊的mysql語句手動修改為oracle語句

二、MyBatis-Plus 支援雙庫配置 【mysqloracle

1、application.yml中配置mybatis-plusdatabase-id

# mybatis-plus配置
mybatis-plus:
  configuration:
    jdbc-type-for-null: 'null' # 解決oracle更新資料為null時無法轉換報錯
    database-id: oracle # 支援多庫配置 mysql,oracle

2、MybatisPlus核心配置檔案 -> 根據不同的資料庫廠商執行不同的SQL

@Configuration
@MapperScan("com.zhengqing.demo.modules.**.mapper*")
public class MybatisPlusConfig {

    /**
     * `xxxMapper.xml`檔案中的`databaseId`會自動識別使用的資料庫型別與這裡相對應
     * 注: 如果沒有指定`databaseId`則該SQL語句適用於所有資料庫哦~
     * 
     * databaseIdProvider:支援多資料庫廠商
     * VendorDatabaseIdProvider: 得到資料庫廠商的標識(驅動getDatabaseProductName()),mybatis就能根據資料庫廠商標識來執行不同的sql;
     * MySQL,Oracle,SQL Server,xxxx
     */
    @Bean
    public DatabaseIdProvider getDatabaseIdProvider(){
        DatabaseIdProvider databaseIdProvider = new VendorDatabaseIdProvider();
        Properties properties = new Properties();
        // 為不同的資料庫廠商起別名
        properties.setProperty("MySQL","mysql");
        properties.setProperty("Oracle","oracle");
        databaseIdProvider.setProperties(properties);
        return databaseIdProvider;
    }

}

3、xxxMapper.xml中通過databaseId指定資料庫型別

<select id="selectUserInfo" resultMap="UserVO" databaseId="mysql">
    SELECT * FROM 表名 LIMIT 1
</select>

<select id="selectUserInfo" resultMap="UserVO" databaseId="oracle">
    SELECT * FROM 表名 WHERE ROWNUM &lt;= 1
</select>

三、Oracle中建立常用函式

這裡根據個人專案情況去實際應用即可~

1、ORACLE_TO_UNIX

Oracle時間 Date型別轉換為Unix時間戳,等同於mysql中的UNIX_TIMESTAMP

create or replace function ORACLE_TO_UNIX(in_date IN DATE) return number is  
begin
  return( ROUND( (in_date -TO_DATE('19700101','yyyymmdd'))*86400 - TO_NUMBER(SUBSTR(TZ_OFFSET(sessiontimezone),1,3))*3600, 0) );
end ORACLE_TO_UNIX;

2、FIND_IN_SET

CREATE OR REPLACE FUNCTION FIND_IN_SET(piv_str1 varchar2, piv_str2 varchar2, p_sep varchar2 := ',')
RETURN NUMBER IS      
  l_idx    number:=0; -- 用於計算piv_str2中分隔符的位置  
  str      varchar2(500);  -- 根據分隔符擷取的子字串  
  piv_str  varchar2(500) := piv_str2; -- 將piv_str2賦值給piv_str  
  res      number:=0; -- 返回結果  
  loopIndex number:=0;
BEGIN  
-- 如果piv_str中沒有分割符,直接判斷piv_str1和piv_str是否相等,相等 res=1  
IF instr(piv_str, p_sep, 1) = 0 THEN  
   IF piv_str = piv_str1 THEN   
      res:= 1;  
   END IF;  
ELSE  
-- 迴圈按分隔符擷取piv_str  
LOOP 
    l_idx := instr(piv_str,p_sep);  
     loopIndex:=loopIndex+1;
      -- 當piv_str中還有分隔符時  
      IF l_idx > 0 THEN  
         -- 擷取第一個分隔符前的欄位str  
         str:= substr(piv_str,1,l_idx-1);  
         -- 判斷 str 和piv_str1 是否相等,相等 res=1 並結束迴圈判斷  
         IF str = piv_str1 THEN   
           res:= loopIndex;  
           EXIT;  
         END IF;  
        piv_str := substr(piv_str,l_idx+length(p_sep));  
      ELSE
        -- 當擷取後的piv_str 中不存在分割符時,判斷piv_str和piv_str1是否相等,相等 res=1  
        IF piv_str = piv_str1 THEN   
           res:= loopIndex;  
        END IF;  
        -- 無論最後是否相等,都跳出迴圈  
        EXIT;  
      END IF;  
END LOOP;  
-- 結束迴圈  
END IF;  
-- 返回res  
RETURN res;  
END FIND_IN_SET; 

四、工具類(MySQL語句轉換Oracle語句)

替換步驟:
  1. xxxMapper.xml 中將所有sql語句上加入 databaseId="mysql"
  2. 複製一份mysql的sql(即 將替換的oracle語句)
  3. 在複製的sql上加入databaseId="oracle"
  4. 找出mysql與oracle語句區別,然後替換sql

溫馨小提示: 這裡工具類只供參考,實際操作根據自己的專案做修改哦,操作前建議先備份自己的專案,以防操作不當丟失程式碼哦!

import org.apache.commons.lang3.StringUtils;
import org.junit.Test;
import java.io.*;
import java.util.*;

/**
 *  <p> mysql遷移oracle 測試工具類 </p>
 *
 * @description :  
 * @author : zhengqing  
 * @date : 2020/1/08 10:10
 */
public class MySQLToOracleTest {

    private final static String ORACLE_SQL = "    <!-- ====================================== ↓↓↓↓↓↓ oracle ↓↓↓↓↓↓  ====================================== -->";

    @Test // 替換專案中的sql語句
    public void testSQL() throws Exception {
        String path = System.getProperty("user.dir") + "\\src\\main\\java\\com\\zhengqing\\xxx"; // TODO 這裡替換為自己的專案路徑
        File file = new File(path);
        HashMap<Object, Object> fileMap = new HashMap<>();
        getAllFileByRecursion(fileMap, file);

        fileMap.forEach((key, value) -> {
            String fileXmlName = (String) key;
            File fileXml = (File) value;
            String filePath = fileXml.getPath();

            if (fileXmlName.equals("Test.xml")) {
                System.out.println(filePath);
                try {
                    // 1、加入 databaseId="mysql"
                    addMysql(filePath);
                    // 2、複製一份oracle的sql
                    if (!checkHasOracle(filePath)) {
                        copyMysqlToOracle(filePath);
                    }
                    // 3、加入 databaseId="oracle"
                    addOracle(filePath);
                    // 4、替換mybatis `xxxMapper.xml` 中的sql語句
                    repalceSQL(filePath);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        });
        System.out.println(fileMap);
    }

    /**
     * 替換mybatis `xxxMapper.xml` 中的sql語句
     */
    private static void repalceSQL(String path) throws IOException {
        File file = new File(path);
        FileReader in = new FileReader(file);
        BufferedReader bufIn = new BufferedReader(in);
        // 記憶體流, 作為臨時流
        CharArrayWriter tempStream = new CharArrayWriter();
        // 替換
        String line = null;
        int row = 0;
        int rowOracle = 0;
        while ((line = bufIn.readLine()) != null) {
            row++;
            if (line.contains(ORACLE_SQL)) {
                rowOracle = row;
            }

            if (rowOracle != 0 && row > rowOracle) {
                // ① 替換 `LIMIT` -> `AND ROWNUM &lt;= 1` TODO 【注: 部分包含`ORDER BY` 關鍵字,需單獨處理】
                if (line.contains("limit") || line.contains("LIMIT")) {
                    System.out.println();
                    System.out.println(" ==============================↓↓↓↓↓↓  copy分頁所需 (" + row + ")  ↓↓↓↓↓↓===================================== ");
                    System.out.println("SELECT * FROM ( SELECT TMP.*, ROWNUM ROW_ID FROM (");
                    System.out.println();
                    System.out.println(") TMP  WHERE ROWNUM &lt;=1) WHERE ROW_ID > 0");
                    System.out.println();
                }
                line = StringUtils.replace(line, "limit 1", "AND ROWNUM &lt;= 1");
                line = StringUtils.replace(line, "LIMIT 1", "AND ROWNUM &lt;= 1");
                line = StringUtils.replace(line, "limit 0,1", "AND ROWNUM &lt;= 1");
                line = StringUtils.replace(line, "LIMIT 0,1", "AND ROWNUM &lt;= 1");

                // ② oracle中不能使用“ ` ”符號
                line = StringUtils.replace(line, "`", "");

                // ③ CONCAT('%', #{name}, '%')  ->     '%'||#{name}||'%' (Oracle中concat函式只能放兩個引數)
                if (line.contains("concat")) {
//                    String newLine = line.substring(line.indexOf("concat(") + 7, line.lastIndexOf("'%')") + 3);
                    line = line.replaceAll(",", " || ");
                    line = line.replaceAll("concat", "");
                }
                if (line.contains("CONCAT")) {
//                    String newLine = line.substring(line.indexOf("CONCAT(") + 7, line.lastIndexOf("'%')") + 3);
                    line = line.replaceAll(",", " || ");
                    line = line.replaceAll("CONCAT", "");
                }

                // ④ `UNIX_TIMESTAMP` -> `ORACLE_TO_UNIX` date型別時間轉10位時間戳
                line = line.replaceAll("UNIX_TIMESTAMP", "ORACLE_TO_UNIX");

                // ⑤ 部分關鍵字需加上雙引號 TODO 【注: 欄位名大寫,對映的別名需儲存原本小寫!】 `level -> "LEVEL"`  `user -> "USER"`      `number -> "NUMBER"`  `desc -> "DESC"`
                List<String> keywordList = new ArrayList<>(Arrays.asList("level", "user", "number"));
                if (!line.contains("test=")) {
                    for (String e : keywordList) {
                        // StringUtils.swapCase(e) : 大小寫互換
                        line = line.replaceAll(" " + e + " ", " \"" + StringUtils.swapCase(e) + "\" ");
                        line = line.replaceAll("." + e + " ", "\\.\"" + StringUtils.swapCase(e) + "\" ");
                        if (line.endsWith(e) || line.endsWith(e + ",")) {
                            line = line.replaceAll(e, "\"" + StringUtils.swapCase(e) + "\"");
                        }
                    }
                }
                if (line.endsWith(" date") || line.endsWith(" date,") || line.endsWith(" 'date'") || line.endsWith(" 'DATE'") || line.endsWith("DATE")) {
                    line = line.replaceAll(" date", " \"date\"");
                    line = line.replaceAll(" date,", " \"date,\"");
                    line = line.replaceAll(" 'date'", " \"date\"");
                    line = line.replaceAll(" 'DATE'", " \"date\"");
                    line = line.replaceAll(" DATE", " \"date\"");
                }
                line = line.replaceAll(" date ", " \"date\" ");
                line = line.replaceAll(" DATE ", " \"date\" ");

                // ⑥ `IFNULL` -> `NVL`
                line = line.replaceAll("IFNULL", "NVL");
                line = line.replaceAll("ifnull", "NVL");

                // ⑦ 時間 `str_to_date` -> `to_date`     `date_format` -> `to_char`
                // `%Y-%m-%d`  -> `yyyy-MM-dd`    `%Y-%m` -> `yyyy-MM`
                line = line.replaceAll("str_to_date", "TO_DATE");
                line = line.replaceAll("STR_TO_DATE", "TO_DATE");
                line = line.replaceAll("date_format", "TO_CHAR");
                line = line.replaceAll("DATE_FORMAT", "TO_CHAR");

                // 這裡注意替換順序問題,最長的應該放最前面!!!
                line = line.replaceAll("%Y-%m-%d %H:%i:%S", "yyyy-MM-dd HH24:mi:ss");
                line = line.replaceAll("%Y-%m-%d %H:%i:%s", "yyyy-MM-dd HH24:mi:ss");
                line = line.replaceAll("%Y-%m-%d %H:%i", "yyyy-MM-dd HH24:mi");
                line = line.replaceAll("%Y-%m-%d %H", "yyyy-MM-dd HH24");
                line = line.replaceAll("%Y-%m-%d %h", "yyyy-MM-dd HH");
                line = line.replaceAll("%Y-%m-%d", "yyyy-MM-dd");
                line = line.replaceAll("%Y-%m", "yyyy-MM");
                line = line.replaceAll("%Y", "yyyy");
                line = line.replaceAll("%H", "HH24");
                line = line.replaceAll("%k", "HH24");

                line = line.replaceAll("now\\(\\)", "(SELECT SYSDATE + 8/24 FROM DUAL)");
                line = line.replaceAll("NOW\\(\\)", "(SELECT SYSDATE + 8/24 FROM DUAL)");

                // ⑧ ...

                // 需手動處理的SQL 【 group by | 批量插入 | ... 】
            }
            // 將該行寫入記憶體
            tempStream.write(line);
            // 新增換行符
            tempStream.append(System.getProperty("line.separator"));
        }
        // 關閉 輸入流
        bufIn.close();
        // 將記憶體中的流 寫入 檔案
        FileWriter out = new FileWriter(file);
        tempStream.writeTo(out);
        out.close();
    }

    /**
     * 加入 databaseId="mysql"
     */
    private static void addMysql(String path) throws IOException {
        File file = new File(path);
        FileReader in = new FileReader(file);
        BufferedReader bufIn = new BufferedReader(in);
        // 記憶體流, 作為臨時流
        CharArrayWriter tempStream = new CharArrayWriter();
        // 替換
        String line = null;
        while ((line = bufIn.readLine()) != null) {
            if ((line.contains("<select") || line.contains("<update") || line.contains("<insert") || line.contains("<delete")) && !line.contains("databaseId")) {
                if (line.endsWith(">")) {
                    line = line.replaceAll(">", " databaseId=\"mysql\">");
                } else {
                    line = line + " databaseId=\"mysql\"";
                }
            }
            // 將該行寫入記憶體
            tempStream.write(line);
            // 新增換行符
            tempStream.append(System.getProperty("line.separator"));
        }
        // 關閉 輸入流
        bufIn.close();
        // 將記憶體中的流 寫入 檔案
        FileWriter out = new FileWriter(file);
        tempStream.writeTo(out);
        out.close();
    }

    /**
     * 加入 databaseId="oracle"
     */
    private static void addOracle(String path) throws IOException {
        File file = new File(path);
        FileReader in = new FileReader(file);
        BufferedReader bufIn = new BufferedReader(in);
        // 記憶體流, 作為臨時流
        CharArrayWriter tempStream = new CharArrayWriter();
        HashSet<String> lineSet = new HashSet<>();
        // 替換
        String line = null;
        while ((line = bufIn.readLine()) != null) {
            if (line.contains("databaseId=\"mysql\"")) {
                if (lineSet.contains(line)) {
                    line = line.replaceAll("databaseId=\"mysql\"", "databaseId=\"oracle\"");
                }
                lineSet.add(line);
            }
            // 將該行寫入記憶體
            tempStream.write(line);
            // 新增換行符
            tempStream.append(System.getProperty("line.separator"));
        }
        // 關閉 輸入流
        bufIn.close();
        // 將記憶體中的流 寫入 檔案
        FileWriter out = new FileWriter(file);
        tempStream.writeTo(out);
        out.close();
    }

    /**
     * 複製一份oracle的sql
     */
    private static void copyMysqlToOracle(String path) throws IOException {
        File file = new File(path);
        FileReader in = new FileReader(file);
        BufferedReader bufIn = new BufferedReader(in);
        // 記憶體流, 作為臨時流
        CharArrayWriter tempStream = new CharArrayWriter();
        // 替換
        String line = null;
        // 需要替換的行
        List<String> lineList = new LinkedList<>();

        int row = 0;
        int firstRow = 0;

        while ((line = bufIn.readLine()) != null) {
            row++;
            if (line.contains("<select") || line.contains("<update") || line.contains("<insert") || line.contains("<delete")) {
                firstRow = row;
            }

            // 新增替換內容
            if (firstRow != 0 && row >= firstRow && !line.contains("</mapper>")) {
                lineList.add(line);
            }

            // 查詢結束位置
            if (line.contains("</mapper>")) {
                tempStream.append(System.getProperty("line.separator"));
                tempStream.write(ORACLE_SQL);
                tempStream.append(System.getProperty("line.separator"));
                tempStream.append(System.getProperty("line.separator"));

                lineList.forEach(lineValue -> {
                    // copy mysql 語句 轉為oracle
                    try {
                        tempStream.write(lineValue);
                        tempStream.append(System.getProperty("line.separator"));
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                });

                tempStream.append(System.getProperty("line.separator"));
            }
            // 將該行寫入記憶體
            tempStream.write(line);
            // 新增換行符
            tempStream.append(System.getProperty("line.separator"));
        }
        // 關閉 輸入流
        bufIn.close();
        // 將記憶體中的流 寫入 檔案
        FileWriter out = new FileWriter(file);
        tempStream.writeTo(out);
        out.close();
    }

    /**
     * 檢查是否已經複製SQL
     */
    private static boolean checkHasOracle(String path) throws IOException {
        File file = new File(path);
        FileReader in = new FileReader(file);
        BufferedReader bufIn = new BufferedReader(in);
        // 記憶體流, 作為臨時流
        CharArrayWriter tempStream = new CharArrayWriter();
        // 替換
        String line = null;
        boolean result = false;
        while ((line = bufIn.readLine()) != null) {
            if (line.contains(ORACLE_SQL)) {
                result = true;
            }
            // 將該行寫入記憶體
            tempStream.write(line);
            // 新增換行符
            tempStream.append(System.getProperty("line.separator"));
        }
        // 關閉 輸入流
        bufIn.close();
        // 將記憶體中的流 寫入 檔案
        FileWriter out = new FileWriter(file);
        tempStream.writeTo(out);
        out.close();
        return result;
    }

    /**
     * 遞迴資料夾 -> 找到所有xml檔案
     */
    private static void getAllFileByRecursion(HashMap<Object, Object> fileMap, File file) {
        File[] fs = file.listFiles();
        for (File f : fs) {
            String fileName = f.getName();
            if (f.isDirectory()) {
                // 若是目錄則遞迴,否則列印該目錄下的檔案
                getAllFileByRecursion(fileMap, f);
            }
            if (f.isFile() && fileName.endsWith(".xml")) {
                fileMap.put(fileName, f);
            }
        }
    }

}

五、總結

這裡簡單說下MySQL和Oracle中的SQL區別,以及mysql語句轉換oracle語句示例

1、分頁

  1. mysql: LIMIT 0,1
  2. oracle: ROWNUM <= 1
情景①:mysql中不含ORDER BY
-- mysql
SELECT * FROM 表名 LIMIT 1

-- oracle
SELECT * FROM 表名  WHERE ROWNUM <= 1
情景②:mysql中含ORDER BY
-- mysql
SELECT * FROM 表名 ORDER BY 欄位名 DESC LIMIT 1 


-- oracle
SELECT * FROM ( 
    SELECT TMP.*, ROWNUM ROW_ID FROM ( 
        SELECT * FROM 表名 ORDER BY 欄位名 DESC
    ) TMP WHERE ROWNUM <= 1 ) 
WHERE ROW_ID > 0;
溫馨小知識:SQL SELECT語句執行順序
  1. FROM子句組裝來自不同資料來源的資料
  2. WHERE子句基於指定的條件對記錄進行篩選
  3. GROUP BY子句將資料劃分為多個分組
  4. 聚集函式進行計算
  5. HAVING子句篩選分組
  6. 計算所有表示式
  7. ORDER BY對結果進行排序

2、oracle中欄位名不能使用符號 " ` " 包括

-- mysql
SELECT `欄位名` FROM 表名

-- oracle
SELECT 欄位名 FROM 表名

3、字串拼接

注: Oracle中CONCAT函式只能放兩個引數,因此改為 || 拼接

  1. mysql: CONCAT('%', 'xxx' , '%')
  2. oracle: '%' || 'xxx' || '%'
-- mysql
SELECT 欄位名 FROM 表名 WHERE 欄位名 LIKE CONCAT('%','helloworld','%')

-- oracle
SELECT 欄位名 FROM 表名 WHERE 欄位名 LIKE ('%' || 'helloworld' || '%')

4、date型別時間轉10位時間戳

  1. mysql: UNIX_TIMESTAMP
  2. oracle: ORACLE_TO_UNIX (注:此函式為步驟三中手動建立的,並非oracle自帶哦!)

5、欄位名Oracle關鍵字需加上雙引號

溫馨小提示: 欄位名需大寫,如果Java實體類對應欄位為小寫,對映的別名注意需保持原本小寫與之對應 ~

例如:

  1. level -> "LEVEL"
  2. user -> "USER"
  3. number -> "NUMBER"
  4. desc -> "DESC"
  5. date -> DATE

6、判斷是否為 NULL: 如果x為NULL,則返回value,否則返回x值本身

  1. mysql: IFNULL(x, value)
  2. oracle: NVL(x, value)

7、日期時間互換

前mysql,後oracle

  1. 字串型別轉時間型別: STR_TO_DATE -> TO_DATE
  2. 時間型別轉指定字串型別: DATE_FORMAT -> TO_CHAR
  3. 獲取系統當前時間: NOW() -> SELECT SYSDATE FROM DUAL
-- 時間型別轉指定字串型別
SELECT DATE_FORMAT( NOW(),'%Y-%m-%d %H:%i:%s');             -- mysql
SELECT TO_CHAR( SYSDATE,'yyyy-MM-dd HH24:mi:ss') FROM DUAL; -- oracle

-- 字串型別轉時間型別
SELECT STR_TO_DATE( NOW(), '%Y-%m-%d %H');             -- mysql
SELECT TO_DATE( '2020-01-09', 'yyyy-MM-dd') FROM DUAL; -- oracle 【 注:oracle中前者字串時間的格式需與後者轉換格式相同哦~ 】

-- 獲取系統當前時間
SELECT NOW(); -- mysql
SELECT SYSDATE + 8/24 FROM DUAL; -- oralce 【注:如果伺服器時間沒有相差8小時則無需加上`8/24`】

-- mysql
SELECT YEAR( NOW() );     -- 求年份
SELECT QUARTER( NOW() );  -- 求季度
SELECT MONTH( NOW() );    -- 求月份

-- oracle
SELECT TO_CHAR(SYSDATE, 'Q') FROM DUAL; -- 求季度

另外這裡給出小編所用到的時間識別符號格式

-- 前:mysql             後:oracle
"%Y-%m-%d %H:%i:%S"     "yyyy-MM-dd HH24:mi:ss"
"%Y-%m-%d %H:%i:%s"     "yyyy-MM-dd HH24:mi:ss"
"%Y-%m-%d %H:%i"        "yyyy-MM-dd HH24:mi"
"%Y-%m-%d %H"           "yyyy-MM-dd HH24"
"%Y-%m-%d %h"           "yyyy-MM-dd HH"
"%Y-%m-%d"              "yyyy-MM-dd"
"%Y-%m"                 "yyyy-MM"
"%Y"                    "yyyy"
"%H"                    "HH24"
"%k"                    "HH24"

8、判斷時 欄位型別必須相同

這裡注意是必須,可能在oracle版本不同的情況下,老版本不同型別也會查詢出來,但建議還是改為相同型別關聯,避免以後資料庫版本升級出現問題!!!

建議小轉大,比如:數字轉字串;並使用CONCAT去修改型別,因為mysql和oracle都支援此函式,並且不會在特殊型別上出現問題 ~

-- ex: `JOIN` 關聯表時 兩張表的關聯`欄位型別`必須`相同`
SELECT a.*,b.*
FROM 表1 a
LEFT JOIN 表2 b on a.字串型別欄位 = CONCAT(b.數字型別欄位, '')

9、批量插入

-- mysql
<insert id="insertBatch" databaseId="mysql">
    INSERT INTO 表名( `欄位名1`, `欄位名2`, `欄位...`) VALUES
    <foreach collection="list" item="item" separator="," open="(" close=")">
        #{item.欄位1},#{item.欄位2},#{item中的每一個欄位名...}
    </foreach>
</insert>

-- oracle
<insert id="insertBatch" databaseId="oracle">
    INSERT INTO 表名(欄位名1,欄位名2,xxx...)
    SELECT A.*
    FROM(
        <foreach collection="list" item="item" index="index" separator="UNION ALL" >
            SELECT
                #{item.欄位1},#{item.欄位2},#{item中的每一個欄位名...}
            FROM DUAL
        </foreach>
    ) A
</insert>

10、分組 GROUP BY

oracle中GROUP BY分組後,查詢出來的所有欄位(除分組欄位)必須為聚合函式的欄位,否則會報錯!

解決:

  1. 查詢欄位改為聚合函式
  2. 使用如下分析函式 OVER (Partition BY ...) 及開窗函式
-- mysql
SELECT 欄位名,xxx... FROM 表名 GROUP BY 分組欄位

-- oracle
SELECT
    *
FROM (
    SELECT tb.*, ROW_NUMBER ( ) OVER ( PARTITION BY tb.分組欄位 ORDER BY tb.排序欄位 DESC ) AS result
    FROM (
        SELECT 欄位名,xxx... FROM 表名 -- 此處為查詢sql,去掉`GROUP BY`分組條件,將分組欄位加到上面 【 注:此sql的查詢欄位中要麼全是聚合函式欄位,要麼都不是! 】
    ) tb
) WHERE result = 1

11、Oracle中表的別名不能用AS, 列的別名可以用AS

why ?:為了防止和Oracle儲存過程中的關鍵字AS衝突的問題

12、注意Oracle對資料型別要求很嚴!!!

MySQL與Oracle不同之處遠不止小編提及的如上幾點,更多的還需要大家根據在實際專案中做對比,然後去修改哦 ~

六、本文MySQL轉Oracle語句工具原始碼

溫馨小提示:如果後期小編空閒會將上文中提供的測試替換工具類再加以修改,到時候會存放在如下github倉庫中...

https://github.com/zhengqingya/mysql-to-ora