Skip to content

Commit

Permalink
Added Caching ability to ExcelRepository
Browse files Browse the repository at this point in the history
  • Loading branch information
@shashankshetty
shashankshetty committed Aug 1, 2009
1 parent 99a47c3 commit f102e51
Show file tree
Hide file tree
Showing 2 changed files with 121 additions and 104 deletions.
Binary file modified lib/ExcelToDTOMapper.DTO.dll
View file
Binary file not shown.
225 changes: 121 additions & 104 deletions src/ExcelMapper/Repository/ExcelRepository.cs
View file
Expand Up @@ -5,123 +5,140 @@
using System.Linq;
using System.Reflection;
using System.Text;

using ExcelMapper.Configuration;
using ExcelMapper.Repository.Connection;
using ExcelMapper.Repository.Extensions;

using RunTimeCodeGenerator.ClassGeneration;

namespace ExcelMapper.Repository
{
public class ExcelRepository : IRepository
{
private readonly IConnectionBuilder _connectionBuilder;
private readonly IFileConfiguration _fileConfiguration;
public class ExcelRepository : IRepository
{
private readonly IConnectionBuilder _connectionBuilder;
private readonly IFileConfiguration _fileConfiguration;
private readonly Dictionary<string, object> _resultCache;

public ExcelRepository(IConnectionBuilder connectionBuilder, IFileConfiguration fileConfiguration)
{
_connectionBuilder = connectionBuilder;
_fileConfiguration = fileConfiguration;
}
public ExcelRepository(IConnectionBuilder connectionBuilder, IFileConfiguration fileConfiguration)
{
_connectionBuilder = connectionBuilder;
_fileConfiguration = fileConfiguration;
_resultCache = new Dictionary<string, object>();
}

public IEnumerable<string> GetWorkSheetNames()
{
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
DataTable schemaTable = connection.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, null);
if (schemaTable != null)
{
for (int i = 0; i < schemaTable.Rows.Count; i++)
{
yield return schemaTable.Rows[i]["TABLE_NAME"].ToString();
}
}
}
}
public IEnumerable<string> GetWorkSheetNames()
{
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
DataTable schemaTable = connection.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, null);
if (schemaTable != null)
{
for (int i = 0; i < schemaTable.Rows.Count; i++)
{
yield return schemaTable.Rows[i]["TABLE_NAME"].ToString();
}
}
}
}

public ClassAttributes GetDTOClassAttributes(string workSheet)
{
string className = workSheet.Replace("$", "");
ClassAttributes classAttributes = new ClassAttributes(className);
public ClassAttributes GetDTOClassAttributes(string workSheet)
{
string className = workSheet.Replace("$", "");
ClassAttributes classAttributes = new ClassAttributes(className);

using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
using (OleDbCommand command = connection.CreateCommand())
{
command.CommandText = String.Format("SELECT * FROM [{0}]", workSheet);
using (OleDbDataReader reader = command.ExecuteReader())
{
if (reader.Read())
{
for (int i = 0; i < reader.FieldCount; i++)
{
classAttributes.Properties.Add(new Property(reader.GetFieldType(i).ToString(),
reader.GetName(i)));
}
}
}
}
}
return classAttributes;
}
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
using (OleDbCommand command = connection.CreateCommand())
{
command.CommandText = String.Format("SELECT * FROM [{0}]", workSheet);
using (OleDbDataReader reader = command.ExecuteReader())
{
if (reader.Read())
{
for (int i = 0; i < reader.FieldCount; i++)
{
classAttributes.Properties.Add(new Property(reader.GetFieldType(i).ToString(),
reader.GetName(i)));
}
}
}
}
}
return classAttributes;
}

public IEnumerable<T> Get<T>(string workSheet)
{
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
using (OleDbCommand command = connection.CreateCommand())
{
command.CommandText = String.Format("SELECT * FROM [{0}$]", workSheet);
using (OleDbDataReader reader = command.ExecuteReader())
{
PropertyInfo[] properties = typeof (T).GetProperties();
public IEnumerable<T> Get<T>(string workSheet)
{

object cachedList;
if (!_resultCache.TryGetValue(workSheet, out cachedList))
{
List<T> resultToStore = new List<T>();
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
using (OleDbCommand command = connection.CreateCommand())
{
command.CommandText = String.Format("SELECT * FROM [{0}$]", workSheet);
using (OleDbDataReader reader = command.ExecuteReader())
{
PropertyInfo[] properties = typeof(T).GetProperties();

while (reader.Read())
{
T instance = Activator.CreateInstance<T>();
for (int i = 0; i < reader.FieldCount; i++)
{
int index = i;
PropertyInfo property = properties.Single(p => p.Name.Equals(reader.GetName(index)));
property.SetValue(instance, reader.GetValue<object>(i), null);
}
yield return instance;
}
}
}
}
}
while (reader.Read())
{
T instance = Activator.CreateInstance<T>();
for (int i = 0; i < reader.FieldCount; i++)
{
int index = i;
PropertyInfo property = properties.Single(p => p.Name.Equals(reader.GetName(index)));
property.SetValue(instance, reader.GetValue<object>(i), null);
}
resultToStore.Add(instance);
}
}
}
}
cachedList = resultToStore;
_resultCache.Add(workSheet, cachedList);
}
IEnumerable<T> resultList = (IEnumerable<T>)cachedList;
foreach (T result in resultList)
{
yield return result;
}
}

private static string ConstructQueryValues(int length)
{
StringBuilder query = new StringBuilder();
for (int i = 0; i < length - 1; i++)
{
query.Append("?, ");
}
query.Append("?");
return query.ToString();
}
private static string ConstructQueryValues(int length)
{
StringBuilder query = new StringBuilder();
for (int i = 0; i < length - 1; i++)
{
query.Append("?, ");
}
query.Append("?");
return query.ToString();
}

public void Put<T>(IEnumerable<T> values)
{
PropertyInfo[] properties = typeof (T).GetProperties();
string query = String.Format("INSERT INTO [{0}$] VALUES ({1})", typeof (T).Name,
ConstructQueryValues(properties.Length));
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
using (OleDbCommand command = connection.CreateCommand())
{
command.CommandText = query;
foreach (var value in values)
{
foreach (var property in properties)
{
command.Parameters.AddWithValue(property.Name, property.GetValue(value, null));
}
command.ExecuteNonQuery();
}
}
}
}
}
public void Put<T>(IEnumerable<T> values)
{
PropertyInfo[] properties = typeof(T).GetProperties();
string query = String.Format("INSERT INTO [{0}$] VALUES ({1})", typeof(T).Name,
ConstructQueryValues(properties.Length));
using (OleDbConnection connection = _connectionBuilder.GetConnection(_fileConfiguration.FileName))
{
using (OleDbCommand command = connection.CreateCommand())
{
command.CommandText = query;
foreach (var value in values)
{
foreach (var property in properties)
{
command.Parameters.AddWithValue(property.Name, property.GetValue(value, null));
}
command.ExecuteNonQuery();
}
}
}
}
}
}

0 comments on commit f102e51

Please sign in to comment.