用C#写的读写CSV文件

用C#写的读写CSV文件用C#写的读取CSV文件的源代码 CSV文件的格子中包含逗号，引号，换行等，都能轻松读取，而且可以把数据转化成DATATABLE格式 using System;using System.Text;using System.Collections;using System.IO;using System.Data;using System.Text.RegularExPRessions;using System.Diagnostics; namespace CsvLib{ #region 类说明信息 /// <summary> /// <DL> /// <DT><b>读CSV文件类,读取指定的CSV文件，可以导出DataTable</b></DT> /// <DD> /// <UL> /// </UL> /// </DD> /// </DL> /// <Author>yangzhihong</Author> /// <CreateDate>2006/01/16</CreateDate> /// <Company></Company> /// <Version>1.0</Version> /// </summary> #endregion 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; } /// <summary> /// /// </summary> /// <param name="fileName">文件名,包括文件路径</param> public CsvStreamReader(string fileName) { this.rowAL = new ArrayList(); this.fileName = fileName; this.encoding = Encoding.Default; LoadCsvFile(); } /// <summary> /// /// </summary> /// <param name="fileName">文件名,包括文件路径</param> /// <param name="encoding">文件编码</param> public CsvStreamReader(string fileName,Encoding encoding) { this.rowAL = new ArrayList(); this.fileName = fileName; this.encoding = encoding; LoadCsvFile(); } /// <summary> /// 文件名,包括文件路径 /// </summary> public string FileName { set { this.fileName = value; LoadCsvFile(); } } /// <summary> /// 文件编码 /// </summary> public Encoding FileEncoding { set { this.encoding = value; } } /// <summary> /// 获取行数 /// </summary> public int RowCount { get { return this.rowAL.Count; } } /// <summary> /// 获取列数 /// </summary> public int ColCount { get { int maxCol; maxCol = 0; for (int i = 0;i<this.rowAL.Count;i++) { ArrayList colAL = (ArrayList) this.rowAL[i]; maxCol = (maxCol > colAL.Count)?maxCol:colAL.Count; } return maxCol; } } /// <summary> /// 获取某行某列的数据 /// row:行,row = 1代表第一行 /// col:列,col = 1代表第一列 /// </summary> public string this[int row,int col] { get { //数据有效性验证 CheckRowValid(row); CheckColValid(col); ArrayList colAL = (ArrayList) this.rowAL[row-1]; //如果请求列数据大于当前行的列时,返回空值 if (colAL.Count < col) { return ""; } return colAL[col-1].ToString(); } } /// <summary> /// 根据最小行，最大行，最小列，最大列，来生成一个DataTable类型的数据 /// 行等于1代表第一行 /// 列等于1代表第一列 /// maxrow: -1代表最大行 /// maxcol: -1代表最大列 /// </summary> 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 < minRow) { throw new Exception("最大行数不能小于最小行数"); } if (maxCol < minCol) { throw new Exception("最大列数不能小于最小列数"); } DataTable csvDT = new DataTable(); int i; int col; int row; //增加列 for (i = minCol;i <= maxCol;i++) { csvDT.Columns.Add(i.ToString()); } for (row = minRow;row <= maxRow;row++) { DataRow csvDR = csvDT.NewRow(); i = 0; for (col = minCol;col <=maxCol;col++) { csvDR[i] = this[row,col]; i++; } csvDT.Rows.Add(csvDR); } return csvDT; } } /// <summary> /// 检查行数是否是有效的 /// </summary> /// <param name="col"></param> private void CheckRowValid(int row) { if (row <= 0) { throw new Exception("行数不能小于0"); } if (row > RowCount) { throw new Exception("没有当前行的数据"); } } /// <summary> /// 检查最大行数是否是有效的 /// </summary> /// <param name="col"></param> private void CheckMaxRowValid(int maxRow) { if (maxRow <= 0 && maxRow != -1) { throw new Exception("行数不能等于0或小于-1"); } if (maxRow > RowCount) { throw new Exception("没有当前行的数据"); } } /// <summary> /// 检查列数是否是有效的 /// </summary> /// <param name="col"></param> private void CheckColValid(int col) { if (col <= 0) { throw new Exception("列数不能小于0"); } if (col > ColCount) { throw new Exception("没有当前列的数据"); } } /// <summary> /// 检查检查最大列数是否是有效的 /// </summary> /// <param name="col"></param> private void CheckMaxColValid(int maxCol) { if (maxCol <= 0 && maxCol != -1) { throw new Exception("列数不能等于0或小于-1"); } if (maxCol > ColCount) { throw new Exception("没有当前列的数据"); } } /// <summary> /// 载入CSV文件 /// </summary> 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文件的格式有错误"); } } /// <summary> /// 获取两个连续引号变成单个引号的数据行 /// </summary> /// <param name="fileDataLine">文件数据行</param> /// <returns></returns> private string GetDeleteQuotaDataLine(string fileDataLine) { return fileDataLine.Replace("/"/"","/""); } /// <summary> /// 判断字符串是否包含奇数个引号 /// </summary> /// <param name="dataLine">数据行</param> /// <returns>为奇数时，返回为真；否则返回为假</returns> private bool IfOddQuota(string dataLine) { int quotaCount; bool oddQuota; quotaCount = 0; for (int i = 0;i < dataLine.Length;i++) { if (dataLine[i] == '/"') { quotaCount++; } } oddQuota = false; if (quotaCount % 2 == 1) { oddQuota = true; } return oddQuota; } /// <summary> /// 判断是否以奇数个引号开始 /// </summary> /// <param name="dataCell"></param> /// <returns></returns> private bool IfOddStartQuota(string dataCell) { int quotaCount; bool oddQuota; quotaCount = 0; for (int i = 0;i < dataCell.Length;i++) { if (dataCell[i] == '/"') { quotaCount++; } else { break; } } oddQuota = false; if (quotaCount % 2 == 1) { oddQuota = true; } return oddQuota; } /// <summary> /// 判断是否以奇数个引号结尾 /// </summary> /// <param name="dataCell"></param> /// <returns></returns> 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; } /// <summary> /// 加入新的数据行 /// </summary> /// <param name="newDataLine">新的数据行</param> private void AddNewDataLine(string newDataLine) { Debug.WriteLine("NewLine:" + newDataLine); //return; ArrayList colAL = new ArrayList(); string[] dataArray = newDataLine.Split(','); bool oddStartQuota; //是否以奇数个引号开始

• ·即使用ADO.NET，也要轻量级实体映射，比D
• ·第三章知识点归纳
• ·MVC地区多级联动扩展实现(非递归形式)
• ·友盟推送 .NET (C#) 服务端 SDK
• ·Azure cache 的配置与应用
• ·导出的问题
• ·WinForm中为按钮添加键盘快捷键，超简单，
• ·RabbitMQ的安装过程
• ·DataReader在Using中使用
• ·[ C# ] 判断一个类是否实现了某个接口