操作 SQL Server Mobile 2005 数据库的常用 C# 代码

整理几段操作 SQL Server Mobile 数据库的常用 C# 代码，供刚刚接触 SQL Server Mobile 开发的朋友参考。

1. 创建数据库

//创建数据库
File.Delete("Test.sdf");
SqlCeEngineengine=newSqlCeEngine(
"DataSource='Test.sdf';LCID=1033;Password=\"s$;2'!dS64\";Encrypt=TRUE;");
engine.CreateDatabase();

2. 验证和修复数据库

//验证和修复数据库
SqlCeEngineengine=newSqlCeEngine("DataSource=AdventureWorks.sdf");
if(false==engine.Verify())
{
MessageBox.Show("Databaseiscorrupted.");
engine.Repair(null,RepairOption.RecoverCorruptedRows);
}

3. 压缩数据库

//压缩数据库
//通过从现有文件新建数据库文件来回收SQLServerMobile数据库中浪费的空间。
//此方法还可用来更改数据库的排序顺序、加密或密码设置。
//该连接字符串指定一个指向将由此方法创建的目标数据库的连接。
//如果指定的数据库已经存在或者具有相同名称的另一文件已经存在，则会引发异常。
//如果为连接字符串传递空字符串，则新的数据库文件将改写旧的数据库文件，
//但名称保持不变。
SqlCeEngineengine=newSqlCeEngine("DataSource=AdventureWorks.sdf");
//engine.Compact(null);
engine.Compact("DataSource=;Password=a@3!7f$dQ;");

4. 收缩数据库

//收缩数据库
//通过将空页移动到文件的结尾然后截断该文件，
//来回收SQLServerMobile数据库中浪费的空间。
//与Compact方法不同，Shrink方法不创建临时数据库文件，
//而是将所有空页和未分配的页都移到了文件的结尾，然后截断，从而减小数据库的总大小。
SqlCeEngineengine=newSqlCeEngine("DataSource=AdventureWorks.sdf");
engine.Shrink();

5. 合并复制

// 合并复制
//实例化并配置SqlCeReplication对象
SqlCeReplicationrepl=newSqlCeReplication();
repl.InternetUrl="http://www.adventure-works.com/sqlmobile/sqlcesa30.dll";
repl.InternetLogin="MyInternetLogin";
repl.InternetPassword="<password>";
repl.Publisher="MyPublisher";
repl.PublisherDatabase="MyPublisherDatabase";
repl.PublisherLogin="MyPublisherLogin";
repl.PublisherPassword="<password>";
repl.Publication="MyPublication";
repl.Subscriber="MySubscriber";
repl.SubscriberConnectionString="DataSource=MyDatabase.sdf";

//创建一个本地SQLServerMobile数据库的订阅
repl.AddSubscription(AddOption.CreateDatabase);

//跟SQLServer数据库进行同步
repl.Synchronize();

//清理repl对象
repl.Dispose();

6. 远程数据访问（RDA）

// 远程数据访问
//实例化并配置SqlCeRemoteDataAccess对象
SqlCeRemoteDataAccessrda=newSqlCeRemoteDataAccess();
rda.InternetUrl="http://www.adventure-works.com/sqlmobile/sqlcesa30.dll";
rda.InternetLogin="MyInternetLogin";
rda.InternetPassword="<password>";
rda.LocalConnectionString="DataSource=MyDatabase.sdf";

//从SQLServer下载数据
rda.Pull(
"Employees",
"SELECT*FROMDimEmployee",
"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;",
RdaTrackOption.TrackingOnWithIndexes,
"ErrorTable");

//
//修改本地数据
//

//将已修改的数据上传到SQLServer
rda.Push(
"DimEmployee",
"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;");

//提交SQL语句在SQLServer上执行
rda.SubmitSql(
"CREATETABLEMyRemoteTable(colAint)",
"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;");

7. 使用 SqlCeResultSet

// 使用 SqlCeResultSet
//创建SQLServerMobile数据库连接
SqlCeConnectionconn=newSqlCeConnection("DataSource=Northwind.sdf");

//创建并配置SqlCeCommand对象
SqlCeCommandcmd=conn.CreateCommand();
cmd.CommandText="SELECT*FROMOrders";

//创建SqlCeResultSet对象，并配置为可滚动、可更新、检测数据源更改
ResultSetOptionsoptions=ResultSetOptions.Scrollable|
ResultSetOptions.Sensitive|
ResultSetOptions.Updatable;
SqlCeResultSetresultSet=cmd.ExecuteResultSet(options);

//创建ResultSetView对象，配置为只显示序号为1,3,5,8的列
ResultSetViewresultSetView=resultSet.ResultSetView;
int[]ordinals=newint[]{1,3,5,8};
resultSetView.Ordinals=ordinals;

//将ResultSetView绑定到DataGrid控件
this.dataGrid.DataSource=resultSetView;

8. 处理 SqlCeException

//处理 SqlCeException
publicstaticvoidShowErrors(SqlCeExceptione)
{
SqlCeErrorCollectionerrorCollection=e.Errors;

StringBuilderbld=newStringBuilder();
Exceptioninner=e.InnerException;

foreach(SqlCeErrorerrinerrs)
{
//标识错误类型的HRESULT值，这些错误不是SQLServerCE固有的
bld.Append("\r\nErrorCode:").Append(err.HResult.ToString("X"));
//对错误进行描述的文本
bld.Append("\r\nMessage:").Append(err.Message);
//获取SqlCeError的本机错误号
bld.Append("\r\nMinorErr.:").Append(err.NativeError);
//生成错误的提供程序的名称
bld.Append("\r\nSource:").Append(err.Source);

//遍历前三个错误参数。SQLServerCE使用错误参数来提供有关错误的其他详细信息。
foreach(intnumParainerr.NumericErrorParameters)
{
//虽然错误可能存在参数，但并非发生的所有错误都返回参数。
//如果发生某个错误时没有返回任何参数，则该数组的值为0。
if(numPara!=0)
{
bld.Append("\r\nNum.Par.:").Append(numPara);
}
}

//遍历最后三个错误参数。SQLServerCE使用错误参数来提供有关错误的其他详细信息。
foreach(stringerrParainerr.ErrorParameters)
{
//虽然错误可能存在参数，但并非发生的所有错误都返回参数。
//如果发生某个错误时没有返回任何参数，则该数组的值将为空字符串。
if(errPara!=String.Empty)
{
bld.Append("\r\nErr.Par.:").Append(errPara);
}
}
}

MessageBox.Show(bld.ToString());
}