在MVVM场景中，应如何轮询数据库表以获取“实时”视图？

的确，您ViewModel不应该做“模型”所负责的任何工作，在这种情况下，是数据访问。

确实有很多方法可以实现此目的，但是我将repository pattern围绕您的数据库相关逻辑进行实现。然后将repository依赖项注入您的中ViewModel。

这两个家伙如何交流又是另一个故事。您可以不时地使用Task.Run()不阻塞UI的类似方法要求新数据。

或者，如果你喜欢，你可以做一个单独的“库轮询”，通知ViewModel当数据被质疑，经events，pub/sub和什么，而不是。

因此repository，绕过Plain strings的最小模拟可能看起来像这样。

// repository 
public interface IRepository<T>
{
    Task<IEnumerable<T>> GetAll();
}

// repository impl
public class SimpleRepository : IRepository<string>
{
    private readonly IList<string> _items = new List<string>();

    public SimpleRepository()
    {}

    public Task<IEnumerable<string>> GetAll()
    {
        if (_items.Count > 10)
            _items.Clear();
        _items.Add(string.Format("string{0}", _items.Count));

        Thread.Sleep(250); // queries take some time...
        return Task.FromResult((IEnumerable<string>) _items);
    }
}

例如，只有GetAll()一种方法可以从存储库中返回所有“记录”。

现在您相关的人ViewModel可以按以下方式使用此存储库。

// ViewModelBase just implements the INotifyPropertyChanged
public class MainViewViewModel : ViewModelBase
{
    private ObservableCollection<string> _items;

    public MainViewViewModel()
        : this(new SimpleRepository())
    {}

    // pass in the repository dependency
    public MainViewViewModel(IRepository<string> simpleRepository)
    {
        SimpleRepository = simpleRepository;
        Task.Run(async () =>
            {
                // sophisticated polling logic here
                while (true)
                {
                    // update collection
                    var results = await SimpleRepository.GetAll();
                    Items = new ObservableCollection<string>(results);
                    Thread.Sleep(250);
                }
            });
    }

    public IRepository<string> SimpleRepository { get; set; }

    public ObservableCollection<string> Items
    {
        get { return _items; }
        set { _items = value; OnPropertyChanged();}
    }
}

因此，这将ObservableCollection<T>不时更新，现在逻辑已超出范围ViewModel。XAML如果您想进行测试，请在下面相关。

<Window x:Class="WpfApplication1.View.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        xmlns:viewModel="clr-namespace:WpfApplication1.ViewModel"
        Title="MainWindow"
        Height="300"
        Width="250">
    <Window.DataContext>
        <viewModel:MainViewViewModel />
    </Window.DataContext>

    <Grid Margin="10">
        <ItemsControl ItemsSource="{Binding Items}">
            <ItemsControl.ItemTemplate>
                <DataTemplate>
                    <TextBlock Text="{Binding}"></TextBlock>
                </DataTemplate>
            </ItemsControl.ItemTemplate>
        </ItemsControl>
    </Grid>
</Window>

而且它肯定看起来，感觉和表现专业！:)

如果您也想从中承担投票责任ViewModel，那么您RepositoryPoller可以将自己表现为

// generic poller
public class RepositoryPoller<T>
{
    public event EventHandler<RepositoryEventArgs<T>> OnQueryComplete;
    private readonly System.Timers.Timer _timer;
    private TimeSpan _timeSpan;

    // wire-up poll timer
    public RepositoryPoller()
    {
        _timer = new System.Timers.Timer();
        _timer.Elapsed += (sender, args) => Query();
    }

    // provide poll interval and repository, or set via properties
    public RepositoryPoller(TimeSpan timeSpan, IRepository<T> repository)
        :this()
    {
        TimeSpan = timeSpan;
        Repository = repository;
    }

    public TimeSpan TimeSpan
    {
        get { return _timeSpan; }
        set { _timeSpan = value; _timer.Interval = _timeSpan.TotalMilliseconds; }
    }

    public IRepository<T> Repository { get; set; }

    public void Start()
    {
        if (TimeSpan.TotalMilliseconds > 0)
            _timer.Start();
    }

    public void Stop()
    {
        _timer.Stop();
    }

    // query for data
    private async void Query()
    {
        var results = (await Repository.GetAll()).ToArray();
        RaiseQueryCompleted(results);
        NotifyQueryCompleted(results);
    }

    // send results as event
    private void RaiseQueryCompleted(IEnumerable<T> results)
    {
        var handler = OnQueryComplete;
        if (handler != null)
            handler(this, new RepositoryEventArgs<T>(results));
    }

    // send results as message
    private void NotifyQueryCompleted(IEnumerable<T> results)
    {
        Messenger.Default.Send(new GenericMessage<IEnumerable<T>>(this, results));
    }
}

// event args holding queried items
public class RepositoryEventArgs<T> : EventArgs
{
    public RepositoryEventArgs(IEnumerable<T> result)
    {
        Results = result;
    }

    public IEnumerable<T> Results { get; set; }
}

因此，轮询器将查询给定时间间隔之间的数据，并通过event较旧的然后更松散的耦合message（使用MVVMLight库NuGet依赖项）通知侦听器。

在您中，ViewModel您将像这样使用它

public MainViewViewModel()
    : this(new RepositoryPoller<string>(
          TimeSpan.FromSeconds(0.5d), new SimpleRepository()))
{}

public MainViewViewModel(RepositoryPoller<string> repositoryPoller)
{
    RepositoryPoller = repositoryPoller;

    // If you prefer pub/sub...
    Messenger.Default.Register<GenericMessage<IEnumerable<string>>>(this, message =>
        {
            var results = message.Content;
            Items = new ObservableCollection<string>(results);
        });

    // Or in case events feel more liek home
    RepositoryPoller.OnQueryComplete += (sender, args) =>
        {
            var results = args.Results;
            Items = new ObservableCollection<string>(results);
        };
    RepositoryPoller.Start();
}

public RepositoryPoller<string> RepositoryPoller { get; set; }

希望它能给您一些想法。