using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.SqlTypes;
using Microsoft.SqlServer.Server;

namespace MyCompany.DBA.Maintenance.Index
{
    public partial class StoredProcedures
    {
        [Microsoft.SqlServer.Server.SqlProcedure]
        public static void RunProcess()
        {
            try
            {
                GetData();

                //TO DO: loop through results and execute additional tasks.
            }
            catch (System.Exception e)
            {
                SqlContext.Pipe.Send("An error occured: " + e.Message);
                throw new System.ApplicationException(e.Message);
            }
        }

        [Microsoft.SqlServer.Server.SqlProcedure]
        public static void GetData()
        {
            System.Text.StringBuilder sql = new System.Text.StringBuilder();

            try
            {
                sql.AppendLine("SELECT * FROM some long join");

                using (SqlConnection conn = new SqlConnection("Context connection=true"))
                {
                    using (SqlCommand command = new SqlCommand(sql.ToString(), conn))
                    {
                        conn.Open();
                        SqlContext.Pipe.ExecuteAndSend(command);
                        conn.Close();
                    }
                }
            }
            catch (System.Exception e)
            {
                SqlContext.Pipe.Send("An error occured: " + e.Message);
                throw new System.ApplicationException(e.Message);
            }
        }
    };
}