程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> MySQL綜合教程 >> MySql多表循環遍歷更新

MySql多表循環遍歷更新

編輯:MySQL綜合教程

先給大家解釋解釋發表這篇博文的主要思想是:

    MySql數據庫中存在大量的表結構,而且這些表都存在一個共同點,就是表中都有相同字段,比如id,name,city,adress,lat,lng。表中字段id,name,city,adress不允許為空,所以表中這幾個字段的數據都是已經賦給實值的,而lat與lng(經緯度)是為空的。現在要寫一個程序,根據city,adress請求獲取數據,把循環每一表中根據city,adress請求獲取的數據更新到相應表,相應表中對應的那一行數據。這句話,可能你有點暈,說白了就是,先循環查詢遍歷表中city與adress的值,根據city,adress的值請求獲取數據,更新到相應行中,這個表循環更新完了就跳到下個表中再循環更新,以此類推,直到全部更新。。。

   這是我們做的一個程序,當時我還天真的以為手動輸入city和adress請求獲取更新,誰不曾料想數據庫表中的數據有好幾萬條,要是手動累死你吧,呵呵。。。所以這個程序思想也是從我們同事那獲取到的,很有用,我也是在不斷學習當中,發表出來供大家參考,資源共享才能更好的進步!!!

MySql數據庫的連接字符串是:

   string MySqlString = "Host=ip地址;Port=端口號;User id=用戶名;pwd=密碼;Database=數據庫名;Character Set=utf8"

第一步,

連接數據庫,寫個根據city,adress請求獲取數據的查詢方法,傳個參數(數據庫的表名),如Get_Data(string tablename)

   查詢語句:string MySqlSelect = "select id,city,address,lat,lng from " + tablename;然後調用ExecuteReader()方法將值傳出去,注意:表中這幾個字段應該先建立一個model類(這裡不細說,大家都懂,就是get{}set{}),方便傳值

              using (MySqlDataReader dataReader = Command.ExecuteReader())
                {
                    while (dataReader.Read())
                    {
                        DataModel dataModel = new DataModel();
                        dataModel.Id = dataReader["id"].ToString();
                        dataModel.City = (string)dataReader["city"];
                        dataModel.Address = (string)dataReader["address"];
                        if (dataReader["latitude"] != DBNull.Value)
                        {
                            dataModel.Latitude = (decimal)dataReader["latitude"];
                        }
                        else
                            dataModel.Latitude = 0.0M;
                        if (dataReader["longitude"] != DBNull.Value)
                        {
                            dataModel.Latitude = (decimal)dataReader["longitude"];
                        }
                        else
                            dataModel.Latitude = 0.0M;
                        dataSource.Add(dataModel);
                    }
                    dataReader.Close();
                    dataReader.Dispose();
                }

第二步,

那就是更新方法了,從查詢到的數據,循環遍歷表名更新。更新方法中有四個參數,根據city,adress查詢出來的id,數據庫的表名,以及要更新的字段lat,lng。如Update_Data(string id, string dataTable, decimal lat, decimal lng)

   更新語句:string MySqlUpdata = "update " + dataTable + " set latitude=" + lat + ",longitude=" + lng + " where id=" + id;然後執行ExecuteNonQuery()方法,返回受影響的行數。

第三步,

在Main()方法中調用,先將表名存在一個數組裡面,形如:

            string[] tableName = new string[10];
            tableName[0] = "A";
            tableName[1] = "B";
            tableName[2] = "C";
            tableName[3] = "D";
            tableName[4] = "E";
            tableName[5] = "F";
            tableName[6] = "G";
            tableName[7] = "H";
            tableName[8] = "I";
            tableName[9] = "J";
           

而後,把表名寫個for循環,實例化上面讓寫的那個Model類,調用第一步裡面的查詢方法,將取得的實體值存在List<Model>泛型集合當中。再foreach遍歷List<Model>泛型集合,取得變量參數的值(lat/lng),調用更新方法,循環更新,就行了。。。代碼示例如下:

           for (i = 0; i < tableName.Length; i++)
            {
                List<Model> DataSource = new List<Model>();
                int h = 0;
                DataSource = Get_Data(tableName[i]);

                foreach (DataModel dm in DataSource)
                {
                   
                    try
                    {
                            Update_Data(dm.Id, tableName[i], dm.Latitude, dm.Longitude);
                            Console.WriteLine("第" + h + "條記錄以更新");
                            h++;
                        
                    }
                    catch (Exception ex)
                    {
                        continue;
                    }
                }
                Console.WriteLine(tableName[i] + "此表已更新完畢!!!");

到此,這篇博客算是寫完了,我不知道正在閱讀的您會不會看的不太明白,我也不知道自己表述的如何,只知道自己能理解,呵呵。。。。

反正這也是資源共享,給需要的您提供一點思路即可。

一家之言,僅供參考!!!  

  

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved