Function getInsertQueryBuild

plugins/destination/mysql/client/write.go:14–47

(table *schema.Table, rowCount int, overwrite bool)

)

func getInsertQueryBuild(table *schema.Table, rowCount int, overwrite bool) *strings.Builder {
	builder := strings.Builder{}
	builder.WriteString("INSERT INTO " + identifier(table.Name))
	builder.WriteString(" (")

	for i, col := range table.Columns {
		builder.WriteString(identifier(col.Name))
		if i < len(table.Columns)-1 {
			builder.WriteString(", ")
		}
	}
	builder.WriteString(") VALUES ")

	for i := 1; i <= rowCount; i++ {
		if i > 1 {
			builder.WriteString(", ")
		}
		builder.WriteString("(")
		builder.WriteString(strings.TrimSuffix(strings.Repeat("?,", len(table.Columns)), ","))
		builder.WriteString(")")
	}

	if overwrite {
		builder.WriteString(" ON DUPLICATE KEY UPDATE ")
		for i, col := range table.Columns {
			builder.WriteString(fmt.Sprintf("%s = VALUES(%s)", identifier(col.Name), identifier(col.Name)))
			if i < len(table.Columns)-1 {
				builder.WriteString(", ")
			}
		}
	}

	return &builder
}

func logTablesWithTruncation(logger zerolog.Logger, tables map[string]bool) {
	if len(tables) == 0 {