1. 程式人生 > >linq資料入庫

linq資料入庫

2.2風險資料入庫

                //風險資料入庫

                T_DATA_RISK RiskData = new T_DATA_RISK();//定義風險資料表

                foreach

 (var item in data2)

                {

                    RiskData.STATIONCODE = item.STATIONCODE;

                    RiskData.MONIDATE = item.MONIDATE;

                    RiskData.RATE_PM25 = item.PM25_R;

                    RiskData.RATE_NO2 = item.NO2_R;

                    RiskData.STYLE = style;

                    try

                    {

                        var riskdata = efAir.FindAll<T_DATA_RISK>(t => t.STATIONCODE == item.STATIONCODE && t.MONIDATE == item.MONIDATE &&t.STYLE==style);

                        if (riskdata.Count() > 0)

                        {

                            efAir.Update<T_DATA_RISK>(RiskData);

                        }

                        else

                        {

                            efAir.Insert<T_DATA_RISK>(RiskData);

                        }

 

                    }

                    catch (Exception)

                    {

                        throw;

                    }

                }

2.3疾病資料入庫

                //疾病資料入庫

                T_DATA_DISEASE DiseaseData = new T_DATA_DISEASE();//定義疾病資料表

                foreach (var item in data2)

                {

                    DiseaseData.STATIONCODE = item.STATIONCODE;

                    DiseaseData.MONIDATE = item.MONIDATE;

                    DiseaseData.RATE = Convert.ToDecimal(item.Rate);

                    DiseaseData.STYLE = style;

                    try

                    {

                        var riskdata = efAir.FindAll<T_DATA_DISEASE>(t => t.STATIONCODE == item.STATIONCODE && t.MONIDATE == item.MONIDATE && t.STYLE == style);

                        if (riskdata.Count() > 0)

                        {

                            efAir.Update<T_DATA_DISEASE>(DiseaseData);

                        }

                        else

                        {

                            efAir.Insert<T_DATA_DISEASE>(DiseaseData);

                        }

 

                    }

                    catch (Exception)

                    {

                        throw;

                    }

                }