GetRoutineBase.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;

using MySql.Data.MySqlClient;

namespace RoutineAnalyzer
{
    abstract class GetRoutineBase : RoutineBase
    {
        public GetRoutineBase(string sql)
            : base(sql)
        {
            SetupExtendedArguments();
        }

        DataTable ExecuteTestCall()
        {
            using (MySqlConnection connection = ParseHelper.CreateDbConnection())
            {
                connection.Open();
                using (MySqlCommand command = connection.CreateCommand())
                {
                    //call the SPROC
                    command.CommandType = System.Data.CommandType.StoredProcedure;
                    command.CommandText = _name;
                    MySqlParameter param = new MySqlParameter();
                    //we use the first parameter because it reflects the ID used to call the SPROC
                    param.ParameterName = _params[0].Name;
                    param.Value = 1;
                    command.Parameters.Add(param);
                    //return the reader as a table
                    using (MySqlDataReader reader = command.ExecuteReader())
                    {
                        DataTable table = new DataTable();
                        table.Load(reader);
                        return table;
                    }
                }
            }
        }

        void SetupExtendedArguments()
        {
            DataTable table = ExecuteTestCall();
            for (int i = 0; i < table.Columns.Count; ++i)
            {
                DataColumn col = table.Columns[i];
                string standInDeclaration = "out " + col.ColumnName + " INTEGER";
                RoutineParamBase param = CreateRoutineParam(standInDeclaration, i + 1);
                _params.Add(param);
            }
        }
    }
}