1. 創建數據庫
//?創建數據庫
File.Delete("Test.sdf");
SqlCeEngine?engine?=?new?SqlCeEngine(
????"Data?Source='Test.sdf';LCID=1033;Password=\"s$;2'!dS64\";Encrypt=TRUE;");
engine.CreateDatabase();
File.Delete("Test.sdf");
SqlCeEngine?engine?=?new?SqlCeEngine(
????"Data?Source='Test.sdf';LCID=1033;Password=\"s$;2'!dS64\";Encrypt=TRUE;");
engine.CreateDatabase();
2. 驗證和修復數據庫
//?驗證和修復數據庫
SqlCeEngine?engine?=?new?SqlCeEngine("Data?Source=AdventureWorks.sdf");
if?(false?==?engine.Verify())
{
????MessageBox.Show("Database?is?corrupted.");
????engine.Repair(null,?RepairOption.RecoverCorruptedRows);
}
SqlCeEngine?engine?=?new?SqlCeEngine("Data?Source=AdventureWorks.sdf");
if?(false?==?engine.Verify())
{
????MessageBox.Show("Database?is?corrupted.");
????engine.Repair(null,?RepairOption.RecoverCorruptedRows);
}
3. 壓縮數據庫
//?壓縮數據庫
//?通過從現有文件新建數據庫文件來回收?SQL?Server?Mobile?數據庫中浪費的空間。
//?此方法還可用來更改數據庫的排序順序、加密或密碼設置。
//?該連接字符串指定一個指向將由此方法創建的目標數據庫的連接。
//?如果指定的數據庫已經存在或者具有相同名稱的另一文件已經存在,則會引發異常。java連接數據庫的代碼?
//?如果為連接字符串傳遞空字符串,則新的數據庫文件將改寫舊的數據庫文件,
//?但名稱保持不變。
SqlCeEngine?engine?=?new?SqlCeEngine("Data?Source=AdventureWorks.sdf");
//engine.Compact(null);
engine.Compact("Data?Source=;?Password=a@3!7f$dQ;");
//?通過從現有文件新建數據庫文件來回收?SQL?Server?Mobile?數據庫中浪費的空間。
//?此方法還可用來更改數據庫的排序順序、加密或密碼設置。
//?該連接字符串指定一個指向將由此方法創建的目標數據庫的連接。
//?如果指定的數據庫已經存在或者具有相同名稱的另一文件已經存在,則會引發異常。java連接數據庫的代碼?
//?如果為連接字符串傳遞空字符串,則新的數據庫文件將改寫舊的數據庫文件,
//?但名稱保持不變。
SqlCeEngine?engine?=?new?SqlCeEngine("Data?Source=AdventureWorks.sdf");
//engine.Compact(null);
engine.Compact("Data?Source=;?Password=a@3!7f$dQ;");
4. 收縮數據庫
//?收縮數據庫
//?通過將空頁移動到文件的結尾然后截斷該文件,
//?來回收?SQL?Server?Mobile?數據庫中浪費的空間。
//?與?Compact?方法不同,Shrink?方法不創建臨時數據庫文件,
//?而是將所有空頁和未分配的頁都移到了文件的結尾,然后截斷,從而減小數據庫的總大小。
SqlCeEngine?engine?=?new?SqlCeEngine("Data?Source=AdventureWorks.sdf");
engine.Shrink();
//?通過將空頁移動到文件的結尾然后截斷該文件,
//?來回收?SQL?Server?Mobile?數據庫中浪費的空間。
//?與?Compact?方法不同,Shrink?方法不創建臨時數據庫文件,
//?而是將所有空頁和未分配的頁都移到了文件的結尾,然后截斷,從而減小數據庫的總大小。
SqlCeEngine?engine?=?new?SqlCeEngine("Data?Source=AdventureWorks.sdf");
engine.Shrink();
5. 合并復制
// 合并復制
//?實例化并配置?SqlCeReplication?對象
SqlCeReplication?repl?=?new?SqlCeReplication();
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?=?"Data?Source=MyDatabase.sdf";
//?創建一個本地?SQL?Server?Mobile?數據庫的訂閱
repl.AddSubscription(AddOption.CreateDatabase);
//?跟?SQL?Server?數據庫進行同步
repl.Synchronize();
//?清理?repl?對象
repl.Dispose();
//?實例化并配置?SqlCeReplication?對象
SqlCeReplication?repl?=?new?SqlCeReplication();
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?=?"Data?Source=MyDatabase.sdf";
//?創建一個本地?SQL?Server?Mobile?數據庫的訂閱
repl.AddSubscription(AddOption.CreateDatabase);
//?跟?SQL?Server?數據庫進行同步
repl.Synchronize();
//?清理?repl?對象
repl.Dispose();
6. 遠程數據訪問(RDA)
// 遠程數據訪問
//?實例化并配置?SqlCeRemoteDataAccess?對象
SqlCeRemoteDataAccess?rda?=?new?SqlCeRemoteDataAccess();
rda.InternetUrl?=?"http://www.adventure-works.com/sqlmobile/sqlcesa30.dll";
rda.InternetLogin?=?"MyInternetLogin";
rda.InternetPassword?=?"<password>";
rda.LocalConnectionString?=?"Data?Source=MyDatabase.sdf";
//?從?SQL?Server?下載數據
rda.Pull(
????"Employees",
????"SELECT?*?FROM?DimEmployee",
????"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;",
????RdaTrackOption.TrackingOnWithIndexes,
????"ErrorTable");
//
//?修改本地數據
//
//?將已修改的數據上傳到?SQL?Server
rda.Push(
????"DimEmployee",?
"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;");
//?提交?SQL?語句在?SQL?Server?上執行
rda.SubmitSql(
????"CREATE?TABLE?MyRemoteTable?(colA?int)",?
????"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;");
//?實例化并配置?SqlCeRemoteDataAccess?對象
SqlCeRemoteDataAccess?rda?=?new?SqlCeRemoteDataAccess();
rda.InternetUrl?=?"http://www.adventure-works.com/sqlmobile/sqlcesa30.dll";
rda.InternetLogin?=?"MyInternetLogin";
rda.InternetPassword?=?"<password>";
rda.LocalConnectionString?=?"Data?Source=MyDatabase.sdf";
//?從?SQL?Server?下載數據
rda.Pull(
????"Employees",
????"SELECT?*?FROM?DimEmployee",
????"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;",
????RdaTrackOption.TrackingOnWithIndexes,
????"ErrorTable");
//
//?修改本地數據
//
//?將已修改的數據上傳到?SQL?Server
rda.Push(
????"DimEmployee",?
"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;");
//?提交?SQL?語句在?SQL?Server?上執行
rda.SubmitSql(
????"CREATE?TABLE?MyRemoteTable?(colA?int)",?
????"Provider=sqloledb;server=MySqlServer;database=AdventureWorks;uid=sa;pwd=;");
7. 使用 SqlCeResultSet
// 使用 SqlCeResultSet
//?創建?SQL?Server?Mobile?數據庫連接
SqlCeConnection?conn?=?new?SqlCeConnection("Data?Source=Northwind.sdf");
//?創建并配置?SqlCeCommand?對象
SqlCeCommand?cmd?=?conn.CreateCommand();
cmd.CommandText?=?"SELECT?*?FROM?Orders";
//?創建?SqlCeResultSet?對象,并配置為可滾動、可更新、檢測數據源更改
ResultSetOptions?options?=?ResultSetOptions.Scrollable?|?
?????????????????????????????????????????ResultSetOptions.Sensitive?|?
?????????????????????????????????????????ResultSetOptions.Updatable;
SqlCeResultSet?resultSet?=?cmd.ExecuteResultSet(options);?
//?創建?ResultSetView?對象,配置為只顯示序號為?1,3,5,8?的列
ResultSetView?resultSetView?=?resultSet.ResultSetView;?
int[]?ordinals?=?new?int[]?{?1,3,5,8};
resultSetView.Ordinals?=?ordinals;
//?將?ResultSetView?綁定到?DataGrid?控件
this.dataGrid.DataSource?=?resultSetView;
//?創建?SQL?Server?Mobile?數據庫連接
SqlCeConnection?conn?=?new?SqlCeConnection("Data?Source=Northwind.sdf");
//?創建并配置?SqlCeCommand?對象
SqlCeCommand?cmd?=?conn.CreateCommand();
cmd.CommandText?=?"SELECT?*?FROM?Orders";
//?創建?SqlCeResultSet?對象,并配置為可滾動、可更新、檢測數據源更改
ResultSetOptions?options?=?ResultSetOptions.Scrollable?|?
?????????????????????????????????????????ResultSetOptions.Sensitive?|?
?????????????????????????????????????????ResultSetOptions.Updatable;
SqlCeResultSet?resultSet?=?cmd.ExecuteResultSet(options);?
//?創建?ResultSetView?對象,配置為只顯示序號為?1,3,5,8?的列
ResultSetView?resultSetView?=?resultSet.ResultSetView;?
int[]?ordinals?=?new?int[]?{?1,3,5,8};
resultSetView.Ordinals?=?ordinals;
//?將?ResultSetView?綁定到?DataGrid?控件
this.dataGrid.DataSource?=?resultSetView;
8. 處理 SqlCeException
//?處理 SqlCeException
public?static?void?ShowErrors(SqlCeException?e)
{
????SqlCeErrorCollection?errs?=?e.Errors;
????StringBuilder?bld?=?new?StringBuilder();
????Exception?inner?=?e.InnerException;
????foreach?(SqlCeError?err?in?errs)
????{
????????//?標識錯誤類型的?HRESULT?值,這些錯誤不是?SQL?Server?CE?固有的
????????bld.Append("\r\nError?Code:?").Append(err.HResult.ToString("X"));
????????//?對錯誤進行描述的文本
????????bld.Append("\r\nMessage:?").Append(err.Message);
????????//?獲取?SqlCeError?的本機錯誤號
????????bld.Append("\r\nMinor?Err.:?").Append(err.NativeError);
????????//?生成錯誤的提供程序的名稱
????????bld.Append("\r\nSource:?").Append(err.Source);
????????//?遍歷前三個錯誤參數。SQL?Server?CE?使用錯誤參數來提供有關錯誤的其他詳細信息。數據庫怎么創建、
????????foreach?(int?numPara?in?err.NumericErrorParameters)
????????{
????????????//?雖然錯誤可能存在參數,但并非發生的所有錯誤都返回參數。
????????????//?如果發生某個錯誤時沒有返回任何參數,則該數組的值為?0。
????????????if?(numPara?!=?0)
????????????{
????????????????bld.Append("\r\nNum.?Par.:?").Append(numPara);
????????????}
????????}
????????//?遍歷最后三個錯誤參數。SQL?Server?CE?使用錯誤參數來提供有關錯誤的其他詳細信息。
????????foreach?(string?errPara?in?err.ErrorParameters)
????????{
????????????//?雖然錯誤可能存在參數,但并非發生的所有錯誤都返回參數。sql數據庫代碼?
????????????//?如果發生某個錯誤時沒有返回任何參數,則該數組的值將為空字符串。
????????????if?(errPara?!=?String.Empty)
????????????{
????????????????bld.Append("\r\nErr.?Par.:?").Append(errPara);
????????????}
????????}
????}
????MessageBox.Show(bld.ToString());
public?static?void?ShowErrors(SqlCeException?e)
{
????SqlCeErrorCollection?errs?=?e.Errors;
????StringBuilder?bld?=?new?StringBuilder();
????Exception?inner?=?e.InnerException;
????foreach?(SqlCeError?err?in?errs)
????{
????????//?標識錯誤類型的?HRESULT?值,這些錯誤不是?SQL?Server?CE?固有的
????????bld.Append("\r\nError?Code:?").Append(err.HResult.ToString("X"));
????????//?對錯誤進行描述的文本
????????bld.Append("\r\nMessage:?").Append(err.Message);
????????//?獲取?SqlCeError?的本機錯誤號
????????bld.Append("\r\nMinor?Err.:?").Append(err.NativeError);
????????//?生成錯誤的提供程序的名稱
????????bld.Append("\r\nSource:?").Append(err.Source);
????????//?遍歷前三個錯誤參數。SQL?Server?CE?使用錯誤參數來提供有關錯誤的其他詳細信息。數據庫怎么創建、
????????foreach?(int?numPara?in?err.NumericErrorParameters)
????????{
????????????//?雖然錯誤可能存在參數,但并非發生的所有錯誤都返回參數。
????????????//?如果發生某個錯誤時沒有返回任何參數,則該數組的值為?0。
????????????if?(numPara?!=?0)
????????????{
????????????????bld.Append("\r\nNum.?Par.:?").Append(numPara);
????????????}
????????}
????????//?遍歷最后三個錯誤參數。SQL?Server?CE?使用錯誤參數來提供有關錯誤的其他詳細信息。
????????foreach?(string?errPara?in?err.ErrorParameters)
????????{
????????????//?雖然錯誤可能存在參數,但并非發生的所有錯誤都返回參數。sql數據庫代碼?
????????????//?如果發生某個錯誤時沒有返回任何參數,則該數組的值將為空字符串。
????????????if?(errPara?!=?String.Empty)
????????????{
????????????????bld.Append("\r\nErr.?Par.:?").Append(errPara);
????????????}
????????}
????}
????MessageBox.Show(bld.ToString());