代码之家 › 专栏 › 技术社区 › merimini

AppFabric ReadThrough实现如何获取数据?

appfabric-cache appfabric sql-server asp.net c#

0

merimini · 技术社区 · 10 年前

我正在尝试使用AppFabric来加快从SQL数据库检索图像的速度。我创建了提供者文件并将其加载到缓存中。然而,我现在正在挣扎。

如何使用提供程序文件从缓存中调用get函数,或者在检索数据时是否需要使用我的提供程序文件?

当我调用.Get(key.key)时,是否需要查看来自数据库的数据?

提供程序的My Read方法如下所示,是否正确?

public override DataCacheItem Read(DataCacheItemKey key)
    {       
        try
        {
            Object retrievedValue = null;
            DataCacheItem cacheItem;

            retrievedValue = *Running SQL Query Retrieving Image from DB*;//Is that a correct approach? 

            if (retrievedValue == null)
                cacheItem = null;
            else
                cacheItem = DataCacheItemFactory.GetCacheItem(key, cacheName, retrievedValue, null);
            return cacheItem;
        }
        catch
        {
            return null;
        }
    }

1 回复 | 直到 10 年前

1

0

Asif Abdulla 10 年前

Example:>

using Microsoft.ApplicationServer.Caching;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data.SqlClient;

namespace SampleProvider
{
  public class Provider : DataCacheStoreProvider
  {
    private readonly String dataCacheName;
    private readonly Dictionary<string, string> config;

    public Provider(string cacheName, Dictionary<string, string> config)
    {
      this.dataCacheName = cacheName; //Store the cache name for future use
      this.config = config;
    }

    public override DataCacheItem Read(DataCacheItemKey key)
    {
      Object retrievedValue = null;
      DataCacheItem cacheItem;

      retrievedValue = ReadFromDatabase(key.Key); //Your implemented method that searches in the backend store based

      if (retrievedValue == null)
        cacheItem = null;
      else
        cacheItem = DataCacheItemFactory.GetCacheItem(key, dataCacheName, retrievedValue, null);
      return cacheItem;
    }
    public override void Read(System.Collections.ObjectModel.ReadOnlyCollection<DataCacheItemKey> keys, IDictionary<DataCacheItemKey, DataCacheItem> items)
    {
      foreach (var key in keys)
      {
        items[key] = Read(key);
      }
    }

    public override void Delete(System.Collections.ObjectModel.Collection<DataCacheItemKey> keys) { }

    public override void Delete(DataCacheItemKey key) { }

    protected override void Dispose(bool disposing) { }

    public override void Write(IDictionary<DataCacheItemKey, DataCacheItem> items) { }

    public override void Write(DataCacheItem item) { }


    private string ReadFromDatabase(string key)
    {
      string value = string.Empty;
      object retrievedValue = null;
      using (SqlConnection connection = new SqlConnection(config["DBConnection"]))
      {
        SqlCommand cmd = new SqlCommand();
        cmd.CommandText = string.Format("select Value from KeyValueStore where [Key] = '{0}'", key);
        cmd.Connection = connection;
        connection.Open();
        retrievedValue = cmd.ExecuteScalar();
        if (retrievedValue != null)
        {
          value = retrievedValue.ToString();
        }
      }

      return value;
    }
  }
}