Skip to content

D
Dapper
Commit 7b502dbc authored by mgravell's avatar mgravell
Browse files
Options

cache query methods

parent 90ae2256
Hide whitespace changes
Inline Side-by-side
Showing with 85 additions and 41 deletions
Dapper/SqlMapper.cs
View file @ 7b502dbc
...@@ -110,6 +110,9 @@ class CacheInfo ...@@ -110,6 +110,9 @@ class CacheInfo
public object Deserializer { get; set; } public object Deserializer { get; set; }
public object[] OtherDeserializers { get; set; } public object[] OtherDeserializers { get; set; }
public Action<IDbCommand, object> ParamReader { get; set; } public Action<IDbCommand, object> ParamReader { get; set; }
private int hitCount;
public int GetHitCount() { return Interlocked.CompareExchange(ref hitCount, 0, 0); }
public void RecordHit() { Interlocked.Increment(ref hitCount); }
} }
#if CSHARP30 #if CSHARP30
private static readonly Dictionary<Identity, CacheInfo> _queryCache = new Dictionary<Identity, CacheInfo>(); private static readonly Dictionary<Identity, CacheInfo> _queryCache = new Dictionary<Identity, CacheInfo>();
...@@ -136,54 +139,95 @@ private static void SetQueryCache(Identity key, CacheInfo value) ...@@ -136,54 +139,95 @@ private static void SetQueryCache(Identity key, CacheInfo value)
} }
private static bool TryGetQueryCache(Identity key, out CacheInfo value) private static bool TryGetQueryCache(Identity key, out CacheInfo value)
{ {
return _queryCache.TryGetValue(key, out value); if(_queryCache.TryGetValue(key, out value))
{
value.RecordHit();
return true;
}
value = null;
return false;
} }
private static void PurgeQueryCache(Identity key) private static void PurgeQueryCache(Identity key)
{ {
CacheInfo info; CacheInfo info;
_queryCache.TryRemove(key, out info); _queryCache.TryRemove(key, out info);
} }
public static int GetCachedSQLCount()
{
return _queryCache.Count;
}
public static IEnumerable<Tuple<string, string, int>> GetCachedSQL(int ignoreHitCountAbove = int.MaxValue)
{
var data = _queryCache.Select(pair => Tuple.Create(pair.Key.connectionString, pair.Key.sql, pair.Value.GetHitCount()));
if (ignoreHitCountAbove < int.MaxValue) data = data.Where(tuple => tuple.Item3 <= ignoreHitCountAbove);
return data;
}
public static IEnumerable<Tuple<int,int>> GetHashCollissions()
{
var counts = new Dictionary<int, int>();
foreach(var key in _queryCache.Keys)
{
int count;
if(!counts.TryGetValue(key.hashCode, out count))
{
counts.Add(key.hashCode, 1);
} else
{
counts[key.hashCode] = count + 1;
}
}
return from pair in counts
where pair.Value > 1
select Tuple.Create(pair.Key, pair.Value);
}
#endif #endif
static readonly Dictionary<RuntimeTypeHandle, DbType> typeMap;
static readonly Dictionary<Type, DbType> typeMap;
static SqlMapper() static SqlMapper()
{ {
typeMap = new Dictionary<RuntimeTypeHandle, DbType>(); typeMap = new Dictionary<Type, DbType>();
typeMap[typeof(byte).TypeHandle] = DbType.Byte; typeMap[typeof(byte)] = DbType.Byte;
typeMap[typeof(sbyte).TypeHandle] = DbType.SByte; typeMap[typeof(sbyte)] = DbType.SByte;
typeMap[typeof(short).TypeHandle] = DbType.Int16; typeMap[typeof(short)] = DbType.Int16;
typeMap[typeof(ushort).TypeHandle] = DbType.UInt16; typeMap[typeof(ushort)] = DbType.UInt16;
typeMap[typeof(int).TypeHandle] = DbType.Int32; typeMap[typeof(int)] = DbType.Int32;
typeMap[typeof(uint).TypeHandle] = DbType.UInt32; typeMap[typeof(uint)] = DbType.UInt32;
typeMap[typeof(long).TypeHandle] = DbType.Int64; typeMap[typeof(long)] = DbType.Int64;
typeMap[typeof(ulong).TypeHandle] = DbType.UInt64; typeMap[typeof(ulong)] = DbType.UInt64;
typeMap[typeof(float).TypeHandle] = DbType.Single; typeMap[typeof(float)] = DbType.Single;
typeMap[typeof(double).TypeHandle] = DbType.Double; typeMap[typeof(double)] = DbType.Double;
typeMap[typeof(decimal).TypeHandle] = DbType.Decimal; typeMap[typeof(decimal)] = DbType.Decimal;
typeMap[typeof(bool).TypeHandle] = DbType.Boolean; typeMap[typeof(bool)] = DbType.Boolean;
typeMap[typeof(string).TypeHandle] = DbType.String; typeMap[typeof(string)] = DbType.String;
typeMap[typeof(char).TypeHandle] = DbType.StringFixedLength; typeMap[typeof(char)] = DbType.StringFixedLength;
typeMap[typeof(Guid).TypeHandle] = DbType.Guid; typeMap[typeof(Guid)] = DbType.Guid;
typeMap[typeof(DateTime).TypeHandle] = DbType.DateTime; typeMap[typeof(DateTime)] = DbType.DateTime;
typeMap[typeof(DateTimeOffset).TypeHandle] = DbType.DateTimeOffset; typeMap[typeof(DateTimeOffset)] = DbType.DateTimeOffset;
typeMap[typeof(byte[]).TypeHandle] = DbType.Binary; typeMap[typeof(byte[])] = DbType.Binary;
typeMap[typeof(byte?).TypeHandle] = DbType.Byte; typeMap[typeof(byte?)] = DbType.Byte;
typeMap[typeof(sbyte?).TypeHandle] = DbType.SByte; typeMap[typeof(sbyte?)] = DbType.SByte;
typeMap[typeof(short?).TypeHandle] = DbType.Int16; typeMap[typeof(short?)] = DbType.Int16;
typeMap[typeof(ushort?).TypeHandle] = DbType.UInt16; typeMap[typeof(ushort?)] = DbType.UInt16;
typeMap[typeof(int?).TypeHandle] = DbType.Int32; typeMap[typeof(int?)] = DbType.Int32;
typeMap[typeof(uint?).TypeHandle] = DbType.UInt32; typeMap[typeof(uint?)] = DbType.UInt32;
typeMap[typeof(long?).TypeHandle] = DbType.Int64; typeMap[typeof(long?)] = DbType.Int64;
typeMap[typeof(ulong?).TypeHandle] = DbType.UInt64; typeMap[typeof(ulong?)] = DbType.UInt64;
typeMap[typeof(float?).TypeHandle] = DbType.Single; typeMap[typeof(float?)] = DbType.Single;
typeMap[typeof(double?).TypeHandle] = DbType.Double; typeMap[typeof(double?)] = DbType.Double;
typeMap[typeof(decimal?).TypeHandle] = DbType.Decimal; typeMap[typeof(decimal?)] = DbType.Decimal;
typeMap[typeof(bool?).TypeHandle] = DbType.Boolean; typeMap[typeof(bool?)] = DbType.Boolean;
typeMap[typeof(char?).TypeHandle] = DbType.StringFixedLength; typeMap[typeof(char?)] = DbType.StringFixedLength;
typeMap[typeof(Guid?).TypeHandle] = DbType.Guid; typeMap[typeof(Guid?)] = DbType.Guid;
typeMap[typeof(DateTime?).TypeHandle] = DbType.DateTime; typeMap[typeof(DateTime?)] = DbType.DateTime;
typeMap[typeof(DateTimeOffset?).TypeHandle] = DbType.DateTimeOffset; typeMap[typeof(DateTimeOffset?)] = DbType.DateTimeOffset;
typeMap[typeof(System.Data.Linq.Binary).TypeHandle] = DbType.Binary; typeMap[typeof(System.Data.Linq.Binary)] = DbType.Binary;
} }
private static DbType LookupDbType(Type type, string name) private static DbType LookupDbType(Type type, string name)
...@@ -195,7 +239,7 @@ private static DbType LookupDbType(Type type, string name) ...@@ -195,7 +239,7 @@ private static DbType LookupDbType(Type type, string name)
{ {
type = Enum.GetUnderlyingType(type); type = Enum.GetUnderlyingType(type);
} }
if (typeMap.TryGetValue(type.TypeHandle, out dbType)) if (typeMap.TryGetValue(type, out dbType))
{ {
return dbType; return dbType;
} }
...@@ -256,9 +300,9 @@ public override bool Equals(object obj) ...@@ -256,9 +300,9 @@ public override bool Equals(object obj)
} }
internal readonly string sql; internal readonly string sql;
internal readonly CommandType? commandType; internal readonly CommandType? commandType;
private readonly int hashCode, gridIndex; internal readonly int hashCode, gridIndex;
private readonly Type type; private readonly Type type;
private readonly string connectionString; internal readonly string connectionString;
internal readonly Type parametersType; internal readonly Type parametersType;
public override int GetHashCode() public override int GetHashCode()
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment