第十四講 數(shù)據(jù)集對象DataRader

1、第十四講 SqlDataReader對象一、SqlDataReader對象SqlDataReader對象是對連接執(zhí)行 Transact-SQL 語句返回的一個只讀的數(shù)據(jù)流。常用屬性：1）Item 索引器屬性，以原始格式獲得一列的值SqlDataReader對象名.索引值SqlDataReader對象名.“表中的字段名”2）FieldCount 獲取當(dāng)前行的列數(shù)3）HasRows 獲取一個值，以表示SqlDataReader對象中是否包含一行或多行記錄。二、常用方法：1）Read 使DataReader對象前進(jìn)到下一條記錄（如果有）2）Close 關(guān)閉DataReader對象。注意，關(guān)閉閱讀器對

2、象并不會自動關(guān)閉底層連接例：在學(xué)生成績數(shù)據(jù)庫中新建一個成績表，輸入期若干個學(xué)生的學(xué)號及語文、數(shù)學(xué)、英語三門課的成績，創(chuàng)建一個視圖，可輸出所有學(xué)生的成績及總分和平均分，并按總分的降序排列。設(shè)計一個應(yīng)用程序，可查看全班所有學(xué)生的總分及平均分。創(chuàng)建視圖的SQL代碼參考如下：CREATE VIEW dbo.成績排名AS SELECT TOP 100 PERCENT 學(xué)號, 語文, 數(shù)學(xué), 英語, 語文 + 數(shù)學(xué) + 英語 AS 總分, (語文 + 數(shù)學(xué) + 英語) / 3 AS 平均分 FROM dbo.成績表 ORDER BY 總分 DESC程序代碼參考如下： string SqlStr = &qu

3、ot;Server=192.168.200.61;User Id=sa;Pwd=;DataBase=stu" SqlConnection con = new SqlConnection(SqlStr); con.Open(); SqlStr = "select * from view1 " SqlCommand cmd = new SqlCommand(SqlStr, con); SqlDataReader dr = cmd.ExecuteReader(); string s = "學(xué)號 語文 數(shù)學(xué) 外語 總分 平均分n" while (dr.

4、Read() int i = 0; while (i < dr.fieldcount) s = s + " " + dri.ToString(); i+; s = s + "n" MessageBox.Show(s); con.Close(); con.Dispose();實作練習(xí)：在航班信息管理數(shù)據(jù)庫中建立一個用戶表 (用戶名,密碼,用戶類型)，輸入若干條記錄，編程查看并輸出用戶表中的所有記錄。 string constr = "Data Source=0F6A988FB791401;Initial Catalog=航班信息管理;Int

5、egrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string comstr = "select * from 用戶表" SqlCommand com = new SqlCommand(comstr, con); SqlDataReader dr = com.ExecuteReader(); string str = "" ; while (dr.Read() for (int i = 0; i < dr.FieldCount

6、 - 1; i+) str = str + dri.ToString() + " " str = str + "n" MessageBox.Show(str); con.Close();三、案例：用戶登錄界面設(shè)計及實現(xiàn)：需要引用的命名空間為：using System.Data.SqlClient;登錄界面代碼： string str = "Server=(local);User Id=sa;Pwd=;DataBase=航班信息管理" SqlConnection con = new SqlConnection(str); con.Ope

7、n(); str = "select * from 用戶表 where 用戶名='" + textBox1.Text + "'" SqlCommand com = new SqlCommand(str, con); com.Connection = con; SqlDataReader dr = com.ExecuteReader(); if(dr.HasRows) dr.Read(); string s = dr1.ToString(); if (s.Trim()=textBox2.Text) Form1 f1 = new Form1(

8、); f1.Show(); else MessageBox.Show("密碼錯誤！"); else MessageBox.Show("用戶名不存在！"); 四、實作練習(xí)：編程實現(xiàn)航班信息管理的用戶注冊功能。參考代碼如下： string constr = "Data Source=0F6A988FB791401;Initial Catalog=航班信息管理;Integrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string

9、 comstr = "select * from 用戶表 where 用戶名='" + textBox1.Text + "'" SqlCommand com = new SqlCommand(comstr, con); SqlDataReader dr = com.ExecuteReader(); if (dr.HasRows) MessageBox.Show("用戶名已存在，重新注冊！"); else con.Close(); con.Open(); comstr = "insert into 用戶表 (用

10、戶名,密碼,用戶類型) values('" + textBox1.Text + "','" + textBox2.Text + "','學(xué)生')" com = new SqlCommand(comstr, con); if (com.ExecuteNonQuery() = 1) MessageBox.Show("注冊成功！"); else MessageBox.Show("數(shù)據(jù)庫寫入失敗！"); con.Close();五、向組合框中添加數(shù)據(jù)庫中的信息 st

