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 ;