我試圖使用SqlBulkCopy
與ServiceStack Ormlite
和已經編寫了下面的擴展方法:爲什麼我不能將ServiceStack Ormlite連接轉換爲SqlConnection?
public static void BulkInsertSqlServer<T>(this IDbConnection dbConn, string targetTable, IEnumerable<T> data, params string[] columns)
{
Ensure.NotNull(dbConn);
Ensure.That(dbConn.State == ConnectionState.Open);
Ensure.NotNullOrEmptyOrWhiteSpace(targetTable);
Ensure.NotNull(data);
Ensure.NotNullOrEmpty(columns);
var sqlConnection = dbConn as SqlConnection;
using (var bcp = new SqlBulkCopy(sqlConnection))
using (var reader = ObjectReader.Create(data, columns))
{
bcp.BatchSize = data.Count();
bcp.DestinationTableName = targetTable;
bcp.WriteToServer(reader);
}
}
對此我用:
_connFactory = new OrmLiteConnectionFactory(connStr, SqlServerOrmLiteDialectProvider.Instance);
using (var db = _connFactory.Open())
using (var tran = db.BeginTransaction())
{
db.BulkInsertSqlServer("User", users, "Name", "Age");
var allRoles = new List<Role>();
foreach (var listOfRoles in users.Select(d => d.Roles))
{
allRoles.AddRange(listOfRoles);
}
db.BulkInsertSqlServer("Role", allRoles, "Name", "UserId", "IsAdmin");
tran.Commit();
}
然而sqlConnection
總是空,任何想法?
的DbConnection似乎並沒有在任何地方聲明。你已經調用了「this」dbConn。 – Fordio 2014-10-03 13:52:39
@ Fordio-編輯。 – MaYaN 2014-10-03 14:16:06
我只能建議它不從它繼承,它也不是SqlConnection。 – Fordio 2014-10-03 14:44:34