mysql迁移数据库到gauss

liulin

2024-08-03 c865f4b5d67560c74ba0a6ec3a18458f534e3425

mysql迁移数据库到gauss

 sql/init.sql

@@ -1,7 +1,7 @@
CREATE OR REPLACE FUNCTION "public"."update_timestamp_column"()
  RETURNS "pg_catalog"."trigger" AS $BODY$
BEGIN
NEW.timestamp_column := current_timestamp;
NEW.update_time := current_timestamp;
RETURN NEW;
END;
$BODY$
@@ -45,6 +45,6 @@
-- 索引
CREATE INDEX "IDX_test_info_create_time" ON "public"."test_info"("create_time");
-- 触发器：自动赋值最后更新时间
CREATE TRIGGER "TG_test_info" BEFORE UPDATE OF "update_time" ON "public"."test_info"
CREATE TRIGGER "TG_test_info" BEFORE INSERT OR UPDATE OF "update_time" ON "public"."test_info"
FOR EACH ROW
EXECUTE PROCEDURE "public"."update_timestamp_column"();

 src/test/java/com/lunhan/xxx/host/GenCodeGauss.java

@@ -1606,7 +1606,7 @@
                    if ("1".equals(isNullable)) {
                        sql += " NULL DEFAULT NULL";
                    } else {
                        sql += " NOT NULL DEFAULT PG_SYSTIMESTAMP()";
                        sql += " NOT NULL DEFAULT pg_systimestamp()";
                    }
                    break;
                case "int":
@@ -1656,7 +1656,7 @@
        sql = "";

        // 触发器：自动赋值最后更新时间
        sql += "CREATE TRIGGER \"TG_" + tableName + "\" BEFORE UPDATE OF \"update_time\" ON \"public\".\"" + tableName + "\"\n" +
        sql += "CREATE TRIGGER \"TG_" + tableName + "\" BEFORE INSERT OR UPDATE OF \"update_time\" ON \"public\".\"" + tableName + "\"\n" +
                "FOR EACH ROW\n" +
                "EXECUTE PROCEDURE \"public\".\"update_timestamp_column\"();";
        result = GenCodeGauss.execSql(connect, sql);

 src/test/java/com/lunhan/xxx/host/Mysql2Gauss.java

@@ -62,7 +62,7 @@
        GenCodeGauss.execSql(CONN_Gauss, "CREATE OR REPLACE FUNCTION \"public\".\"update_timestamp_column\"()\n" +
                "  RETURNS \"pg_catalog\".\"trigger\" AS $BODY$\n" +
                "BEGIN\n" +
                "NEW.timestamp_column := current_timestamp;\n" +
                "NEW.update_time := current_timestamp;\n" +
                "RETURN NEW;\n" +
                "END;\n" +
                "$BODY$\n" +
@@ -88,7 +88,7 @@
            // 获取mysql表所有数据
            String sqlSelect = "SELECT * FROM " + Mysql_DB_NAME + "." + table.getKey();
            Integer count = 1;
            Integer pageSize = 1;
            Integer pageSize = 500;
            String orderBy = "id";
            Object lastId = null;
            while (count > 0) {