Column rename

This transformation let you rename the properties names of your ingoing data. Also, you can remove columns from your flow.

Overview

ColumnRename allows you to rename the column or properties names of your ingoing data. You can provide a column mapping with the old and the new name for each column. The mapping can also be automatically retrieved from existing DbColumnMap attributes. This transformation works with object, ExpandoObject and array as input data type. It will always output an ExpandoObject with the new mapped property names.

If you have an array as input type, instead of providing the old name you need to enter the array index and the new name.

Buffer

The ColumnRename is a non blocking transformation and has one input buffer.

Code snippet 

var source = new DbSource<MyInputRow>();
var map = new ColumnRename<MyInputRow>();
map.RenameColumns = new []
{
    new RenameColumn() { CurrentName = "OldCol1", NewName = "Col1"),
    new RenameColumn() { CurrentName = "OldCol2", RemoveColumn = true)
};
var dest = new DbDestination(SqlConnection, "ColumnRenameDest");

source.LinkTo<ExpandoObject>(map).LinkTo(dest);

Rename columns

You should always provide a list of renaming columns, either by providing this list manually via the RenameColumnns properties or by having the RenameColum attribute on the corresponding properties in your strongly typed object.

The RenameColumns contains information about the renaming - this should be the old and the new name for each column (except arrays, where you can define an ArrayIndex). If you want to remove a column, you need to provide the current name and set a flag for removing the column. If no mapping is provided, it will just convert your ingoing data type into an ExpandoObject.

Example for attribute usage 

public class MyInputRow
{
    [RenameColumn("NewCol1")]
    public int Col1 { get; set; }
    [RenameColumn("NewCol2")]
    public string Col2 { get; set; }
}

public void RenamingWithAttributes() {
    var source = new MemorySource<MyInputRow>();
    var input = new MyInputRow() {
        Col1 = 1,
        Col2 = "Test",
    };
    source.DataAsList.Add(input);
    var map = new ColumnRename<MyInputRow>();
    var dest = new MemoryDestination();
    source.LinkTo<ExpandoObject>(map).LinkTo(dest);
    Network.Execute(source);
    dynamic output = dest.Data.First();
    IDictionary<string,object> outputDict = dest.Data.First();
    
    Console.WriteLine("Does property Col1 still exists?" + outputDict.ContainsKey("Col1"));
    Console.WriteLine("Does property Col2 still exists?" + outputDict.ContainsKey("Col2"));
    Console.WriteLine("Does property NewCol1 now exists?" + outputDict.ContainsKey("NewCol1"));
    Console.WriteLine("Does property NewCol2 still exists?" + outputDict.ContainsKey("NewCol2"));
    Console.WriteLine("NewCol1: " + output.NewCol1 + " NewCol2: " + output.NewCol2);
    //Output
    /*
      Does property Col1 still exists?False
      Does property Col2 still exists?False
      Does property NewCol1 now exists?True
      Does property NewCol2 still exists?True
      NewCol1: 1 NewCol2: Test
    */
}
Edit this page on GitHub
← Filter transformation
Distinct →