ITPub博客

首页 > 数据库 > 数据库开发技术 > ASP.NET 2.0中执行数据库操作命令 -- C#

ASP.NET 2.0中执行数据库操作命令 -- C#

原创 数据库开发技术 作者:xxdxxdxxd 时间:2007-01-16 16:26:07 0 删除 编辑
数据库命令执行时使用Command对象。Command类有三种:SqlCommandOleDbCommandOdbcCommand

  Command对象主要用来运行SELECTINSERTUPDATEDELETE之类的SQL语句。Command对象还可以调用存储过程或从特定表中取得记录。

   DataReader对象主要是用来读取数据结果,使用它读取记录时通常比从DataSet更快。DataReader类有三种: SqlDataReaderOleDbDataReaderOdbcDataReaderDataReader对象用Commmand对象从数据库 中读取记录,并且DataReader对象只能向前的读取记录,用于在某些情况下替代DataSet对象(DataSet对象可以存储数据库中的行拷贝, 可以在切断数据库的连接时处理这个拷贝,我们将在以后的章节中详细介绍该对象)

  注意:不能用DataReader修改数据库中的记录,它是采用向前的,只读的方式读取数据库。[@more@]

  SqlCommand

   SqlCommand对象用于对Sql Server数据库执行命令。OleDbCommand对象用于对支持OleDb的数据库执行命令,如OracleAccess OdbcCommand对象用于对支持Odbc的数据库执行命令。尽管SqlCommand类是针对Sql Server的,但是这个类的许多属性、方法与事件和OleDbCommandOdbcCommand等类相似。本章将重点讲解SqlCommand 定的属性与方法,其他的Command类你可以参考相应的帮助文档。

  注意:使用不同的Command对象需要导入不同的命名空间。 OleDbCommand的命名空间为System.Data.OleDbSqlCommand的命名空间为 System.Data.SqlClientOdbcCommand的命名空间为System.Data.Odbc

  SqlCommand属性:

属性 说明 CommandText 其返回类型为string, 获取或设置要对数据源执行的 SQL 语句、存储过程或表。 CommandTimeOut 其返回类型为int,获取或设置在终止执行命令的尝试并生成错误之前的等待时间。 CommandType 其返回类型为CommandType,读取或设置表示CommandText属性将如何被解释的值,其有效的值可以为CommandType.Text CommandType.StoredProcedurCommandType.TableDirect,分别表示SQL语句、存储过程调用或要读取的 表,默认为Text Connection 其返回类型为string, 获取或设置 SqlCommand 的此实例使用的 SqlConnection Parameters 其返回类型为SqlParameterCollection,取得提供给命令的参数(如有)
  SqlCommand方法:

方法 说明 Cancle() 其返回类型为void,取消命令的执行 CreateParameter() 其返回类型为SqlParameter, 用于创建 SqlParameter 对象的新实例。 ExecuteNonQuery() 其返回类型为int,执行不返回结果集的Sql语句,包括INSERTUPDATEDELETE语句、DDL语句和不返回结果集的存储过程调用。返回的int值是命令影响的数据库行数。 ExecuteReader() 其返回类型为SqlDataReader, 执行SELECT语句、TableDirect命令或返回结果集的存储过程调用。在SqlDataReader对象中返回结果集。 ExecuteScalar() 其返回类型为object,执行返回单个值的SELECT语句(任何其他的值将被忽略)。这个命令结果作为对象被返回。 ExecuteXmlReader() 其返回类型为XmlReader,执行返回XML数据的SELECT语句,用XmlReader对象返回结果集,只适用于SqlCommand类 生成SqlCommand对象

  我们可以用构造函数生成SqlCommand对象,也可以调用SqlConnection对象的CreateCommand()方法生成SqlCommand对象,下面分别介绍这两种方法。

  用构造函数生成SqlCommand对象

  SqlCommand对象的构造函数如下所示:

SqlCommand()
SqlCommand(string commandText)
SqlCommand(string commandText,SqlConnection mySqlConnection)
  程序代码说明:在上述语法范例的程序代码中,commandText包含SQL语句、存储过程调用或要读取的表。mySqlConnection是对应的SqlConnection对象。

  在使用SqlCommand对象之前,首先要确定一个SqlConnection对象,用于和SQL Server数据库进行数据传递。

mySqlConnection.ConnectionString="server=localhost;database=Northwind;
integrated security=SSPI";
  然后可以用下列语句生成新的SqlCommand对象:

SqlCommand mySqlCommand=new SqlCommand();
  再将mySqlCommand对象的Connection属性设置为mySqlConnection

mySqlCommand.Connection= mySqlConnection;
   这样mySqlCommand对象就可以使用mySqlConnection与数据库进行数据传递。现在,Command对象的CommandType 属性确定要执行的命令类型。可以用System.Data.CommandType枚举值指定CommandType属性。
CommandType的枚举值如下表所示:

数值 说明 Text 表示命令是SQL语句,默认值是Text StoredProcedure 表示命令是储存过程调用 TableDirect 表示被读取的行和列的表名。注意:SqlCommand对象不支持TableDirect,要使用其他的Command类的对象。
  例如你可以采用如下的形式执行一个SQL查询:

