微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

c# – 读取数百万条数据记录的最佳表现

我有一个包含大量数据(数百万行)的数据库,并且在白天用大量数据进行更新,我还备份了这个数据库用于报告,因此获取数据报告不会影响到主数据库性能.

为了将数据库与主数据库同步备份,我编写了一个查询数据库并将新数据插入备份数据库Windows服务…每次查询从主数据库获取5000行时…

编辑:

查询如下:

const string cmdstr = "SELECT * FROM [RLCConvertor].[dbo].[RLCDiffheader] WHERE ID >= @Start and ID <= @End";

这是代码

using (var conn = new sqlConnection(_connectionString))
{
            conn.open();
            var cmd = new sqlCommand(cmdstr,conn);               
            cmd.Parameters.AddWithValue("@Start",start);
            cmd.Parameters.AddWithValue("@End",end);

            sqlDataReader reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess);

            while (reader.Read())
            {
                var rldDiffId = Convert.ToInt32(reader["ID"].ToString());
                var rlcDifheader = new RLCDiffheader
                {
                    Tech_head_Type = long.Parse(reader["Tech_head_Type"].ToString()),ItemCode = long.Parse(reader["ItemCode"].ToString()),SessionNumber = long.Parse(reader["SessionNumber"].ToString()),MarketFeedCode = reader["MarketFeedCode"].ToString(),MarketPlaceCode = reader["MarketPlaceCode"].ToString(),FinancialMarketCode = reader["FinancialMarketCode"].ToString(),CIDGrc = reader["CIDGrc"].ToString(),InstrumentID = reader["InstrumentID"].ToString(),CValMNE = reader["CValMNE"].ToString(),DEven = reader["DEven"].ToString(),HEven = reader["HEven"].ToString(),MessageCodeType = reader["MessageCodeType"].ToString(),SEQbyINSTandType = reader["SEQbyINSTandType"].ToString()                                            
                };
                newRLCDiffheaders.Add(rldDiffId,rlcDifheader);
            }
            conn.Close();
        }

但是当我启动服务时…主数据库性能变得更糟……代码效率不高?有没有更好的方法?因为我搜索并发现dataReader对于这种情况是最好的…或者我应该使用DataTable和sqlDataAdapter?

解决方法

您无法将此视为问题的正确答案或解决方案.
由于评论很大,我正在为您提供解决方案.

您可以尝试使用Ad hoc查询的概念吗?

使用此方法,您可以使用以下方法查询一个数据库

SELECT a.*
FROM OPENROWSET('sqlNCLI','Server=Seattle1;Trusted_Connection=yes;','SELECT GroupName,Name,DepartmentID
      FROM AdventureWorks2012.HumanResources.Department
      ORDER BY GroupName,Name') AS a;

阅读更多
http://technet.microsoft.com/en-us/library/ms187569.aspx
http://technet.microsoft.com/en-us/library/ms190312.aspx

由于您正在使用服务,因此服务帐户肯定有权读取主数据库并插入以报告数据库.我建议你在报告数据库中有一个SP,它可以使用OpenRowSet访问主数据库并插入它.

查询将类似于此.

Insert into tbl
SELECT a.*
    FROM OPENROWSET('sqlNCLI',DepartmentID
          FROM AdventureWorks2012.HumanResources.Department
          ORDER BY GroupName,Name') AS a;

构成服务,您需要调用SP.我们有一个类似的问题,这是由openrowset完成的,我不知道它可以提供多少性能影响.但我建议你做一个POC,然后分析一下.请再次将此视为建议.

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