#697: add support for cleaning 'JAVA SOURCE' in Oracle DB

flyway-core/src/main/java/com/googlecode/flyway/core/dbsupport/oracle/OracleSchema.java

@@ -126,6 +126,10 @@ protected void doClean() throws SQLException {
         for (String statement : generateDropStatementsForObjectType("TYPE", "FORCE")) {
             jdbcTemplate.execute(statement);
         }
+
+        for (String statement : generateDropStatementsForObjectType("JAVA SOURCE", "")) {
+            jdbcTemplate.execute(statement);
+        }
     }
 
     /**

flyway-core/src/test/java/com/googlecode/flyway/core/dbsupport/oracle/OracleMigrationMediumTest.java

@@ -26,6 +26,7 @@
 import com.googlecode.flyway.core.DbCategory;
 
 import javax.sql.DataSource;
+import java.sql.SQLException;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Properties;
@@ -281,4 +282,25 @@ public void referencePartitionedTable() throws FlywayException {
         flyway.clean();
         flyway.migrate();
     }
+
+    /**
+     * Tests support for cleaning together with JAVA SOURCE Type.
+     */
+    @Test
+    public void javaSource() throws FlywayException, SQLException {
+        flyway.setLocations("com/googlecode/flyway/core/dbsupport/oracle/sql/javaSource");
+
+        flyway.migrate();
+        assertTrue(isExistMyJavaSource());
+
+        flyway.clean();
+        assertFalse(isExistMyJavaSource());
+    }
+
+    private boolean isExistMyJavaSource() throws SQLException {
+        String query = "SELECT count(*) FROM all_objects WHERE object_name = ? AND owner = ?";
+        String objectName = "MyJavaSource";
+        String owner = flyway.getSchemas()[0];
+        return jdbcTemplate.queryForInt(query, objectName, owner) != 0;
+    }
 }

flyway-core/src/test/java/com/googlecode/flyway/core/dbsupport/oracle/sql/javaSource/V1__JavaSource.java

@@ -0,0 +1,32 @@
+package com.googlecode.flyway.core.dbsupport.oracle.sql.javaSource;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+
+import com.googlecode.flyway.core.api.migration.jdbc.JdbcMigration;
+
+public class V1__JavaSource implements JdbcMigration {
+
+    private static final String SOURCE_SQL =
+            "CREATE OR REPLACE AND COMPILE JAVA SOURCE NAMED \"MyJavaSource\" AS\n" +
+                    "public class MyJavaSource {\n" +
+                    "  public static int sum(int a, int b) { return a + b; }\n" +
+                    "}";
+
+    public static void main(String[] args) {
+        System.out.println(SOURCE_SQL);
+    }
+
+    public void migrate(Connection connection) throws Exception {
+        PreparedStatement statement =
+            connection.prepareStatement(SOURCE_SQL);
+        try {
+            statement.setEscapeProcessing(false);
+            statement.execute();
+        } finally {
+            statement.close();
+        }
+    }
+
+
+}