Ado.Net基础拾遗一：读取数据

从数据库中读取数据：

使用DataReader对象从数据库中读取数据

首先需要添加几个命名空间

//需要添加的命名空间
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

配置文件如下

<configuration>
    <connectionStrings>
        <add name="NorthwindConnectionString" connectionString="Data Source=TANGPRO-PC;Initial Catalog=Northwind;Integrated Security=True"
            providerName="System.Data.SqlClient" />
    </connectionStrings>
</configuration>

具体实现代码

　　　　　　  //从配置文件中读取数据库连接信息
            string conStr = ConfigurationManager.ConnectionStrings["NorthwindConnectionString"].ConnectionString;
            SqlConnection conn = new SqlConnection(conStr);//使用SqlConnection对象与数据库相连接


            //Command对象使用Connection对象执行SQL查询，它返回的结果通常存储在 DataSet或DataReader中
            SqlCommand myCommand = new SqlCommand();
            myCommand.CommandText = "SELECT TOP 3 * FROM CUSTOMERS"; //需要执行的SQL语句
            myCommand.CommandType = CommandType.Text; //CommandType.Text 表示 SQL 语句是内部文本
            myCommand.Connection = conn; //SqlCommand对象的连接对象

            //打开连接
            myCommand.Connection.Open();

            //此处存放在 DataReader中
            SqlDataReader myReader = myCommand.ExecuteReader(CommandBehavior.CloseConnection);

            //将返回的数据绑定到 GridView控件中
            GridView1.DataSource = myReader;
            GridView1.DataBind();

            //读取完毕后销毁连接
            myCommand.Dispose();
            conn.Dispose();

结果：

 使用数据适配器

•  SqlDataAdaper是一个特殊的类，其作用是在断开连接的DataTable对象和物理数据源之间搭起桥梁
• 其提供双向的传输机制，它可以在数据源上执行SELECT语句，将结果传送到DataTable对象中，还可以执行标准的INSERT,UPDATE,DELETE语句，从DataTable对象中提取输入的数据
• SqlDataAdaper类提供了一个Fill()方法，调用Flii()方法将执行SelectCommand属性中提供的命令，获取结果集，并把它复制到DataTable对象中

实现代码：

   protected void Page_Load(object sender, EventArgs e)
        {
            if (!Page.IsPostBack)
            {
                //从配置文件中读取数据库连接信息
                string conStr = ConfigurationManager.ConnectionStrings["NorthwindConnectionString"].ConnectionString;
                SqlConnection conn = new SqlConnection(conStr);//使用SqlConnection对象与数据库相连接

                SqlCommand cmd = new SqlCommand();
                cmd.CommandType = CommandType.Text;
                cmd.Connection = conn;
                cmd.CommandText = "SELECT TOP 5 * FROM CUSTOMERS";

                DataTable myTable = new DataTable();
                
                SqlDataAdapter myAdapter = new SqlDataAdapter();

                //使用前面创建的 SqlCommand 对象填充 DataAdapter对象的SelectCommand属性
                myAdapter.SelectCommand = cmd;

                //调用Flii()方法将执行SelectCommand属性中提供的命令，获取结果集，并把它复制到DataTable对象中
                myAdapter.Fill(myTable); //Fill()方法返回一个已填充的DataTable对象

                GridView1.DataSource = myTable.DefaultView;
                GridView1.DataBind();

                myAdapter.Dispose();
                cmd.Dispose();
                conn.Dispose();
            }

        }

结果

使用参数

       protected void Page_Load(object sender, EventArgs e)
        {
            if (!Page.IsPostBack)
            {
                string conStr = ConfigurationManager.ConnectionStrings["NorthwindConnectionString"].ConnectionString;
                SqlConnection conn = new SqlConnection(conStr);

                SqlCommand myCommand = new SqlCommand();
                myCommand.CommandType = CommandType.Text; 
                myCommand.Connection = conn;
                myCommand.CommandText = "SELECT * FROM CUSTOMERS WHERE CITY = @CITY AND CONTACTNAME= @CONTACT"; //此处使用了参数@CITY @CONTACT


                //创建SqlParameter对象，使用参数有助于防止可能的 SQL 注入攻击
                //一般只需要填写ParameterName 和 Value属性即可
                SqlParameter cityPara = new SqlParameter();
                cityPara.ParameterName = "@CITY";  //这个读写属性获取或设置参数的名称
                cityPara.SqlDbType = SqlDbType.VarChar; //获取或设置参数值的SQL Server数据库类型
                cityPara.Size = 15; //这个读写属性获取或设置参数值的大小
                cityPara.Value = "Berlin"; //参数对象提供的值，这个值在运行期间传送给命令中定义的参数

                SqlParameter contactPara = new SqlParameter();
                contactPara.ParameterName = "@CONTACT";
                contactPara.SqlDbType = SqlDbType.VarChar;
                contactPara.Size = 15;
                contactPara.Value = "Maria Anders";


                //向SqlCommand对象中加入参数
                myCommand.Parameters.Add(cityPara);
                myCommand.Parameters.Add(contactPara);

                myCommand.Connection.Open();

                SqlDataReader myReader = myCommand.ExecuteReader(CommandBehavior.CloseConnection);

                GridView1.DataSource = myReader;
                GridView1.DataBind();

                myCommand.Dispose();
                conn.Dispose();
            }
        }

第二种加入参数的方法（更简便）

     　　　　　　myCommand.CommandText = "SELECT * FROM CUSTOMERS WHERE CITY = @CITY AND CONTACTNAME= @CONTACT"; //此处使用了参数@CITY @CONTACT

                myCommand.Parameters.Add(new SqlParameter("CITY", "Berlin")); //期中CITY对应 SQL语句中的 @CITY   ，Berlin是其需要输入的值
                myCommand.Parameters.Add(new SqlParameter("CONTACT", "Maria Anders"));

结果：