11、ring str = "Server=(local);User Id=sa;Pwd=;DataBase=航班信息管理" SqlConnection con = new SqlConnection(str); con.Open(); SqlCommand cmd = new SqlCommand("select 航班號 from 航班信息表"); cmd.Connection = con; SqlDataReader dr = cmd.ExecuteReader(); while (dr.Read() comboBox3.Items.Add(dr0); c

12、omboBox3.Text = comboBox3.Items0.ToString();con.Close();向下拉列表框圖中添加數(shù)據(jù)集 string constr = "Data Source=417-80;Initial Catalog=student;Integrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string sqlstr = "select userType from userType" SqlCommand com =

13、new SqlCommand(sqlstr, con); SqlDataReader dr = com.ExecuteReader(); while (dr.Read() cmbUserTpe.Items.Add (dr0.ToString (); con.Close(); cmbUserTpe.SelectedIndex = 0;定義用戶類型類 public class UserTypeClass int userTypeID; string userType; public int UserTypeID get return userTypeID; public string UserTy

14、pe get return userType; public UserTypeClass(int id,string type) userTypeID = id; userType = type; 將用戶類型對象添加到下拉列表框中 string constr = "Data Source=417-80;Initial Catalog=student;Integrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string sqlstr = "select

15、* from userType" SqlCommand com = new SqlCommand(sqlstr, con); SqlDataReader dr = com.ExecuteReader(); while (dr.Read() UserTypeClass x = new UserTypeClass(Convert .ToInt16 ( dr0),dr.GetString(1); cmbUserTpe.Items.Add (x); con.Close(); cmbUserTpe.SelectedIndex = 0; cmbUserTpe.DisplayMember = &q

16、uot;UserType"完成用戶注冊 string constr = "Data Source=417-80;Initial Catalog=student;Integrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string sqlstr = "insert into usertabel(username,userpwd,usertypeid) values('0','1',2)" UserTyp

17、eClass x=cmbUserTpe.SelectedItem as UserTypeClass ; sqlstr = string.Format(sqlstr, txtUsername.Text, txtUserPWD.Text, x.UserTypeID); SqlCommand com = new SqlCommand(sqlstr, con); if (com.ExecuteNonQuery() > 0) MessageBox.Show("用戶注冊成功！"); con.Close();用戶注冊功能的完善（二次輸入密碼是否一致，用戶名是否已注冊） if (tx

18、tUserPWD.Text != txtUserPWD2.Text) MessageBox.Show("二次輸入的密碼不一致！"); else string constr = "Data Source=417-80;Initial Catalog=student;Integrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string sqlstr = "select * from usertabel where username=&#

19、39;" + txtUsername.Text + "'" SqlCommand com = new SqlCommand(sqlstr, con); if (com.ExecuteScalar() !=null) MessageBox.Show("用戶名已注冊！"); else sqlstr = "insert into usertabel(username,userpwd,usertypeid) values('0','1',2)" UserTypeClass x = cmbUse

20、rTpe.SelectedItem as UserTypeClass; sqlstr = string.Format(sqlstr, txtUsername.Text, txtUserPWD.Text, x.UserTypeID); com = new SqlCommand(sqlstr, con); if (com.ExecuteNonQuery() > 0) MessageBox.Show("用戶注冊成功！"); con.Close(); 用戶登錄功能的實現(xiàn)與SQL注入式攻擊的防范： string constr = "Data Source=417-80

21、;Initial Catalog=student;Integrated Security=True" SqlConnection con = new SqlConnection(constr); con.Open(); string sqlstr = "select * from usertabel where username='0' and userpwd='1'" sqlstr =string .Format (sqlstr,txtUsername.Text ,txtUserPWD.Text ); SqlCommand com

22、 = new SqlCommand(sqlstr, con); if (com.ExecuteScalar() != null) MessageBox.Show("登錄成功！"); this.Close(); else MessageBox.Show("登錄失敗！"); con.Close();SQL注入式攻擊若用戶輸入的用戶名為abc，密碼為' or '1'='1 則sqlstr =string .Format (sqlstr,txtUsername.Text ,txtUserPWD.Text );命令生成的sqlstr為：s