FTP的相关操作

//判断本地有没有ftp上的文件

OracleDB db = new OracleDB(GetConnection.GetConnectionString(\"Database\")); FileStream fs = null;

Stream responseStream = null; FtpWebRequest request1 =

(FtpWebRequest)WebRequest.Create(@\"ftp://10.157.136.28/eHR/eHRMasterData\");

request1.Credentials = new NetworkCredential(\"eHR_Reader\", \"Foxconn123\"); request1.Method = WebRequestMethods.Ftp.ListDirectory;

FtpWebResponse response1 = (FtpWebResponse)request1.GetResponse(); Stream responseStream1 = response1.GetResponseStream();

StreamReader reader = new StreamReader(responseStream1, Encoding.Default); string line = null ; FileStream f=null;

while ((line = reader.ReadLine()) != null) {

if (File.Exists(@\"D:\\\" + line.Trim())) { } else {

f=File.Create(@\"D:\\\" + line.Trim()); }

if(f!=null) {

//从ftp中下载txt文件到本地

FtpWebRequest ftpRequest =

(FtpWebRequest)WebRequest.Create(\"ftp://10.157.136.28/eHR/eHRMasterData/\" + line.Trim()); ftpRequest.Credentials = new NetworkCredential(\"eHR_Reader\", \"Foxconn123\");

ftpRequest.Method = WebRequestMethods.Ftp.DownloadFile; //获取一个 ?求响 ?对 象

FtpWebResponse response = (FtpWebResponse)ftpRequest.GetResponse(); //获取请 求的响 ?流

responseStream = response.GetResponseStream();

StreamReader reader1 = new StreamReader(responseStream, Encoding.Default); int buffer_count = 65536;

byte[] buffer = new byte[buffer_count]; int size = 0;

while ((size = responseStream.Read(buffer, 0, buffer_count)) > 0) {

f.Write(buffer, 0, size); }

f.Flush(); f.Close();

responseStream1.Close();

int flag=InsertToTable(line);//调用方法 if (flag == 1) {

MessageBox.Show(\"操作完成！\"); }

} } }

从ftp上读取txt中的内容导入数据库表格中

public static int InsertToTable(string filename) {

OracleDB db = new OracleDB(GetConnection.GetConnectionString(\"Database\")); int flag = 0; try {

FtpWebRequest ftpRequest =

(FtpWebRequest)WebRequest.Create(\"ftp://10.157.136.28/eHR/eHRMasterData/\"+filename); ftpRequest.Credentials = new NetworkCredential(\"eHR_Reader\", \"Foxconn123\");

FtpWebResponse ftpResponse = (FtpWebResponse)ftpRequest.GetResponse(); Stream stream = ftpResponse.GetResponseStream();

StreamReader sr = new StreamReader(stream, System.Text.Encoding.Default); string strLine = null;

ArrayList al = new ArrayList();

while ((strLine = sr.ReadLine()) != null)

{

int n = 0; int m = -2;

for (int i = 0; i <= 4; i++) {

n = strLine.IndexOf(\"^^\", m + 2, strLine.Length - (m + 2)); if (n == -1) {

n = strLine.Length; }

string empno = strLine.Substring(m + 2, n - (m + 2)); m = n;

al.Add(empno); }

db.Connect();

string sql_select = \"select count(*) from PERSONNELLIST where empno='\" + al[0] + \"'\";

DataSet ds = new DataSet(); ds = db.GetDataSet(sql_select);

if (Convert.ToInt32(ds.Tables[0].Rows[0][0]) >= 1) {

string sql_update = \"update PERSONNELLIST set empname='\" + al[1] + \"',dptname='\" + al[2] + \"',worktime='\" + al[3] + \"',works='\" + al[4] + \"' where empno='\" + al[0] + \"'\";

db.ExecCommand(sql_update);

} else {

string sql = \"insert into PERSONNELLIST values('\" + al[0] + \"','\" + al[1] + \"','\" + al[2] + \"','\" + al[3] + \"','\" + al[4] + \"')\"; db.ExecCommand(sql); }

strLine = null; al.Clear(); flag = 1; }

return flag;

}

catch (Exception ex) {

Console.WriteLine(ex.Message); Console.ReadLine(); return flag; } }