SSIS动态删除分区

//如果分区存在将返回false,不在生成分区，如果是3月1号执行的动态生成分区SSIS包，那么以后的3月数据都将加载不进来

 if (aMeasureGroup.Partitions.Contains(sPartition))
    {

                Dts.Variables["User::IsNotePresent"].Value = false;
                Dts.Variables["User::Xmla_script"].Value = "";
                Dts.TaskResult = (int)ScriptResults.Success;
                
    }

SELECT ‘Drug DW‘                                                        AS DataSoureID,--数据源

       ‘Drug_SSAS‘                                                       AS DatabaseID,--分区来自哪一个cube
       ‘Drug DW‘                                                       AS CubeName,--分区来自哪一个cube

       ‘Drug DW‘                                                       AS CubeID,

       ‘Fact OP Fee Detail‘                                            AS MeasureGroup,--指定是一个度量值组

       ‘Fact OP Fee Detail‘                                            AS MeasureGroupID,

       ‘Fact OP Fee Detail ‘ +left(convert(varchar(10),getdate(),112),6) AS Partition--分区名称=度量值组名称+年月

/*
   Microsoft SQL Server Integration Services Script Task
   Write scripts using Microsoft Visual C# 2008.
   The ScriptMain is the entry point class of the script.
*/

using System;
using System.Data;
using Microsoft.SqlServer.Dts.Runtime;
using System.Windows.Forms;
using Microsoft.AnalysisServices;
namespace ST_c86e3263ba3a4082bcf1335a1946efbb.csproj
{
    [System.AddIn.AddIn("ScriptMain", Version = "1.0", Publisher = "", Description = "")]
    public partial class ScriptMain : Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
    {
        

        #region VSTA generated code
        enum ScriptResults
        {
            Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success,
            Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
        };
        #endregion

   

        public void Main()
        {
            // TODO: Add your code here
         
            String sPartition =(String) Dts.Variables["Partition"].Value;
         
            String sCubeName = (String) Dts.Variables["CubeName"].Value;           
            String sMeasureGroup = (String) Dts.Variables["MeasureGroup"].Value;
          
            String sServer = (String)Dts.Variables["IPserver"].Value;
           
            String sDataBaseID = (String) Dts.Variables["DatabaseID"].Value;
          
            String sCubeID = (String) Dts.Variables["CubeID"].Value;
        
            String sMeasureGroupID = (String) Dts.Variables["MeasureGroupID"].Value;
           
            String sDataSoureID = (String)Dts.Variables["DataSourceID"].Value;
          
           
            ConnectionManager cm = Dts.Connections.Add("MSOLAP100");
            cm.ConnectionString = "Provider=MSOLAP.4;Data Source="+sServer+";IntegratedSecurity=SSPI;Initial Catalog=" + sDataBaseID;


            Microsoft.AnalysisServices.Server aServer = new Server();
            aServer.Connect(sServer);
            Microsoft.AnalysisServices.Database aDatabase = aServer.Databases.FindByName(sDataBaseID);

            CubeCollection cubeCollection = aDatabase.Cubes;
            foreach (Cube item in cubeCollection)
            {
                string name = item.Name;
            }

            Microsoft.AnalysisServices.Cube aCube = aDatabase.Cubes.FindByName(sCubeName);


            Microsoft.AnalysisServices.MeasureGroup aMeasureGroup;
            try
            {

                MeasureGroupCollection collection = aCube.MeasureGroups;

                aMeasureGroup = collection.FindByName(sMeasureGroup);
            }
            catch (Exception ex)
            {
                throw ex;
            }


            if (aMeasureGroup.Partitions.Contains(sPartition))
            {
               
                Dts.Variables["XmlStr"].Value = "<Delete xmlns=\"http://schemas.microsoft.com/analysisservices/2003/engine\">"
                + " <Object>"
              + "<DatabaseID>" + sDataBaseID + "</DatabaseID>"
             + "<CubeID>" + sCubeID + "</CubeID>"
            + "<MeasureGroupID>" + sMeasureGroupID + "</MeasureGroupID>"
            + "<PartitionID>" + sPartition + "</PartitionID>"
           + "</Object>"
           + "</Delete> ";
                Dts.TaskResult = (int)ScriptResults.Success;


            }
          
            
        }
    }
}