opensource/Chat2DB
1
0
Fork 0
mirror of https://github.com/CodePhiliaX/Chat2DB.git synced 2025-07-29 18:53:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

pgsql-schema-export

Browse Source
This commit is contained in:
zgq
2024-03-20 18:25:44 +08:00
parent 1469908d27
commit 0dc73e4d34
2 changed files with 20 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
chat2db-server/chat2db-plugins/chat2db-postgresql/src/main/java/ai/chat2db/plugin/postgresql/PostgreSQLDBManage.java
View File

@ -8,6 +8,7 @@ import ai.chat2db.spi.sql.SQLExecutor;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import java.sql.*; import java.sql.*;
import java.util.ArrayList;
import static ai.chat2db.plugin.postgresql.consts.SQLConst.*; import static ai.chat2db.plugin.postgresql.consts.SQLConst.*;
@ -17,7 +18,7 @@ public class PostgreSQLDBManage extends DefaultDBManage implements DBManage {
public String exportDatabase(Connection connection, String databaseName, String schemaName, boolean containData) throws SQLException { public String exportDatabase(Connection connection, String databaseName, String schemaName, boolean containData) throws SQLException {
StringBuilder sqlBuilder = new StringBuilder(); StringBuilder sqlBuilder = new StringBuilder();
exportTypes(connection, schemaName, sqlBuilder); exportTypes(connection, schemaName, sqlBuilder);
exportTables(connection, schemaName, sqlBuilder, containData); exportTables(connection, databaseName, schemaName, sqlBuilder, containData);
exportViews(connection, schemaName, sqlBuilder); exportViews(connection, schemaName, sqlBuilder);
exportFunctions(connection, schemaName, sqlBuilder); exportFunctions(connection, schemaName, sqlBuilder);
exportTriggers(connection, schemaName, sqlBuilder); exportTriggers(connection, schemaName, sqlBuilder);
@ -31,26 +32,32 @@ public class PostgreSQLDBManage extends DefaultDBManage implements DBManage {
} }
} }
} }
private void exportTables(Connection connection, String schemaName, StringBuilder sqlBuilder, boolean containData) throws SQLException { private void exportTables(Connection connection, String databaseName, String schemaName, StringBuilder sqlBuilder, boolean containData) throws SQLException {
String tablesQuery = "SELECT table_name FROM information_schema.tables WHERE table_schema = '" + schemaName + "' AND table_type = 'BASE TABLE'"; try (ResultSet resultSet = connection.getMetaData().getTables(databaseName, schemaName, null,
try (Statement statement = connection.createStatement(); ResultSet tables = statement.executeQuery(tablesQuery)) { new String[]{"TABLE", "SYSTEM TABLE","PARTITIONED TABLE"})) {
while (tables.next()) { ArrayList<String> tableNames = new ArrayList<>();
String tableName = tables.getString(1); while (resultSet.next()) {
exportTable(connection, schemaName, tableName, sqlBuilder, containData); String tableName = resultSet.getString("TABLE_NAME");
tableNames.add(tableName);
}
for (String tableName : tableNames) {
exportTable(connection, schemaName, tableName, sqlBuilder);
}
if (containData) {
for (String tableName : tableNames) {
exportTableData(connection, schemaName, tableName, sqlBuilder);
}
} }
} }
} }
private void exportTable(Connection connection, String schemaName, String tableName, StringBuilder sqlBuilder, boolean containData) throws SQLException { private void exportTable(Connection connection, String schemaName, String tableName, StringBuilder sqlBuilder) throws SQLException {
String tableQuery = "select pg_get_tabledef" + "(" + "'" + schemaName + "'" + "," + "'" + tableName + "'" + "," + "true" + "," + "'" + "COMMENTS" + "'" + ")" + ";"; String tableQuery = "select pg_get_tabledef" + "(" + "'" + schemaName + "'" + "," + "'" + tableName + "'" + "," + "true" + "," + "'" + "COMMENTS" + "'" + ")" + ";";
try (Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery(tableQuery)) { try (Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery(tableQuery)) {
sqlBuilder.append("\n").append("DROP TABLE IF EXISTS ").append(schemaName).append(".").append(tableName).append(";\n"); sqlBuilder.append("\n").append("DROP TABLE IF EXISTS ").append(schemaName).append(".").append(tableName).append(";\n");
if (resultSet.next()) { if (resultSet.next()) {
sqlBuilder.append(resultSet.getString(1)).append("\n"); sqlBuilder.append(resultSet.getString(1)).append("\n");
} }
if (containData) {
exportTableData(connection, schemaName, tableName, sqlBuilder);
}
} }
} }
@ -88,7 +95,7 @@ public class PostgreSQLDBManage extends DefaultDBManage implements DBManage {
String viewName = resultSet.getString("table_name"); String viewName = resultSet.getString("table_name");
String viewDefinition = resultSet.getString("view_definition"); String viewDefinition = resultSet.getString("view_definition");
sqlBuilder.append("DROP VIEW IF EXISTS ").append(schemaName).append(".").append(viewName).append(";\n"); sqlBuilder.append("DROP VIEW IF EXISTS ").append(schemaName).append(".").append(viewName).append(";\n");
sqlBuilder.append("CREATE VIEW ").append(schemaName).append(".").append(viewName).append(" AS ").append(viewDefinition).append(";\n\n"); sqlBuilder.append("CREATE VIEW ").append(schemaName).append(".").append(viewName).append(" AS ").append(viewDefinition).append("\n\n");
} }
} }
} }
@ -111,7 +118,6 @@ public class PostgreSQLDBManage extends DefaultDBManage implements DBManage {
while (resultSet.next()) { while (resultSet.next()) {
String triggerName = resultSet.getString("tgname"); String triggerName = resultSet.getString("tgname");
String triggerDefinition = resultSet.getString("trigger_definition"); String triggerDefinition = resultSet.getString("trigger_definition");
sqlBuilder.append("DROP TRIGGER IF EXISTS ").append(schemaName).append(".").append(triggerName).append(";\n");
sqlBuilder.append(triggerDefinition).append(";\n\n"); sqlBuilder.append(triggerDefinition).append(";\n\n");
} }
} }

1
chat2db-server/chat2db-plugins/chat2db-postgresql/src/main/java/ai/chat2db/plugin/postgresql/consts/SQLConst.java
View File

@ -610,6 +610,7 @@ public class SQLConst {
if bSkip THEN CONTINUE; END IF; if bSkip THEN CONTINUE; END IF;
-- Add IF NOT EXISTS clause so partition index additions will not be created if declarative partition in effect and index already created on parent -- Add IF NOT EXISTS clause so partition index additions will not be created if declarative partition in effect and index already created on parent
v_indexrec.indexdef := REPLACE(v_indexrec.indexdef, 'CREATE UNIQUE INDEX', 'CREATE UNIQUE INDEX IF NOT EXISTS');
v_indexrec.indexdef := REPLACE(v_indexrec.indexdef, 'CREATE INDEX', 'CREATE INDEX IF NOT EXISTS'); v_indexrec.indexdef := REPLACE(v_indexrec.indexdef, 'CREATE INDEX', 'CREATE INDEX IF NOT EXISTS');
-- RAISE INFO 'DEBUG8: adding index, %', v_indexrec.indexname; -- RAISE INFO 'DEBUG8: adding index, %', v_indexrec.indexname;