SQLCE数据库操作总结.doc

演练：使用 SQL Server CE 数据库Visual Studio .NET 2003 本节将指导您完成使用 Microsoft SQL Server 2000 Windows CE Edition (SQL Server CE) 数据库时需要执行的主要任务。假定您没有任何 SQL Server CE 数据库，需要在新的 Microsoft Visual Studio .NET 项目中创建新的数据库。该演练包括以下任务： 创建新的 SQL Server CE 数据库 读取 SQL Server CE 数据库数据 更改 SQL Server CE 数据库中的数据 阐释以上每个任务步骤的代码旨在一起运行。不能在任务中运行仅用于特定步骤的代码。有关完整代码列表，请参见代码列表：使用 SQL Server CE 数据库。创建新的数据库SQL Server CE 中的数据库是存储结构化数据的表集合。在可以存储数据库之前，必须创建数据库。在创建数据库之后，可以创建保存数据的表。在本节中，您将创建一个新的数据库，然后创建一个表，最后将数据添加到该表中。若要执行这些步骤，请使用 SQL Server CE (System.Data.SqlServerCe) .NET Framework 精简版数据提供程序的 SqlCeConnection、SqlCeEngine 和 SqlCeCommand 类。注意不能在此任务中运行仅用于特定步骤的代码。有关完整代码列表，请参见代码列表：使用 SQL Server CE 数据库。创建新的 SQL Server CE 数据库 1. 启动 Visual Studio .NET，然后打开一个新项目。 2. 创建对使用的命名空间的引用。 复制using System;using System.IO;using System.Text;using System.Data;using System.Data.SqlServerCe;using System.Collections;using System.Windows.Forms;using System.Data.Common;3. 创建 WalkThrough 类。 复制public class WalkThrough static void Main() SqlCeConnection conn = null; try 4. 验证具有您打算使用的名称的数据库是否已存在。 复制 if (File.Exists (Test.sdf) ) File.Delete (Test.sdf);5. 使用 System.Data.SqlCeEngine 对象创建名为 Test.sdf 的空数据库。 注意SQL Server CE 中，数据库名称的文件扩展名为 .sdf。复制 SqlCeEngine engine = new SqlCeEngine (Data Source = Test.sdf); engine.CreateDatabase ();6. 连接到这个新数据库。 复制conn = new SqlCeConnection (Data Source = Test.sdf);conn.Open();创建新表 1. 使用 System.Data.SqlCeCommand 创建命令类的实例。 复制SqlCeCommand cmd = conn.CreateCommand();2. 运行命令 cmd 创建表。用于创建表的指令必须在 cmd.CommandText 所包含的 SQL 代码中。 若要使用 SQL Server CE 的 SQL 编程语言创建表，请使用 CREATE TABLE 语法。有关更多信息，请参见SQL Server CE 联机手册中的用于 SQL Server CE 的 SQL 参考。 复制cmd.CommandText = CREATE TABLE TestTbl(col1 int PRIMARY KEY, col2 ntext, col3 money);cmd.ExecuteNonQuery();将数据添加到新表中 1. 运行命令以添加数据行。与创建表相同，用于添加行的指令也必须在 cmd.CommandText 所包含的 SQL 代码中。 若要使用 SQL Server CE 的 SQL 编程语言将行添加到表中，请使用 INSERT 语法。有关更多信息，请参见SQL Server CE 联机手册中的用于 SQL Server CE 的 SQL 参考。 复制cmd.CommandText = INSERT INTO TestTbl(col1, col2, col3) VALUES (0, abc, 15.66);cmd.ExecuteNonQuery();2. 创建命令，使用参数将数据多次插入表中。 参数可以更高效地查询数据库，因为可以使用一组包含参数的 SQL 语句插入多个值。有关更多信息，请参见SQL Server CE 联机手册的在查询中使用参数。 复制cmd.CommandText = INSERT INTO TestTbl(col1, col2, col3) VALUES (?, ?, ?);cmd.Parameters.Add(new SqlCeParameter(p1, SqlDbType.Int);cmd.Parameters.Add(new SqlCeParameter(p2, SqlDbType.NText);cmd.Parameters.Add(new SqlCeParameter(p3, SqlDbType.Money);cmd.Parametersp2.Size = 50;cmd.Prepare();3. 执行参数化命令，将数据插入表中。 复制cmd.Parametersp1.Value = 1;cmd.Parametersp2.Value = abc;cmd.Parametersp3.Value = 15.66;cmd.ExecuteNonQuery();4. 清除参数，并检查已插入表中的数据。 若要使用 SQL Server CE 的 SQL 编程语言读取现有数据，请使用 SELECT 语法。有关更多信息，请参见SQL Server CE 联机手册中的用于 SQL Server CE 的 SQL 参考。 复制cmd.Parameters.Clear();/Set the command text to a SELECT query./cmd.CommandText = SELECT * FROM TestTbl;读取 SQL Server CE 数据库数据读取数据库数据是一种常见的任务，通常涉及对表行信息的访问。为使用 System.Data.SqlServerCe 执行此任务，您需要 SqlCeDataReader 和 SqlCeCommand 对象。注意有关完整代码列表，请参见代码列表：使用 SQL Server CE 数据库。1. 调用 SqlCeCommand 对象的 ExecuteReader 方法以创建 SqlCeDataReader 的实例。 复制SqlCeDataReader rdr = cmd.ExecuteReader();2. 指示数据读取器 rdr 在行存在时在每行的列中显示数据。 复制while (rdr.Read()MessageBox.Show(col1 = + rdr.GetInt32(0) + col2 = + rdr.GetString(1) + col3 = + rdr.GetSqlMoney(2);更改 SQL Server CE 数据库中的数据在创建表后，可以以多种方式修改表中的数据：更改特定数据的属性，添加和删除数据行，甚至还可以通过修改表中的列来更改存储数据的方式。在本节中，您将更改表项的值，查找更改的表的数据并处理所有错误。为执行这些步骤，您将使用在前面的任务中使用的类：SqlCeCommand 和 SqlCeDataReader。另外，您将使用 SqlCeException 进行错误处理。注意不能在此任务中运行仅用于特定步骤的代码。有关完整代码列表，请参见代码列表：使用 SQL Server CE 数据库。更新 SQL Server CE 表中的数据 设置命令对象以使用 UPDATE 语句。 若要使用 SQL Server CE 的 SQL 编程语言更改行列的值，请使用 UPDATE 语法。有关更多信息，请参见SQL Server CE 联机手册中的用于 SQL Server CE 的 SQL 参考。 复制cmd.CommandText = UPDATE TestTbl SET col2 = some new value WHERE col1 = 0;cmd.ExecuteNonQuery();读取 SQL Server CE 表中的数据 1. 设置命令对象以使用 SELECT 语句，然后通过执行 SqlCeCommand.ExecuteReader 创建数据读取器的实例。 复制 cmd.CommandText = SELECT * FROM TestTbl; rdr = cmd.ExecuteReader(); while (rdr.Read() MessageBox.Show( col1 = + rdr.GetInt32(0) + col2 = + rdr.GetString(1) + col3 = + rdr.GetSqlMoney(2); 2. 使用 SqlCeException 捕获任何错误，然后关闭与数据库的连接。 复制 catch (SqlCeException e) ShowErrors(e);finally if(conn.State = ConnectionState.Open) conn.Close(); public static void ShowErrors(SqlCeException e) SqlCeErrorCollection errorCollection = e.Errors; StringBuilder bld = new StringBuilder(); foreach (SqlCeError err in errorCollection) bld.Append(n Error Code: + err.HResult.ToString(X); bld.Append(n Message : + err.Message); bld.Append(n Minor Err.: + err.NativeError); bld.Append(n Source : + err.Source); foreach (int numPar in err.NumericErrorParameters) if (0 != numPar) bld.Append(n Num. Par. : + numPar); foreach (string errPar in err.ErrorParameters) if (String.Empty != errPar) bld.Append(n Err. Par. : + errPar); MessageBox.Show(bld.ToString(); bld.Remove(0, bld.Length); 有关 SQL Server CE 中的错误处理的更多信息，请参见SQL Server CE 联机手册中的错误处理。