SqlBulkCopy Wcf Rest 在 2 个 sql server 表之间移动数据

Question

我正在尝试将某些表中的数据从一个 sql server 数据库移动到另一个 sql server 数据库。我打算写一个 wcf 休息服务来做到这一点。我也在尝试使用 SQLBulkCopy 来实现这一点。我正在尝试在单击按钮时实现以下功能。将 Table1 数据从源 sql server 复制到目标 sql server 中的表 1。与表 2 和表 3 相同。我在几件事上受阻。 sql bulk copy 是 wcf rest 服务传输数据的最佳选择吗？我被要求不要在这个任务中使用 ssis。如果在将数据从源移动到目标时出现任何异常，则应将目标数据还原回来。这有点像交易。如何实现此交易功能。任何指针都会有所帮助。

Answer 1

根据您提供的信息，您的解决方案类似于我插入的示例代码。 SQLBulkCopy 的指针：BCopyTutorial1、BCopyTutorial2 带有事务范围示例的 SQLBulkCopy：TrasactionBulkCopy

根据您的问题，我的版本是这些的简化版本。

界面：

[ServiceContract]
public interface IYourBulkCopyService {

    [OperationContract]
    void PerformBulkCopy();
}

实施：

public class YourBulkCopyService : IYourBulkCopyService {

    public void PerformBulkCopy() {
        string sourceCs =  ConfigurationManager.AppSettings["SourceCs"];
        string destinationCs =  ConfigurationManager.AppSettings["DestinationCs"];

        // Open a sourceConnection to the AdventureWorks database. 
        using (SqlConnection sourceConnection = new SqlConnection(sourceCs) {
            sourceConnection.Open();

            //  Get data from the source table as a SqlDataReader.         
            SqlCommand commandSourceData = new SqlCommand(
                "SELECT * FROM YourSourceTable", sourceConnection);
            SqlDataReader reader = commandSourceData.ExecuteReader();

            //Set up the bulk copy object inside the transaction.  
            using (SqlConnection destinationConnection = new SqlConnection(destinationCs)) {
                destinationConnection.Open();

                using (SqlTransaction transaction = destinationConnection.BeginTransaction()) {
                    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(
                               destinationConnection, SqlBulkCopyOptions.KeepIdentity,
                               transaction)) {
                        bulkCopy.BatchSize = 10;
                        bulkCopy.DestinationTableName =
                            "YourDestinationTable";

                        // Write from the source to the destination. 
                        try {
                            bulkCopy.WriteToServer(reader);
                            transaction.Commit();
                        } catch (Exception ex) {
                            // If any error, rollback
                            Console.WriteLine(ex.Message);
                            transaction.Rollback();
                        } finally {
                            reader.Close();
                        }
                    }
                }
            }
        }
    }
}