diff --git a/src/main/groovy/org/grails/plugins/databasemigration/liquibase/GroovyChange.groovy b/src/main/groovy/org/grails/plugins/databasemigration/liquibase/GroovyChange.groovy
index af0e3137..86ca976f 100644
--- a/src/main/groovy/org/grails/plugins/databasemigration/liquibase/GroovyChange.groovy
+++ b/src/main/groovy/org/grails/plugins/databasemigration/liquibase/GroovyChange.groovy
@@ -92,6 +92,9 @@ class GroovyChange extends AbstractChange {
 
         ctx = parsedNode.getChildValue(null, 'applicationContext', ApplicationContext)
         dataSourceName = parsedNode.getChildValue(null, DATA_SOURCE_NAME_KEY, String)
+        if (dataSourceName.startsWith("dataSource_")) {
+            dataSourceName = dataSourceName.substring("dataSource_".length())
+        }
         initClosure = parsedNode.getChildValue(null, 'init', Closure)
         validateClosure = parsedNode.getChildValue(null, 'validate', Closure)
         changeClosure = parsedNode.getChildValue(null, 'change', Closure)