62,050
社区成员
发帖
与我相关
我的任务
分享
StreamReader sr=null;
try
{
sr= new StreamReader(baseLocation, Encoding.GetEncoding("gb2312"));
string strLine = sr.ReadLine();
while (strLine != null)
{
if (strLine.Contains("#HEAD") == true)
{
strLine = sr.ReadLine();
}
if (strLine.Length > 5)
{
string[] contents = strLine.Split('|');
string yhbh = contents[1].ToString();
string ghtm = contents[2].ToString();
string sjjbh = contents[3].ToString();
string sjrq1 = contents[4].ToString();
string fffs = contents[5].ToString();
string sjrxm = contents[6].ToString();
string sjrdz = contents[7].ToString();
string sjryb = contents[8].ToString();
string txhm = contents[9].ToString();
string ygh = contents[10].ToString();
string bwb = contents[11].ToString();
int count = GetSXX(dc, yhbh, sjrq1);
string in_sql = string.Format("insert into ZJGHX (UserID,GHTM,SJJBH,SJRQ,FFFS,SJRXM,SJRDZ,SJRYB,TXHM,YGH,PCID,SXX,BWB) values('{0}','{1}','{2}','{3}','{4}','{5}','{6}','{7}','{8}','{9}','{10}',{11},'{12}')", yhbh, ghtm, sjjbh, sjrq1, fffs, sjrxm, sjrdz, sjryb, txhm, ygh, guid, count,bwb);
string fin_sql = "select count(*) from zjghx where ghtm='"+ghtm+"'";
if (DA.ExecuteScalar(fin_sql).ToString() == "0")
{
dc.ExecuteNonQuery(in_sql);
}
else
{
string del_sql = "delete from zjghx where ghtm='"+ghtm+"'";
DA.ExecuteNonQuery(del_sql);
in_sql = string.Format("sql语句);
DA.ExecuteNonQuery(in_sql);
}
strLine = sr.ReadLine();
}
else
{
strLine = sr.ReadLine();
}
if (strLine.Contains("#END")==true)
{
break;
}
}
}
catch (Exception ex)
{
this.tbmsg.Text = ex.Message;
}
finally
{
sr.Close();
}