Check for error during insert parse

mpchadwick · Jul 16, 2022 · c16d6e1 · c16d6e1
1 parent 4e13946
commit c16d6e1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/processor.go b/src/processor.go
@@ -28,7 +28,10 @@ func (p LineProcessor) ProcessLine(s string) string {
 }
 
 func (p LineProcessor) processInsert(s string) string {
-	stmt, _ := sqlparser.Parse(s)
+	stmt, err := sqlparser.Parse(s)
+	if err != nil {
+		return s
+	}
 	insert, ok := stmt.(*sqlparser.Insert)
 
 	// This _shouldn't happen but the statement might not be an Insert