[置顶] ADO.NET在C#中关于SQL操作的理解

         SQL语言可以操作关系数据库，但在.NET中无法直接使用SQL语言。.NET提供了ADO.NET组件来访问和操作数据库，组建简单的来说就是一组想关的类（Connection  ,Command, DataReader, DataADapter ,DataSet.）,访问和操作不同的数据库需要使用不同的数据提供程序，现在就一SQL Sever 数据库为例。一般的数据库操作无非就是读和写，ADO.NET中提供了只读的类DataReader和可读可写的类DataSet。

         DataReader 只能向前和向右读取数据，它类似一个标尺，如果当前读取数据的过程中连接中断，则数据丢失（当然数据库中的数据不会丢失）。当然这些大家都知道，但为什么是只能向前向右，而且数据在连接中断又连接后不能恢复呢 ？我个人理解是DataReader在内存当中通过一个类似指针的东西来连接到数据库中既读即取，这也就是为什么DataReader只能读而不能修改和写的原因了。

        DataSet类呢它是把数据一次取到内存当中存放在TABLE中（table可以有多个，具体要用那个表当中的可以这样来写DataSet   ds= new DataSet()  ;   ds.Table[i].Rows 来制定）存放在内存中是一个什么概念？这也就是为什么有权限的用户可以修改，读取，写入数据库了，因为内存是在客户端，数据在用户自己的控制范围之内，我想修改就修改，只要写入的时候符合约束，其他都ok。

  下面就贴一段简单的SQLHelper类中的代码：

// File:    SqlDbHelper.cs
// Author:  audrey
// Created: 2009年6月15日 10:30:03
// Purpose: Definition of Class SqlDbHelper

using System;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
using System.Collections.Generic;

public class SqlDbHelper
{
   //private static string CONNECTION_STRING = "server=william\\sqlexpress;database=musicbar;uid=sa;pwd=william.shan";
    //Data Source=.\SQLEXPRESS;AttachDbFilename=D:\MusicWebSite\ch6\App_Data\MusicBar.mdf;Integrated Security=True;Connect Timeout=30;User Instance=True
    private static string CONNECTION_STRING = @"Data Source=.;DataBase=MusicBar;Integrated Security=True";

    /// <summary>
    /// 执行Select语句，
    /// </summary>
    /// <param name="strSql"></param>
    /// <returns></returns>
    public static DataSet ExecuteSelectSql(string strSql)
   {
       SqlConnection conn = new SqlConnection(CONNECTION_STRING);
       SqlDataAdapter da = new SqlDataAdapter(strSql, conn);
       DataSet ds = new DataSet();
       try
       {
           da.Fill(ds);
           return ds;
       }
       catch (Exception ex)
       {
           throw new Exception("执行SQL出现错误：\r\n"+strSql+"\r\n"+ex.ToString());
       }
       finally
       {
           conn.Close();
       }
       
       
      //throw new NotImplementedException();
   }
   /// <summary>
   /// 执行UPDATE语句
   /// </summary>
   /// <param name="strSql"></param>
   /// <returns></returns>
   public static int ExecuteUpdateSql(string strSql)
   {

       SqlConnection conn = new SqlConnection(CONNECTION_STRING);
       SqlCommand comm = new SqlCommand();
       comm.Connection = conn;
       comm.CommandType = CommandType.Text;
       comm.CommandText = strSql;
       int ret = -1;
       try
       {
           conn.Open();
           ret = comm.ExecuteNonQuery();

           return ret;
       }
       catch (Exception ex)
       {
           throw new Exception("执行SQL出现错误：\r\n" + strSql + "\r\n" + ex.ToString());
       }
       finally
       {
           conn.Close();
       }
       
       //throw new NotImplementedException();
   }
   /// <summary>
   /// 执行Delete语句
   /// </summary>
   /// <param name="strSql"></param>
   /// <returns></returns>
    public static int ExecuteDelSql(string strSql)
   {
       SqlConnection conn = new SqlConnection(CONNECTION_STRING);
       SqlCommand comm = new SqlCommand(strSql,conn);       
       int ret = -1;
       try
       {
           conn.Open();
           ret = comm.ExecuteNonQuery();
           return ret;
       }
       catch (Exception ex)
       {
           throw new Exception("执行SQL出现错误：\r\n" + strSql + "\r\n" + ex.ToString());
       }
       finally
       {
           conn.Close();
       }
       
      //throw new NotImplementedException();
   }
   /// <summary>
   /// 执行Insert语句
   /// </summary>
   /// <param name="strSql"></param>
   /// <returns></returns>
    public static int ExecuteInsertSql(string strSql)
   {
       SqlConnection conn = new SqlConnection(CONNECTION_STRING);
       SqlCommand comm = new SqlCommand();
       comm.Connection = conn;
       comm.CommandType = CommandType.Text;
       comm.CommandText = strSql;
       int ret = -1;
       try
       {
           conn.Open();
           ret = comm.ExecuteNonQuery();

           return ret;
       }
       catch (Exception ex)
       {
           throw new Exception("执行SQL出现错误：\r\n" + strSql + "\r\n" + ex.ToString());
       }
       finally
       {
           conn.Close();
       }
       

      //throw new NotImplementedException();
   }
   
   public static Object ExecuteScalar(string strSql)
   {
       SqlConnection conn = new SqlConnection(CONNECTION_STRING);
       SqlCommand comm = new SqlCommand();
       comm.Connection = conn;
       comm.CommandType = CommandType.Text;
       comm.CommandText = strSql;
       
       try
       {
           conn.Open();
           SqlDataReader dr = comm.ExecuteReader();
           if (dr.Read())
           {
               return dr[0];
           }
           else
           {
               return null;
           }
       }
       catch (Exception ex)
       {
           throw new Exception("执行SQL出现错误：\r\n" + strSql + "\r\n" + ex.ToString());
       }
       finally
       {
           conn.Close();
       }
       

      //throw new NotImplementedException();
   }
   
   public SqlConnection GetConnection()
   {
       SqlConnection conn = new SqlConnection(CONNECTION_STRING);
       return conn;
      //throw new NotImplementedException();
   }
}

    关于数据库的操作根据操作的不同选择不同的类，具体如下图：

   关于其它数据库的操作就不一一叙述了，当掌握了操作一门数据库的操作之后，举一反三，只要添加适当的类，就ok。

   水平有限，欢迎拍砖，大家互相交流学习嘛！！！