1. 程式人生 > 其它 >c# DBHelper物件匯出sql語句

c# DBHelper物件匯出sql語句

/// <summary>
/// 由資料集DataSet自動生成Insert的SQL語句集合
/// </summary>
/// <param name="ds">資料集</param>
/// <param name="TableName">表名</param>
/// <returns></returns>
public static ArrayList DataSetToArrayList(DataSet ds, String TableName)
{
ArrayList allSql = new ArrayList();
//
string FieldAll = "";
//獲取列名集合
for (int i = 0; i < ds.Tables[0].Columns.Count; i++)
{
FieldAll = FieldAll + ds.Tables[0].Columns[i].ColumnName.ToString() + ",";
}
FieldAll = FieldAll.Substring(0, FieldAll.Length - 1);//去掉最後一個“,”

DataView dv = ds.Tables[0].DefaultView;
string ValueAll = "";
//判斷欄位型別,其實也可以全部用單引號引起來,只是資料庫處理時,內部需要轉化型別
for (int n = 0; n < dv.Count; n++)// 用於迴圈寫insert
{
for (int m = 0; m < ds.Tables[0].Columns.Count; m++)//
{
switch (dv[n][m].GetType().ToString())
{
case "System.DateTime":
ValueAll += "'" + (Convert.ToDateTime(dv[n][m])).ToString("yyyy-MM-dd") + "'";
ValueAll += ",";
break;
case "System.String":
ValueAll += "'" + dv[n][m].ToString() + "'";
ValueAll += ",";
break;
case "System.Int32":
ValueAll += Convert.ToInt32(dv[n][m]);
ValueAll += ",";
break;
case "System.Single":
ValueAll += Convert.ToSingle(dv[n][m]);
ValueAll += ",";
break;
case "System.Double":
ValueAll += Convert.ToDouble(dv[n][m]);
ValueAll += ",";
break;
case "System.Decimal":
ValueAll += Convert.ToDecimal(dv[n][m]);
ValueAll += ",";
break;
default:
ValueAll += "'" + dv[n][m].ToString() + "'";
ValueAll += ",";
break;
}
}
ValueAll = ValueAll.Substring(0, ValueAll.Length - 1); //去掉最後一個“,”
allSql.Add("insert into " + TableName + " (" + FieldAll + ") values(" + ValueAll + ");");//insert
ValueAll = "";//清空 繼續迴圈
}
return allSql; //返回語句
}
private void Export_mm3s()
{
MessageBox.Show("正在匯出mm3s資料!");
ArrayList list = new ArrayList();
string sql = "select * from agencytable";
DataSet dt = DBHelper.GetInstance().ExecuteQuery(DBHelper.connectionString, CommandType.Text, sql, null);
list = DataSetToArrayList(dt, "agencytable");
// 建立檔案。如果檔案存在則覆蓋
FileStream fs = File.Open(@"d:\內容.sql", FileMode.Create);
// 建立寫入流
StreamWriter wr = new StreamWriter(fs,System.Text.Encoding.UTF8);
// 將ArrayList中的每個項逐一寫入檔案
for (int i = 0; i < list.Count; i++)
{
wr.WriteLine(list[i]);
}
// 關閉寫入流
wr.Flush();
wr.Close();

// 關閉檔案
fs.Close();

}