Microsoft SQL Server 2012 - 11.0.5058.0 (X64) 
	May 14 2014 18:34:29 
	Copyright (c) Microsoft Corporation
	Enterprise Edition: Core-based Licensing (64-bit) on Windows NT 6.2 <X64> (Build 9200: ) (Hypervisor)

CREATE TABLE [dbo].[Traffic](
	[Id] [bigint] IDENTITY(1,1) NOT NULL,
	[FixationDateTime] [datetime2](7) NOT NULL,
	[CameraId] [smallint] NULL,
	[TrafficStatusId] [tinyint] NOT NULL,
	[LaneNumber] [tinyint] NULL,
	[TransportSpeed] [real] NULL,
	[NotRead] [bit] NOT NULL,
	[GCRecord] [bit] NOT NULL DEFAULT ((0)),
	[OptimisticLockField] [tinyint] NULL,
	[TransportNumberActual] [varchar](20) NOT NULL,
	[TransportNumberActualReverse] [varchar](20) NOT NULL,
	[RestrictionReason] [nvarchar](1000) NULL,
 CONSTRAINT [PK_TRAFFIC] PRIMARY KEY NONCLUSTERED 
(
	[Id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [fgTrafficPrimaryIndex]
)


CREATE CLUSTERED INDEX [CIX_Traffic_FixationDateTime] ON [dbo].[Traffic]
(
	[FixationDateTime] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)
on [fgTraffic]

System.Data.SqlClient.SqlException (0x80131904): Истекло время ожидания (Timeout). 
Время ожидания истекло до завершения операции или сервер не отвечает. ---> System.ComponentModel.Win32Exception (0x80004005): Время ожидания операции истекло
   в System.Data.SqlClient.SqlConnection.OnError(SqlException exception, Boolean breakConnection, Action`1 wrapCloseInAction)
   в System.Data.SqlClient.SqlInternalConnection.OnError(SqlException exception, Boolean breakConnection, Action`1 wrapCloseInAction)
   в System.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(TdsParserStateObject stateObj, Boolean callerHasConnectionLock, Boolean asyncClose)
   в System.Data.SqlClient.TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, Boolean& dataReady)
   в System.Data.SqlClient.SqlDataReader.TryConsumeMetaData()
   в System.Data.SqlClient.SqlDataReader.get_MetaData()
   в System.Data.SqlClient.SqlCommand.FinishExecuteReader(SqlDataReader ds, RunBehavior runBehavior, String resetOptionsString)
   в System.Data.SqlClient.SqlCommand.RunExecuteReaderTds(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, Boolean async, Int32 timeout, Task& task, Boolean asyncWrite)
   в System.Data.SqlClient.SqlCommand.RunExecuteReader
(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, String method, TaskCompletionSource`1 completion, Int32 timeout, Task& task, Boolean asyncWrite)
   в System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, String method)
   в System.Data.SqlClient.SqlCommand.ExecuteReader(CommandBehavior behavior, String method)
   в System.Data.SqlClient.SqlCommand.ExecuteReader()
   в DTech.RoadTraffic.Loader.Impl.SqlInsert.SqlHelper.GetIds[T](TableName tableName, InputGetIdDto[] dtos)
   в DTech.RoadTraffic.Loader.Impl.ProcessTraffic.TrafficBulkSaver.SaveTraffics(SqlHelper helper, ITrafficMappingResult[] mappingResults)
   в DTech.RoadTraffic.Loader.Impl.ProcessTraffic.TrafficBulkSaver.BeginTransaction(ITrafficMappingResult[] mappingResults, SqlConnection connection)
ClientConnectionId:c1a631b5-f5e2-4237-88b3-6357b2bd7358

        public IEnumerable<GetIdDtoResult<T>> GetIds<T>(TableName tableName, InputGetIdDto[] dtos)
        {
            var commandText = GenerateCommandText(tableName, dtos);

            var result = new List<GetIdDtoResult<T>>();
            using (var connection = new SqlConnection(_config.ConnectionString))
            {
                connection.Open();
                using (var transaction = connection.BeginTransaction(IsolationLevel.ReadUncommitted))
                {
                    var command = new SqlCommand(commandText, connection, transaction)
                    {
                        CommandTimeout = 30
                    };

                    command.Parameters.Add("@min", SqlDbType.DateTime2);
                    command.Parameters["@min"].Value = dtos.Min(d => d.FixationDateTime);

                    command.Parameters.Add("@max", SqlDbType.DateTime2);
                    command.Parameters["@max"].Value = dtos.Max(d => d.FixationDateTime);

                    using (var dataReader = command.ExecuteReader())
                    {
                        const int indexOfId = 0;
                        const int indexOfFixDate = 1;
                        const int indexOfGrnz = 2;

                        while (dataReader.Read())
                        {
                            var id = (T) Convert.ChangeType(dataReader.GetValue(indexOfId), typeof(T));
                            var fixationDate = (DateTime) dataReader.GetValue(indexOfFixDate);
                            var transportNumber = dataReader.GetValue(indexOfGrnz).ToString();

                            result.Add(new GetIdDtoResult<T>
                            {
                                Id = id, 
                                FixationDateTime = fixationDate,
                                TransportNumber = transportNumber
                            });
                        }
                    }
                }
            }
            return result;
        }

        private static string GenerateCommandText(TableName table, InputGetIdDto[] dtos)
        {
            if (table == TableName.None)
            {
                throw new ArgumentOutOfRangeException("table");
            }

            var grnzProperyName = table == TableName.RestrictionCar ? "TransportNumber" : "TransportNumberActual";

            var tableName = GetTableName(table);
            var predicateText = new StringBuilder();
            
            var length = dtos.Length;
            for (var i = 0; i < length; i++)
            {
                var fixationDate = dtos[i].FixationDateTime.ToString("yyyy-MM-dd HH:mm:ss.fffffff");
                var transportNumber = dtos[i].TransportNumber;

                predicateText.AppendFormat("(FixationDateTime = \'{0}\' and {1} = \'{2}\')", fixationDate, grnzProperyName,
                    transportNumber);
                if (i < length - 1)
                    predicateText.Append(" or ");
            }

            var commandText = string.Format("select Id, FixationDateTime, {0} from {1} " +
                                            "where (FixationDateTime >= @min and FixationDateTime <= @max) and " +
                                            "({2})", grnzProperyName, tableName, predicateText);
            return commandText;
        }