Создайте динамическую функцию создания и вставки таблицы sqlite

Question

У меня есть около 8-9 функций для заполнения таблиц из SQL в Sqlite, и я пытаюсь создать динамическую функцию, для которой я просто передам некоторые параметры, и она создаст таблицу sqlite (если она не существует),создайте несколько экземпляров в цикле типа, который я хочу вставить в конкретную таблицу, задайте для него свойства и затем вставьте его.Вот примеры функций:

private bool ReloadItemsFromServer()
    {
        try
        {
            using (GS.cnn)
            {
                SqlCommand command = new SqlCommand("rsp_FillItem_MobileDevice;", GS.cnn);
                command.CommandType = System.Data.CommandType.StoredProcedure;
                GS.cnn.Open();
                SqlDataReader reader = command.ExecuteReader();

                if (reader.HasRows)
                {
                    string dbPath = Path.Combine(System.Environment.GetFolderPath(System.Environment.SpecialFolder.Personal), "DataBase.PremierAndroid");
                    using (var sqliteConn = new SQLiteConnection(dbPath))
                    {
                        sqliteConn.CreateTable<Item>();

                        while (reader.Read())
                        {
                            {
                                var newItem = new Item();
                                newItem.ItemID = reader.GetInt32(0);
                                newItem.ItemBaseID = reader.GetInt32(1);
                                newItem.BrandID = reader.GetInt32(2);
                                newItem.Issue = reader.GetInt32(3);

                                sqliteConn.Insert(newItem);
                            }
                        }
                    }
                }
                else
                {
                    _dlgAlert = new AlertDialog.Builder(this).Create();
                    _dlgAlert.SetMessage(Resources.GetString(Resource.String.NoRowsForItemFound));
                    _dlgAlert.SetTitle(Resources.GetString(Resource.String.Error));
                    _dlgAlert.SetButton("OK", delegate { });
                    _dlgAlert.Show();
                    return false;
                }
                reader.Close();
            }
            return true;
        }
        catch (Exception ex)
        {
            _dlgAlert = new AlertDialog.Builder(this).Create();
            _dlgAlert.SetMessage(ex.Message);
            _dlgAlert.SetTitle(Resources.GetString(Resource.String.Error));
            _dlgAlert.SetButton("OK", delegate { });
            _dlgAlert.Show();
            return false;
        }
        finally
        {
            if (GS.cnn.State != ConnectionState.Closed)
            {
                GS.cnn.Close();
            }
        }
    }

, а вот еще одна:

private bool ReloadContragentsFromServer()
    {
        try
        {
            using (GS.cnn)
            {
                SqlCommand command = new SqlCommand("rsp_FillContragent_MobileDevice;", GS.cnn);
                command.CommandType = System.Data.CommandType.StoredProcedure;
                GS.cnn.Open();
                SqlDataReader reader = command.ExecuteReader();

                if (reader.HasRows)
                {
                    string dbPath = Path.Combine(System.Environment.GetFolderPath(System.Environment.SpecialFolder.Personal), "DataBase.PremierAndroid");
                    using (var sqliteConn = new SQLiteConnection(dbPath))
                    {
                        sqliteConn.CreateTable<Contragent>();

                        while (reader.Read())
                        {
                            {
                                var newContragent = new Contragent();
                                newContragent.ContragentID = reader.GetInt32(0);
                                newContragent.ContragentTypeID = reader.GetInt32(1);
                                newContragent.ContragentGroupID = reader.GetInt32(2);
                                newContragent.FullName = reader.GetString(3);
                                newContragent.BULSTAT = reader.GetString(4);
                                newContragent.ItemPriceGroupID = reader.GetInt32(5);
                                newContragent.ItemDiscountGroupID = reader.GetInt32(6);

                                sqliteConn.Insert(newContragent);
                            }
                        }
                    }
                }
                else
                {
                    _dlgAlert = new AlertDialog.Builder(this).Create();
                    _dlgAlert.SetMessage(Resources.GetString(Resource.String.NoRowsForContragentFound));
                    _dlgAlert.SetTitle(Resources.GetString(Resource.String.Error));
                    _dlgAlert.SetButton("OK", delegate { });
                    _dlgAlert.Show();
                    return false;
                }
                reader.Close();
            }
            return true;
        }
        catch (Exception ex)
        {
            _dlgAlert = new AlertDialog.Builder(this).Create();
            _dlgAlert.SetMessage(ex.Message);
            _dlgAlert.SetTitle(Resources.GetString(Resource.String.Error));
            _dlgAlert.SetButton("OK", delegate { });
            _dlgAlert.Show();
            return false;
        }
        finally
        {
            if (GS.cnn.State != ConnectionState.Closed)
            {
                GS.cnn.Close();
            }
        }
    }

