SignalR + EF - automatyczne pobieranie swiezych danych z DB

  private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
        {
            if (e.Type == SqlNotificationType.Change)
            {
                MessageHub.SendMessages();
            }
        }

var repo = new MessageRepository();
            var data = repo.GetAllMessages();

 public class DatabaseContext: DbContext
    {
        public DatabaseContext()
            : base("DefaultConnection")
        {
        }
   
        public DbSet<Raport> Raports{ get; set; }

        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            modelBuilder.Conventions.Remove<PluralizingTableNameConvention>();
        }
    }

 public IEnumerable<Raport> GetAllRaports()
        {
            IList<Raport> raports;

            using (var db = new InformationSystemEntities())
            {
                db.Database.Connection.Open();
                raports = (from s in db.Raports
                    select s).ToList();
                db.Database.Connection.Close();
                return raports;
            }
        }

  public static IEnumerable<Raport> GetRaports()
        {
            ObjectSet<Raport> objectSet = null;
            IList<Raport> raportData = HttpContext.Current.Cache.Get("Raport") as IList<Raport>;
            if (raportData == null)
            {
                using (var context = new InformationSystemEntities())
                {
                    IQueryable<Raport> categoryDataCache = context.Raports;
                    using (SqlConnection connection = new SqlConnection(connectionString.ProviderConnectionString))
                    {
                        connection.Open();
                        var db = new DatabaseContext();
                        ObjectContext objectContext = ((IObjectContextAdapter)db).ObjectContext;
                        objectSet = objectContext.CreateObjectSet<Raport>("Raports");
                        connection.Close();
                      
                   /*     SqlCommand command = new SqlCommand(((ObjectQuery)categoryDataCache).ToTraceString(), connection);
                        SqlCacheDependency dependency = new SqlCacheDependency(command);
                        raportData = categoryDataCache.ToList();
                        HttpContext.Current.Cache.Insert("Raport", raportData, dependency);
                        command.ExecuteNonQuery();
                    */
                    }
                }
            }

            return objectSet;

 private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
        {
            if (e.Type == SqlNotificationType.Change)
            {
                MessageHub.SendMessages();
            }
        }

   public IEnumerable<Raport> GetAllMessages1()
        {
            var messages = new List<Raport>();
            using (var connection = new SqlConnection(_connString))
            {
                connection.Open();
                using (var command = new SqlCommand(@"SELECT [Id], [What]  FROM [dbo].[Raport]", connection))
                {
                    command.Notification = null;

                    var dependency = new SqlDependency(command);
                    dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);

                    if (connection.State == ConnectionState.Closed)
                        connection.Open();

                    var reader = command.ExecuteReader();

                    while (reader.Read())
                    {
                        messages.Add(item: new Raport
                        {
                            Id= (int)reader["Id"], 
                            What = (string)reader["What"],
                            Where = "",//(string)reader["Where"], 
                            Project = "",//(string)reader["Project"],
                            Who = "",//(string) reader["Who"],
                            When = DateTime.Now,// Convert.ToDateTime(reader["When"]),
                            How = "",//(string)reader["How"],
                            Asset = "",//(string)reader["Asset"],
                            Name = "",//(string)reader["Name"],
                            Item = "",//(string)reader["Item"],
                            ItemId = "",//(string)reader["ItemId"],
                            Notes = ""//(string)reader["Notes"]
                        });
                    }
                }

            }
            return messages;


        }

using (var notifier = new EntityChangeNotifier<Raport, InformationSystemEntities>(x => x.Id > 0))
            {
                notifier.Changed += (sender, e) =>
                {
                    IMessageHub<IEnumerable<Raport>> hub = new MessageHub();
                    hub.SendMessages(e.Results);

                    foreach (var et in e.Results)
                    {
                        raports.Add(et);
                    }
                };
            }
 

 
Results = GetCurrent()

 
Results = GetCurrentLatest()