3. Command对象

Command对象表示一个可以对数据源执行的命令。在这里主要介绍的是SqlCommand对象，SqlCommand继承自Command对象的公共基类DBCommand。
3.1 SQL或存储过程 命令的执行
可以通过SqlCommand.ExecuteNonQuery方法来执行一个SQL命令，该方法不会返回任何一个结果集。这个方法通常用来执行SQL语句中的Update、Insert、Delete命令。
当然也可以用来执行如Create Table，Drop DataBase命令等
例4: 使用SqlCommand更新和删除电影记录的方法UpdateMovie和DeleteMovie()
=== App_Code\DawnDataObject.cs ===

Code
namespace DawnDataObject
{
public class Movies
{
public static readonly string _connectionString; // 连接数据库字符串为静态成员，每个实例共享。

static Movies(){
_connectionString = WebConfigurationManager.ConnectionStrings[ " DawnEnterpriseDBConnectionString " ].
ConnectionString;
}

private string _title;
private string _director;
private Int32 _id;

// Movies类中包括的属性有Title、Director
public string Title{
get { return _title; }
set { _title = value; }
}
public string Director {
get { return _director; }
set { _director = value; }
}
public Int32 Id {
get { return _id; }
}

// Movies类中的GetAll方法返回一个List对象，该对象可以被GridView等控件做为数据源绑定
public List < Movies > GetAll( out long executeTime) // executeTime作为out参数
{
List < Movies > result = new List < Movies > ();
SqlConnection conn = new SqlConnection(_connectionString);
SqlCommand comm = new SqlCommand( " select Id,Title,Director from Movies " , conn);
conn.StatisticsEnabled = true ;
using (conn){ // using关键字指定了conn一旦离开这个代码段，自动调用其Dispose函数
conn.Open();
SqlDataReader reader = comm.ExecuteReader();
while (reader.Read()){
Movies newmovie = new Movies();
newmovie._title = ( string )reader[ " Title " ];
newmovie._director = ( string )reader[ " Director " ];
newmovie._id = (Int32)reader[ " Id " ];
result.Add(newmovie);
}
IDictionary stats = conn.RetrieveStatistics();
executeTime = ( long )stats[ " ExecutionTime " ];
return result;
}
}

// 对Movies表进行更新的方法
public void UpdateMovie( int id, string title, string director)
{
SqlConnection conn = new SqlConnection(_connectionString);
SqlCommand command = conn.CreateCommand(); // 使用SqlConnection.CreateCommand获得SqlCommand对象
command.CommandText = " Update Movies set Title=@title,Director=@director where Id=@id " ;
command.Parameters.AddWithValue( " @id " , id);
command.Parameters.AddWithValue( " @title " , title);
command.Parameters.AddWithValue( " @director " , director);
using (conn){
conn.Open();
command.ExecuteNonQuery();
}
}

// 对Movies表进行删除的方法
public void DeleteMovie( int id)
{
SqlConnection conn = new SqlConnection(_connectionString);
// 使用new SqlCommand获得SqlCommand对象
SqlCommand command = new SqlCommand( " delete from Movies where Id=@id " ,conn);
command.Parameters.AddWithValue( " @id " , id);
using (conn)
{
conn.Open();
command.ExecuteNonQuery();
}
}

}
}

=== Movies.aspx ===

Code
< asp:GridView ID ="GridView1" runat ="server" DataKeyNames ="Id"
AutoGenerateColumns ="False" DataSourceID ="ObjectDataSource1"
onrowcommand ="GridView1_RowCommand" onrowdeleting ="GridView1_RowDeleting"
AllowPaging ="True" >
< Columns >
< asp:BoundField HeaderText ="Id" DataField ="Id" Visible ="false" />
< asp:BoundField HeaderText ="Title" DataField ="Title" />
< asp:BoundField HeaderText ="Director" DataField ="Director" />
< asp:CommandField ShowEditButton ="True" />
< asp:CommandField ShowDeleteButton ="True" />
</ Columns >
</ asp:GridView >
< asp:ObjectDataSource ID ="ObjectDataSource1" TypeName ="DawnDataObject.Movies"
SelectMethod ="GetAll" UpdateMethod ="UpdateMovie" DeleteMethod ="DeleteMovie" runat ="server" onselected ="ObjectDataSource1_Selected" >
< SelectParameters >
< asp:Parameter Name ="executeTime" DbType ="Int64" Direction ="Output" />
</ SelectParameters >
< UpdateParameters >
< asp:Parameter Name ="Id" DbType ="Int32" />
< asp:Parameter Name ="Title" DbType ="String" />
< asp:Parameter Name ="Director" DbType ="String" />
</ UpdateParameters >
< DeleteParameters >
< asp:Parameter Name ="Id" DbType ="Int32" />
</ DeleteParameters >
</ asp:ObjectDataSource >