Вы можете увидеть, что отличается.Как я могу сделать так, чтобы я просто вызвал один метод и дал ему несколько параметров, чтобы у меня не было 8-9 блоков кода, которые несколько повторяются?

В настоящее время это динамическая функция (незавершенная):

private bool LoadDataFromServer(string procedure, Type passedType)
    {
        try
        {
            using (GS.cnn)
            {
                SqlCommand command = new SqlCommand(procedure, GS.cnn);
                command.CommandType = System.Data.CommandType.StoredProcedure;
                GS.cnn.Open();
                SqlDataReader reader = command.ExecuteReader();

                if (reader.HasRows)
                {
                    string dbPath = Path.Combine(System.Environment.GetFolderPath(System.Environment.SpecialFolder.Personal), "DataBase.PremierAndroid");
                    using (var sqliteConn = new SQLiteConnection(dbPath))
                    {
                        sqliteConn.CreateTable(passedType);

                        while (reader.Read()) //to do > i++ bla bla
                        {
                            {
                                var newItem = Activator.CreateInstance(passedType);

                                //newItem - loop through properties and set = reader.get(int/string)(i)

                                sqliteConn.Insert(newItem);
                            }
                        }
                    }
                }
                else
                {
                    _dlgAlert = new AlertDialog.Builder(this).Create();
                    _dlgAlert.SetMessage(Resources.GetString(Resource.String.NoRowsForItemFound));
                    _dlgAlert.SetTitle(Resources.GetString(Resource.String.Error));
                    _dlgAlert.SetButton("OK", delegate { });
                    _dlgAlert.Show();
                    return false;
                }
                reader.Close();
            }
            return true;
        }
        catch (Exception ex)
        {
            _dlgAlert = new AlertDialog.Builder(this).Create();
            _dlgAlert.SetMessage(ex.Message);
            _dlgAlert.SetTitle(Resources.GetString(Resource.String.Error));
            _dlgAlert.SetButton("OK", delegate { });
            _dlgAlert.Show();
            return false;
        }
        finally
        {
            if (GS.cnn.State != ConnectionState.Closed)
            {
                GS.cnn.Close();
            }
        }
    }

Спасибо

Answer 1

пусть рефлексия и наследование помогают так:

class Caller{

    // see how it sends objects to method 'processAllClasses' with different classes
    void main(){    
        ItemClass1 i1 = new ItemClass1();
        i1.setItemsB(1,2);
        processAllClasses(i1);

        ItemClass2 i2 = new ItemClass2();
        i2.setItemsB(10, 20);
        processAllClasses(i2);
    }

    //using reflection and inherit to process different classes, obj is what need to be processed on.
    //alternative way:
    //get members from the type, then assign values to them one by one
    void processAllClasses(ParentClass myobjvalue)
    { 
        Type realtype = myobjvalue.GetType();
        ParentClass myobj = new ParentClass(); 
        MethodInfo mi = realtype.GetMethod("setItemsA");
        object obj = Activator.CreateInstance(realtype);
        Object[] parameter = new Object[] { myobjvalue };
        mi.Invoke(obj, parameter); 
    }
}



class ParentClass {

}


class ItemClass1: ParentClass
{
    int ItemID;
    int ItemBaseID;
    public void setItemsA(ItemClass1 itemclass1)
    {
        this.ItemID = itemclass1.ItemID;
        this.ItemBaseID = itemclass1.ItemBaseID;
    }
    public void setItemsB(int ItemID, int ItemBaseID)
    {
        this.ItemID = ItemID;
        this.ItemBaseID = ItemBaseID;
    }

}

class ItemClass2 : ParentClass
{
    int ContragentID;
    int ContragentTypeID;
    public void setItemsA(ItemClass2 itemclass2)
    {
        this.ContragentID = itemclass2.ContragentID;
        this.ContragentTypeID = itemclass2.ContragentTypeID;
    }
    public void setItemsB(int ContragentID, int ContragentTypeID)
    {
        this.ContragentID = ContragentID;
        this.ContragentTypeID = ContragentTypeID;
    }

}