From c865f4b5d67560c74ba0a6ec3a18458f534e3425 Mon Sep 17 00:00:00 2001
From: liulin <lin.liu@aliyun.com>
Date: 星期六, 03 八月 2024 22:27:24 +0800
Subject: [PATCH] mysql迁移数据库到gauss
---
src/test/java/com/lunhan/xxx/host/GenCodeGauss.java | 4 ++--
src/test/java/com/lunhan/xxx/host/Mysql2Gauss.java | 4 ++--
sql/init.sql | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/sql/init.sql b/sql/init.sql
index 73c01d5..70b33fa 100644
--- a/sql/init.sql
+++ b/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"();
diff --git a/src/test/java/com/lunhan/xxx/host/GenCodeGauss.java b/src/test/java/com/lunhan/xxx/host/GenCodeGauss.java
index a40a4fe..589d63b 100644
--- a/src/test/java/com/lunhan/xxx/host/GenCodeGauss.java
+++ b/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);
diff --git a/src/test/java/com/lunhan/xxx/host/Mysql2Gauss.java b/src/test/java/com/lunhan/xxx/host/Mysql2Gauss.java
index 2b1ba3a..dbd0ac2 100644
--- a/src/test/java/com/lunhan/xxx/host/Mysql2Gauss.java
+++ b/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) {
--
Gitblit v1.9.3