3.2 执行带参数的命令
大多数SQL命令都带有参数，比如在执行对数据库记录更新时，就要提供参数表示数据记录项的新值
最好不要通过手工串接+=操作来构建SQL命令参数，因为这样很容易遭受SQL注入攻击。
而使用SqlParameter对象来表示参数有很多种构建方式，最简单的就像下面一样来调用 SqlCommand.AddWithValue()方法

当使用AddWithValue()方法时，SqlCommand自动识别并推测参数的类型和大小。该方法会假设字符串值类型为NVarChar, 整数值类型为Int,十进行数值类型为Decimal,以此类推。
另一种构建参数的方法是直接创建SqlParameter对象，并加入到SqlCommand对象中。这样做的好处是：可以显式指定参数名称，大小，精度，刻度和传递方向。

第三种方法，直接使用Add的一个重载方法来创建新的SqlParameter对象

以上，使用第一种方法比较简便，直观。
图2: Command与Parameters的关系图如下所示：


3.3 执行存储过程
SqlCommand对象可以用来执行存储过程 ，执行存储过程如下所示：
SqlCommand cmd = new SqlCommand("GetTitles",conn);
cmd.CommandType = CommandType.StoredProcedure;
在SqlCommand的第一个参数中，不要把参数放到里面去，只要放存储过程名就行了，参数在SqlCommand的SqlParameters对象中添加
例5: 使用存储过程而非SQL语句更新电影信息记录
=== 存储过程创建 ===

=== App_Code\DawnDataObject.cs ===

Code
// 只要变更例4中的UpdateMovie函数，其它代码不变
public void UpdateMovie( int id, string title, string director)
{
SqlConnection conn = new SqlConnection(_connectionString);
SqlCommand command = conn.CreateCommand(); // 使用SqlConnection.CreateCommand获得SqlCommand对象
// 与例4相比，只要变更下面两句
command.CommandText = " UpdateMovie " ;
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddWithValue( " @id " , id);
command.Parameters.AddWithValue( " @title " , title);
command.Parameters.AddWithValue( " @director " , director);
using (conn){
conn.Open();
command.ExecuteNonQuery();
}
}

存储过程可以有返回值(returnvalue)，也可以有输出参数(output),那么，作为程序，如何调用存储过程后，取得相应的返回值呢。
例6: 从存储过程中取得返回值
=== SelectMovies存储过程 ===

=== movies.aspx ===

Code
< script runat ="server" >
void Page_Load()
{
lblMovieCount.Text = GetMovieCount().ToString();
}
private int GetMovieCount()
{
int result = 0 ;
string connectionString = WebConfigurationManager.connectionString[ " Movies " ].ConnectionString;
SqlConnection con = new SqlConnection(connectionString);
SqlCommand cmd = new SqlCommand( " GetMovieCount " , con);
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add( " @ReturnVal " , SqlDbType.Int).Direction = ParameterDirection.ReturnValue; // 设定返回值参数
using (con)
{
con.Open();
cmd.ExecuteNonQuery(); // 好像一定要使用ExecuteNonQuery,如果使用ExecuteReader，则相应的返回值就取不出来。
result = ( int )cmd.Parameters[ " @ReturnVal " ].Value; // 取得返回值参数值
}
return result;
}
</ script >

=== movies.aspx ===

Code
< script runat =server >
public List < Movie5 > GetBoxOffice(out decimal SumBoxOfficeTotals)
{
List < Movie5 > results = new List < Movie5 > ();
SqlConnection con = new SqlConnection(_connectionString);
SqlCommand cmd = new SqlCommand( " GetBoxOfficeTotals " , con);
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add( " @SumBoxOfficeTotals " , SqlDbType.Money).Direction = ParameterDirection.Output;
using (con)
{
con.Open();
SqlDataReader reader = cmd.ExecuteReader(); // 使用OUTPUT参数，可以使用ExecuteReader。与ReturnValue不同。
while (reader.Read())
{
Movie5 newMovie = new Movie5();
newMovie.Title = (string)reader[ " Title " ];
newMovie.BoxOfficeTotals = (decimal)reader[ " BoxOfficeTotals " ];
results.Add(newMovie);
}
reader.Close();
SumBoxOfficeTotals = (decimal)cmd.Parameters[ " @SumBoxOfficeTotals " ].
Value;
}
return results;
}
</ script >

3.4 单一的返回值
如果需要从数据库查询中获取单一的返回值，可以使用SqlCommand.ExecuteScalar()方法。该方法总是返回查询结果集中第一行第一列的数据值。
ExecuteScalar方法返回值的类型为object,可以将它转换为想要的类型。

