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

//
// Записать все записи из памяти в БД одной транзакцией!
//
// В случае успеха все записи добавляются в таблицу cdr_records,
// а имя файла добавляется в таблицу cdr_files (COMMIT)
//
// В случае неудачи - ничего не происходит и делается запись в журнал (ROLLBACK)
//
static void WriteRecordsToDB (
    string shortFilename,            // in: имя CDR-файла
    List<CdrRecord> cdrRecordsList    // in: массив записей, прочитанных из CDR-файла
)
{
    try {
        // вариант с using(...) из примера MSDN
        using (SqlConnection connect = new SqlConnection (DBCONNECTION_STRING)) {

            // установить соединение с SQL сервером - может бросить исключение!
            connect.Open ();
            SqlTransaction transaction = connect.BeginTransaction ("MyTransaction");

            try {
                SqlCommand cmd = connect.CreateCommand ();
                cmd.Connection = connect;
                cmd.Transaction = transaction;
                cmd.CommandType = System.Data.CommandType.Text;

                // записать все записи из массива в БД
                for (int i = 0; i < cdrRecordsList.Count; ++i) {
                    CdrRecord rec = cdrRecordsList[ i ];

                    StringWriter strWriter = new StringWriter ();
                    strWriter.Write ("'{0}', '{1}', '{2}', '{3}', '{4}'",
                        rec.data_type, rec.field_a, rec.field_b, , rec.field_c, rec.field_d
                    );

                    cmd.CommandText = "INSERT INTO cdr_records " +
                        "(data_type, rec.field_a, rec.field_b, , rec.field_c, rec.field_d) " +
                        "VALUES (" + strWriter.ToString () + ")";
                    cmd.ExecuteNonQuery ();
                }

                // записать имя обработанного файла в БД
                cmd.CommandText = "INSERT INTO cdr_files (fname) VALUES ('" + shortFilename + "')";
                cmd.ExecuteNonQuery ();

                // попытаться завершить транзакцию
                transaction.Commit ();
            }
            catch (Exception ex) {
                LogMessage ("WriteRecordsToDB(): " + shortFilename + " is not processed.", ex);

                // попытать откатить транзакцию
                try {
                    transaction.Rollback ();
                }
                catch (Exception ex2) {
                    LogMessage ("WriteRecordsToDB(): transaction.Rollback() failed.", ex2);
                }
            }
        }
    }
    catch (Exception ex) {
        // перехват connect.Open(), BeginTransaction()
        LogMessage ("WriteRecordsToDB(): " + shortFilename + " is not processed.", ex);
    }
}

/// <summary>
/// Записать все записи из памяти в БД одной транзакцией!
/// 
/// В случае успеха все записи добавляются в таблицу cdr_records,
/// а имя файла добавляется в таблицу cdr_files (COMMIT)
/// 
/// В случае неудачи - ничего не происходит и делается запись в журнал (ROLLBACK)
/// </summary>
/// <param name="shortFilename">имя CDR-файла</param>
/// <param name="cdrRecordsList">массив записей, прочитанных из CDR-файла</param>
static void WriteRecordsToDB(string shortFilename, List<CdrRecord> cdrRecordsList)
{
    try
    {
        // вариант с using(...) из примера MSDN
        using (SqlConnection connect = new SqlConnection(DBCONNECTION_STRING))
        using (SqlCommand cmd = new SqlCommand("INSERT INTO cdr_records (data_type, field_a, field_b, field_c, field_d) values (@data_type, @field_a, @field_b, @field_c, @field_d)", connect))
        using (SqlCommand cmd2 = new SqlCommand("INSERT INTO cdr_files (fname) VALUES (@fname)")) 
        {
            cmd.Parameters.Add("@data_type", SqlDbType.VarChar, 666);
            cmd.Parameters.Add("@field_a", SqlDbType.VarChar, 666);
            cmd.Parameters.Add("@field_b", SqlDbType.VarChar, 666);
            cmd.Parameters.Add("@field_c", SqlDbType.VarChar, 666);
            cmd.Parameters.Add("@field_d", SqlDbType.VarChar, 666);
            
            cmd2.Parameters.Add("@fname", SqlDbType.VarChar, 666).Value = shortFilename;
            
            // установить соединение с SQL сервером - может бросить исключение!
            connect.Open();
            using (SqlTransaction transaction = connect.BeginTransaction("MyTransaction"))
            {
                cmd.Transaction = transaction;
                cmd2.Transaction = transaction;
                // записать все записи из массива в БД
                foreach(CdrRecord rec in cdrRecordsList)
                {
                    cmd.Parameters["data_type"].Value = rec.data_type;
                    cmd.Parameters["@field_a"].Value = rec.field_a;
                    cmd.Parameters["@field_b"].Value = rec.field_b;
                    cmd.Parameters["@field_c"].Value = rec.field_c;
                    cmd.Parameters["@field_d"].Value = rec.field_d;

                    cmd.ExecuteNonQuery();
                }
                cmd2.ExecuteNonQuery();

                // попытаться завершить транзакцию
                transaction.Commit();
            }
        }
    }
    catch (Exception ex)
    {
        // перехват connect.Open(), BeginTransaction()
        LogMessage("WriteRecordsToDB(): " + shortFilename + " is not processed.", ex);
    }
}

R_X>Вот фрагмент кода, но что-то подсказывает мне, что он еще далек от идеала

