批量增删改数据

public bool ExecuteInsertBulkData(string tempSql, byte[] dsbyte, string sql)

        {

            DataSet dsRet = (DataSet)G._DeserializeObj(dsbyte);//转化成数据集

            byte[] ret = null;

            Database db = CreateDatabase();

            SqlConnection sqlCon = null;

           

            using (DbConnection conn = db.CreateConnection())

            {

               

                    string str = sql;

                    sqlCon = new SqlConnection(conn.ConnectionString);

                    sqlCon.Open();

               

                    SqlCommand cmd = new SqlCommand(tempSql, sqlCon);//构建生成的临时表结构

                    int m = cmd.ExecuteNonQuery();

                    foreach (DataTable dt in dsRet.Tables)

                    {

                        string dtTempName = "#" + dt.TableName; //构建需要插入数据的临时表名称

                        SqlBulkCopy sqlBC = new SqlBulkCopy(sqlCon);//启用批量复制；

                        sqlBC.BulkCopyTimeout = 5000;

                        sqlBC.DestinationTableName = dtTempName;

                        sqlBC.NotifyAfter = 100;

                        sqlBC.WriteToServer(dt);

                    }

               

                    //************************开始事务操作数据*****************************//

                    SqlCommand command = sqlCon.CreateCommand();

                    SqlTransaction transaction;

                    transaction = sqlCon.BeginTransaction("SampleTransaction");//开始事务

                    command.Connection = sqlCon;

                    command.Transaction = transaction;

                try

                {

                    command.CommandText = sql;

                    command.ExecuteNonQuery();

                    transaction.Commit();//提交事务

                    return true;

                }

                catch (System.Exception ex)

                {

                    G.LogErr("ExecuteInsertBulkData", ex);

                    transaction.Rollback();

                    return false;

                }

                finally

                {

                    sqlCon.Close();

                }

            }

        }