SqlCommand mySqlCommand=new SqlCommand();
mySqlCommand.Connection=mySqlConnection;
mySqlCommand.CommandText=”SELECT * FROM Employees”;
//mySqlCommand.CommandType=CommandType.Text;
   程序代码说明:在上述语法范例的程序代码中,我们设置了mySqlCommand对象的commandText为一个SELECT查询语句,并且指定了 mySqlCommand对象的CommandType属性为CommandType.Text,表示命令是SQL语句。由于 CommandType.Text是默认的CommandType值,所以我们可以将其注译掉。

  还有一个更具效率的形式,那就是使用SqlCommand对象的其中一种构造函数:

SqlCommand mySqlCommand=new SqlCommand(”SELECT * FROM Employees”,myConnection);
  程序代码说明:在上述语法范例的程序代码中,我们可以直接利用SqlCommand(string commandText,SqlConnection mySqlConnection) 构造函数,从而使得程序代码更加的简练和直观。

  还可以使用储存过程来查询所需要的数据,我们可以采用如下的代码形式:

SqlCommand mySqlCommand=new SqlCommand(”GetEmpolyees”,myConnection);
mySqlCommand.CommandType=CommandType.StoredProcedure;
  程序代码说明:在上述语法范例的程序代码中,GetEmpolyees为一个储存过程名,用来实现所有的雇员信息查询。并且将CommandType值指定为StoredProcedure,表示命令是储存过程调用。

  使用CreateCommand()方法生成SqlCommand对象

  如果不用构造函数,也可以使用SqlConnection对象的CreateCommand()方法生成SqlCommand对象。这个方法返回新的SqlCommand对象。例如:

SqlCommand mySqlCommand=mySqlConnection.CreateCommand();

SqlDataReader

  可以用SqlDataReader类对象从SQL Server数据库中读取行;用OleDbDataReader类对象从支持OLE DB的数据库中读行,如OracleAccess;用OdbcDataReader类对象从支持ODBC的数据库中读取行。

   DataReader对象允许你以向前的,只读的方式读取数据,有时候DataReader对象也称为消软管游标。DataReader对象采用了一种 简化的数据读取方式,但是提高了性能的同时也牺牲了很多特性。例如在DataSet中支持的排序,分页等功能。这些功能将在以后的章节进行详细的介绍。

  SqlDataReader的属性

属性 说明 Depth 其返回类型为int,取得表示当前行嵌入深度的值 FieldCount 其返回类型为int,取得当前行的列数 IsColsed 其返回类型为bool,取得一个布尔值,表示是否关闭数据读取 RecordsAffected 其返回类型为int, 取得执行SQL语句增加、修改或删除的行数。
  SqlDataReader的方法

方法 说明 Reader() 其返回类型为bool,将数据阅读器移到结果集的下一行并读取该行。这个方法返回的布尔值表示结果集中是否有多行 GetValue() 其返回类型为object, 返回指定列的值 GetValues() 其返回类型为int,将当前行中所有列的值复制到指定对象数组。这个方法返回的int是数组元素的个数 NextResult() 其返回类型为bool,将数据阅读器移到结果集的下一行。这个方法返回的布尔值表示结果集中是否有多行 Close() 关闭 SqlDataReader 对象 GetInt32(),GetChar(),
GateDataTime(),Get×××() 返回指定列的值,并且返回的类型为相应的数据类型。例如GetInt32()返回整型的数值。注意,如果你将返回值赋予一个类型不匹配的变量时,将会抛出一个InvalidCastException异常
   ExecuteReader()方法执行查询

  下面是一个用ExecuteReader()方法执行SELECT语句的范例。这个方法用DataReader对象返回结果集,然后可以用此对象读取数据库返回的行。

  范例程序代码如下:

