我有一个应用程序,我必须从数据库中获取大量数据。由于它未能获得所有这些行(接近 2,000,000 行......),我将其中断,并且每次运行 sql 查询并且每次仅获得 200,000 行。
我使用向其中输入所有数据的 DataTable(意思是 - 所有 2,000,000 行都应该在那里)。
前几轮还不错。然后它因 OutOfMemoryException 而失败。
我的代码工作如下:
private static void RunQueryAndAddToDT(string sql, string lastRowID, SqlConnection conn, DataTable dt, int prevRowCount)
{
if (string.IsNullOrEmpty(sql))
{
sql = generateSqlQuery(lastRowID);
}
if (conn.State == ConnectionState.Closed)
{
conn.Open();
}
using (IDbCommand cmd2 = conn.CreateCommand())
{
cmd2.CommandType = CommandType.Text;
cmd2.CommandText = sql;
cmd2.CommandTimeout = 0;
using (IDataReader reader = cmd2.ExecuteReader())
{
while (reader.Read())
{
DataRow row = dt.NewRow();
row["RowID"] = reader["RowID"].ToString();
row["MyCol"] = reader["MyCol"].ToString();
... //In one of these rows it returns the exception.
dt.Rows.Add(row);
}
}
}
if (conn != null)
{
conn.Close();
}
if (dt.Rows.Count > prevRowCount)
{
lastRowID = dt.Rows[dt.Rows.Count - 1]["RowID"].ToString();
sql = string.Empty;
RunQueryAndAddToDT(sql, lastRowID, conn, dt, dt.Rows.Count);
}
}
在我看来,读者似乎一直在收集行,这就是它只在第三轮或第二轮抛出异常的原因。
不应该使用清理内存吗?什么可以解决我的问题?
注意:我应该解释一下 - 我别无选择,只能将所有这些行放到数据表中,因为我稍后会对它们进行一些操作,并且行的顺序很重要,我不能拆分它,因为有时我有取一些行的数据并设置为一行等等,所以我不能放弃它。
谢谢。