首页 > 代码库 > ADO.NET的学习

ADO.NET的学习

 ADO.NET的几个对象

  • Connection:管理数据库的连接
  • Command:对数据库执行命令
  • DataReader:数据流读取器,返回的数据都是快速的且只是“向前”的数据流。无法实例化,只能通过Command创建
  • DateSet:缓存数据,对数据进行操作
  • DataAdapter:数据适配器,数据库和DataSet的桥梁

ADO.NET命名空间

 注:图取自网络

技术分享

常见的是SQL数据源

引用命名空间:

using System.Data.SqlClient;

一、Connection类

连接数据库,Connection会被Command对象使用,这样就能够知道是在哪个数据源上面执行命令。

Connection有两个重要属性:ConnectionString和State,连接字符串和连接状态

       两个重要方法:Open()和Close(),用来打开和关闭数据库连接

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
    conn.Open();       
}

 conn.State.ToString():当前连接状态,返回值为Closed 或Open

二、Command对象

Command有两个重要属性:CommandType, 指明CommandText 是SQL语句,存储过程还是表操作,默认值为CommandType.Text; 

                                                    两个值:(1)CommandType.StoredProcedure,以存储过程方式执行

                           (2)CommandType.Text SQL语句执行

                           (3)CommandType.TableDirect,直接处理某个表

               CommandText,值为SQL语句或是存储过程名词,默认为SQL语句

创建命令对象的两种方式

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
    conn.Open();   
    SqlCommand SqlCommand= conn .CreateCommand(); //这种方式比较好
SqlCommand.CommandText="select * from Student"; //或是实例化一个对象 //SqlCommand sqlcmd=new SqlCommand(); //sqlcmd.CommandText ="select * from student"; //sqlcmd.Connection=conn;
}

 

三个重要方法:

  • ExecuteReader():返回DataReader对象,DataReader对象说明详见下文

 

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
     SqlCommand command = conn.CreateCommand();
   command.CommandText = "Select * form Student";
   //CommandBehavior.CloseConnetion 关闭dataReader时,同时也把与它相关联的Connection连接也一起关闭   