01 public partial class _Default : System.Web.UI.Page
02 {
03  protected void Page_Load(object sender, EventArgs e)
04  {
05   string connectionString =
06 ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString;
07   SqlConnection con = new SqlConnection(connectionString);
08   string sql = "SELECT top 5 CustomerID,CompanyName,ContactName,Address
09          FROM Customers";
10   SqlCommand cmd = new SqlCommand(sql, con);
11   con.Open();
12   SqlDataReader reader = cmd.ExecuteReader();
13   StringBuilder htmlStr = new StringBuilder("");
14   while (reader.Read())
15   {
16    htmlStr.Append("CustomerID" + reader["CustomerID"] + "
");
17    htmlStr.Append("CompanyName" + reader["CompanyName"] + "
");
18    htmlStr.Append("ContactName" + reader.GetString(2) + "
");
19    htmlStr.Append("Address" + reader.GetString(3) + "
");
20    htmlStr.Append("


");
21   }
22   reader.Close();
23   con.Close();
24   HtmlContent.Text = htmlStr.ToString();
25  }
26 }
  程序代码说明 在上述语法范例的程序代码中,第512行代码生成所要的对象并执行SELECT语句,从Customers表中读取前5条记录。cmd返回的结果集存放 reader对象中,然后你可以用Reader()方法读取reader对象的记录。这个方法在有另一个可读的行时返回布尔真值,否则返回布尔假值。可 以从reader对象中读取一个记录的各个列值,只要在方括号中传入列名即可。如第1617行所示,我们用reader[“CustomerID”] CustomerID列的各项内容。你也可以直接在方括号中传入数字值指定想要列的索引。如第1819行代码所显示,由于我们在用SELECT进行数 据查询的时,ContactNameAddress分别位于第3和第4列,而相应的索引值则为23,所以我们可以用reader.GetString (2)reader.GetString(3)读取ContactNameAddress列的数据。如第14行代码所示,我们可以在While循环中 Reader()方法一一读取每条记录。

每次程序执行命令时,都要将相应的命令通过网络传递到数据库中,并在数据库进行执行,然后将结果返回到程序中,从而产生大量的网络通信流。我们可以使用ExecuteReader()方法同时执行多条SELECT语句查询减少重复的数据传递。

  下面的实例是使用ExecuteReader()方法同时查询三个表中的数据,并将返回的三个结果集显示在页面上。

  范例程序代码如下:

01 public partial class _Default : System.Web.UI.Page
02 {
03  protected void Page_Load(object sender, EventArgs e)
04  {
05   string connectionString =
06 ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString;
07   SqlConnection con = new SqlConnection(connectionString);
08   SqlCommand cmd = con.CreateCommand();
09   cmd.CommandText = "SELECT TOP 3 ProductID,ProductName
10   FROM Products ORDER BY ProductID;" +
11    "SELECT TOP 3 CustomerID,CompanyName
12    FROM Customers ORDER BY CustomerID;" +
13     "SELECT TOP 3 OrderID,CustomerID
14     FROM Orders ORDER BY OrderID;";
15   con.Open();
16   SqlDataReader reader = cmd.ExecuteReader();
17   StringBuilder htmStr=new StringBuilder("");
18   int i = 0;
19   do
20   {
21    htmStr.Append("结果集");
22    htmStr.Append(i.ToString());
23    htmStr.Append("
");
24    while (reader.Read())
25    {
26     htmStr.Append("reader[0]=" + reader[0]);
27     htmStr.Append("
");
28     htmStr.Append("reader[1]=" + reader[1]);
29     htmStr.Append("

");
30    }
31    htmStr.Append("


");
32    i++;
33   } while (reader.NextResult());
34   reader.Close();
35   con.Close();
36   HtmlContent.Text = htmStr.ToString();
37  }
38 }
  程序代码说明 在上述语法范例的程序代码中,第9行到第14中定义了3个查询语句,各语句之间用分号进行间隔。第16行调用ExecuteReader()方法,并返回 SqlDataReader对象,并且对三条不同的SELECT语句各返回一个结果集。要读取第一个结果集的话,可以用SqlDataReader对象的 Reader()方法。Reader()方法在没有其他的可读行时将返回一个false值。当一个结果集的所有记录都读取完毕后,可以调用 SqlDataReader对象的NextResult()方法,然后在读取下一个结果集,在没有其他的结果集时,也返回一个false值。

   提示:外循环do…while测试结尾的reader. NextResult()的返回值。由于do…while循环末尾检测这个条件,这样就保证了do…while循环至少执行一次。之所以在末尾才调用 NextResult()方法,是因为这样可以首先把SqlDataReader对象移到下一个结果集,然后才返回表示是否还有下一个结果集的布尔结果。 如果使用while循环中,则有可能直接跳过第一个结果集,从而产生错误。

ExecuteScalar()方法执行SELECT语句,返回单个值,并且忽略其他的任何读取的结果。ExecuteScalar()方法返回的结果 是一个object对象。ExecuteScalar()主要是用来执行SELECT语句,或者执行包括聚合函数的SQL语句。

  下面我们将使用如下的程序读取Products表中的记录条数,并且在相应的查询语句中使用COUNT()聚合函数。

  范例程序代码如下:

01 public partial class _Default : System.Web.UI.Page
02 {
03  protected void Page_Load(object sender, EventArgs e)
04  {
05   string connectionString =
06    ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString;
07   SqlConnection con = new SqlConnection(connectionString);
08   SqlCommand cmd = con.CreateCommand();
09   cmd.CommandText = "SELECT COUNT(*) FROM Products";
10   con.Open();
11   int returnValue = (int)cmd.ExecuteScalar();
12   HtmlContent.Text = "Products表中共有" + returnValue.ToString()+"条记录";
13  }
14 }


  程序代码说明:在上述语法范例的程序代码中,第9行即为查询Products表中的记录条数的SQL语句。第11行代码用 ExecuteScalar()方法执行SELECT语句。注意,由于ExecuteScalar()方法的结果为object对象,因此我们要将其进行 强制类型转换,再赋予相应的变量。

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/1697933/viewspace-890807/,如需转载,请注明出处,否则将追究法律责任。

上一篇: Linux 命令
下一篇: PHP新手上路
请登录后发表评论 登录
全部评论

注册时间:2008-09-15

  • 博文量
    56
  • 访问量
    510740