Method WriteTableBatch

plugins/destination/mysql/client/write.go:135–145

(ctx context.Context, name string, msgs message.WriteInserts)

}

func (c *Client) WriteTableBatch(ctx context.Context, name string, msgs message.WriteInserts) error {
	if len(msgs) == 0 {
		return nil
	}
	table := msgs[0].GetTable()
	hasPks := len(table.PrimaryKeys()) > 0
	if hasPks {
		return c.overwriteTableBatch(ctx, msgs)
	}
	return c.appendTableBatch(ctx, msgs)
}