--- a/pkg/imports/fm.go	Wed Feb 26 12:34:11 2020 +0100
+++ b/pkg/imports/fm.go	Wed Feb 26 12:54:33 2020 +0100
@@ -179,6 +179,7 @@
 					insertBcnlatDirimpSQL,
 				),
 				consumeBCNLAT,
+				createInvalidation("bcnlat"),
 				func() interface{} { return new(bcnlatProperties) },
 			),
 		})
@@ -194,6 +195,7 @@
 						"marsys", "boyshp", "catlam"),
 				),
 				consumeBOYLAT,
+				createInvalidation("boylat"),
 				func() interface{} { return new(boylatProperties) },
 			),
 		})
@@ -209,6 +211,7 @@
 						"marsys", "boyshp", "catcam"),
 				),
 				consumeBOYCAR,
+				createInvalidation("boycar"),
 				func() interface{} { return new(boycarProperties) },
 			),
 		})
@@ -223,6 +226,7 @@
 						"colour", "colpat", "conrad", "marsys", "boyshp"),
 				),
 				consumeBOYSAW,
+				createInvalidation("boysaw"),
 				func() interface{} { return new(boysawProperties) },
 			),
 		})
@@ -238,6 +242,7 @@
 						"marsys", "boyshp", "catspm"),
 				),
 				consumeBOYSPP,
+				createInvalidation("boyspp"),
 				func() interface{} { return new(boysppProperties) },
 			),
 		})
@@ -253,6 +258,7 @@
 					insertDaymarDirimpSQL,
 				),
 				consumeDAYMAR,
+				createInvalidation("daymar"),
 				func() interface{} { return new(daymarProperties) },
 			),
 		})
@@ -271,6 +277,7 @@
 						"sigseq", "status"),
 				),
 				consumeLIGHTS,
+				createInvalidation("lights"),
 				func() interface{} { return new(lightsProperties) },
 			),
 		})
@@ -289,6 +296,7 @@
 					insertNotmrkDirimpSQL,
 				),
 				consumeNOTMRK,
+				createInvalidation("notmark"),
 				func() interface{} { return new(notmrkProperties) },
 			),
 		})
@@ -303,6 +311,7 @@
 						"condtn", "siggrp", "catrtb", "radwal"),
 				),
 				consumeRTPBCN,
+				createInvalidation("rtpbcn"),
 				func() interface{} { return new(rtpbcnProperties) },
 			),
 		})
@@ -317,6 +326,7 @@
 						"colour", "colpat", "condtn", "topshp"),
 				),
 				consumeTOPMAR,
+				createInvalidation("topmar"),
 				func() interface{} { return new(topmarProperties) },
 			),
 		})
@@ -425,6 +435,24 @@
 `
 )
 
+func createInvalidation(fmType string) func(*SQLPointConsumer) error {
+
+	invalidateFairwayMarksSQL := fmt.Sprintf(invalidateFairwayMarksSQLtmpl, fmType)
+
+	return func(spc *SQLPointConsumer) error {
+		res, err := spc.tx.ExecContext(spc.ctx, invalidateFairwayMarksSQL)
+		if err != nil {
+			return err
+		}
+		nOld, err := res.RowsAffected()
+		if err != nil {
+			return err
+		}
+		spc.feedback.Info("Number of features removed from data source: %d", nOld)
+		return nil
+	}
+}
+
 // Create INSERT statement for specific fairway marks type
 func createInsertFMSQL(fmType string, attributes ...string) string {
 	attNums := "$16"