make the actions into a list

api/v1alpha1/migration_types.go

@@ -59,6 +59,9 @@ type MigrationSpec struct {
 	// +kubebuilder:validation:Required
 	Database Database `json:"database"`
 
+	// settings for flyway
+	FlywayConfiguration FlywayConfiguration `json:"flywayConfiguration"`
+
 	// settings defining the SQL migrations
 	// +kubebuilder:validation:Required
 	MigrationSource MigrationSource `json:"migrationSource"`
@@ -87,13 +90,19 @@ func (r *Migration) GetCredentials() v1.SecretReference {
 	}
 }
 
-// MigrationSource defines the source for the flyway-migrations.
-type MigrationSource struct {
-
+type FlywayConfiguration struct {
 	// Reference to the flyway image to use.
 	// +kubebuilder:validation:Optional
 	FlywayImage string `json:"flywayImage"`
 
+	// The flyway actions to apply, like "info", "migrate"
+	// +kubebuilder:default={"info", "migrate", "info"}
+	CommandLines []string `json:"commandLines"`
+}
+
+// MigrationSource defines the source for the flyway-migrations.
+type MigrationSource struct {
+
 	// Reference to the image holding the SQLs to migrate
 	// +kubebuilder:validation:Required
 	ImageRef string `json:"imageRef"`

config/crd/bases/flyway.davidkarlsen.com_migrations.yaml

@@ -69,6 +69,24 @@ spec:
                 - jdbcUrl
                 - username
                 type: object
+              flywayConfiguration:
+                description: settings for flyway
+                properties:
+                  commandLines:
+                    default:
+                    - info
+                    - migrate
+                    - info
+                    description: The flyway actions to apply
+                    items:
+                      type: string
+                    type: array
+                  flywayImage:
+                    description: Reference to the flyway image to use.
+                    type: string
+                required:
+                - commandLines
+                type: object
               migrationSource:
                 description: settings defining the SQL migrations
                 properties:
@@ -90,9 +108,6 @@ spec:
                     default: UTF-8
                     description: The encoding of the SQL-files.
                     type: string
-                  flywayImage:
-                    description: Reference to the flyway image to use.
-                    type: string
                   imageRef:
                     description: Reference to the image holding the SQLs to migrate
                     type: string
@@ -113,6 +128,7 @@ spec:
                 type: object
             required:
             - database
+            - flywayConfiguration
             - migrationSource
             type: object
           status:

internal/controller/jobutil.go

@@ -43,10 +43,17 @@ func hasSucceeded(job *batchv1.Job) bool {
 }
 
 func getFlywayImage(migration *flywayv1alpha1.Migration) string {
-	image, _ := lo.Coalesce(migration.Spec.MigrationSource.FlywayImage, env.GetDefault(envNameFlywayImage, defaultFlywayImage))
+	image, _ := lo.Coalesce(migration.Spec.FlywayConfiguration.FlywayImage, env.GetDefault(envNameFlywayImage, defaultFlywayImage))
 	return image
 }
 
+func getFlywayArgs(migration *flywayv1alpha1.Migration) []string {
+	args := migration.Spec.FlywayConfiguration.CommandLines
+	args = append(args, "-outputType=json")
+
+	return args
+}
+
 func createJobSpec(migration *flywayv1alpha1.Migration) *batchv1.Job {
 	const targetPath = "/mnt/target/"
 	envVars := []corev1.EnvVar{
@@ -109,7 +116,7 @@ func createJobSpec(migration *flywayv1alpha1.Migration) *batchv1.Job {
 							Name:            "flyway",
 							Image:           getFlywayImage(migration),
 							ImagePullPolicy: corev1.PullAlways,
-							Args:            []string{"info", "migrate", "info", "-outputType=json"},
+							Args:            getFlywayArgs(migration),
 							Env:             envVars,
 							VolumeMounts: []corev1.VolumeMount{
 								{