3.5 返回结果集
在例1、例3、例4中，利用了SqlCommand.ExecuteReader()方法，调用这个方法将返回一个SqlDataReader对象，我们使用该对象读取每一行数据，并将数据存入一个泛型集合(List<Movie>)中,
如果希望省略复制步骤，并且不把获取的记录存入集合对象中，那么这里需要向ExecuteReader方法传递一个CommandBehavior.CloseConnection参数，该参数会使数据库连接与SqlDataReader对象关联起来，当从SqlDataReader对象中 读取了所有的数据记录 后。连接将自动关闭。
默认的向ExecuteReader方法传递一个CommandBehavior.Default参数，它表示此查询 可能返回多个结果集 。执行查询可能会影响数据库状态。调用SqlCommand.ExecuteReader(CommandBehavior.Default)就相当于调用SqlCommand.ExecuteReader()
例8: 不使用泛型集合作数据源
=== App_Code\DawnDataObject.cs ===

Code
namespace DawnDataObject
{
public class Movies
{
public SqlDataReader GetDataReader()
{
SqlConnection conn = new SqlConnection(_connectionString);
SqlCommand command = new SqlCommand( " SelectMovies " , conn);
command.CommandType = CommandType.StoredProcedure;
conn.Open();
return command.ExecuteReader(CommandBehavior.CloseConnection); // 直接返回DataReader作为数据源
}

public void UpdateMovies() {…}
public void DeleteMovies() {…}
}
}

=== movies.aspx ===

Code
<!-- 因为DataReader的原因,这里的GridView不支持分页,排序 -->
< asp:GridView ID ="GridView1" runat ="server" DataKeyNames ="Id"
AutoGenerateColumns ="False" DataSourceID ="ObjectDataSource1"
onrowcommand ="GridView1_RowCommand" onrowdeleting ="GridView1_RowDeleting" >
< Columns >
< asp:BoundField HeaderText ="Id" DataField ="Id" Visible ="false" />
< asp:BoundField HeaderText ="Title" DataField ="Title" />
< asp:BoundField HeaderText ="Director" DataField ="Director" />
< asp:CommandField ShowEditButton ="True" />
< asp:CommandField ShowDeleteButton ="True" />
</ Columns >
< asp:ObjectDataSource ID ="ObjectDataSource1" TypeName ="DawnDataObject.Movies"
SelectMethod ="GetDataReader" UpdateMethod ="UpdateMovie" DeleteMethod ="DeleteMovie" runat ="server" >
< UpdateParameters >
< asp:Parameter Name ="Id" DbType ="Int32" />
< asp:Parameter Name ="Title" DbType ="String" />
< asp:Parameter Name ="Director" DbType ="String" />
</ UpdateParameters >
< DeleteParameters >
< asp:Parameter Name ="Id" DbType ="Int32" />
</ DeleteParameters >
</ asp:ObjectDataSource >

4. DataReader对象

DataReader对象可以用来表示数据库查询的结果。该对象可以通过调用Command对象的ExecuteReader()方法获得.
调用DataReader的HasRows属性或者Read()方法，可以判断DataReader对象所表示的查询结果中是否包含数据行记录
调用Reader()方法，可以将DataReader对象所表示的当前数据行向前移动一行，移动一行后，返回true,到末尾，无法向前移动，返回false.
任意时刻上，DataReader对象只表示查询结果集中的某一行记录。
图3：DataReader与Command关系如下图所示:


4 .1 获得DataReader对象中数据行的字段值
如果要获得当前行中相应的字段值，可以使用以下方法来获得：
● string title = (string)reader["title"];     // 通过字段名称返回Object类型，再转换
● string title = (string)reader[0];           // 通过字段位置返回Object类型，再转换
● string title = reader.GetString(0);       // 通过字段位置返回string类型。
● string title = reader.GetSqlString(0);   // 通过字段位置，返回SqlString类型。

4.2 返回多个结果集
一个简单的数据库查询可以返回多个结果集，如以下SQL语句
"select * from MovieCategories; select * from movies"
在一次命令提交中执行多个查询可以提高效率，也可以避免战胜多个数据库连接。
在返回多个结果集的情况下，可以使用SqlDataReader的MoveResult()方法切换到下一个结果集中。
例9:返回多个结果集
=== App_Code\DawnDataObject.cs ===

