У меня есть база данных MySQL с таблицами. Я создаю службу Windows, которая будет извлекать данные из таблицы MySql c2b2_callbacks
и передавать значение моему классу DTO.
Ниже мое избрание
public async Task<IEnumerable<Callback>> GetCallbacks()
{
using(MySqlConnection conn = new MySqlConnection(connectionString))
{
try
{
await conn.OpenAsync();
//MySqlTransaction sqlTransaction = await conn.BeginTransactionAsync();
using (M2AContext context = new M2AContext())
{
//context.Database.UseTransaction(sqlTransaction);
// Error
IEnumerable<CallBack> transactions = await context.Transactions.SqlQuery("SELECT * FROM oapi_test.c2b2_callbacks WHERE Status = 0 AND MSISDN REGEXP \'^([a-z]*[a-z]\\s*){3}([0-9]*[0-9]){3}([a-z]){1}$\';").ToListAsync();
return transactions;
}
}
catch(Exception e)
{
//log
Console.WriteLine($"Error {e.Message}");
return null;
}
}
}
Ниже Мой CallBack
класс
public class CallBack
{
public string TransID { get; set; }
public DateTime TransTime { get; set; }
public string MSISDN { get; set; }
public Int16 Status { get; set; }
}
Ниже мой контекст
[DbConfigurationType(typeof(MySqlEFConfiguration))]
public class M2AContext: DbContext
{
public M2AContext(): base()
{
}
public M2AContext(DbConnection connection, bool ownedconnection): base(connection, ownedconnection)
{
}
public DbSet<Callbacks> Transactions { get; set; }
protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
base.OnModelCreating(modelBuilder);
}
}
Я пытаюсь получить транзакции, но в операторе SELECT
не получается и выдает эту ошибку
{"Object reference not set to an instance of an object."}
Я просмотрел эту документацию и не знаю, почему возникает эта ошибка.
Это трассировка стека
at MySql.Data.MySqlClient.MySqlProviderServices.GetDbProviderManifestToken(DbConnection connection)
at System.Data.Entity.Core.Common.DbProviderServices.GetProviderManifestToken(DbConnection connection)
at MySql.Data.Entity.MySqlManifestTokenResolver.ResolveManifestToken(DbConnection connection)
at System.Data.Entity.Utilities.DbConnectionExtensions.GetProviderInfo(DbConnection connection, DbProviderManifest& providerManifest)
at System.Data.Entity.DbModelBuilder.Build(DbConnection providerConnection)
at System.Data.Entity.Internal.LazyInternalContext.CreateModel(LazyInternalContext internalContext)
at System.Data.Entity.Internal.RetryLazy`2.GetValue(TInput input)
at System.Data.Entity.Internal.LazyInternalContext.InitializeContext()
at System.Data.Entity.Internal.InternalContext.GetEntitySetAndBaseTypeForType(Type entityType)
at System.Data.Entity.Internal.Linq.InternalSet`1.Initialize()
at System.Data.Entity.Internal.Linq.InternalSet`1.get_InternalContext()
at System.Data.Entity.Internal.Linq.InternalSet`1.ExecuteSqlQueryAsync(String sql, Boolean asNoTracking, Nullable`1 streaming, Object[] parameters)
at System.Data.Entity.Internal.InternalSqlSetQuery.GetAsyncEnumerator()
at System.Data.Entity.Infrastructure.DbRawSqlQuery`1.System.Data.Entity.Infrastructure.IDbAsyncEnumerable<TElement>.GetAsyncEnumerator()
at System.Data.Entity.Infrastructure.IDbAsyncEnumerableExtensions.ForEachAsync[T](IDbAsyncEnumerable`1 source, Action`1 action, CancellationToken cancellationToken)
at System.Data.Entity.Infrastructure.IDbAsyncEnumerableExtensions.ToListAsync[T](IDbAsyncEnumerable`1 source, CancellationToken cancellationToken)
at System.Data.Entity.Infrastructure.IDbAsyncEnumerableExtensions.ToListAsync[T](IDbAsyncEnumerable`1 source)
at System.Data.Entity.Infrastructure.DbRawSqlQuery`1.ToListAsync()
at m2a.Repositories.Repository.<GetCallbacks>d__2.MoveNext() in C:\Users\JNyingi\source\repos\m2a\Repositories\Repository.cs:line 38