ftp读取txt数据并插入数据库

去官网下载http://enterprisedt.com/ .netftp组件

目前最新版本为2.2.3，下载后在bin目录中找到edtFTPnet.dll，在项目中添加引用。 

using EnterpriseDT.Net.Ftp;

public partial class test_ftp : System.Web.UI.Page {

    protected void Page_Load(object sender, EventArgs e)    

{         if (!IsPostBack)      

    {           

     Connect_Ftp();        

       insertdata();    

     }

    }

    #region 连接FTP     private static void Connect_Ftp()     {       

        string[] strArray = null;       

  FTPClient ftp = new FTPClient();              

  var itccConfig = ConfigFactory.GetConfig<IitccConfig>();        

try      

   {             //以下开始获取FTP数据         

     ftp.RemoteHost = itccConfig.FTPIp;           

  ftp.ControlPort = 21;          

   ftp.Timeout = 0x2710;

            ftp.Connect();         

    ftp.Login(itccConfig.FTPName, itccConfig.FTPPassWord);

            ftp.ConnectMode = FTPConnectMode.PASV;        

     ftp.TransferType = FTPTransferType.ASCII;

            ftp.ChDir("/home/ftpuser/itcc/"); //文件夹路径 

            strArray = ftp.Dir(".", true);

            string strDay = DateTime.Now.AddDays(-1).ToString("yyyyMMdd");         

    //foreach (string strFile in strArray)         

    //{             //if (strFile.Length >= 0)         

    //{             //string strfilename = strFile.Substring(0, 24).TrimStart();          

   string strfilename = "poc_ftp_T04_2015-06-11T0329309.txt";         

    //if (strfilename == "per" + strDay + ".txt")         

    //{             // if (CheckIsOver(ConnectionString, strfilename, strDay))       

      //{             //if (CheckIsInserting(ConnectionString, strfilename, strDay))          

   //{             //string strLogFile = @"E:loguploadcopy." + strfilename;         

    string strLogFile = @"E:downftpcopy." + strfilename;

            if (File.Exists(strLogFile))              

   File.Delete(strLogFile);            

ftp.Get(strLogFile, strfilename);               

      //ftp.Get(strfilename);             //以上为获取FTP数据，并将文件存放在本地硬盘中      

        //Insert_Date(ConnectionString, null, strDay, strDataInfo, strFilePath + @"/" + strLogFile);//数据插入数据库              // }             //}             //}             //}             //}

            if (ftp.Connected)       

      {                               ftp.Quit();

            }           

        }         catch (Exception ex)        

{             if (ftp.Connected)          

   {                 ftp.Quit();             }          

   throw ex;         }        

    }    

#endregion

    private static void insertdata()     {        

FileStream fs = new FileStream("E:/downftp/copy.poc_ftp_T04_2015-06-11T0329309.txt", FileMode.Open, FileAccess.Read, FileShare.ReadWrite);

        System.IO.StreamReader my = new System.IO.StreamReader(fs, System.Text.Encoding.UTF8);

        string line;      

   while ((line = my.ReadLine()) != null)       

  {             //Response.Write(line + "<br />");     

        string[] mm = line.Split(';');          

   Insert(mm);         }

        my.Close();

    }     private static void Insert(string[] mm)   

  {         for (int i = 0; i < mm.Length/8; i++)        

{             string employeecode = mm[i*8];         

    string employeename = mm[i*8+1];           

  string phone1 = mm[i * 8 + 2];           

  string phone2 = mm[i * 8 + 3];         

    string phone3 = mm[i * 8 + 4];            

string email = mm[i * 8 + 5];        

     string department = mm[i * 8 + 6];        

     string workplace = mm[i * 8 + 7];

            EmployeeCommand cmd = new EmployeeCommand();        

     if (cmd.EmployyeeCode(employeecode) == true)         

    {                 cmd.UpdateEmployee(employeecode, employeename, phone1, phone2, phone3, department, workplace, email);             }        

     else             {                 cmd.CreateEmployee(employeecode, employeename, phone1, phone2, phone3, department, workplace, email);

            }         }     }

}