Adding the Copy Data Object to ETL Task

SOAP request:

<s:Envelope xmlns:s="http://schemas.xmlsoap.org/soap/envelope/">

<s:Body xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema">

<SetEtl xmlns="http://www.fsight.ru/PP.SOM.Som">

<tEtl xmlns="">

  <id>S1!M!S!L1</id>

  </tEtl>

<tArg xmlns="">

<pattern>

  <obInst>true</obInst>

  <objects>Add</objects>

<object>

  <settings>true</settings>

  </object>

  </pattern>

<meta>

<objects>

<its>

<it>

  <k>0</k>

  <id>COPY_TABLE</id>

  <vis>true</vis>

  <type>PlainDataCopy</type>

<settings>

<plainDataCopy>

<provider>

<obDesc isShortcut="false" isLink="false" hf="false">

  <i>DATA_INDICATORS</i>

  <n>Table</n>

  <k>37885</k>

  <c>769</c>

  <p>7011</p>

  <h>false</h>

  <hasPrv>false</hasPrv>

  <ic>false</ic>

  </obDesc>

  </provider>

<consumer>

<obDesc isShortcut="false" isLink="false" hf="false">

  <i>BACKUP_DATA</i>

  <n>Table</n>

  <k>37886</k>

  <c>769</c>

  <p>7011</p>

  <h>false</h>

  <hasPrv>false</hasPrv>

  <ic>false</ic>

  </obDesc>

  </consumer>

  <autoLink>true</autoLink>

  <clearConsumer>true</clearConsumer>

  </plainDataCopy>

  </settings>

  </it>

  </its>

  </objects>

  </meta>

<metaGet>

  <obInst>true</obInst>

  <objects>Get</objects>

  </metaGet>

  </tArg>

  </SetEtl>

  </s:Body>

  </s:Envelope>

SOAP response:

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">

<soapenv:Body>

<SetEtlResult xmlns="http://www.fsight.ru/PP.SOM.Som" xmlns:q1="http://www.fsight.ru/PP.SOM.Som" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

<id xmlns="">

  <id>S1!M!S!L1</id>

  </id>

<meta xmlns="">

<obInst>

<obDesc ds="" isShortcut="0" isLink="0" ver="3" hf="0">

  <i>ETL_INDICATOR</i>

  <n>ETL task for factor loading</n>

  <k>7012</k>

  <c>4097</c>

  <p>7011</p>

  <h>0</h>

  <hasPrv>0</hasPrv>

  <ic>0</ic>

  <isPermanent>1</isPermanent>

  <isTemp>0</isTemp>

  </obDesc>

  </obInst>

  <dirty>1</dirty>

<objects>

<its>

<it>

  <k>0</k>

  <id>PLAINDATAEXCELPROVIDEREX1</id>

  <n>Import from Excel</n>

  <vis>1</vis>

  <type>PlainDataExcelProviderEx</type>

<settings>

<plainProvider>

<provider>

<props>

  <type>ExcelEx</type>

<excelEx>

<stringDataFormat>

  <useSystem>1</useSystem>

  <dateFormat>DD.MM.YYYY</dateFormat>

  <decimalSeparator>,</decimalSeparator>

  <usePredefinedDateFormats>1</usePredefinedDateFormats>

  </stringDataFormat>

  <typeGuessRows>100</typeGuessRows>

  <autoFillMode>DataRow</autoFillMode>

  <filterIf />

  <sheet>Sheet1</sheet>

  <hasHeader>1</hasHeader>

  <headerRow>0</headerRow>

  <format>xlsx</format>

  <dataRow>0</dataRow>

  </excelEx>

  <srcFileName>D:\Work\Indicator.xls</srcFileName>

  </props>

  </provider>

  <fetchBlockSize>-1</fetchBlockSize>

  <ignoreIncorrectVals>0</ignoreIncorrectVals>

  <unpivotMode>0</unpivotMode>

  <queryForFile>0</queryForFile>

  </plainProvider>

  </settings>

  </it>

<it>

  <k>1</k>

  <id>PLAINDATAMETABASECONSUMER1</id>

  <n>Repository consumer</n>

  <vis>1</vis>

  <type>PlainDataMetabaseConsumer</type>