using (SqlDataReader dr = command.ExecuteReader(CommandBehavior.CloseConnection))   {     while (dr.Read())     {       //开始读取数据了,接下来你想怎么样就怎么样了       string str = dr.GetSqlString(0).ToString();     }   } }

 

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
    SqlConnection conn = new SqlConnection(str);        //创建连接
    SqlCommand cmd = conn.CreateCommand();              //创建命令
    cmd.CommandText = "SELECT * FROM Person";           //设置操作语句
    conn.Open();                                        //打开连接
    //SqlDataReader读取数据
    using (SqlDataReader reader = cmd.ExecuteReader())
    {
      while (reader.Read())
        {
               Console.WriteLine(reader[0] + ":" + reader[1]);  //输出当前行的第一列,第二列数据
        }
    }

    cmd.CommandText = "SELECT Count(*) FROM Person";
    object obj = cmd.ExecuteScalar();                   //仅查询第一行第一列
    Console.WriteLine((int)obj);
    conn.Close();                                       //关闭连接
             
}
  • ExecuteScalar():返回数据第一行第一列的值,如Count(*),如果没有数据,则返回NULL
  • ExecuteNonQuery():返回增、删、改的影响行数
using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{         
    SqlCommand cmd = conn.CreateCommand();              //创建命令
    cmd.CommandText = "Update Person Set PersonName = ‘Ado.net修改‘ WHERE PersonId = @Id";    //设置操作语句
    cmd.Parameters.Add("@Id", SqlDbType.Int);           //添加参数,说明类型
    cmd.Parameters["@Id"].Value = http://www.mamicode.com/1;                    //设置参数值
    conn.Open();                                        //打开连接
    int i = cmd.ExecuteNonQuery();                      //执行命令,ExecuteNonQuery由名称看出,只能用于非查询语句
    conn.Close();                                       //关闭连接
    Console.WriteLine(i);                               //输出影响行数

  //直接使用参数集合添加你需要的参数,推荐这种写法
  //SqlParameter[] parameters = new SqlParameter[]
  //{
    //new SqlParameter("@name",SqlDbType.NVarChar,100){Value = "http://www.mamicode.com/yang"},
    //new SqlParameter("@age",SqlDbType.Int,2){Value = http://www.mamicode.com/888},
    //new SqlParameter("@address",SqlDbType.NVarChar,20){Value = "http://www.mamicode.com/Jiang Su"}, 
  //};
  //ommand.Parameters.AddRange(parameters);
}

 三、DataReader类

常见方法:

(1)Read()返回Bool,是否还有下一行,并移到结果集的下一行

(2)GetOrdinal(string 列名),返回序列号,通过列名来获取当前列的索引号,这样如果下次你列名顺序发生变化也没有关系

(3)GetName(int 序列号):  获取列名,参数为指定列名的序列号,返回string

int nameId= dr.GetOrdinal("name");
string columnName = dr.GetName(nameId);
//知道列名获取值
using (SqlDataReader reader = cmd.ExecuteReader())
{
   while (reader.Read())
     {
        Console.WriteLine(reader.GetString(sdr.GetOrdinal("name"))); 
   } 
}

(4)NextResult(),当查询为批处理查询时,使用这个方法去读取下一个结果集,返回值为Bool,如果存在多个结果集,则为 true;否则为 false

using (SqlConnection conn = new SqlConnection(strConnString))
{    conn.Open();   
using (SqlCommand cmd = new SqlCommand())
   {      cmd.Connection
= conn;      // 利用分号「;」串连多句 SQL 语句,之后再一次丢进数据库去执行,达成「批次」读取或更新      // 数据库的目的。此技巧亦适用于 INSERT、UPDATE、DELETE 的「批次」执行。      cmd.CommandText = "SELECT 字段1,字段2 FROM 数据表1 ; SELECT * FROM 数据表2";      using (SqlDataReader dr = cmd.ExecuteReader())
     {       
while(dr.Read())
       {          
this.DropDownList1.Items.Add(dr.GetSqlString(0).ToString() + dr.GetSqlInt32(1).ToString());        }     dr.NextResult();      while(dr.Read())
    {          
this.DropDownList2.Items.Add(dr.GetString(0) + dr.GetInt32(1));       }     }   } }

 

四、SqlDataAdapter 数据适配器

有四个重载

无参
SqlDataAdapter(SqlCommand)          // 执行命令对象实例
SqlDataAdapter(String, SqlConnection)   //只能指定查询语句 ②连接对象实例
SqlDataAdapter(String, ConnectionString)// 用 SelectCommand 和一个连接字符串初始化 SqlDataAdapter 类的一个新实例

一个重要方法:Fill(),数据填充至DataSet

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{      
  DataSet dataSet = new DataSet();  
    conn.Open();
    SqlCommand command = conn.CreateCommand();
    command.CommandText = "select name,age,address from MyInformation";
    SqlDataAdapter dataAdapter = new SqlDataAdapter(command);
    dataAdapter.Fill(dataSet);  //填充数据
}

对数据进行增加操作

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
    using (SqlConnection conn = new SqlConnection(ConnectionString()))
 {
     conn.Open();
     //构建查询语句,也可以指定SqlCommand,其中变换的方法有很多
     SqlDataAdapter da = new SqlDataAdapter("select LastName,FirstName from dbo.Employees", conn);
     DataSet ds = new DataSet();
     da.Fill(ds);
     //这句话很重要,它会把你在DataSet增加的数据转化为SQL语句用来更新数据库
     SqlCommandBuilder cmdBuilder = new SqlCommandBuilder(da);
     //添加行,实例化一个行对象,注意是用NewRow来创建行
     DataRow row = ds.Tables[0].NewRow();
     row[0] = "Yang";
     row[1] = "鬼头";
     ds.Tables[0].Rows.Add(row);  //添加到表中
     da.Update(ds);             //把DataSet中表和数据库进行对比,更新
 }     
}

更新操作

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{        
    using (SqlConnection conn = new SqlConnection(""))
{
    SqlDataAdapter da = new SqlDataAdapter("SQL语句或你自己定义的命令对象", conn);
    DataSet ds = new DataSet();
    da.Fill(ds);
    //很重要的一句话
    SqlCommandBuilder cmdBuilder = new SqlCommandBuilder(da);
    ds.Tables[0].Rows[12][1] = ""; //修改数据
    da.Update(ds);
    //调用Update方法其中隐式的调用了AcceptChanges方法,更新数据集中的数据
    //如果你继续使用这个数据集而没有调用这个方法,在后面的使用会出现异常
    ds.AcceptChanges();  //这句话可以不写的
}  
}

最后

对于一些增删改,都应加上事务,防止出错能回滚数据

using (SqlConnection conn = newSqlConnection("DataSource(local);Integrated Security=SSPI;Initial Catalog=Northwind"))    
{    //事务
     SqlTransaction myTran = con.BeginTransaction(); 
    tyr
   {
        //正常代码执行  
         ..............
//提交事务 myTran.Commit(); }
catch(Exception e) { //出错,事务回滚 myTran.Rollback(); } }

 

ADO.NET的学习