KD_ID=");
string jkdidstr = onesql.Substring(fs +14);
string[]jkdcs = jkdidstr.Split(new string[] { "' and CS_ID='" },StringSplitOptions.RemoveEmptyEntries);
string jkd= jkdcs[0];
string jkcs =jkdcs[1].ToString().Replace("'\r", "");
myCommand.Parameters[":value"].Value =p.ToString()+"##########";
myCommand.Parameters[":jkdid"].Value =jkd.Replace("'", "");
myCommand.Parameters[":jkdcs"].Value =jkcs.Replace("'", "");
myCommand.ExecuteNonQuery();
if (p %5000 == 0)
{
myTrans.Commit();
myTrans= myConnection.BeginTransaction(IsolationLevel.ReadCommitted);
Console.WriteLine(p.ToString()+" "+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") );
mydialog.WriteLine(p.ToString() + " " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
}
}
以这样的方式每5000条提交一次,节省了大量的频繁交互,速度就有了很大的提升。
版权声明:本文为博主原创文章,未经博主允许不得转载。