<obDesc ds="" isShortcut="0" isLink="0" ver="0" hf="0">

  <i>T_INDICATOR</i>

  <n>Table</n>

  <k>7013</k>

  <c>769</c>

  <p>7011</p>

  <h>0</h>

  <hasPrv>0</hasPrv>

  <ic>0</ic>

  </obDesc>

  <read>1</read>

  <write>1</write>

<settings>

<plainConsumer>

<consumer>

<props>

  <type>Mb</type>

<mb>

<dataset ds="" isShortcut="0" isLink="0" ver="0" hf="0">

  <i>T_INDICATOR</i>

  <n>Table</n>

  <k>7013</k>

  <c>769</c>

  <p>7011</p>

  <h>0</h>

  <hasPrv>0</hasPrv>

  <ic>0</ic>

  </dataset>

  </mb>

  </props>

  </consumer>

  <keyFieldNames />

  <clearConsumer>1</clearConsumer>

<bulk>

  <commitCount>1024</commitCount>

  <actionOnProblem>DiscardRecordsInTransaction</actionOnProblem>

  <saveInvalidRecs>0</saveInvalidRecs>

  <invalidRecsFileName />

  <useStopLimit>0</useStopLimit>

  <stopLimit>1024</stopLimit>

  <eventId />

  </bulk>

  </plainConsumer>

  </settings>

  </it>

<it>

  <k>2</k>

  <id>PLAINDATACOPY1</id>

  <n>Copy data</n>

  <vis>1</vis>

  <type>PlainDataCopy</type>

<settings>

<plainDataCopy>

  <provider />

<consumer>

<obDesc ds="" isShortcut="0" isLink="0" ver="0" hf="0">

  <i>T_INDICATOR</i>

  <n>Table</n>

  <k>7013</k>

  <c>769</c>

  <p>7011</p>

  <h>0</h>

  <hasPrv>0</hasPrv>

  <ic>0</ic>

  </obDesc>

  <keyFieldNames />

  </consumer>

  <clearConsumer>1</clearConsumer>

  <commitCount>1024</commitCount>

  <actionOnProblem>DiscardRecordsInTransaction</actionOnProblem>

  </plainDataCopy>

  </settings>

  </it>

<it>

  <k>3</k>

  <id>COPY_TABLE</id>

  <n>Copy data1</n>

  <vis>1</vis>

  <type>PlainDataCopy</type>

<settings>

<plainDataCopy>

<provider>

<obDesc ds="" isShortcut="0" isLink="0" ver="0" hf="0">

  <i>DATA_INDICATORS</i>

  <n>Table</n>

  <k>37885</k>

  <c>769</c>

  <p>7011</p>

  <h>0</h>

  <hasPrv>0</hasPrv>

  <ic>0</ic>

  </obDesc>

  </provider>

<consumer>

<obDesc ds="" isShortcut="0" isLink="0" ver="0" hf="0">

  <i>BACKUP_DATA</i>

  <n>Table</n>

  <k>37886</k>

  <c>769</c>

  <p>7011</p>

  <h>0</h>

  <hasPrv>0</hasPrv>

  <ic>0</ic>

  </obDesc>

  <keyFieldNames />

  </consumer>

  <clearConsumer>1</clearConsumer>

  <commitCount>1024</commitCount>

  <actionOnProblem>DiscardRecordsInTransaction</actionOnProblem>

  </plainDataCopy>

  </settings>

  </it>

  </its>

  </objects>

  <shapes />

  </meta>

  </SetEtlResult>

  </soapenv:Body>

  </soapenv:Envelope>

JSON request:

{
 "SetEtl" : 
  {
   "tEtl" : 
    {
     "id" : "S1!M!S!L1"
    },
   "tArg" : 
    {
     "pattern" : 
      {
       "obInst" : "true",
       "objects" : "Add",
       "object" : 
        {
         "settings" : "true"
        }
      },
     "meta" : 
      {
       "objects" : 
        {
         "its" : 
          {
           "it" : 
            [
              {
               "k" : "0",
               "id" : "COPY_TABLE",
               "vis" : "true",
               "type" : "PlainDataCopy",
               "settings" : 
                {
                 "plainDataCopy" : 
                  {
                   "provider" : 
                    {
                     "obDesc" : 
                      {
                       "@isShortcut" : "false",
                       "@isLink" : "false",
                       "@hf" : "false",
                       "i" : "DATA_INDICATORS",
                       "n" : "Table",
                       "k" : "37885",
                       "c" : "769",
                       "p" : "7011",
                       "h" : "false",
                       "hasPrv" : "false",
                       "ic" : "false"
                      }
                    },
                   "consumer" : 
                    {
                     "obDesc" : 
                      {
                       "@isShortcut" : "false",
                       "@isLink" : "false",
                       "@hf" : "false",
                       "i" : "BACKUP_DATA",
                       "n" : "Table",
                       "k" : "37886",
                       "c" : "769",
                       "p" : "7011",
                       "h" : "false",
                       "hasPrv" : "false",
                       "ic" : "false"
                      }
                    },
                   "autoLink" : "true",
                   "clearConsumer" : "true"
                  }
                }
              }
            ]
          }
        }
      },
     "metaGet" : 
      {
       "obInst" : "true",
       "objects" : "Get"
      }
    }
  }
}

