SQL2005 CompactEdition数据存储体系(6)

private NorthwindDataSet LoadDataSet()
{
    NorthwindDataSet nwData = new NorthwindDataSet();
    CustomersTableAdapter adapter = new CustomersTableAdapter();
    adapter.Fill(nwData.Customers);
    return nwData;
}

private void SaveChanges(NorthwindDataSet nwData)
{
    CustomersTableAdapter adapter = new CustomersTableAdapter();
    adapter.Update(nwData);
}

private void UpdateCompanyName(string custId, string companyName)
{
    // 建立连接，只需要 sdf 文件的路径
    SqlCeConnection conn = 
        new SqlCeConnection(
           @"Data Source ='.\Northwind.sdf'");
    
    // 建立选择查询，在结果集里列出行的内容
    string selQuery = 
       "SELECT * FROM Customers WHERE [Customer ID] = @CustID";
    SqlCeCommand getCustCmd = new SqlCeCommand(selQuery, conn);
    getCustCmd.Parameters.Add("@CustID", custId);

    using (conn)
    {
        conn.Open();
        // 把行拉进结果集，
        // 使用选项来允许已连接的、随机的和可读写的访问
        SqlCeResultSet resultSet = 
            getCustCmd.ExecuteResultSet(
               ResultSetOptions.Scrollable | 
               ResultSetOptions.Updatable);
        // 移到第一个记录
        if (resultSet.ReadFirst())
        {
            // 得到列的位置
            int ordinal = resultSet.GetOrdinal("Company Name");
            // 设置值
            resultSet.SetString(ordinal, companyName);
            // 永久保存
            resultSet.Update();
        }
        else // 没有匹配的
        {
            throw new ArgumentException("Customer not found");
        }
    }
}