2012-02-10 51 views
1

我有一个DataTable,它是从.xls表生成的。如何使用来自其他源的数据(DataTable)更新SQL Server表

我想将此DataTable存储到SQL Server数据库中的现有表中。

我使用SqlBulkCopy来存储具有独特PK的行。

问题是,我也有具有相同PK如SQL Server表但包含细胞与不同值相比SQL Server表的其他行。

简而言之:

让我DataTable说我有一排这样的:

ID(PK)|名称|号码

005 | abc | 123

006 | lge | 122

对于我的SQL服务器我有这样的;

id(PK)|名称|号码

004 | cbs | 345

005 | lks | 122

现在你看到行可以使用SqlBulkCopy直接上传到SQL Server中。另一方面,行不能使用它插入,因为SQL服务器表包含具有相同PK的行。

现在我试着手动提取该行。将每个单元格提取到一个ArrayList中,然后生成一个UPDATE Table语句。然而这种方法似乎不可行,因为我有很多行要处理。

我正在寻找更好的方法来实现此目标。

任何帮助表示赞赏。

感谢的

+0

有人可以帮我格式化表吗?我希望它看起来不太混乱。 – rofans91 2012-02-10 03:21:12

+0

你说你想要一个成功的实现,但是你不能解释*'005'的'id'究竟会发生什么。你想覆盖数据库表中的数据吗?或者只是从'DataTable'忽略它? – 2012-02-10 03:21:40

+0

我想覆盖它。 – rofans91 2012-02-10 03:24:40

回答

2

使用下面的代码:

C#端代码从数据表中读取数据,并准备XML数据:

DataTable dt = new DataTable(); 
StringBuilder sb = new StringBuilder(); 

sb.Append("<R>"); 
for (int i = 0; i < dt.Rows.Count; i++) 
{ 
    sb.Append("<C><ID>" + dt.Rows[0].ToString() + "</ID>"); 
    sb.Append("<N>" + dt.Rows[1].ToString() + "</N>"); 
    sb.Append("<I>" + dt.Rows[2].ToString() + "</I></C>"); 
} 

sb.Append("</R>"); 

///pass XML string to DB side 
/// 
//sb.ToString(); //here u get all data from data table as xml format 

数据库端存储过程(你将需要更新表名):

CREATE PROCEDURE dbo.UpdateData 
    -- Add the parameters for the stored procedure here 
    @data  XML 
AS 
BEGIN 
    SET NOCOUNT ON; 

    -- keep data into temp table 
    create table #tmp_data (id nchar(2),name varchar(20), number int) 

    DECLARE @XMLDocPointer INT 
    EXEC sp_xml_preparedocument @XMLDocPointer OUTPUT, @DATA 

    INSERT INTO #tmp_data(id,name,number) 
    SELECT ID,N,I 
    FROM OPENXML(@XMLDocPointer,'/R/C',2) 
    WITH(
      ID nchar(30), 
      N VARCHAR(20), 
      I int 
     ) 

    EXEC sp_xml_removedocument @XMLDocPointer 

    begin tran 
     -------------------INSERT not existing ones 
     INSERT INTO TABLE (id,name,number) 
     SELECT id,name,number 
     FROM #tmp_data 
     WHERE NOT EXISTS 
     (
      SELECT 1 
      FROM TABLE 
      WHERE ID = #tmp_data.ID 
     ) 

     --- update existing ones 
     UPDATE TABLE 
     SET name = #tmp_data.name, number = #tmp_data.number 
     FROM #tmp_data 
     WHERE #tmp_data.id = TABLE.id 

     commit tran 

    if(@@error <> 0) 
     rollback tran 

END 
+0

很棒的答案!做得好! – rofans91 2012-02-10 08:26:40

相关问题