Maison >développement back-end >Tutoriel C#.Net >Explication détaillée de l'utilisation de l'écriture de la classe SqlHelper en C#

Explication détaillée de l'utilisation de l'écriture de la classe SqlHelper en C#

黄舟
黄舟original
2017-09-18 11:25:293147parcourir

Cet article présente principalement l'utilisation de C# pour écrire la classe SqlHelper. L'éditeur pense que c'est plutôt bien, je vais donc le partager avec vous maintenant et le donner comme référence. Suivons l'éditeur et jetons un oeil

Week-end ennuyeux, incapable d'étudier et de coder. Je voulais trouver quelque chose à faire mais je ne savais pas quoi faire. J'ai soudain découvert que j'avais presque oublié le SqlHelper que j'avais appris. Puis le corps du tigre trembla et il se demanda comment avait-il pu tomber si bas. Il alluma immédiatement l'ordinateur et toucha le clavier avec les deux mains. J'ai écrit cet article pour faire le bilan du processus d'apprentissage et pour partager les connaissances (d'ailleurs pour passer le temps -^.^-).

Le texte commence ci-dessous

Ici, nous prenons le programme console comme exemple. Nous devons d'abord configurer la chaîne de connexion. Nous devons ajouter les nœuds suivants au fichier app.config :


<connectionStrings>
   <add name="Sql" connectionString="server=数据库地址;uid=用户名;pwd=密码;database=数据库名"/>
  </connectionStrings>

1. créez un nom pour la classe SqlHepler, puis créez une méthode pour obtenir la chaîne de connexion configurée dans le fichier app.config.


public static string GetSqlConnectionString()
 {
   return ConfigurationManager.
     ConnectionStrings["Sql"].ConnectionString;
 }

2. Encapsulons la première méthode SqlHepler, encapsulons un SQL exécuté et renvoyons le nombre de lignes affectées.


 public static int ExecuteNonQuery(string sqlText,params SqlParameter[] parameters)
{
   using (SqlConnection conn = new SqlConnection(GetSqlConnectionString()))  
   {
     using (SqlCommand cmd=conn.CreateCommand())
     {
       conn.Open();  //打开数据库
       cmd.CommandText = sqlText;  //对CommandText进行赋值
       cmd.Parameters.AddRange(parameters);  //对数据库使用参数进行赋值
       return cmd.ExecuteNonQuery();
     }
   }
}

Description du paramètre : sqlText : le script SQL qui doit être exécuté, paramètres : l'ensemble de paramètres requis

Cette méthode est principalement utilisé Effectue des opérations de suppression, de mise à jour et d'insertion et renvoie le nombre de lignes affectées.

3. Continuez à encapsuler une opération de requête et renvoyez la valeur de la première ligne et de la première colonne dans le résultat de la requête


public static object ExecuteScalar(string sqlText, params SqlParameter[] parameters)
 {
  using (SqlConnection conn=new SqlConnection(GetSqlConnectionString()))
  {
   using (SqlCommand cmd=conn.CreateCommand())
   {
     conn.Open();
     cmd.CommandText = sqlText;
     cmd.Parameters.AddRange(parameters);
     return cmd.ExecuteScalar();
   }
  }
}

Description du paramètre :Comme ci-dessus.

La valeur de retour de cette méthode est object, nous pouvons donc utiliser cette classe lorsque nous ne savons pas quel type de données nous interrogeons.

4. Encapsulez une méthode de requête commune et renvoyez un DataTable


public static DataTable ExecuteDataTable(string sqlText, params SqlParameter[] parameters) 
 {
  using (SqlDataAdapter adapter =new SqlDataAdapter(sqlText,GetSqlConnectionString()))
  {
    DataTable dt = new DataTable();
    adapter.SelectCommand.Parameters.AddRange(parameters);
    adapter.Fill(dt);
    return dt;
   }
}

Description du paramètre : comme ci-dessus.

Cette méthode est principalement utilisée pour certaines données de requête dt sera remplie avec les données interrogées puis renverra les données.

5. Enfin, écrivez et encapsulez une méthode de requête, qui renvoie un type SqlDataReader


