zoukankan      html  css  js  c++  java

  • C# 再谈数据库的操作

    首先介绍ADO.NET中的几个常用的对象，介绍的很简单。

    1.SqlConnection  这是数据库连接对象，通过对其进行实例化来创建针对数据库的连接，其参数为数据库连接字符串。如下：

    [csharp] view plaincopy
     
    1. SqlConnection conn = new SqlConnection(strConnection)  


    上面strConnection代表连接字符串

          上面建立了连接，这个连接的名称为conn,这就相当于建立了一天从程序连接到数据库的水管，水管拉好了，但是要想从数据库中取出数据，还得拧开水龙头才可以，所以使用下面的语句打开水龙头(打开连接)
    conn.Open();

            OK.,连接打开了，下面就可以取数据了，也就是可以接水了。但是需要注意的是水接完后，还得把水龙头关掉，这就需要下面的语句来执行
    conn.close();
        2.   SqlCommand  当然上面关掉水龙头的的动作应该放在程序的最后，也就是我们取完需要的数据之后。再执行了conn.open()之后，我们就可以对数据库进行操作了。对数据的操作包括插入，更改，删除和查询操作，这是最基本的几个操作。针对这些操作ADO.NET提供了不同的对象来方便大家使用。我们首先来说增加，更改和删除操作。

             这些操作离不开SqlCommand对象，顾名思义，这个对象时用来执行命令的，什么命令呢？当然是数据库操作命令了，也就是增加，删除，更改，查询这些命令，更具体的说也就是执行上面几种操作的sql语句。OK，既然如此，我们首先就要创建这个对象，怎么创建呢？先说两种方法。
    •使用上面创建的数据库连接对象conn来创建，语法如下：SqlCommand cmd = conn.CreateCommand()

    •直接实例化SqlCommand对象，然后将数据库连接对象赋给SqlCommand对象的Connection属性。如下•

    [csharp] view plaincopy
     
    1. SqlCommand cmd = new SqlCommand();cmd.Connection = conn;  



    大家会发现，无论哪种方法都是将数据库连接对象conn和SqlCommand对象进行关联，这是为什么呢？正如上面所说的，SqlCommand对象时用来执行sql语句的，也就是对数据库的增加，更改，删除，查询操作，但是我们是针对哪个数据库进行操作呢？关键就在这里，大家回想一下数据库连接字符串，里面指定了数据库所在的服务器，以及数据库的名称。这就很明白了，我们将特定的数据库连接对象和SqlCommand对象关联起来，就指明了我们操作的是哪个数据库。比如我们在创建了conn对象之后，在创建一个conn1对象，把其连接字符串改一改，例如将服务器的名称改了，这样可能就是连接另一台计算机上的数据库了。OK，事情就是这样你可以在程序中创建多个数据库连接对象，可以为SqlCommand对象随意指定一个数据库连接对象。

          好了，上面已经创建了SqlCommand对象，并且将其和数据库连接对象关联起来，这就解决了对哪个数据进行操作的问题。下面要解决的问题是对数据库执行什么操作。如果是增加数据，我们就编写insert语句，如果是更改，就编写Update语句，如果是删除，就是用delete语句，如果是查询，就使用selsect语句。这里假设我们要向数据库中的某张表增加一条数据，其sql语句是

    [csharp] view plaincopy
     
    1. string sqlstr="insert into Users(username,password,email) values(@username,@password,@email)"  



        这里我们并没有使用字符串拼接的方式为字段赋值，而是使用了@username,@password，这种方式，我们可以将其看做占位符，在后面的代码中将会使用实际的值将其替换，微软说这种方式有效解决了sql注入的问题，至于其内部到底怎么实现的，就搞不清楚了，总之这是微软推荐的一种方式，我们以后也要使用这种方式。

          然后将这条语句赋给SqlCommand对象的CommdText属性，这样SqlCommand对象就知道要执行什么操作了，如下所示：

    [csharp] view plaincopy
     
    1. cmd.CommandText = sqlstr;  



          OK，现在给@username,@password，@email这三个占位符赋值，赋值的方法很多，下面采用的方式是比较普遍的一种：
                      

    [csharp] view plaincopy
     
    1. SqlParameter username = new SqlParameter("@username", this.txt_username.Text);  
    2. SqlParameter password = new SqlParameter("@password", this.txt_username.Text);  
    3. SqlParameter email = new SqlParameter("@email", this.txt_username.Text);  
    4. cmd.Parameters.Add(username);    
    [csharp] view plaincopy
     
    1. cmd.Parameters.Add(password);  
    2. cmd.Parameters.Add(email);  

    SqlParameter 类，顾名思义，这是一个用来操作sql语句中的参数(@username,@password,@email就是这里所指的参数)的类，它的作用就是将sql语句中的参数和其实际值产生一个映射关系，我们举个例子来说，页面上我们使用三个控件来供用户输入用户名，密码，邮箱信息，假设其ID分别为txt_username,txt_password,txt_email。OK，我们要做的工作就是使用txt_username控件的值替代上面sql语句中的@username,使用txt_password替代@password，使用txt_email替代@email。好了，目的就是这样。那么如何达成目标呢？就是使用上面的语句

    [csharp] view plaincopy
     
    1. SqlParameter username = new SqlParameter("@username", this.txt_username.Text);  

    这行代码就是告诉程序，将来在执行这条sql语句时，要使用this.txt_username.Text替换@username。

    OK 映射关系已经建立起来了，大家已经发现了，每一个SqlParameter对象存储了一对映射关系，然后我们要做的就是将这几对映射关系添加到SqlCommand对象，也就是使用上面的语句：

    [csharp] view plaincopy
     
    1. cmd.Parameters.Add(username);  


    这句话的作用就是告诉程序cmd在执行sql语句时，要使用这些映射关系替换sql语句中的参数(占位符)。

    OK，现在我们知道了要操作哪个数据库，要进行什么操作，下面的问题就是如何操作了。增加，更改和删除三种操作不需要返回数据，只需要返回一个操作状态就行了，这个状态就是一个整形数字。1代表操作成功。所以我们可以使用
    cmd.ExecuteNonQuery()
    方法来执行这条语句，ExecuteNonQuery()方法就是执行一条插入语句或者一条更改语句或者一条删除语句，其返回的是受影响的行数，只要其返回值>1，就表明执行成功。至于其为什么不能执行查询语句呢？因为查询语句要返回的是数据，而不是查询出了几行，所以不能使用这个方法。所以我们可以这样使用此方法：

    [csharp] view plaincopy
     
    1. if (cmd.ExecuteNonQuery() >0)  
    2.  {  
    3.      ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('注册成功,请登录')</script>", false);  
    4.      Response.Redirect("Login.aspx");  
    5.  }  
    6.  else  
    7.  {  
    8.      ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('注册失败')</script>", false);  
    9.  }  
    10.   
    11.   
    12.        


            

    OK，上面讲了插入，更改和删除的用法都是一样的，所需更改的只有sql语句。

    下面我们说下从数据库中查询数据。

    前面都一样，所需要更改的只是sql语句，我们更改前面的

    [csharp] view plaincopy
     
    1. string sqlstr="select * from Users where username=@username";  



    现在我们要获取的是实实在在的数据，而不是影响的行数，所以不能使用ExecuteNonQuery。

    最常用的有三种查询数据的方式，我们先介绍SqlCommand对象的ExecuteReader方法，此方法的返回值为SqlDataReader对象，这个对象也是ADO,NET中一个非常重要的对象，这个对象在程序和数据库之间建立了一个流，也可以理解为在程序和数据库之间划了一条线，这条线最开始指向数据库中查询出来的结果集的第1行的上面（当然身为程序员，我们可以给其一个更形象化的名字--指针），如下图所示：


    红色箭头就是执行玩ExecuteReader方法后指针的初始位置----在第一条记录的前面。

    这时候我们可以使用Read()方法将指针移动到下一条记录。Read()方法的作用有2个，首先返回一个bool值，这个值表示当前记录是否有下一条记录，然后将指针移动下一条记录。ExecuteReader()方法先说到这里，后面会有详细的例子，大家一看就明白了。

    也许大家已经注意到了，我们上面的sql语句

    [csharp] view plaincopy
     
    1. string sqlstr="select * from Users where username=@username";  


    查询的是所有列，事实上在登录验证的时候，只查询密码列就可以了，所以这行代码可以改成

    [csharp] view plaincopy
     
    1. string sqlstr="select password from users where username=@username";  

    在实际应用中，数据库中存储的用户名肯定是唯一的，所以上面语句查询出来的结果应该是1行(假设用户输入的用户名存在)，而且这1行只有1列---密码列(password)，也就是说查询出来的结果是一个值，这个值存储在结果集的第1行，第1列。对于这种情况的查询，我们可以是也弄个ExecuteScalar()方法，此方法返回的是一个Object类型的对象，所以我们在使用时还需要类型转换，下面有例子，一看就会明白。

    下面介绍第三种查询数据的方式，这涉及到另外3个对象SqlDataAdapter和DataSet或者DataTable.

    3.    SqlDataAdapter和DataSet，DataTable

           首先说一下DataTable对象，大家都知道HTML中的Table标签，其是由行和列组成的一个表格，同样DataTable也是有行和列组成的一个表格，每个单元格中存储的都是数据。

           然后是DataSet对象，此对象就是一个DataTable的集合，可以通过下标来访问其中特定的DataTable。

           重点是SqlDataAdapter对象，此对象的作用是从数据库中查询出数据，然后填充到DataTable或者DataSet中(填充DataSet，其实还是填充到DataTable中，我们以后就直接使用DataTable，而不再重复DataSet)。

            大家留意数据库中查询出得结果集的样式，如下图所示：

       

    它是以表格的形式来显示的，而DataTable 也是以这种形式来存储查询到的结果集的。大家记住这张图，这对于后面对DataTale的操作很有帮助

    下面我们要讨论的就是SqlDataAdapter如何使用了。这个对象的使用方法很多，为了大家易于理解，我这里只说一种，其余的大家可以自己去尝试。步骤如下：

    • 声明数据库连接对象，这在前面已经实现
    • 声明SqlCommand对象，这在前面已经实现
    • 将SqlDataAdapter对象和SqlCommand对象产生关联。语法入选：
    [csharp] view plaincopy
     
    1. SqlDataAdapter adapter=new SqlDataAdapter(cmd);  
    • 使用SqlDataAdapter对象的Fill方法来填充DataTable，语法如下：
    [csharp] view plaincopy
     
    1. DataTable dt=new DataTable();  
    2. adapter.Fill(dt);  


    第3个步骤是和SqlCommand对象相关联，获取此对象的CommandText属性，也就是获取我们要执行的sql语句。

    第4个步骤中的Fill方法至少执行了三个工作

    • 打开连接，相当于conn,open()，所以我们使用SqlDataAdapter对象时，不用写这句代码了，连接会自动打开的。
    • 执行CommandText属性所对应的sql语句
    • 将查询的结果填充到DataTable中

    OK，现在我们已经完成了从数据中查询数据的工作吗，接下来就是如何操作这些数据了。下面会给出例子，会用注释说明。 不多说了，上例子。

    4      实例说明

    实现简单的注册，登录功能

    首先是注册页面，布局如下：


    [csharp] view plaincopy
     
    1. DataTable dt=new DataTable();  
    2.                     adapter.Fill(dt);  

    后台代码如下所示：

    [csharp] view plaincopy
     
    1. string strConnection = "user id=sa;password=sa;initial catalog=MyTest;Server=YHB;Connect Timeout=30";  
    2.             //实例化数据库连接对象  
    3.             using (SqlConnection conn = new SqlConnection(strConnection))  
    4.             {  
    5.                 //实例化命令对象  
    6.                 using (SqlCommand cmd = conn.CreateCommand())  
    7.                 {  
    8.                     cmd.CommandText = "insert into Users(username,password,email) values(@username,@password,@email)";  
    9.                     //实例化SqlParameter对象，为@username等建立映射关系  
    10.                     SqlParameter username = new SqlParameter("@username", this.txt_username.Text);  
    11.                     SqlParameter password = new SqlParameter("@password", this.txt_username.Text);  
    12.                     SqlParameter email = new SqlParameter("@email", this.txt_username.Text);  
    13.                     //将映射关系添加到cmd中  
    14.                     cmd.Parameters.Add(username);  
    15.                     cmd.Parameters.Add(password);  
    16.                     cmd.Parameters.Add(email);  
    17.                     //打开数据连接  
    18.                     conn.Open();  
    19.                     //执行插入操作  
    20.                     if (cmd.ExecuteNonQuery() >0)  
    21.                     {                          
    22.                         Response.Redirect("Login.aspx");  
    23.                     }  
    24.                     else  
    25.                     {  
    26.                         ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('注册失败')</script>", false);  
    27.                     }  
    28.                 }  
    29.             }  


    然后是登录页面，布局如下：

    后台代码如下：

    [csharp] view plaincopy
     
    1. //连接字符串  
    2.            string strConnection = "user id=sa;password=sa;initial catalog=MyTest;Server=YHB;Connect Timeout=30";  
    3.            //实例化数据库连接对象  
    4.            using (SqlConnection conn = new SqlConnection(strConnection))  
    5.            {  
    6.                //实例化命令对象  
    7.                using (SqlCommand cmd = conn.CreateCommand())  
    8.                {                      
    9.                    cmd.CommandText = "select password from users where username=@username";  
    10.                    //实例化SqlParameter对象，为@username等建立映射关系  
    11.                    SqlParameter username = new SqlParameter("@username", this.txt_username.Text);  
    12.                    //将映射关系添加到cmd中  
    13.                    cmd.Parameters.Add(username);  
    14.                    //打开数据连接  
    15.                    conn.Open();  
    16.                    object obj = cmd.ExecuteScalar();  
    17.                    if (obj == null)  
    18.                    {  
    19.                        ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('用户名不存在')</script>", false);  
    20.                    }  
    21.                    else  
    22.                    {  
    23.                        string password = Convert.ToString(obj);  
    24.                        //比较从数据库获取的密码和用户输入的密码是否一致  
    25.                        if (password != this.txt_password.Text)  
    26.                        {  
    27.                            ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('密码不正确')</script>", false);  
    28.                        }  
    29.                        else  
    30.                        {  
    31.                            ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('登陆成功')</script>", false);  
    32.                        }  
    33.                    }  
    34.                }  
    35.            }  

    上面使用的是cmd.ExecuteScalar()方法来获取查询结果。下面我们改成使用SqlDataReader对象来操作数据

    [csharp] view plaincopy
     
    1. //连接字符串  
    2.             string strConnection = "user id=sa;password=sa;initial catalog=MyTest;Server=YHB;Connect Timeout=30";  
    3.             //实例化数据库连接对象  
    4.             using (SqlConnection conn = new SqlConnection(strConnection))  
    5.             {  
    6.                 //实例化命令对象  
    7.                 using (SqlCommand cmd = conn.CreateCommand())  
    8.                 {  
    9.                     cmd.CommandText = "select password from users where username=@username";  
    10.                     //实例化SqlParameter对象，为@username等建立映射关系  
    11.                     SqlParameter username = new SqlParameter("@username", this.txt_username.Text);  
    12.                     //将映射关系添加到cmd中  
    13.                     cmd.Parameters.Add(username);  
    14.                     //打开数据连接  
    15.                     conn.Open();  
    16.                     SqlDataReader reader = cmd.ExecuteReader();  
    17.                     //判断是否有查询结果  
    18.                     if (reader.HasRows)  
    19.                     {  
    20.                         //读取下一行  
    21.                         while (reader.Read())  
    22.                         {  
    23.                             <span style="color:#ff0000;">string password =Convert.ToString(reader.GetSqlString(reader.GetOrdinal("password")));</span>  
    24.                             if (string.IsNullOrEmpty(password))  
    25.                             {  
    26.                                 ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('用户名不存在')</script>", false);  
    27.                             }  
    28.                             else  
    29.                             {                                  
    30.                                 //比较从数据库获取的密码和用户输入的密码是否一致  
    31.                                 if (password != this.txt_password.Text)  
    32.                                 {  
    33.                                     ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('密码不正确')</script>", false);  
    34.                                 }  
    35.                                 else  
    36.                                 {  
    37.                                     ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('登陆成功')</script>", false);  
    38.                                 }  
    39.                             }  
    40.   
    41.                         }  
    42.                     }  
    43.                       
    44.                 }  
    45.             }  


    下面解释一下红色的那句代码。可以将其拆解开来。

    reader.GetOrdinal("password")：获取指定列的序号，也就是说SqlDataReader对象每次只读取1行，这个方法获取的是“password”这一列在这1行的序号，也就是索引

    reader.GetSqlString(reader.GetOrdinal("password"))：GetSqlString方法根据列的序号获取列的值

    最后将返回值转换成string类型

    最后使用第三种方式，代码如下：

    [csharp] view plaincopy
     
    1. //连接字符串  
    2.             string strConnection = "user id=sa;password=sa;initial catalog=MyTest;Server=YHB;Connect Timeout=30";  
    3.             //实例化数据库连接对象  
    4.             using (SqlConnection conn = new SqlConnection(strConnection))  
    5.             {  
    6.                 //实例化命令对象  
    7.                 using (SqlCommand cmd = conn.CreateCommand())  
    8.                 {  
    9.                     cmd.CommandText = "select password from users where username=@username";  
    10.                     //实例化SqlParameter对象，为@username等建立映射关系  
    11.                     SqlParameter username = new SqlParameter("@username", this.txt_username.Text);  
    12.                     //将映射关系添加到cmd中  
    13.                     cmd.Parameters.Add(username);  
    14.                     //声明SqlDataAdapter对象  
    15.   
    16.                     SqlDataAdapter adapter = new SqlDataAdapter(cmd);  
    17.                     DataTable dt = new DataTable();  
    18.                     adapter.Fill(dt);  
    19.                     //判断是否有查询结果  
    20.                     if (dt.Rows.Count>0)  
    21.                     {  
    22.   
    23.                         //因为最多只返回一行数据(因为用户名是唯一的)，所以可以直接使用dt.Rows[0]标示第1行，使用dt.Rows[0]["password"]来获取第1行中列名称为"password"的字段的值。  
    24.                             string password = Convert.ToString(dt.Rows[0]["password"]);  
    25.                             if (string.IsNullOrEmpty(password))  
    26.                             {  
    27.                                 ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('用户名不存在')</script>", false);  
    28.                             }  
    29.                             else  
    30.                             {  
    31.                                 //比较从数据库获取的密码和用户输入的密码是否一致  
    32.                                 if (password != this.txt_password.Text)  
    33.                                 {  
    34.                                     ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('密码不正确')</script>", false);  
    35.                                 }  
    36.                                 else  
    37.                                 {  
    38.                                     ClientScript.RegisterStartupScript(GetType(), "提示", "<script>alert('登陆成功')</script>", false);  
    39.                                 }  
    40.                             }  
    41.   
    42.                         }  
    43.                 }  
    44.             }  
    高山仰止， 景行行止。 四牡鲱鲱， 六辔如琴。 觏尔新婚， 以慰我心。
  • 相关阅读:
    vue中使用v-on绑定事件中，获取$event.currentTarget，日志打印为null
    问题记录：events.js:183 throw er; // Unhandled 'error' event Error: listen EADDRINUSE 127.0.0.1:8888
    跨域通信——多窗口通信
    fiddler抓包工具-常用功能1
    git使用手册
    webpack.config.js配置文件
    Loader转换器
    webpack安装使用
    <el-table>里的数据已经修改了,但是页面不更新
    <el-onload>使用属性file-list时返回数据里必须含url字段
  • 原文地址：https://www.cnblogs.com/davidshi/p/3291274.html
Copyright © 2011-2022 走看看