【发布时间】:2018-01-17 11:50:07
【问题描述】:
我正在使用以下代码批量插入超过 100 000 条记录
C#函数:
public void ExcelUpload(DataTable dt)
{
try
{
objBus.ClearMDPreprocessed();
lblError1.Visible = true;
lblError1.Text = "Preparing Sheet for Validations. Please Wait...";
using (StreamWriter wr = new StreamWriter(MapPath(ConfigurationManager.AppSettings["MASTER_DATA_FOLDER"].ToString()) + "\\RawMasterData_PREPROCESSED.txt"))//(@"e:\WorkingFolder\output.txt"))
{
foreach (DataRow row in dt.Rows)
{
wr.WriteLine(row["EMPNO"] + "," + row["MODEL"] + "," + row["PRIMARY_SUPERVISOR"] + "," + row["PROJECT_MANAGER"] + "," + row["ISBPS"] + "," + row["BU"]);
}
}
System.Diagnostics.Process sysprocess = new Process();
string myCommand = @"/c SQLLDR " + ConfigurationManager.AppSettings["ORA_CONN_MASTER_" + ConfigurationManager.AppSettings["CONN"].ToString().Trim()].ToString().Trim() + " LOG=" + MapPath(ConfigurationManager.AppSettings["MASTER_DATA_FOLDER"].ToString()) + "\\MasterDataUpd_PP.Log" + " CONTROL=" + MapPath(ConfigurationManager.AppSettings["MASTER_DATA_FOLDER"].ToString()) + "\\Ctrl_PreProcessed_Raw.txt";
ProcessStartInfo startInfo = new ProcessStartInfo("cmd.exe", myCommand);
startInfo.RedirectStandardOutput = true;
startInfo.UseShellExecute = false;
startInfo.WorkingDirectory = MapPath(ConfigurationManager.AppSettings["MASTER_DATA_FOLDER"].ToString());
startInfo.RedirectStandardError = true;
startInfo.RedirectStandardInput = true;
sysprocess = System.Diagnostics.Process.Start(startInfo);
sysprocess.WaitForExit();
if ((sysprocess.ExitCode == 4))
{
lblError1.Visible = true;
lblError1.Text = "Sheet ready for Validations.Click on Validate";
btnValidate.Visible = true;
btnDirectUpload.Visible = true;
}
else
HttpContext.Current.Response.Write("NOT DONE");
}
catch (Exception ex)
{
throw ex;
}
}
Ctrl_Preprocessed_Raw.txt 内容:
LOAD DATA
INFILE RawMasterData_PREPROCESSED.txt
BADFILE dataFile.bad
APPEND INTO TABLE MSI_MASTER_DATA_RAW
FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '"'
TRAILING NULLCOLS
(EMPNO,MODEL,PRIMARY_SUPERVISOR,PROJECT_MANAGER,ISBPS,BU)
【问题讨论】:
-
你为什么要调用 sqlldr?为什么不直接在代码中解析和加载文件呢?更容易控制和调试(你不会发布到 SO 想知道 wtf 有 5120 行等)。从 C# 进行系统调用还有其他问题。并且有几个很好的 csv 解析器库可以为您完成许多繁琐的工作。
-
很奇怪,您手动解析 csv 文件以调用 sqlldr。查看 nuget.org/packages/LumenWorksCsvReader 并熟悉 Oracle 插入语句。
-
如果直接针对 SQL*Loader 运行它会发生什么?
标签: c# oracle insert sql-loader