lihongjie/coal
1
0
Fork 0
mirror of https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git synced 2026-01-25 07:46:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

完善脚本

Browse Source
This commit is contained in:
lihongjie0209
2024-01-09 22:13:51 +08:00
parent d52386dc92
commit 9ee4672036
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
script/genSQL.groovy
View File

@@ -1,9 +1,22 @@
def execute = """C:\\Program Files\\PostgreSQL\\15\\bin\\pg_dump.exe -d coal_master -h 127.0.0.1 -p 5432 -U postgres -a --inserts -t t_permission -t t_resource -t t_permission_resources --column-inserts """ def execute = """D:\\dev\\postgresql-16.1-1\\bin\\pg_dump.exe -d coal_master -h 192.168.59.128 -p 5432 -U postgres -a --inserts -t t_permission -t t_resource -t t_permission_resources --column-inserts """
.execute(["PGPASSWORD=abc@123"], new File("../")) .execute(["PGPASSWORD=abc@123"], new File("../"))
def bs = new ByteArrayOutputStream()
execute.consumeProcessErrorStream(bs)
def insertSQL = execute.text.split("\n").findAll { it.startsWith("INSERT") }.collect {it.replace("INSERT INTO public.", "INSERT INTO ")}
def insertSQL = execute.text.split("\n").findAll { it.startsWith("INSERT") }.collect { it.replace("INSERT INTO public.", "INSERT INTO ") }
if (execute.exitValue() != 0) {
println(new String(bs.toByteArray(), "GBK"))
throw new Exception("execute.exitValue()!=0")}
if (insertSQL.size() < 10) {
throw new Exception("insertSQL.size() < 10")
}
insertSQL.add(0, """ insertSQL.add(0, """
truncate table t_permission; truncate table t_permission;
@@ -17,4 +30,4 @@ truncate table t_resource;
def lastVersion = new File("../src/main/resources/db/migration/").listFiles().findAll { it.name.matches("V\\d+__.+") }.collect { it.name.split("_")[0].substring(1).toInteger() }.sort().last() def lastVersion = new File("../src/main/resources/db/migration/").listFiles().findAll { it.name.matches("V\\d+__.+") }.collect { it.name.split("_")[0].substring(1).toInteger() }.sort().last()
(new File("../src/main/resources/db/migration/V${lastVersion+1}__resourceAll.sql")).text = insertSQL.join("\n") (new File("../src/main/resources/db/migration/V${lastVersion + 1}__resourceAll.sql")).text = insertSQL.join("\n")