使用C#进行数据库增删改查(二)

宿春磊Charles

发布于 2022-03-29 10:20:35

7580

发布于 2022-03-29 10:20:35

文章被收录于专栏：DotNet 致知

这节接着讲用C#进行数据库CRUD，高级部分。

事务：

事务是执行一批sql语句，如果中途失败，全部回滚，数据不会受影响，中途没有出错则会提交事务，真正对数据进行修改。C#提供了SqlTransaction类来处理数据库事务，下面通过一个示例方法来看一下这个类如何使用:

using(SqlConnection connection=new SqlConnection(connString)
{
  //开启连接
  connection.Open();
  using (SqlCommand command = connection.CreateCommand ())
  {
    using (SqlTransaction transaction = connection.BeginTransaction ())
    {
      try
      {
          int count = 0;
          //将事务对象绑定到执行对象上
          command.Transaction = transaction;
          if (parameters != null)
              command.Parameters.AddRange (parameters);
          //执行sql,注意：此时数据并未真正修改
          foreach (string sql in sqls)
          {
              command.CommandText = sql;
              count += command.ExecuteNonQuery();
          }
          //执行时不出错就会提交事务，此时数据真正被修改
          transaction.Commit();
          return count;
      }
      catch
      {
          //执行时出错或者中途连接断开都会回滚事务
          transaction.Rollback();
          return 0;
      }
    }
  }
}

使用连接对象创建出执行对象和事务对象，执行完毕没有错误的话，执行事务对象的Commit()方法提交，如果出错执行Rollback()方法回滚。

异步方法：

在我们在执行sql的时候有时希望是异步执行的，为此微软推出了Task类和一批基于Task的异步方法，很典型的就是在老方法后加上Async这个后缀，如：ExecuteNonQuery()的异步版本是ExecuteNonQueryAsync()。尤其是在UI线程中进行耗时操作时我们需要将这种操作放在后台，下面以查询操作为例做一下异步版本的演示：

/// <summary>
/// 执行查询操作(异步泛型版)
/// </summary>
/// <param name="sql">sql语句</param>
/// <param name="parameters">参数</param>
/// <returns>数据集合，出错返回null</returns>
public static async Task<List<T>> SelectDBAsync<T> (string sql, SqlParameter[] parameters) where T : new()
{
  if (connection == null)
  {
      Console.WriteLine ("数据库未连接");
      return null;
  }

  using (SqlCommand command = new SqlCommand (sql, connection))
  {
    try
    {
        if (parameters != null)
        {
            command.Parameters.AddRange (parameters);
        }
        //调用异步方法
        SqlDataReader reader = await command.ExecuteReaderAsync ();
        if (reader.HasRows)
        {
            List<T> data = new List<T> ();
            Type type = typeof (T);
            object o = Activator.CreateInstance (type);
            while (reader.Read ())
            {
                foreach (var property in type.GetProperties ())
                {
                    property.SetValue (o, reader[property.Name]);
                }
                data.Add ((T)o);
            }
            reader.Close ();
            return data;
        }

        return null;
    }
    catch
    {
        return null;
    }
  }
}

//在主线程中调用此方法查询数据（数据表跟上一篇文章一样），具体逻辑如下：
SqlParameter[] parameters = new[] { new SqlParameter ("@sname", "李四"), };
Task<List<StudentModel>> studentInfo = ADOUtils.SelectDBAsync<StudentModel> ("select SID,SName,SGender from StudentInfo where SName=@sname ", parameters);
studentInfo.ContinueWith((result) =>
{
    if (studentInfo != null)
        foreach (StudentModel studentModel in result.Result)
        {
            Console.WriteLine(studentModel);
        }
    else
    {
        Console.WriteLine("未查询到数据");
    }
});
//主线程最后要睡一会，防止数据还没输出程序就结束了
Thread.Sleep(5000);

执行结果如下：