FileHelper 一个极好的数据文本文件处理类库 - Blues - 博客园

1using System;
2using System.Configuration;
3using System.Data.SqlClient;
4//在此处增加对这个类库的引用就可以了
5using FileHelpers;
6
7
8namespace FileHelpersSample
9{
10    public partial class _Default : System.Web.UI.Page
11    {
12        protected void Page_Load(object sender, EventArgs e)
13        {
14
15        }
16
17        protected void btImportFLFtoSQLbyLINQ_Click(object sender, EventArgs e)
18        {
19
20            //清空所有已存在记录,
21            string SQLCommand = “TRUNCATE TABLE dbo.prm”;
22            int sqlresult = RunSQLStatement(SQLCommand);
23            Response.Write(sqlresult);
24            Response.Write(“<hr />”);
25
26            string strCSVFile = System.Web.HttpContext.Current.Server.MapPath(“./”) + “Data\\rrr.csv”;
27
28            //一次性读入整个文本文件
29            //FileHelperEngine<FLFRecordClass> engine = new FileHelperEngine<FLFRecordClass>();
30            //FLFRecordClass[] res = engine.ReadFile(strCSVFile);
31
32            //异步方式，一次读入一行，处理一行
33            FileHelperAsyncEngine<FLFRecordClass> engine = new FileHelperAsyncEngine<FLFRecordClass>();
34            engine.BeginReadFile(strCSVFile);
35
36            int i = 0;
37            while (engine.ReadNext() != null)
38            {
39                FLFRecordClass f = engine.LastRecord;
40
41                string Command;
42                
60
61                int j = RunSQLStatement(Command);
62                Response.Write(j);
63                Response.Write(“<br />”);
64                //if (i > 2) break;
65                i++;
66            }
67               engine.Close;
Response.Write(“<hr />”);
68            Response.Write(i);
69
70
71        }
72
73
74        public static SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings[“FLFConnectionString”].ConnectionString);
75
76        //自定义函数，用于实现对SQL数据库的更新操作
77        public int RunSQLStatement(string Command)
78        {
79            SqlCommand DataCommand = new SqlCommand(Command, conn);
80            DataCommand.Connection.Open();
81            int i = DataCommand.ExecuteNonQuery();
82            DataCommand.Connection.Close();
83            return i;
84        }
85
86    }
87}
88