如何使用 sqldataadapter 来检索多个行

以下代码阐明了如何使用 sqldataadapter 对象发出可生成 dataset 或 datatable 的命令。它从 sql server northwind 数据库中检索一组产品类别。

using system.data;
using system.data.sqlclient;

public datatable retrieverowswithdatatable()
{
  using ( sqlconnection conn = new sqlconnection(connectionstring) )
  {
    conn.open();
    sqlcommand cmd = new sqlcommand("datretrieveproducts", conn);
    cmd.commandtype = commandtype.storedprocedure;
    sqldataadapter adapter = new sqldataadapter( cmd );
    datatable datatable = new datatable("products");
    adapter .fill(datatable);
    return datatable;
  }
}

使用 sqladapter 生成 dataset 或 datatable

如何使用 sqldatareader 来检索多个行

以下代码片段阐明了可检索多个行的 sqldatareader 方法。

using system.io;
using system.data;
using system.data.sqlclient;

public sqldatareader retrieverowswithdatareader()
{
  sqlconnection conn = new sqlconnection(
         "server=(local);integrated security=sspi;database=northwind");
  sqlcommand cmd = new sqlcommand("datretrieveproducts", conn );
  cmd.commandtype = commandtype.storedprocedure;
  try
  {
    conn.open();
    // generate the reader. commandbehavior.closeconnection causes the
    // the connection to be closed when the reader object is closed
    return( cmd.executereader( commandbehavior.closeconnection ) );
  }
  catch
  {
    conn.close();
    throw;
  }
}

// display the product list using the console
private void displayproducts()
{
  sqldatareader reader = retrieverowswithdatareader();
  try
  {
    while (reader.read())
    {
      console.writeline("{0} {1} {2}", 
                        reader.getint32(0).tostring(), 
                        reader.getstring(1) );
    }
  }
  finally
  {
    reader.close(); // also closes the connection due to the
                    // commandbehavior enum used when generating the reader
  }
}

使用 sqldatareader 检索行

如何使用 xmlreader 检索多个行

可以使用 sqlcommand 对象来生成 xmlreader 对象，后者可提供对 xml 数据的基于流的只进访问。命令（通常为存储过程）必须产生基于 xml 的结果集，对于 sql server 2000 而言，该结果集通常包含一个带有有效 for xml 子句的 select 语句。以下代码片段阐明了该方法：

public void retrieveanddisplayrowswithxmlreader()
{
  using( sqlconnection conn = new sqlconnection(connectionstring) )
  {;
    sqlcommand cmd = new sqlcommand("datretrieveproductsxml", conn );
    cmd.commandtype = commandtype.storedprocedure;
try
  {
      conn.open();
    xmltextreader xreader = (xmltextreader)cmd.executexmlreader();
    while ( xreader.read() )
    {
      if ( xreader.name == "products" ) 
      {
        string stroutput = xreader.getattribute("productid");
        stroutput += " ";
        stroutput += xreader.getattribute("productname");
        console.writeline( stroutput );
      }
    }
    xreader.close();  // xmltextreader does not support idisposable so it cant be
                      // used within a using keyword 
  }
}
  

上述代码使用了以下存储过程：

create procedure datretrieveproductsxml
as
select * from products 
for xml auto
go

使用 xmlreader 检索 xml 数据

如何使用存储过程输出参数来检索单个行

借助于命名的输出参数，可以调用在单个行内返回检索到的数据项的存储过程。以下代码片段使用存储过程来检索 northwind 数据库的 products 表中包含的特定产品的产品名称和单价。

void getproductdetails( int productid, 
                        out string productname, out decimal unitprice )
{
  using( sqlconnection conn = new sqlconnection(
        "server=(local);integrated security=sspi;database=northwind") )
  {
    // set up the command object used to execute the stored proc
    sqlcommand cmd = new sqlcommand( "datgetproductdetailsspoutput", conn )
    cmd.commandtype = commandtype.storedprocedure;
    // establish stored proc parameters.
    //  @productid int input
    //  @productname nvarchar(40) output
    //  @unitprice money output

    // must explicitly set the direction of output parameters
    sqlparameter paramprodid = 
             cmd.parameters.add( "@productid", productid );
    paramprodid.direction = parameterdirection.input;
    sqlparameter paramprodname = 
             cmd.parameters.add( "@productname", sqldbtype.varchar, 40 );
    paramprodname.direction = parameterdirection.output;
    sqlparameter paramunitprice = 
             cmd.parameters.add( "@unitprice", sqldbtype.money );
    paramunitprice.direction = parameterdirection.output;

    conn.open();
    // use executenonquery to run the command. 
    // although no rows are returned any mapped output parameters 
    // (and potentially return values) are populated 
    cmd.executenonquery( );
    // return output parameters from stored proc
    productname = paramprodname.value.tostring();
    unitprice = (decimal)paramunitprice.value; 
  }
}

使用存储过程输出参数来检索单个行

上述代码片段调用了以下存储过程。

create procedure datgetproductdetailsspoutput
@productid int,
@productname nvarchar(40) output,
@unitprice money output
as
select @productname = productname, 
       @unitprice = unitprice 
from products 
where productid = @productid
go