今天在别人的系统上做一个扩展小东东，其中有很多地方将DataSet中的数据导成csv文件，同时要求也能从csv文件直接导入数据，在网上查阅了一些相关资料总算搞定了，现简单写下来以备后用同时也希望能给有相同需求的朋友一定的帮助：
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.Common;
using System.Data.OleDb;
using System.Windows.Forms;
using System.IO;
namespace XRSoft.Client.Common
{
/// <summary>
/// 将DataSet写成CSV文件
/// </summary>
public class DataSet2CSV
{
#region 001----将DataSet转换成CSV文件
public static void Export2CSV(DataSet ds, string tableName, bool containColumName, string fileName)
{
string csvStr = ConverDataSet2CSV(ds,tableName,containColumName);
if(csvStr=="") return;
FileStream fs = new FileStream(fileName, FileMode.Create, FileAccess.ReadWrite);
//将string转换成byte[]
byte[] csvArray = System.Text.Encoding.ASCII.GetBytes(csvStr.ToCharArray(), 0, csvStr.Length - 1);
fs.Write(csvArray,0,csvStr.Length - 1);
fs.Close();
fs = null;
}
/// <summary>
/// 将指定的数据集中指定的表转换成CSV字符串
/// </summary>
/// <param name="ds"></param>
/// <param name="tableName"></param>
/// <returns></returns>
private static string ConverDataSet2CSV(DataSet ds, string tableName,bool containColumName)
{
//首先判断数据集中是否包含指定的表
if (ds == null || !ds.Tables.Contains(tableName))
{
MessageBox.Show("指定的数据集为空或不包含要写出的数据表！", "系统提示：", MessageBoxButtons.OK, MessageBoxIcon.Stop);
return "";
}
string csvStr = "";
//下面写出数据
DataTable tb = ds.Tables[tableName];
//写表名
//csvStr += tb.TableName + "\n";
//第一步：写出列名
if (containColumName)
{
foreach (DataColumn column in tb.Columns)
{
csvStr += "\""+column.ColumnName +"\"" +",";
}
//去掉最后一个","
csvStr = csvStr.Remove(csvStr.LastIndexOf(","), 1);
csvStr += "\n";
}
//第二步：写出数据
foreach (DataRow row in tb.Rows)
{
foreach (DataColumn column in tb.Columns)
{
csvStr += "\"" + row[column].ToString() + "\"" + ",";
}
csvStr = csvStr.Remove(csvStr.LastIndexOf(","), 1);
csvStr += "\n";
}
return csvStr;
}
#endregion
#region 002----从CSV文件填充DataSet
public static DataSet ConverCSV2DataSet(string fileName, string tableName)
{
DataSet ds = new DataSet();
string _filePath, _fileName;
_filePath = fileName.Substring(0, fileName.LastIndexOf(@"\") + 1);
_fileName = fileName.Substring(fileName.LastIndexOf(@"\")+1);
string conStr = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source= " + _filePath + @"\" + ";Extended Properties=\"Text;HDR=Yes;FMT=Delimited\"";
OleDbConnection oleCon = new OleDbConnection(conStr);
OleDbDataAdapter da = new OleDbDataAdapter("Select * from " + _fileName,oleCon);
da.Fill(ds,tableName);
oleCon.Close();
return ds;
}
#endregion
}
}
下面是导出、和导入数据的调用方法：
//1、导出
private void button1_Click(object sender, EventArgs e)
{
if (this.dsMaster != null && dsMaster.Tables.Contains("CUSTOMER"))
{
this.saveFileDialog1.AddExtension = true;
this.saveFileDialog1.CreatePrompt = true;
this.saveFileDialog1.Filter = "CSV FILE(*.csv)|*.csv";
DialogResult result = this.saveFileDialog1.ShowDialog();
this.saveFileDialog1.RestoreDirectory = true;
if (result == DialogResult.OK)
{
DataSet2CSV.Export2CSV(this.dsMaster, "CUSTOMER", true, this.saveFileDialog1.FileName);
}
}
}
//2、导入
private void button2_Click(object sender, EventArgs e)
{
//导入数据
DataSet ds ;
this.openFileDialog1.Filter = @"CSV FILES(*.csv)|*.csv";
DialogResult result = this.openFileDialog1.ShowDialog();
if (result == DialogResult.OK)
{
ds = DataSet2CSV.ConverCSV2DataSet(this.openFileDialog1.FileName, "CUSTOMER");
if (ds != null && ds.Tables.Contains("CUSTOMER"))
{
this.dataGridView1.DataSource = ds.Tables["CUSTOMER"].DefaultView;
}
}
}
以上是我刚刚随便测试写的代码，不妥之处敬请批评批正，谢谢!
本文转自94cool博客园博客，原文链接：http://www.cnblogs.com/94cool/archive/2011/12/31/2308174.html，如需转载请自行联系原作者