Code
namespace mulitResults
{
public class DataLayer1
{
private static readonly string _connectionString;

public class MovieCategory // 表示电影种类实体,注意是嵌套类
{
private int _id;
private string _name;
public int Id
{
get { return _id; }
set { _id = value; }
}
public string Name
{
get { return _name; }
set { _name = value; }
}
}

public class Movie // 表示电影实体,注意是嵌套类
{
private string _title;
private int _categoryId;
public string Title
{
get { return _title; }
set { _title = value; }
}
public int CategoryId
{
get { return _categoryId; }
set { _categoryId = value; }
}
}

// 不像刚才实体列表作为返回值反回,现在作为参数返回
public static void GetMovieData(List < DataLayer1.MovieCategory > movieCategories,List < DataLayer1.Movie > movies)
{
string commandText = " SELECT Id,Name FROM MovieCategories;SELECT Title,CategoryId FROM Movies " ;
SqlConnection con = new SqlConnection(_connectionString);
SqlCommand cmd = new SqlCommand(commandText, con);
using (con)
{
// Execute command
con.Open();
SqlDataReader reader = cmd.ExecuteReader();
// Create movie categories
while (reader.Read())
{
DataLayer1.MovieCategory newCategory = new DataLayer1.
MovieCategory();
newCategory.Id = ( int )reader[ " Id " ];
newCategory.Name = ( string )reader[ " Name " ];
movieCategories.Add(newCategory);
}
// Move to next result set
reader.NextResult();
// Create movies
while (reader.Read())
{
DataLayer1.Movie newMovie = new DataLayer1.Movie();
newMovie.Title = ( string )reader[ " Title " ];
newMovie.CategoryId = ( int )reader[ " CategoryID " ];
movies.Add(newMovie);
}
}
}
static DataLayer1()
{
_connectionString = WebConfigurationManager.ConnectionStrings[ " Movies " ].ConnectionString;
}
}
}

=== ShowMovies.aspx ===

Code
< script runat ="server" >
void Page_Load()
{
// Get database data
List < DataLayer1.MovieCategory > categories = new List < DataLayer1.MovieCategory > ();
List < DataLayer1.Movie > movies = new List < DataLayer1.Movie > ();
DataLayer1.GetMovieData(categories, movies);
// Bind the data
grdCategories.DataSource = categories;
grdCategories.DataBind();
grdMovies.DataSource = movies;
grdMovies.DataBind();
}
</ script >
< h1 > Movie Categories </ h1 >
< asp:GridView id ="grdCategories" Runat ="server" />
< h1 > Movies </ h1 >
< asp:GridView id ="grdMovies" Runat ="server" />

4.3 多活动结果集MARS (Multiple Active Resultsets)
ADO.NET 2.0提供了MARS的新特性，在以前版本的ADO.NET中，数据库连接在一个有限时间段内能且只能表示一个查询结果集。
利用MARS特性，可以使用单一的数据库连接表示多个查询结果集。
MARS在以下场景中很有价值：程序对一个结果集遍历的过程中，同时需要对当前结果集中的记录执行一些额外的数据库操作。
打开MARS功能，需要在连接字符口串中包含以下字段: MultipleActiveResultSets=True;
例10: 使用多个结果集

Code
< script runat =”server” >
void BuildTree()
{
// Create MARS connection
SqlConnection con = new SqlConnection(_connectionString);
// Create Movie Categories command
string cmdCategoriesText = " SELECT Id,Name FROM MovieCategories " ;
SqlCommand cmdCategories = new SqlCommand(cmdCategoriesText, con);
// Create Movie command
string cmdMoviesText = " SELECT Title FROM Movies " + " WHERE CategoryId=@CategoryID " ;
SqlCommand cmdMovies = new SqlCommand(cmdMoviesText, con);
cmdMovies.Parameters.Add( " @CategoryId " , SqlDbType.Int);
using (con)
{
con.Open();
// 打开一个结果集,表示电影目录
SqlDataReader categories = cmdCategories.ExecuteReader();
while (categories.Read())
{
// Add category node
int id = categories.GetInt32( 0 );
string name = categories.GetString( 1 );
TreeNode catNode = new TreeNode(name);
TreeView1.Nodes.Add(catNode);
// Iterate through matching movies
cmdMovies.Parameters[ " @CategoryId " ].Value = id;
SqlDataReader movies = cmdMovies.ExecuteReader(); // 打开另一个结果集.注:上一个结果集还没有被关闭.
while (movies.Read())
{
// Add movie node
string title = movies.GetString( 0 );
TreeNode movieNode = new TreeNode(title);
catNode.ChildNodes.Add(movieNode);
}
movies.Close();
}
}
void Page_Load()
{
if ( ! Page.IsPostBack)
BuildTree();
}
</ script >

< asp:TreeView id =”TreeView1” Runat =”server” /> ASP.NET Core on K8S深入学习（14）Ingress灰度发布

本文介绍了Nginx Ingress提供的三种灰度发布（canary）的方式，然后介绍了如何使用Nginx Ingress并进行配置实现ASP.NET Core WebAPI应用服务的灰度发布实践，最后对比三种方式的优先级及限制，希望对你有所帮助。

ASP.NET Core on K8S深入学习（12）Ingress

本文介绍了Ingress的基本概念与Nginx Ingress的安装与配置，然后通过部署两个ASP.NET Core WebAPI服务到K8s集群进行Ingress的快速验证。