Код рефрактора с массовой вставкой SQL {ADO.NET, ODP.NET} - PullRequest
Новая
       16

Код рефрактора с массовой вставкой SQL {ADO.NET, ODP.NET}

0 голосов
/ 17 августа 2011

Привет, я использую массовую вставку SQL в Oracle 10g Db. Я использую ODP.NET, потому что мне нужно вставить 20.000 - 40.000 строк в таблицу. Долгое время использовать LINQ to SQL (для оракула devart http://www.devart.com/linqconnect/). Теперь я должен использовать объект "ADO.NET", но мой код выглядит ужасно. Можете ли вы помочь мне и дать мои идеи, как это рефракторить? Я хотел бы найти компромисс между читабельностью кода и производительностью.

Извините за мой английский 

    private void InitArrays(int size)
    {
        _id = new string[size];
        _lm = new DateTime[size];
        _priceWithoutDiscount = new decimal[size];
        _priceWithDiscount = new decimal[size];
        _talkTime = new int[size];
        _type = new string[size];
        _voiceNetwork = new string[size];
        _callNo = new string[size];
        _callDate = new DateTime[size];
        _callType = new string[size];
        _surname = new string[size];
        _name = new string[size];
        _no = new string[size];
    }

    private void PrepareArrays(IList<Call> calls)
    {
        InitArrays(calls.Count);

        Parallel.For(0, calls.Count, i =>
        {
            _id[i] = IdGenerator.GenerateGuidForCall(calls[i]);
            _no[i] = calls[i].Number;
            _name[i] = calls[i].Name;
            _surname[i] = calls[i].Surname;
            _callType[i] = calls[i].CallType;
            _callDate[i] = calls[i].Dt;
            _callNo[i] = calls[i].CallingNumber;
            _voiceNetwork[i] = calls[i].VoiceNetwork;
            _type[i] = calls[i].Type;
            _talkTime[i] = calls[i].TalkTimeInSec;
            _priceWithDiscount[i] = (decimal)calls[i].PriceWithDiscount;
            _priceWithoutDiscount[i] = (decimal)calls[i].PriceWithoutDiscount;
            _lm[i] = DateTime.Now;

        });
    }


    public void InsertCalls(IList<Call> calls)
    {
        PrepareArrays(calls);

        string sql = "insert into r_calls (ID, NO, NAME, SURNAME, CALL_TYPE, CALL_DATE, CALL_NO, VOICE_NETWORK,"
                     +"TYPE, TALK_TIME,PRICE_WITH_DISCOUNT, PRICE_WITHOUT_DISCOUNT, LM_MODIFIED) "
                     + "values (:id, :no, :name, :surname, :callType, :callDate, :callNo, :voiceNetwork, :type,"
                     +" :talkTime, :priceWithDiscount, :priceWithoutDiscount, :lm)";


        var cnn = new OracleConnection(GenerateConnectionString());
        cnn.Open();
        OracleCommand cmd = cnn.CreateCommand();
        cmd.CommandText = sql;
        cmd.CommandType = CommandType.Text;
        cmd.BindByName = true;

        // To use ArrayBinding, we need to set ArrayBindCount
        cmd.ArrayBindCount = _id.Count();

        // Instead of single values pass arrays of values as parameters
        cmd.Parameters.Add(":id", OracleDbType.Varchar2, 
                            _id, ParameterDirection.Input);

        cmd.Parameters.Add(":no", OracleDbType.Varchar2,
                            _no, ParameterDirection.Input);

        cmd.Parameters.Add(":name", OracleDbType.Varchar2,
                            _name, ParameterDirection.Input);

        cmd.Parameters.Add(":surname", OracleDbType.Varchar2,
                            _surname, ParameterDirection.Input);

        cmd.Parameters.Add(":callType", OracleDbType.Varchar2,
                            _callType, ParameterDirection.Input);

        cmd.Parameters.Add(":callDate", OracleDbType.Date,
                            _callDate, ParameterDirection.Input);

        cmd.Parameters.Add(":callNo", OracleDbType.Varchar2,
                            _callNo, ParameterDirection.Input);

        cmd.Parameters.Add(":voiceNetwork", OracleDbType.Varchar2,
                            _voiceNetwork, ParameterDirection.Input);

        cmd.Parameters.Add(":type", OracleDbType.Varchar2,
                            _type, ParameterDirection.Input);

        cmd.Parameters.Add(":talkTime", OracleDbType.Decimal,
                            _talkTime, ParameterDirection.Input);

        cmd.Parameters.Add(":priceWithDiscount", OracleDbType.Decimal,
                            _priceWithDiscount, ParameterDirection.Input);

        cmd.Parameters.Add(":priceWithoutDiscount", OracleDbType.Decimal,
                            _priceWithoutDiscount, ParameterDirection.Input);

        cmd.Parameters.Add(":lm", OracleDbType.Date,
                        _lm, ParameterDirection.Input);


        cmd.ExecuteNonQuery();
        cnn.Close();

    }

Ответы [ 2 ]

0 голосов
/ 17 августа 2011

Это может быть не все решение, но сначала я бы попытался избежать жесткого кодирования имен параметров. Я получу имена параметров из самой схемы таблицы, а затем отправлю данные поверх нее. Немного рефакторинга это так. Я написал статью об этом, проверьте это: http://www.codeproject.com/KB/TipsnTricks/StoredProcSchemaSaving.aspx

0 голосов
/ 17 августа 2011

Это выглядит хорошо для меня, но я бы предложил запустить StyleCop поверх него.

Кроме того, вы можете использовать другое форматирование для операторов SQL: 

string sqlStatement = @"
insert into TABLE
( COL1,  COL2,  COL3) VALUES
(:COL1, :COL2, :COL3)
";

Также используйте using для соединения и команды. Он реализует IDisposable и поэтому может быть заключен в блок using. 

using(var connection = this.GetSomeConnection())
using(var command = this.InitTheCommandSomehow(connection))
{
    // here your code can safely throw exceptions etc.
    // and the connection will still be closed

    ...

    cmd.Parameters.Add(
        "id",
        OracleDbType.Varchar2,
        _id,
        ParameterDirection.Input);

    ...

}
...