进行Windows Mobile的应用的开发，很多时候需要对数据库进行访问，存储和读取。可是微软没有为Native C++提供象ADO.NET下的封装，所以我自己封装了一个SqlCe访问类。

简述

本文讲述在Windows Mobile和Wince下，Native C++访问SqlCe的封装类的实现。由于微软没有为C++提供像ADO.NET的封装，为Native C++访问SqlCe制造了一定的难度，因此对OleDB访问SqlCe进行封装，方便使用SQL语句对SqlCe进行操作。

SqlCe访问技术概述

ADO.NET

.NET Compact Framework逐渐成为Windows Mobile和Wince的开发的主流，微软为CF.NET提供了ADO.NET访问SqlCe，对SqlCe的访问封装在System.Data.SqlServerCe下，和其他数据库(SQL Server, Oracle)访问基本兼容，但是不支持DbProviderFactory。例如下面的代码不能通过编译，因为没有SqlCeProviderFactory类。

DbProviderFactory factory = SqlCeProviderFactory.Instance;

我之前封装了一个ADO.NET的SqlCe访问类，可以参考 .NET Compact Framework下SQL CE的使用 和 实现了SqlCeHepler的单元测试类见.NET Compact Framework下的单元测试。

OleDb

在Native的世界，可以通过OleDb来访问SqlCe。OleDb封装在sqlceoledb35.dll下，使用OleDb需要安装一个Cab包如下：

C:\Program Files\Microsoft SQL Server Compact Edition\v3.5\Devices\wce500\armv4i\sqlce.repl.ppc.wce5.armv4i.CAB

上述路径根据平台有所不同。

注意上述sqlceoledb35.dll只是支持SqlCe 3.5，微软对不同版本的SqlCe的兼容性不是很好，可以参考 SQL Server Express和SQL Server Compact的应用 和 .NET Campact Framework下SQL CE兼容性问题 了解SqlCe的历史我兼容性问题。

本文后续会重点讲述OleDb。

ADO

在Windows Mobile和Wince平台，微软官方不支持ADO。但是有一个社区实现，可以参考 A set of ADOCE classes。我没有试过，所以不好评论。

实现

下面讲述如何基于OleDb实现对SqlCe的访问。

文档和Samples

微软提供了在线文档，可以在 Microsoft SQL Server Compact 3.5 Books Online and Samples下载。上述链接只是包含在线文档，没有提供例子程序的，所以这个名字有点骗人感情之嫌。虽然提供了在线文档，但是文档的质量不高，有些细节没讲，例如调用ICommand::Execute的入口参数就没有讲，我做的时候只能自己试。

虽然上面的链接不提供Samples，但是我们还有另外一个方法取得Samples。在

C:\Program Files\Microsoft SQL Server 2005 Mobile Edition\Samples\NorthwindOleDb

下可以得到Sample代码，前提是安装了Microsoft SQL Server 2005 Mobile Edition。但是要注意不同SqlCe版本实现有所不同，这个代码要结合上面的Online book修改才行。

基于SQL语句的实现

微软的例子程序NorthwindOleDb提供了通过OleDb访问SqlCe的方法，但是不提供对SQL语句的封装，直接对表的访问效率比较高，但是也有很大的不便性。因为每个操作都单独封装一个函数，每个函数大概至少需要100行代码，而且有指针等资源的分配，释放等操作，一旦没有处理好就发生内存泄漏了。所以我偏向于使用统一的SQL语句接口对SqlCe进行操作，虽然牺牲了点性能，却提供了方便性。下面是当前版本的封装类。这个类是基于João Paulo Figueira 的OleDbClientLib3实现的。

打开关闭

bool Open(const CString& dbPath);
void Close();

上面为打开和关闭SqlCe数据库链接的操作，这里实现为长链接，也就是不调用Close()的话，数据库的Session一直链接着，这样的好处是缩短访问时间。

新建删除

bool CreateDatabase(const CString& dbPath);
bool DeleteDatabase(const CString& dbPath);

