drainer: escape quote in value of column (#1132)

ref #1131
pingcap · Jan 21, 2022 · b607f34 · b607f34
1 parent 4246eae
commit b607f34
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/loader/model.go b/pkg/loader/model.go
@@ -519,6 +519,10 @@ func genOracleValue(column *model.ColumnInfo, value interface{}) string {
 		mysql.TypeYear, mysql.TypeFloat, mysql.TypeDouble, mysql.TypeNewDecimal:
 		return fmt.Sprintf("%v", value)
 	default:
-		return fmt.Sprintf("'%v'", value)
+		return fmt.Sprintf("'%s'", processOracleQuoteStringValue(fmt.Sprintf("%v", value)))
 	}
 }
+
+func processOracleQuoteStringValue(data string) string {
+	return strings.ReplaceAll(data, "'", "''")
+}