R_X>                // записать все записи из массива в БД
R_X>                for (int i = 0; i < .Count; ++i) {
R_X>                    CdrRecord rec = cdrRecordsList[ i ];

R_X>                    StringWriter strWriter = new StringWriter ();
R_X>                    strWriter.Write ("'{0}', '{1}', '{2}', '{3}', '{4}'",
R_X>                        rec.data_type, rec.field_a, rec.field_b, , rec.field_c, rec.field_d
R_X>                    );

R_X>                    cmd.CommandText = "INSERT INTO cdr_records " +
R_X>                        "(data_type, rec.field_a, rec.field_b, , rec.field_c, rec.field_d) " +
R_X>                        "VALUES (" + strWriter.ToString () + ")";
R_X>                    cmd.ExecuteNonQuery ();
R_X>                }

insert cdr_records values(....);insert cdr_records values(....) ..... ;insert cdr_records values(....)

___>insert cdr_records values(....);insert cdr_records values(....) ..... ;insert cdr_records values(....)
___>

insert cdr_records (<список столбцов>)
select 1, 2, 3, "some value" union all
select 1, 4, 1, "aasdsa" union all
...
select 3, 46, 784, "arsadf"

    cmd.Parameters.Add("@data_type", SqlDbType.VarChar, 10);

    cmd.Parameters["data_type"].Value = rec.data_type;

    cmd.Parameters.Add("@data_type", SqlDbType.VarChar, 10).Value = rec.data_type ;

PM>что вы имеете в виду?

public class MyCollection : IEnumerable<MyItem>
{
    public IEnumerable<MyItem> Sort(string Value)
    { 
        foreach(MyItem item in this)
        {
            if(item.MyProperty == Value)
                yield return item;
        }
    }
}

MyCollection collection = new MyCollection();
foreach (MyItem item in collection.Sort("MyValue"))
{ 
    //Do something
}

/// <summary>Releases the unmanaged resources used by the <see cref="T:System.Data.Common.DbTransaction"></see>.</summary>
/// <filterpriority>1</filterpriority>
public void Dispose()
{
      this.Dispose(true);
}

protected override void Dispose(bool disposing)
{
      if (disposing)
      {
            RuntimeHelpers.PrepareConstrainedRegions();
            try
            {
                  if (!this.IsZombied && !this.IsYukonPartialZombie)
                  {
                        this._internalTransaction.Dispose();
                  }
            }
            catch (OutOfMemoryException exception3)
            {
                  this._connection.Abort(exception3);
                  throw;
            }
            catch (StackOverflowException exception2)
            {
                  this._connection.Abort(exception2);
                  throw;
            }
            catch (ThreadAbortException exception1)
            {
                  this._connection.Abort(exception1);
                  throw;
            }
      }
      base.Dispose(disposing);
}

internal void Dispose()
{
      this.Dispose(true);
      GC.SuppressFinalize(this);
}

private void Dispose(bool disposing)
{
      Bid.PoolerTrace("<sc.SqlInteralTransaction.Dispose|RES|CPOOL> %d#, Disposing\n", this.ObjectID);
      if (disposing && (this._innerConnection != null))
      {
            this._disposing = true;
            this.Rollback();
      }
}

create table ИменаФайлов(
    Имя nvarchar(256) primary key clustered
)

set ansi_nulls, quoted_identifier on
create proc ВозвратитьИменаКоторыхНетВТаблице(
    @xml ntext
)
as begin
    set nocount on

    declare @hdoc int, @ret_code int
    exec @ret_code = dbo.sp_xml_preparedocument @hdoc output, @xmldoc
    if @ret_code != 0
    return @ret_code

    select
        Имя
    from
        openxml(@hdoc, '/root/child::*') with(
            ИмяДляПроверки nvarchar(256) '@И',
    ) as Вход
    where
        not exists(
            select
                null
            from
                dbo.ИменаФайлов иф
            where
                иф.Имя = Вход.ИмяДляПроверки
        )
    ;

    exec dbo.sp_xml_removedocument @hdoc
end

    // Имеем на входе:
    //   _СоедБД - соединение с базой данных
    //   _Файлы - список файлов для проверки
    // Возвращаемый результат:
    //   остаются только те, которых нет в БД
    List<string> ПроверкаИменФайловНаНаличиеВБазе(SqlConnection  _СоедБД, List<string> _Файлы)
    {
        SqlCommand com = new SqlCommand("dbo.ВозвратитьИменаКоторыхНетВТаблице", _СоедБД);
        com.CommandType = CommandType.StoredProcedure;
        com.Parameters.Add("@xml", SqlDbType.NText);

        StringBuilder xml = new StringBuilder("<?xml version=\"1.0\"?><root>", 32768);
        foreach (string Файл in _Файлы)
        {
            xml.Append("<с И=\"");
            xml.Append(Файл);
            xml.Append("\"/>");
        }
        xml.Append("</root>");

        List<string> ReturnList = new List<string>(_Файлы.Count);
        com.Parameters["@xml"].Value = xml.ToString();
        using (SqlDataReader reader = com.ExecuteReader(CommandBehavior.SingleResult))
        {
            while (reader.Read())
            {
                ReturnList.Add((string)reader["Имя"]);
            }
        }

        return ReturnList;
    }

set ansi_nulls, quoted_identifier on
GO
create proc ВозвратитьИменаКоторыхНетВТаблице(
    @xml ntext
)
as begin
    set nocount on

    declare @hdoc int, @ret_code int
    exec @ret_code = dbo.sp_xml_preparedocument @hdoc output, @xml

    ...

F>Я сперва не поверил, проверял Рефлектором Да, действительно делал коммит.

// begin transaction
try
{
  ...
  // commit transaction
}
catch
{
  // rollback transaction
}

// begin transaction
try
{
  ...
  // commit transaction
}
finally
{
  //if (transaction.stillOpen)
    // rollback transaction
}

using(Transaction t = connection.BeginTransaction)
{
  ...
  t.Commit();
}

using(Transaction t = connection.BeginTransaction)
{
  try
    {
  ...
    }
    catch
    {
    t.Rollback();
    }
}

1.2.0 alpha rev. 655