JSON response:

{
 "SetEtlResult" : 
  {
   "id" : 
    {
     "id" : "S1!M!S!L1"
    },
   "meta" : 
    {
     "obInst" : 
      {
       "obDesc" : 
        {
         "@ds" : "",
         "@isShortcut" : "0",
         "@isLink" : "0",
         "@ver" : "3",
         "@hf" : "0",
         "i" : "ETL_INDICATOR",
         "n" : "ETL task for loading indicators",
         "k" : "7012",
         "c" : "4097",
         "p" : "7011",
         "h" : "0",
         "hasPrv" : "0",
         "ic" : "0",
         "isPermanent" : "1",
         "isTemp" : "0"
        }
      },
     "dirty" : "1",
     "objects" : 
      {
       "its" : 
        {
         "it" : 
          [
            {
             "k" : "0",
             "id" : "PLAINDATAEXCELPROVIDEREX1",
             "n" : "Import from Excel",
             "vis" : "1",
             "type" : "PlainDataExcelProviderEx",
             "settings" : 
              {
               "plainProvider" : 
                {
                 "provider" : 
                  {
                   "props" : 
                    {
                     "type" : "ExcelEx",
                     "excelEx" : 
                      {
                       "stringDataFormat" : 
                        {
                         "useSystem" : "1",
                         "dateFormat" : "DD.MM.YYYY",
                         "decimalSeparator" : ",",
                         "usePredefinedDateFormats" : "1"
                        },
                       "typeGuessRows" : "100",
                       "autoFillMode" : "DataRow",
                       "filterIf" : "",
                       "sheet" : "Sheet1",
                       "hasHeader" : "1",
                       "headerRow" : "0",
                       "format" : "xlsx",
                       "dataRow" : "0"
                      },
                     "srcFileName" : "D:\Work\Indicator.xls"
                    }
                  },
                 "fetchBlockSize" : "-1",
                 "ignoreIncorrectVals" : "0",
                 "unpivotMode" : "0",
                 "queryForFile" : "0"
                }
              }
            },
            {
             "k" : "1",
             "id" : "PLAINDATAMETABASECONSUMER1",
             "n" : "Repository consumer",
             "vis" : "1",
             "type" : "PlainDataMetabaseConsumer",
             "obDesc" : 
              {
               "@ds" : "",
               "@isShortcut" : "0",
               "@isLink" : "0",
               "@ver" : "0",
               "@hf" : "0",
               "i" : "T_INDICATOR",
               "n" : "Table",
               "k" : "7013",
               "c" : "769",
               "p" : "7011",
               "h" : "0",
               "hasPrv" : "0",
               "ic" : "0"
              },
             "read" : "1",
             "write" : "1",
             "settings" : 
              {
               "plainConsumer" : 
                {
                 "consumer" : 
                  {
                   "props" : 
                    {
                     "type" : "Mb",
                     "mb" : 
                      {
                       "dataset" : 
                        {
                         "@ds" : "",
                         "@isShortcut" : "0",
                         "@isLink" : "0",
                         "@ver" : "0",
                         "@hf" : "0",
                         "i" : "T_INDICATOR",
                         "n" : "Table",
                         "k" : "7013",
                         "c" : "769",
                         "p" : "7011",
                         "h" : "0",
                         "hasPrv" : "0",
                         "ic" : "0"
                        }
                      }
                    }
                  },
                 "keyFieldNames" : "",
                 "clearConsumer" : "1",
                 "bulk" : 
                  {
                   "commitCount" : "1024",
                   "actionOnProblem" : "DiscardRecordsInTransaction",
                   "saveInvalidRecs" : "0",
                   "invalidRecsFileName" : "",
                   "useStopLimit" : "0",
                   "stopLimit" : "1024",
                   "eventId" : ""
                  }
                }
              }
            },
            {
             "k" : "2",
             "id" : "PLAINDATACOPY1",
             "n" : "Copy data",
             "vis" : "1",
             "type" : "PlainDataCopy",
             "settings" : 
              {
               "plainDataCopy" : 
                {
                 "provider" : "",
                 "consumer" : 
                  {
                   "obDesc" : 
                    {
                     "@ds" : "",
                     "@isShortcut" : "0",
                     "@isLink" : "0",
                     "@ver" : "0",
                     "@hf" : "0",
                     "i" : "T_INDICATOR",
                     "n" : "Table",
                     "k" : "7013",
                     "c" : "769",
                     "p" : "7011",
                     "h" : "0",
                     "hasPrv" : "0",
                     "ic" : "0"
                    },
                   "keyFieldNames" : ""
                  },
                 "clearConsumer" : "1",
                 "commitCount" : "1024",
                 "actionOnProblem" : "DiscardRecordsInTransaction"
                }
              }
            },
            {
             "k" : "3",
             "id" : "COPY_TABLE",
             "n" : "Copy data1",
             "vis" : "1",
             "type" : "PlainDataCopy",
             "settings" : 
              {
               "plainDataCopy" : 
                {
                 "provider" : 
                  {
                   "obDesc" : 
                    {
                     "@ds" : "",
                     "@isShortcut" : "0",
                     "@isLink" : "0",
                     "@ver" : "0",
                     "@hf" : "0",
                     "i" : "DATA_INDICATORS",
                     "n" : "Table",
                     "k" : "37885",
                     "c" : "769",
                     "p" : "7011",
                     "h" : "0",
                     "hasPrv" : "0",
                     "ic" : "0"
                    }
                  },
                 "consumer" : 
                  {
                   "obDesc" : 
                    {
                     "@ds" : "",
                     "@isShortcut" : "0",
                     "@isLink" : "0",
                     "@ver" : "0",
                     "@hf" : "0",
                     "i" : "BACKUP_DATA",
                     "n" : "Table",
                     "k" : "37886",
                     "c" : "769",
                     "p" : "7011",
                     "h" : "0",
                     "hasPrv" : "0",
                     "ic" : "0"
                    },
                   "keyFieldNames" : ""
                  },
                 "clearConsumer" : "1",
                 "commitCount" : "1024",
                 "actionOnProblem" : "DiscardRecordsInTransaction"
                }
              }
            }
          ]
        }
      },
     "shapes" : ""
    }
  }
}

