Temporarily cancel the export trigger

Author: pdxzzz

chat2db-server/chat2db-plugins/chat2db-oracle/src/main/java/ai/chat2db/plugin/oracle/OracleDBManage.java

@@ -24,8 +24,8 @@ public void exportDatabase(Connection connection, String databaseName, String sc
         exportTables(connection, databaseName, schemaName, asyncContext);
         exportViews(connection, asyncContext, schemaName);
         exportProcedures(connection, schemaName, asyncContext);
-        exportTriggers(connection, schemaName, asyncContext);
         exportFunctions(connection, schemaName, asyncContext);
+//        exportTriggers(connection, schemaName, asyncContext);
     }
 
     private void exportTables(Connection connection, String databaseName, String schemaName, AsyncContext asyncContext) throws SQLException {

chat2db-server/chat2db-plugins/chat2db-oracle/src/main/java/ai/chat2db/plugin/oracle/OracleMetaData.java

@@ -87,7 +87,7 @@ public String tableDDL(Connection connection, String databaseName, String schema
         SQLExecutor.getInstance().execute(connection, sql, resultSet -> {
             try {
                 if (resultSet.next()) {
-                    ddlBuilder.append(resultSet.getString("sql"));
+                    ddlBuilder.append(resultSet.getString("sql")).append(";");
                 }
             } catch (SQLException e) {
                 throw new RuntimeException(e);
@@ -259,11 +259,15 @@ public Function function(Connection connection, @NotEmpty String databaseName, S
             function.setDatabaseName(databaseName);
             function.setSchemaName(schemaName);
             function.setFunctionName(functionName);
-            StringBuilder bodyBuilder = new StringBuilder("CREATE ");
+            StringBuilder bodyBuilder = new StringBuilder("CREATE OR REPLACE ");
             while (resultSet.next()) {
                 bodyBuilder.append(resultSet.getString("TEXT")).append("\n");
             }
-            function.setFunctionBody(bodyBuilder.toString());
+            String functionBody = bodyBuilder.toString().trim();
+            if (!functionBody.endsWith("/")) {
+                functionBody += "\n/";
+            }
+            function.setFunctionBody(functionBody);
             return function;
 
         });
@@ -391,11 +395,15 @@ public Procedure procedure(Connection connection, @NotEmpty String databaseName,
             procedure.setDatabaseName(databaseName);
             procedure.setSchemaName(schemaName);
             procedure.setProcedureName(procedureName);
-            StringBuilder bodyBuilder = new StringBuilder("CREATE ");
+            StringBuilder bodyBuilder = new StringBuilder("CREATE OR REPLACE ");
             while (resultSet.next()) {
                 bodyBuilder.append(resultSet.getString("TEXT")).append("\n");
             }
-            procedure.setProcedureBody(bodyBuilder.toString());
+            String procedureBody = bodyBuilder.toString().trim(); // 去掉最后的空白字符
+            if (!procedureBody.endsWith("/")) {
+                procedureBody += "\n/";
+            }
+            procedure.setProcedureBody(procedureBody);
             return procedure;
         });
     }
@@ -412,7 +420,7 @@ public Table view(Connection connection, String databaseName, String schemaName,
             table.setSchemaName(schemaName);
             table.setName(viewName);
             if (resultSet.next()) {
-                table.setDdl("CREATE VIEW " + viewName + " AS " + resultSet.getString("TEXT"));
+                table.setDdl("CREATE OR REPLACE VIEW " + viewName + " AS " + resultSet.getString("TEXT"));
             }
             return table;
         });