由于SqlCe是in-process数据库，物理上表现为就一个文件，可以方便新建和删除，上述接口就是新建和删除SqlCe数据库，新建后自动打开数据库的Senssion了。

增删改操作

int  ExecuteNonQuery(const CString& sql);

把增删改的语句调用ExecuteNonQuery()执行就可以了。

SqlCeHelper db;
HRESULT hr = db.Open(DB_FILE_NAME);
if(hr < 0)
{
    CString cstr = db.GetErrorsMessage();
char* str = new char[cstr.GetLength()+1];
    sprintf(str, "%S", cstr);
    FAIL(str);
delete str;
}

CString sqlStr;
for(int i=0; i<max; ++i)
{
    SYSTEMTIME currentTime;    
    GetLocalTime(&currentTime);
    sqlStr.Format(L"INSERT INTO T1 (F1, F2, F3) VALUES(%d, 'STR%d', '%d-%d-%d %d:%d:%d')", 
        i, i, currentTime.wYear, currentTime.wMonth, currentTime.wDay, currentTime.wHour, currentTime.wMinute, currentTime.wSecond);
    hr = db.ExecuteNonQuery(sqlStr);
if(hr < 0)
    {
        CString cstr = db.GetErrorsMessage();
char* str = new char[cstr.GetLength()+1];
        sprintf(str, "%S", cstr);
        FAIL(str);
delete str;
    }
}

db.Close();

上面是一个Insert语句的例子。

事务处理

void BeginTransaction();
void CommitTransaction();
void RollbackTransaction();

但是当前版本还没有事务支持。

查询操作

其实这么多操作之中查询操作的实现是最复杂的。

int     ExecuteReader(const CString& sql);

执行ExecuteReader()会根据select语句初始化一个结果集，和ADO.net的实现不一样，这个结果集不是直接通过DataSet或者DataReader来返回的，而是保持在内部的IRowset的结构里面。为了方便使用，SqlCeHelper实现了一个只读，向前的数据读取方法。

bool IsEndOfRecordSet();
void MoveNext();
void CloseReader();

int        GetRowInt(const long ordinal);
double    GetRowDouble(const long ordinal);
CString    GetRowStr(const long ordinal);

当调用ExecuteReader()后，可以调用IsEndOfRecordSet()判断结果集是否为空。MoveNext()为移动到下一条记录。GetRowInt(), GetRowDouble()和 GetRowStr()为读取当前记录的数据。CloseReader()关闭结果集。

    SqlCeHelper db;
    HRESULT hr = db.Open(DB_FILE_NAME);
if(hr < 0)
    {
        CString cstr = db.GetErrorsMessage();
char* str = new char[cstr.GetLength()+1];
        sprintf(str, "%S", cstr);
        FAIL(str);
delete str;
    }

    CString sqlStr;
    sqlStr.Format(L"SELECT * FROM T1");
    hr = db.ExecuteReader(sqlStr);
if(hr < 0)
    {
        CString cstr = db.GetErrorsMessage();
char* str = new char[cstr.GetLength()+1];
        sprintf(str, "%S", cstr);
        FAIL(str);
delete str;
    }

while(!db.IsEndOfRecordSet())
    {
        wprintf(L"F1=[%d], F2=[%s], F3=[%s]\n", db.GetRowInt(1), db.GetRowStr(2), db.GetRowStr(3));
        db.MoveNext();
    }
    db.CloseReader();
    db.Close();

上面演示整个读取过程。

Unit Test

TO-DO-LIST

**Support to open the database with password
**Support to specify the Open Mode
**Support to load Ole Db without COM registry.
**Support Transactions
**Support Parameters

关于项目

我把项目host到codeplex了，项目主页链接如下：

SqlCeHelper - Native C++ SQL Helper class for SQL Server Compact

检查和下载最新版本链接如下

http://sqlcehelper.codeplex.com/SourceControl/ListDownloadableCommits.aspx