public static SqlDataReader ExecuteReader(string sqlText, params SqlParameter[] parameters)
{
   //SqlDataReader要求,它读取数据的时候有,它独占它的SqlConnection对象,而且SqlConnection必须是Open状态
   SqlConnection conn = new SqlConnection(GetSqlConnectionString());//不要释放连接,因为后面还需要连接打开状态
   SqlCommand cmd = conn.CreateCommand();
   conn.Open();
   cmd.CommandText = sqlText;
   cmd.Parameters.AddRange(parameters);
   //CommandBehavior.CloseConnection当SqlDataReader释放的时候,顺便把SqlConnection对象也释放掉
   return cmd.ExecuteReader(CommandBehavior.CloseConnection); 
}

Description du paramètre : toujours comme ci-dessus.

L'objet de type SqlDataReader renvoyé par cette méthode doit toujours utiliser l'objet SqlConnection, il ne peut donc pas être libéré. Ce type de données est lu ligne par ligne. Reading utilise la méthode Read() de cette classe. La valeur de retour est bool pour déterminer si les données sont vides (c'est-à-dire si la dernière ligne a été lue). Cette méthode lira automatiquement l'enregistrement suivant.

En tant que débutant, cette fois, je viens de donner une brève introduction et de revoir la classe SqlHepler.

Joindre tous les codes :


using System.Configuration;
using System.Data;
using System.Data.SqlClient;

namespace UserInfoMgr
{
  class SqlHelper
  {
    /// <summary>
    /// 获取连接字符串
    /// </summary>
    /// <returns>连接字符串</returns>
    public static string GetSqlConnectionString()
    {
      return ConfigurationManager.ConnectionStrings["Sql"].ConnectionString;
    }

    /// <summary>
    /// 封装一个执行的sql 返回受影响的行数
    /// </summary>
    /// <param name="sqlText">执行的sql脚本</param>
    /// <param name="parameters">参数集合</param>
    /// <returns>受影响的行数</returns>
    public static int ExecuteNonQuery(string sqlText,params SqlParameter[] parameters)
    {
      using (SqlConnection conn = new SqlConnection(GetSqlConnectionString()))
      {
        using (SqlCommand cmd=conn.CreateCommand())
        {
          conn.Open();
          cmd.CommandText = sqlText;
          cmd.Parameters.AddRange(parameters);
          return cmd.ExecuteNonQuery();
        }
      }
    }

    /// <summary>
    /// 执行sql,返回查询结果中的第一行第一列的值
    /// </summary>
    /// <param name="sqlText">执行的sql脚本</param>
    /// <param name="parameters">参数集合</param>
    /// <returns>查询结果中的第一行第一列的值</returns>
    public static object ExecuteScalar(string sqlText, params SqlParameter[] parameters)
    {
      using (SqlConnection conn=new SqlConnection(GetSqlConnectionString()))
      {
        using (SqlCommand cmd=conn.CreateCommand())
        {
          conn.Open();
          cmd.CommandText = sqlText;
          cmd.Parameters.AddRange(parameters);
          return cmd.ExecuteScalar();
        }
      }
    }

    /// <summary>
    /// 执行sql 返回一个DataTable
    /// </summary>
    /// <param name="sqlText">执行的sql脚本</param>
    /// <param name="parameters">参数集合</param>
    /// <returns>返回一个DataTable</returns>
    public static DataTable ExecuteDataTable(string sqlText, params SqlParameter[] parameters) 
    {
      using (SqlDataAdapter adapter =new SqlDataAdapter(sqlText,GetSqlConnectionString()))
      {
        DataTable dt = new DataTable();
        adapter.SelectCommand.Parameters.AddRange(parameters);
        adapter.Fill(dt);
        return dt;
      }
    }

    /// <summary>
    /// 执行sql脚本
    /// </summary>
    /// <param name="sqlText">执行的sql脚本</param>
    /// <param name="parameters">参数集合</param>
    /// <returns>返回一个SqlDataReader</returns>
    public static SqlDataReader ExecuteReader(string sqlText, params SqlParameter[] parameters)
    {
      //SqlDataReader要求,它读取数据的时候有,它独占它的SqlConnection对象,而且SqlConnection必须是Open状态
      SqlConnection conn = new SqlConnection(GetSqlConnectionString());//不要释放连接,因为后面还需要连接打开状态
      SqlCommand cmd = conn.CreateCommand();
      conn.Open();
      cmd.CommandText = sqlText;
      cmd.Parameters.AddRange(parameters);
      //CommandBehavior.CloseConnection当SqlDataReader释放的时候,顺便把SqlConnection对象也释放掉
      return cmd.ExecuteReader(CommandBehavior.CloseConnection); 
    }
  }
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn