最近需求要将数据保存到.csv文件(逗号分隔值 )中然后上传到ftp服务器上,供系统调用。CSV数据格式并没有非常统一的标准 但是为了避免出错 我们在开发的时候统一格式是这样的
"name","pwd","date"
"张三","123","2015-09-30"
接下来代码处理中默认格式都是这样的 其实就是纯文本的形式
为什么要用csv文件
这就涉及到数据互通的问题,有些程序支持的表格数据另一些程序并不见得支持,而csv格式的却被大多数的应用程序支持,所以在交换保存数据的时候是个不错的选择。
而在项目开发中 有需要做的处理也不是很简单的
比如有csv文件的读取 数据的转换(如转成datatable),csv文件的重命名 ,csv文件的写入,文件上传到ftp服务器上等等
这里将开发的方法进行了简单的整理,以备不时之需,时间仓促,有不足之处大家多多指点。
注意的点
①文件处理完的时候一定记得关闭释放数据流 否则文件会被占用
②csv并没有严格的标准,多人开发的时候必须规定好格式,统一开发
一、将CSV文件的数据读取到DataTable中
首先,我们为了方便管理,在web网站中常常需要读取csv文件中的数据并且显示在网站上方便查询。所以比较方便的办法是见csv文件中的数据转换成datatable形式,代码如下。
////// 将CSV文件的数据读取到DataTable中 /// /// CSV文件路径 ///返回读取了CSV数据的DataTable public static DataTable OpenCSV(string filePath) { DataTable dt = new DataTable(); FileStream fs = new FileStream(filePath, System.IO.FileMode.Open, System.IO.FileAccess.Read); StreamReader sr = new StreamReader(fs, Encoding.UTF8); //StreamReader sr = new StreamReader(fs, encoding); //string fileContent = sr.ReadToEnd(); //记录每次读取的一行记录 string strLine = ""; //记录每行记录中的各字段内容 string[] aryLine = null; string[] tableHead = null; //标示列数 int columnCount = 0; //标示是否是读取的第一行 bool IsFirst = true; //逐行读取CSV中的数据 while ((strLine = sr.ReadLine()) != null) { if (IsFirst == true) { tableHead = strLine.Split(','); IsFirst = false; columnCount = tableHead.Length; //创建列 for (int i = 0; i 0) { dt.DefaultView.Sort = tableHead[2] + " " + "DESC"; } sr.Close(); fs.Close(); return dt; }
二、将DataTable中数据写入到CSV文件中
当然我们一个文件中的数据迁移到另一个文件中或者 直接从数据库中查询的数据 插入到csv文件中 ,有一种方法是通过datatable的形式中转,所以 需要把datatable 转成 csv 代码如下:
////// 将DataTable中数据写入到CSV文件中 /// /// 提供保存数据的DataTable /// CSV的文件路径 public static bool SaveCSV(DataTable dt, string fullPath) { try { FileInfo fi = new FileInfo(fullPath); if (!fi.Directory.Exists) { fi.Directory.Create(); } FileStream fs = new FileStream(fullPath, System.IO.FileMode.Create, System.IO.FileAccess.Write); //StreamWriter sw = new StreamWriter(fs, System.Text.Encoding.Default); StreamWriter sw = new StreamWriter(fs, System.Text.Encoding.UTF8); string data = ""; //写出列名称 for (int i = 0; i catch { return false; } }
三、修改文件名称
修改文件名称 我们需要保存历史数据 或者实时的知道那个文件被修改 可以通过改变文件的名称 如加上当天的日期等等 方便管理
////// 修改文件名称 /// /// 旧的路径 完整的物理路径 /// 新的路径 ///public static bool ChangeFileName(string OldPath, string NewPath) { bool re = false; //OldPath = HttpContext.Current.Server.MapPath(OldPath);虚拟的 //NewPath = HttpContext.Current.Server.MapPath(NewPath); try { if (File.Exists(OldPath)) { File.Move(OldPath, NewPath); re = true; } } catch { re = false; } return re; }
四、scv文件的数据写入
直接在网页表单提交数据保存在csv文件中 直接写入文件
////// 写入文件 /// /// /// ///public static bool SaveCSV(string fullPath,string Data) { bool re = true; try { FileStream FileStream = new FileStream(fullPath, FileMode.Append); StreamWriter sw = new StreamWriter(FileStream, System.Text.Encoding.UTF8); sw.WriteLine(Data); //清空缓冲区 sw.Flush(); //关闭流 sw.Close(); FileStream.Close(); } catch { re = false; } return re; }
C#如何读取csv格式文件
一、CSV文件规则
1 开头是不留空,以行为单位。
2 可含或不含列名,含列名则居文件第一行。
3 一行数据不跨行,无空行。
4 以半角逗号(即,)作分隔符,列为空也要表达其存在。
5 列内容如存在半角逗号(即,)则用半角引号(即',')将该字段值包含起来。
6 列内容如存在半角引号(即")则应替换成半角双引号("")转义,并用半角引号(即"")将该字段值包含起来。
7 文件读写时引号,逗号操作规则互逆。
8 内码格式不限,可为 ASCII、Unicode 或者其他。
9 不支持特殊字符
二、C#读取csv文件的方法
//读CSV文件类,读取指定的CSV文件,可以导出DataTable
public class CsvStreamReader
{
private ArrayList rowAL; //行链表,CSV文件的每一行就是一个链
private string fileName; //文件名
private Encoding encoding; //编码
public CsvStreamReader()
{
this.rowAL = new ArrayList();
this.fileName = "";
this.encoding = Encoding.Default;
}
///
///
///
/// 文件名,包括文件路径
public CsvStreamReader(string fileName)
{
this.rowAL = new ArrayList();
this.fileName = fileName;
this.encoding = Encoding.Default;
LoadCsvFile();
}
///
///
///
/// 文件名,包括文件路径
/// 文件编码
public CsvStreamReader(string fileName, Encoding encoding)
{
this.rowAL = new ArrayList();
this.fileName = fileName;
this.encoding = encoding;
LoadCsvFile();
}
///
/// 文件名,包括文件路径
///
public string FileName
{
set
{
this.fileName = value;
LoadCsvFile();
}
}
///
/// 文件编码
///
public Encoding FileEncoding
{
set
{
this.encoding = value;
}
}
///
/// 获取行数
///
public int RowCount
{
get
{
return this.rowAL.Count;
}
}
///
/// 获取列数
///
public int ColCount
{
get
{
int maxCol;
maxCol = 0;
for (int i = 0; i colAL.Count) ? maxCol : colAL.Count;
}
return maxCol;
}
}
///
/// 获取某行某列的数据
/// row:行,row = 1代表第一行
/// col:列,col = 1代表第一列
///
public string this[int row, int col]
{
get
{
//数据有效性验证
CheckRowValid(row);
CheckColValid(col);
ArrayList colAL = (ArrayList)this.rowAL[row - 1];
//如果请求列数据大于当前行的列时,返回空值
if (colAL.Count
/// 根据最小行,最大行,最小列,最大列,来生成一个DataTable类型的数据
/// 行等于1代表第一行
/// 列等于1代表第一列
/// maxrow: -1代表最大行
/// maxcol: -1代表最大列
///
public DataTable this[int minRow, int maxRow, int minCol, int maxCol]
{
get
{
//数据有效性验证
CheckRowValid(minRow);
CheckMaxRowValid(maxRow);
CheckColValid(minCol);
CheckMaxColValid(maxCol);
if (maxRow == -1)
{
maxRow = RowCount;
}
if (maxCol == -1)
{
maxCol = ColCount;
}
if (maxRow
/// 检查行数是否是有效的
///
///
private void CheckRowValid(int row)
{
if (row RowCount)
{
throw new Exception("没有当前行的数据");
}
}
///
/// 检查最大行数是否是有效的
///
///
private void CheckMaxRowValid(int maxRow)
{
if (maxRow RowCount)
{
throw new Exception("没有当前行的数据");
}
}
///
/// 检查列数是否是有效的
///
///
private void CheckColValid(int col)
{
if (col ColCount)
{
throw new Exception("没有当前列的数据");
}
}
///
/// 检查检查最大列数是否是有效的
///
///
private void CheckMaxColValid(int maxCol)
{
if (maxCol ColCount)
{
throw new Exception("没有当前列的数据");
}
}
///
/// 载入CSV文件
///
private void LoadCsvFile()
{
//对数据的有效性进行验证
if (this.fileName == null)
{
throw new Exception("请指定要载入的CSV文件名");
}
else if (!File.Exists(this.fileName))
{
throw new Exception("指定的CSV文件不存在");
}
else
{
}
if (this.encoding == null)
{
this.encoding = Encoding.Default;
}
StreamReader sr = new StreamReader(this.fileName, this.encoding);
string csvDataLine;
csvDataLine = "";
while (true)
{
string fileDataLine;
fileDataLine = sr.ReadLine();
if (fileDataLine == null)
{
break;
}
if (csvDataLine == "")
{
csvDataLine = fileDataLine;//GetDeleteQuotaDataLine(fileDataLine);
}
else
{
csvDataLine += "\r\n" + fileDataLine;//GetDeleteQuotaDataLine(fileDataLine);
}
//如果包含偶数个引号,说明该行数据中出现回车符或包含逗号
if (!IfOddQuota(csvDataLine))
{
AddNewDataLine(csvDataLine);
csvDataLine = "";
}
}
sr.Close();
//数据行出现奇数个引号
if (csvDataLine.Length > 0)
{
throw new Exception("CSV文件的格式有错误");
}
}
///
/// 获取两个连续引号变成单个引号的数据行
///
/// 文件数据行
///
private string GetDeleteQuotaDataLine(string fileDataLine)
{
return fileDataLine.Replace("\"\"", "\"");
}
///
/// 判断字符串是否包含奇数个引号
///
/// 数据行
/// 为奇数时,返回为真;否则返回为假
private bool IfOddQuota(string dataLine)
{
int quotaCount;
bool oddQuota;
quotaCount = 0;
for (int i = 0; i
/// 判断是否以奇数个引号开始
///
///
///
private bool IfOddStartQuota(string dataCell)
{
int quotaCount;
bool oddQuota;
quotaCount = 0;
for (int i = 0; i
/// 判断是否以奇数个引号结尾
///
///
///
private bool IfOddEndQuota(string dataCell)
{
int quotaCount;
bool oddQuota;
quotaCount = 0;
for (int i = dataCell.Length - 1; i >= 0; i--)
{
if (dataCell[i] == '\"')
{
quotaCount++;
}
else
{
break;
}
}
oddQuota = false;
if (quotaCount % 2 == 1)
{
oddQuota = true;
}
return oddQuota;
}
///
/// 加入新的数据行
///
/// 新的数据行
private void AddNewDataLine(string newDataLine)
{
//System.Diagnostics.Debug.WriteLine("NewLine:" + newDataLine);
////return;
ArrayList colAL = new ArrayList();
string[] dataArray = newDataLine.Split(',');
bool oddStartQuota; //是否以奇数个引号开始
string cellData;
oddStartQuota = false;
cellData = "";
for (int i = 0; i 2 && !IfOddQuota(dataArray[i]))
{
colAL.Add(GetHandleData(dataArray[i]));
oddStartQuota = false;
continue;
}
else
{
oddStartQuota = true;
cellData = dataArray[i];
continue;
}
}
else
{
colAL.Add(GetHandleData(dataArray[i]));
}
}
}
if (oddStartQuota)
{
throw new Exception("数据格式有问题");
}
this.rowAL.Add(colAL);
}
///
/// 去掉格子的首尾引号,把双引号变成单引号
///
///
///
private string GetHandleData(string fileCellData)
{
if (fileCellData == "")
{
return "";
}
if (IfOddStartQuota(fileCellData))
{
if (IfOddEndQuota(fileCellData))
{
return fileCellData.Substring(1, fileCellData.Length - 2).Replace("\"\"", "\""); //去掉首尾引号,然后把双引号变成单引号
}
else
{
throw new Exception("数据引号无法匹配" + fileCellData);
}
}
else
{
//考虑形如"" """" """"""
if (fileCellData.Length > 2 && fileCellData[0] == '\"')
{
fileCellData = fileCellData.Substring(1, fileCellData.Length - 2).Replace("\"\"", "\""); //去掉首尾引号,然后把双引号变成单引号
}
}
return fileCellData;
}
}
C#:将DataTable内容写入到CSV文件 与 将CSV文件内容读取到DataTab
一、将DataTable内容写入到CSV文件
///
/// 将DataTable中的数据保存成CSV文件
///
private void btnSaveCSV_Click(object sender, EventArgs e)
{
saveFileDialog1.Filter = "CSV文件|*.CSV";
saveFileDialog1.InitialDirectory = "C:\";
if (saveFileDialog1.ShowDialog() == DialogResult.Cancel)
{
return;
}
else
{
string fileName = saveFileDialog1.FileName;
SaveCSV(ds.Tables[0], fileName);
}
}
///
/// 将DataTable中数据写入到CSV文件中
///
/// 提供保存数据的DataTable
/// CSV的文件路径
public void SaveCSV(DataTable dt, string fileName)
{
FileStream fs = new FileStream(fileName, System.IO.FileMode.Create, System.IO.FileAccess.Write);
StreamWriter sw = new StreamWriter(fs, System.Text.Encoding.Default);
string data = "";
//写出列名称
for (int i = 0; i