I'm making a synchronization application, from Firebird to SQL Server. And I'm using BulkInsert from Dapper Plus.
var fbClient = new FirebirdConnect();
using (var source = fbClient.GetConnection())
{
if (source.State == ConnectionState.Closed)
source.Open();
var sqlClient = new AzureConnect();
using (var target = sqlClient.GetConnection())
{
if (target.State == ConnectionState.Closed)
target.Open();
var lastUpdate = connection.Query<DateTime>($"select coalesce((select max(DateSyncTarget) from {metadados.TargetName}), getdate()-10000) LastUpdate").ToList();
var resultSource = source.Query<MyClass>("select * from MyClass");
target.BulkInsert(resultSource.Where(w => w.Data > lastUpdate[0]));
var resultTargert = target.Query<MyClassSource>("select * from MyClass")
source.BulkInsert(resultTargert.Where(w => w.Data > lastUpdate[0]));//Error here
}
}
Everything happens well when I consult the source to do the insertion in the target.
But when I query on target to insert into source, it is giving the following error:
The Provider could not be resolved. You must explicity set the Provider.
Some idea of what causes the error?
EDITED:
Full stack:
em ..(BulkOperation )
em ..(BulkOperation )
em Z.BulkOperations.BulkOperation.BulkInsert()
em Z.Dapper.Plus.DapperPlusAction.Execute()
em Z.Dapper.Plus.DapperPlusAction..ctor(BaseDapperPlusActionSet action, String key, DapperPlusActionKind kind, Object dataSource)
em Z.Dapper.Plus.DapperPlusActionSet`1.AddAction(String mapperKey, DapperPlusActionKind actionKind, TEntity item)
em Z.Dapper.Plus.DapperPlusActionSet`1.DapperPlusActionSetBuilder(IDbConnection connection, IDbTransaction transaction, String mapperKey, DapperPlusActionKind actionKind, TEntity item, Func`2[] selectors)
em Z.Dapper.Plus.DapperPlusExtensions.BulkInsert[T](IDbConnection connection, String mapperKey, T item, Func`2[] selectors)
em Z.Dapper.Plus.DapperPlusExtensions.BulkInsert[T](IDbConnection connection, T item, Func`2[] selectors)
em Project.Plugins.Utils.Extensions.CommandExtensions.InsertSource[T](IDbConnection connection, IEnumerable result) na D:\Projetos\Project-API-Cloud\project-etl\Project.Plugins.Utils\Extensions\CommandExtensions.cs:linha 52
em Autorizacoes.ERP.LIBSENHA.JobAutorizacoes.Execute(IJobExecutionContext context) na D:\Projetos\Project-API-Cloud\Project-etl\Autorizacoes\JobAutorizacoes.cs:linha 105