很多用户在使用阿里云云数据库SQL Server时，为了加快插入速度，都尝试使用大容量插入的方式，大家都知道，对于完整恢复模式下的数据库，大容量导入执行的所有行插入操作都会完整地记录在事务日志中。如果使用完整恢复模式，大型数据导入会导致填充事务日志的速度很快。相反，对于简单恢复模式或大容量日志恢复模式，大容量导入操作的按最小方式记录日志减少了大容量导入操作填满日志空间的可能性。另外，按最小方式记录日志的效率也比按完整方式记录日志高 。
但实际上，当大容量导入与数据库镜像共存时，会出现镜像 Suspend的情况，这个情况是由于微软在2008 R2上的BUG导致，详细你可以了解 https://support.microsoft.com/en-us/kb/2700641,微软已经明确表示在2008 R2不会FIXED，那么如何正确在RDS使用大容量导入并避免镜像异常，下面介绍几种方式。
只需要将SqlBulkCopy 指定SqlBulkCopyOptions.CheckConstraints就好，即：SqlBulkCopy blkcpy = new SqlBulkCopy(desConnString,SqlBulkCopyOptions.CheckConstraints)
例如：将本地的一个大表通过SQLBulkCopy方式导入到RDS的实例中
static void Main()
{
? ? string srcConnString = "Data Source=(local);Integrated Security=true;
? ? Initial Catalog=testdb";
? ? string desConnString = "Data Source=****.sqlserver.rds.aliyuncs.com,3433;
? ? UserID=**;Password=**;Initial Catalog=testdb";
? ? SqlConnection srcConnection = new SqlConnection();
? ? SqlConnection desConnection = new SqlConnection();
? ? SqlCommand sqlcmd = new SqlCommand();
? ? SqlDataAdapter da = new SqlDataAdapter();
? ? DataTable dt = new DataTable();
? ? srcConnection.ConnectionString = srcConnString;
? ? desConnection.ConnectionString = desConnString;
? ? sqlcmd.Connection = srcConnection;
? ? sqlcmd.CommandText = @"
? ? SELECT top 1000000 [PersonType],[NameStyle],[Title],[FirstName],[MiddleName],
? ? [LastName],[Suffix],[EmailPromotion],[AdditionalContactInfo],[Demographics],NULL?
? ? as rowguid,[ModifiedDate] FROM [testdb].[dbo].[Person]";
? ? sqlcmd.CommandType = CommandType.Text;
? ? sqlcmd.Connection.Open();
? ? da.SelectCommand = sqlcmd;
? ? da.Fill(dt);
? ? using (SqlBulkCopy blkcpy =?
? ? new ?SqlBulkCopy(desConnString,SqlBulkCopyOptions.CheckConstraints))
? ? // using (SqlBulkCopy blkcpy =?
? ? // new SqlBulkCopy(desConnString,SqlBulkCopyOptions.Default))
? ? {
? ? ? ? blkcpy.BatchSize = 2000;
? ? ? ? blkcpy.BulkCopyTimeout = 5000;
? ? ? ? blkcpy.SqlRowsCopied += new SqlRowsCopiedEventHandler(OnSqlRowsCopied);
? ? ? ? blkcpy.NotifyAfter = 2000;
? ? ? ? foreach (DataColumn dc in dt.Columns)
? ? ? ? {
? ? ? ? ? ? blkcpy.ColumnMappings.Add(dc.ColumnName,dc.ColumnName);
? ? ? ? }
? ? ? ? try
? ? ? ? {
? ? ? ? ? ? blkcpy.DestinationTableName = "Person";
? ? ? ? ? ? blkcpy.WriteToServer(dt);
? ? ? ? }
? ? ? ? catch (Exception ex)
? ? ? ? {
? ? ? ? ? ? Console.WriteLine(ex.Message);
? ? ? ? }
? ? ? ? finally
? ? ? ? {
? ? ? ? ? ? sqlcmd.Clone();
? ? ? ? ? ? srcConnection.Close();
? ? ? ? ? ? desConnection.Close();
? ? ? ? }
? ? }
}
private static void OnSqlRowsCopied(
? ? object sender,SqlRowsCopiedEventArgs e)
{
? ? Console.WriteLine("Copied {0} so far...",e.RowsCopied);
}
同样的道理，需要在copyOptions指定检查约束性
SQLServerBulkCopyOptions copyOptions = new SQLServerBulkCopyOptions(); ?
copyOptions.setCheckConstraints(true);
测试时，请用Microsoft JDBC Drivers 6.0 的sqljdbc41.jar，sqljdbc4.jar及更老版本没有SQLServerBulkCopy 实现。
例如: 将本地的一个大表通过SQLServerBulkCopy方式导入到RDS的实例中
import java.sql.*;
import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;
import com.microsoft.sqlserver.jdbc.SQLServerBulkCopyOptions;
public class Program {
? ? public static void main(String[] args) ?
? ? { ?
? ? ? ? String sourceConnectionString ?= "jdbc:sqlserver://localhost:1433;" + ?
? ? ? ? ? ? ? ? "databaseName=testdb;user=****;password=****"; ?
? ? ? ? String destConnectionString ?= "jdbc:sqlserver://*****.sqlserver.rds.aliyuncs.com:3433;" + ?
? ? ? ? ? ? ? ? "databaseName=testdb;user=****;password=**** "; ?
? ? ? ? try ?{
......
}catch{
.......
}
}
(ps：由于微信字数限制，欲查看完整代码，请点击“阅读原文”，进行查看。)
大容量导入数据会带来更快的插入，解决了用户在有大量数据导入缓慢困惑，在阿里云数据库中，你可以使用五种方式来实现业务场景，但是基于镜像的主备关系，需要特别加入一个检查约束的选项，这是写这个最佳实践的目的，一旦镜像SUSPEND，不断有DUMP文件产生，一来需要时间来修正，二来DUMP文件也会不断占用空间，但不会影响用户的可用性和可靠性。有两种方式在RDS中不能实现，另外，还可以通过ODBC来实现大容量导入，具体请参见https://msdn.microsoft.com/en-us/library/ms403302.aspx。希望这些对大家有用，特别是阿里云云数据库使用用户。