public static SetEtlResult AddETLObject(MbId mb, EtlId moniker)
{
    var somClient = new SomPortTypeClient(); //Proxy object for operation execution
    //Operation execution parameters
    var tSet = new SetEtl()
    {
        tArg = new SetEtlArg()
        {
            pattern = new EtlMdPattern()
            {
                objects = ListOperation.Add,
                @object = new EtlObjectPattern()
                {
                    settings = true
                }
            },
            meta = new EtlMd()
            {
                objects = new EtlObjects()
                {
                    its = new EtlObject[]
                    {
                        new EtlObject()
                        {
                            //Basic properties
                            id = "COPY_TABLE",
                            k = 0,
                            type = EtlObjectType.PlainDataCopy,
                            vis = true,
                            //Set up data copy object
                            settings = new EtlObjectSettings()
                            {
                                plainDataCopy = new EtlPlainDataCopy()
                                {
                                    autoLink = true,
                                    clearConsumer = true,
                                    //Provider
                                    provider = new DtProvider()
                                    {
                                        obDesc = FindObjectById(mb, "DATA_INDICATORS")
                                    },
                                    //Consumer
                                    consumer = new DtConsumer()
                                    {
                                        obDesc = FindObjectById(mb, "BACKUP_DATA")
                                    }
                                }
                            }
                        }
                    }
                }
            },
            metaGet = new EtlMdPattern() 
            {
                objects = ListOperation.Get
            }
        },
        tEtl = moniker
    };
    //Add object to ETL task
    var result = somClient.SetEtl(tSet);
    return result;
}