如何使用具有相同主键的本地数据库表来更新远程表？

Question

我想从本地数据库表中更新数据库的远程表。 但是，当我为主人更新我fackign不匹配主键的问题。 那么有没有一种机制，我可以用本地相同的主键来更新远程数据库表。如果我在本地删除一条记录，则远程的主键不匹配。 虽然我有两种类型的表，没有主键和主键。

在这里，我做到了这一点

如果在本地与主键的表。

public bool PublishDressingDetails() 
     { 
      int isUpdated = -1; 
      try 
      { 
       DataTable DressingDetailsLocalDT = cDressing.GetAllDressingDetailsDTForExport(); 
       if (DressingDetailsLocalDT.Rows.Count > 0) 
       { 

        //SqlDataAdapter DA = new SqlDataAdapter("select * from Toppings where ClientID=2", connWeb); 
        SqlDataAdapter DA = new SqlDataAdapter("select * from DressingDetails", connWeb); 

        DA.InsertCommand.Transaction = transaction; 
        DA.UpdateCommand.Transaction = transaction; 
        DA.DeleteCommand.Transaction = transaction; 

        SqlCommandBuilder SCB = new SqlCommandBuilder(DA); 

        DataSet DS = new DataSet(); 
        DA.Fill(DS, "DressingDetails"); 
        //DS.Tables[0].PrimaryKey = new DataColumn[] { DS.Tables[0].Columns["ClientID"], DS.Tables[0].Columns["ToppingID"] }; 
        DS.Tables[0].PrimaryKey = new DataColumn[] { DS.Tables[0].Columns["DressingID"] }; 

        object[] searchVal = new object[1]; 
        //searchVal[0] = "2"; 

        //DataRow drSrc; 
        foreach (DataRow drLocal in DressingDetailsLocalDT.Rows) 
        { 
         searchVal[0] = drLocal["DressingID"].ToString(); 
         DataRow drSrc = DS.Tables[0].Rows.Find(searchVal); 
         if (drSrc == null) 
         { 
          drSrc = DS.Tables[0].NewRow(); 
          //drSrc["ClientID"] = "2"; 
          drSrc["DressingID"] = drLocal["DressingID"].ToString(); 

          if (drLocal["Description"] != DBNull.Value) 
          { 
           drSrc["Description"] = drLocal["Description"].ToString(); 
          } 
          else drSrc["Description"] = DBNull.Value; 

          if (drLocal["Position"] != DBNull.Value) 
          { 
           drSrc["Position"] = drLocal["Position"].ToString(); 
          } 
          else drSrc["Position"] = DBNull.Value; 


          if (drLocal["IsDeleted"] != DBNull.Value) 
          { 
           drSrc["IsDeleted"] = drLocal["IsDeleted"].ToString(); 
          } 
          else drSrc["IsDeleted"] = DBNull.Value; 


          if (drLocal["icon"] != DBNull.Value) 
           drSrc["icon"] = drLocal["icon"]; 
          else 
           drSrc["icon"] = DBNull.Value; 


          DS.Tables[0].Rows.Add(drSrc); 
         } 
         else 
         { 
          //drSrc["ClientID"] = "2"; 
          drSrc["DressingID"] = drLocal["DressingID"].ToString(); 
          if (drLocal["Description"] != DBNull.Value) 
          { 
           drSrc["Description"] = drLocal["Description"].ToString(); 
          } 
          else drSrc["Description"] = DBNull.Value; 

          if (drLocal["Position"] != DBNull.Value) 
          { 
           drSrc["Position"] = drLocal["Position"].ToString(); 
          } 
          else drSrc["Position"] = DBNull.Value; 

          if (drLocal["IsDeleted"] != DBNull.Value) 
          { 
           drSrc["IsDeleted"] = drLocal["IsDeleted"].ToString(); 
          } 
          else drSrc["IsDeleted"] = DBNull.Value; 


          if (drLocal["icon"] != DBNull.Value) 
           drSrc["icon"] = drLocal["icon"]; 
          else 
           drSrc["icon"] = DBNull.Value; 
         } 

        } 
        isUpdated = DA.Update(DS, "DressingDetails"); 

       } 
      } 
      catch (Exception ex) 
      { 
       throw ex; 
      } 

      return (isUpdated != -1) ? true : false; 
     } 

没有主键。

public bool PublishMealDealDetail() 
     { 
      bool isUpdated = true; 
      try 
      { 
       DataTable dtLocal = libEPOS.cMealDeal.GetAllMealDealDetailsDTForExport(); 
       if (dtLocal.Rows.Count > 0) 
       { 
        //truncate table on web 
        string sqlTrunc = "TRUNCATE TABLE MealDealDetail"; 
        SqlCommand cmd = new SqlCommand(sqlTrunc, connWeb, transaction); 
        // connWeb.Open(); 
        cmd.ExecuteNonQuery(); 
        SqlBulkCopy bulkcopy = new SqlBulkCopy(connWeb); 
        bulkcopy.DestinationTableName = "MealDealDetail"; 
        try 
        { 
         bulkcopy.WriteToServer(dtLocal); 
        } 
        catch (Exception e) 
        { 
         transaction.Rollback(); 
         isUpdated = false; 
         Console.WriteLine(e.Message); 
        } 

       } 
      } 
      catch (Exception ex) 
      { 
       transaction.Rollback(); 
       isUpdated = false; 
       throw ex; 
      } 

      return isUpdated; 
     } 

Answer 1

在更新表格时，U可以利用System.Data.SqlClient.SqlBulkCopyOptions.KeepIdentity来保持从一个源到另一个源的身份。

MSDN这里：http://msdn.microsoft.com/en-us/library/system.data.sqlclient.sqlbulkcopyoptions(v=vs.110).aspx

System.Data.SqlClient.SqlBulkCopy bulkcopy = new System.Data.SqlClient.SqlBulkCopy(connWeb,System.Data.SqlClient.SqlBulkCopyOptions.KeepIdentity);