每一块缓存对象，在数据库中会产生一个表，而表名称是有缓存控制器自动生成的，访问缓存的工作全部交由缓存控制器完成，通过缓存项的ID和ModuleKey来访问。

在sqlite中还需要一个系统表来维护每个缓存项和实际缓存存储表之间的对应关系，我们称之为配置表，它将在缓存控制器创建sqlite缓存数据库文件时创建。

配置表共有以下几个字段，分别和缓存对象模型CdlCacheItem类映射：

创建数据库的方法如下

    
    

     
     
staticvoidCreateDB() 
     
     
{ 
     
     
//总共有ID、ModuleKey、Comments、AddDate这几列 
     
     
stringsql="CREATETABLESYSCDLTABLES(ID
     
     
INTEGERNOTNULLPRIMARYKEYAUTOINCREMENTUNIQUE,MODULEKEYVARCHAR(200),
     
     
COMMENTSVARCHAR(500),TABLENAMEVARCHAR(100),ADDDATEDATETIME)"; 
     
     
sqliteDBHelper.CreateDB(CACHEFILEPATH,sql); 
     
     
}
    
    

每个缓存项（缓存对象模型）定义如下，和配置表对应：

    
    

     
     
///<summary>
     
     
///缓存项对象 
     
     
///</summary>
     
     
///<Author>TeckyLee</Author>
     
     
///<Date>2011-1-1115:11</Date>
     
     
publicclassCdlCacheItem 
     
     
{ 
     
     
intm_id; 
     
     

     
     
publicintId 
     
     
{ 
     
     
get{returnm_id;} 
     
     
set{m_id=value;} 
     
     
} 
     
     
stringm_moduleKey; 
     
     

     
     
publicstringModuleKey 
     
     
{ 
     
     
get{returnm_moduleKey;} 
     
     
set{m_moduleKey=value;} 
     
     
} 
     
     
stringm_comments; 
     
     

     
     
publicstringComments 
     
     
{ 
     
     
get{returnm_comments;} 
     
     
set{m_comments=value;} 
     
     
} 
     
     
stringm_tableName; 
     
     

     
     
publicstringTableName 
     
     
{ 
     
     
get{returnm_tableName;} 
     
     
set{m_tableName=value;} 
     
     
} 
     
     
DateTimem_timestamp; 
     
     

     
     
publicDateTimeTimestamp 
     
     
{ 
     
     
get{returnm_timestamp;} 
     
     
set{m_timestamp=value;} 
     
     
} 
     
     
}
    
    

下面是控制器的接口定义：

    
    

     
     
publicinterfaceICdlCacheController 
     
     
{ 
     
     
voidBeginLoadRow(); 
     
     
voidEndLoadRow(); 
     
     
System.Collections.Generic.IList<CdlCacheItem>GetCdlCacheItems(stringmoduleKey); 
     
     
CdlCacheItemGetCdlCacheItems(intid); 
     
     
voidLoadRow(System.Data.DataRowrow,stringtableName); 
     
     
voidLoadRow(IEnumerable<object>row,stringtableName); 
     
     
stringLoadTable(System.Data.DataTabledt,stringmoduleKey,stringcomments); 
     
     
System.Data.Common.DbDataReaderQueryCdlTableReader(CdlCacheItemitem); 
     
     
System.Data.DataTableQueryCdlTables(CdlCacheItemitem); 
     
     
System.Data.DataTableQueryCdlTables(stringsql); 
     
     
voidRemoveAllTables(); 
     
     
voidRemoveCdlTables(stringmoduleKey); 
     
     
voidRemoveCdlTables(System.Collections.Generic.IList<CdlCacheItem>items); 
     
     
voidRemoveCdlTables(CdlCacheItemitem); 
     
     
voidRemoveCdlTables(intid); 
     
     
}
    
    

上面的函数下面来做个说明：

1、BeginLoadRow、LoadRow和EndLoadRow，三个函数组为了在我们查询主数据库时使用Reader方式读取数据时，可以一条条将数据同时存放在缓存中。

2、RemoveAllTables和RemoveCdlTables是用来删除缓存项的。

3、GetCdlCacheItems，通过moduleKey得到多个缓存项。比如用户想基于这几天内保存的某个功能的数据做一次快速分析，那么我们就可以通过这个函数得到缓存列表，由用户选择列表中的一个来继续。

4、QueryCdlTableReader，得到某个缓存数据的Reader对象，这样可以一行行的分析，一次读出大数据量的数据到DataTable中，内存可能会溢出的。

5、QueryCdlTables，将某个缓存项查询并装载到DataTable中。

提高缓存数据写入效率@H_403_70@

    
    

     
     
sqliteConnectionm_connection; 
     
     
sqliteCommandm_command; 
     
     
DbTransactionm_transaction; 
     
     
publicvoidBeginLoadRow() 
     
     
{ 
     
     
m_connection=newsqliteConnection("DataSource="+CACHEFILEPATH); 
     
     

     
     
m_connection.Open(); 
     
     
m_transaction=m_connection.BeginTransaction(); 
     
     
m_command=newsqliteCommand(m_connection); 
     
     
} 
     
     
publicvoidEndLoadRow() 
     
     
{ 
     
     
try 
     
     
{ 
     
     
if(m_command!=null) 
     
     
m_command.Dispose(); 
     
     

     
     
if(m_transaction!=null) 
     
     
{ 
     
     
m_transaction.Commit(); 
     
     
} 
     
     

     
     
if(m_connection!=null) 
     
     
{ 
     
     
m_connection.Close(); 
     
     
m_connection.Dispose(); 
     
     
} 
     
     
} 
     
     
catch(System.Exceptionex) 
     
     
{ 
     
     
LogHandle.Error(ex); 
     
     
} 
     
     
}