先給大家解釋解釋發表這篇博文的主要思想是:
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] + "此表已更新完畢!!!");
到此,這篇博客算是寫完了,我不知道正在閱讀的您會不會看的不太明白,我也不知道自己表述的如何,只知道自己能理解,呵呵。。。。
反正這也是資源共享,給需要的您提供一點思路即可。
一家之言,僅供參考!!!