将文本文件转换为DataSet的两种方式

 

将文本文件转换为DataSet的两种方式

摘要：本文介绍采用ODBC .NET Framework 数据提供程序和System.IO下面的FileStream、StreamReader对象来将一定格式的文本文件转换为DataSet;

 

方式一：利用ODBC .NET Framework 数据提供程序的OdbcDataAdapter对象来填充一个DataSet ；

 private DataSet GetDataset(string strFilePath)
        {
            if (!File.Exists(strFilePath))
            {
                return null;
            }
            string strFolderPath = Path.GetDirectoryName(strFilePath);
            string strCSVFile = Path.GetFileName(strFilePath);

            DataSet ds = null;
            string strConnection = "Driver={Microsoft Text Driver (*.txt; *.csv)};Dbq=" + strFolderPath + ";Extensions=asc,csv,tab,txt;Persist Security Info=False";
            try
            {
                using (OdbcConnection conn = new OdbcConnection(strConnection.Trim()))
                {
                    conn.Open();
                    string strSql = "select * from [" + strCSVFile + "]";
                    OdbcDataAdapter odbcDAdapter = new OdbcDataAdapter(strSql, conn);
                    ds = new DataSet();
                    odbcDAdapter.Fill(ds, "table");
                    conn.Close();
                }
                return ds;
            }
            catch (Exception e)
            {
                throw e;
            }
            return ds;
        }

方式二：利用FileStream和StreamReader读取文件内容，手动创建一个DataSet;

        static DataSet GetDatasetFromTxtFile(String strFilePath,String strSpilter)
        {
            FileStream fs = null;
            StreamReader s = null;
            DataSet ds = null;

            try
            {
                fs = new FileStream(strFilePath, FileMode.Open);
                s = new StreamReader(fs, System.Text.Encoding.Unicode);
                ds = new DataSet();

                //创建表
                ds.Tables.Add("unicode");

                //生成列
                string[] columns = s.ReadLine().Split(strSpilter.ToCharArray());
                foreach (string c in columns)
                {
                    if (c.Length > 0)
                    {
                        string[] items = c.Split(strSpilter.ToCharArray());
                        ds.Tables["unicode"].Columns.Add(items[0]);
                    }
                }
                //生成行
                string AllData = s.ReadToEnd();
                string[] rows = AllData.Split("\r\n".ToCharArray());
                foreach (string r in rows)
                {
                    if (r.Length > 0)
                    {
                        string[] items = r.Split(strSpilter.ToCharArray());
                        ds.Tables["unicode"].Rows.Add(items);
                    }
                }

            }
            catch(Exception e)
            {
                throw e;
            }
            finally
            {
                s.Close();
                fs.Close();
            }            
            return ds;
        }

三、测试：
 

TXT文件的格式为：（字段名和字段内容的采用逗号分开）

列名1，列名2，列名3

字段内容1，字段内容2，字段内容3

……

代码为：

测试程序，在.NET2005下通过
using System;
using System.Collections.Generic;
using System.Text;
using System.IO;
using System.Data;
using System.Data.Odbc;

namespace UnicodeTest
{
    class Program
    {
        static void Main(string[] args)
        {
            //=========读取unicode文件
            String str = @"D:\unicode.txt";
            String strSpilter = ",";

            DataSet ds = GetDatasetFromTxtFile(str, strSpilter);

            //测试输出
            DataTable dt = ds.Tables["unicode"];
            String strCol = string.Empty;
            foreach (DataColumn dc in dt.Columns)
            {
                strCol += dc.ColumnName + ("\t");
            }
            Console.WriteLine("{0}{1}", strCol, Environment.NewLine);
            foreach (DataRow dr in dt.Rows)
            {
                Console.WriteLine("{0}{7}{1}{7}{2}{7}{3}{7}{4}{7}{5}{6}",
                    dr[0].ToString(), dr[1].ToString(), dr[2].ToString(),
                    dr[3].ToString(), dr[4].ToString(), dr[5].ToString(),
                    Environment.NewLine, "\t");

            }
            //======================//
        }

        static DataSet GetDatasetFromTxtFile(String strFilePath,String strSpilter)
        {
            FileStream fs = null;
            StreamReader s = null;
            DataSet ds = null;

            try
            {
                fs = new FileStream(strFilePath, FileMode.Open);
                s = new StreamReader(fs, System.Text.Encoding.Unicode);
                ds = new DataSet();

                //创建表
                ds.Tables.Add("unicode");

                //生成列
                string[] columns = s.ReadLine().Split(strSpilter.ToCharArray());
                foreach (string c in columns)
                {
                    if (c.Length > 0)
                    {
                        string[] items = c.Split(strSpilter.ToCharArray());
                        ds.Tables["unicode"].Columns.Add(items[0]);
                    }
                }
                //生成行
                string AllData = s.ReadToEnd();
                string[] rows = AllData.Split("\r\n".ToCharArray());
                foreach (string r in rows)
                {
                    if (r.Length > 0)
                    {
                        string[] items = r.Split(strSpilter.ToCharArray());
                        ds.Tables["unicode"].Rows.Add(items);
                    }
                }

            }
            catch(Exception e)
            {
                throw e;
            }
            finally
            {
                s.Close();
                fs.Close();
            }            
            return ds;
        }

        private DataSet GetDataset(string strFilePath)
        {
            if (!File.Exists(strFilePath))
            {
                return null;
            }
            string strFolderPath = Path.GetDirectoryName(strFilePath);
            string strCSVFile = Path.GetFileName(strFilePath);

            DataSet ds = null;
            string strConnection = "Driver={Microsoft Text Driver (*.txt; *.csv)};Dbq=" + strFolderPath + ";Extensions=asc,csv,tab,txt;Persist Security Info=False";
            try
            {
                using (OdbcConnection conn = new OdbcConnection(strConnection.Trim()))
                {
                    conn.Open();
                    string strSql = "select * from [" + strCSVFile + "]";
                    OdbcDataAdapter odbcDAdapter = new OdbcDataAdapter(strSql, conn);
                    ds = new DataSet();
                    odbcDAdapter.Fill(ds, "table");
                    conn.Close();
                }
                return ds;
            }
            catch (Exception e)
            {
                throw e;
            }
            return ds;
        }
    }
}

  结：

1.      如果文件不是ANSI文件格式而是Unicode格式时，采用方法一得到的是乱码或者空字符(我的操作系统为中文版Server2003)，而采用二可以得到更好的控制，因为我们在实例化StreamReader的时候可以指定读取文件的编码格式，从而可以得到我们理想的效果；

2.      得到的DataSet可以得到DataTable来进行本地的相关数据处理也可以转换为XML或者序列化得到一个字节流来进行相关远程处理和实时传输；