Загрузка данных из текстовых файлов с выборкой через ADO.

 // Загружает данные из текстовых данных
      

    // Параметры
      

    // Стр_КаталогДанных - <Строка>
      

    // Автор: Gmix 04.05.2006 12:22:09
      

    // Возвращаемое значение:
      

    // <Булево>
      

    Функция ЗагрузитьДанныеИзtxt(Стр_КаталогДанных)
      

     // проверки заполнения
      

      

     ОБ_ФайлДанных=Новый Файл(Стр_КаталогДанных);
      

     Если НЕ ОБ_ФайлДанных.ЭтоКаталог() Тогда
      

     Сообщить("Необходимо указать каталог данных!",СтатусСообщения.ОченьВажное);
      

     Возврат Ложь;
      

     КонецЕсли;
      

      

     Если НЕ ОБ_ФайлДанных.Существует() Тогда
      

     Сообщить("Каталог """+Стр_КаталогДанных+""" не существует!",СтатусСообщения.ОченьВажное);
      

     Возврат Ложь;
      

     КонецЕсли;
      

      

     ОБ_АДОКонект = Новый COMОбъект("ADODB.Connection");
      

     ОБ_АДОРекордсетШапка = Новый COMОбъект("ADODB.Recordset");
      

     ОБ_АДОРекордсетСтроки = Новый COMОбъект("ADODB.Recordset");
      

      

     //Определяем пару файлов
      

     Стр_ОкончаниеФайла="";
      

     ФайлыШапок = НайтиФайлы(Стр_КаталогДанных, "Head_*.txt");
      

     Для каждого ФайлШапки Из ФайлыШапок Цикл
      

     Стр_ОкончаниеФайла=Сред(ФайлШапки.ИмяБезРасширения,6);
      

     Стр_таблицаШапки=ФайлШапки.Имя;
      

      

     Стр_ТаблицаСтрок="Rows_"+Стр_ОкончаниеФайла+".txt";
      

     Стр_ИмяФайлСтрок=ДобавлениеСлеша(Стр_КаталогДанных)+Стр_ТаблицаСтрок;
      

     ФайлСтрок=Новый Файл(Стр_ИмяФайлСтрок);
      

     Если НЕ ФайлСтрок.Существует() Тогда
      

     Сообщить("Не найден файл строк для файла шапки """+Стр_таблицаШапки+"""! Пара файлов не обработана",СтатусСообщения.Важное);
      

     Продолжить;
      

     КонецЕсли;
      

      

     //Создаем схему данных
      

     ФайлСхемыДанных=Новый Файл(ДобавлениеСлеша(Стр_КаталогДанных)+"schema.ini");
      

     Если ФайлСхемыДанных.Существует() Тогда
      

     Попытка
      

     УдалитьФайлы(ФайлСхемыДанных.Путь,ФайлСхемыДанных.Имя);
      

     Исключение
      

     Сообщить("Не возможно удалить файл """+ФайлСхемыДанных.ПолноеИмя+""" для создания новой схемы данных! Проверте атрибуты файла",СтатусСообщения.Важное);
      

     Возврат Ложь;
      

     КонецПопытки;
      

     КонецЕсли;
      

      

     Стр_СхемаДанныхТхт="["+Стр_таблицаШапки+"]
      

     |ColNameHeader=False
      

     |Format=FixedLength
      

     |Col1=NumberNote Text Width 20
      

     |Col2=StoreNum Text Width 5
      

     |Col3=DataNote DateTime Width 10
      

     |Col4=DataDev DateTime Width 10
      

     |Col5=DataDes DateTime Width 10
      

     |Col6=CountLine Long Width 4
      

     |["+Стр_ТаблицаСтрок+"]
      

     |ColNameHeader=False
      

     |Format=FixedLength
      

     |Col1=NumberNote Text Width 20
      

     |Col2=Articul Text Width 7
      

     |Col3=Counts Double Width 9";
      

      

     ТекстСхемы=Новый ЗаписьТекста(ФайлСхемыДанных.ПолноеИмя, КодировкаТекста.ANSI);
      

     ТекстСхемы.Записать(Стр_СхемаДанныхТхт);
      

     ТекстСхемы.Закрыть();
      

      

     // Создаем коннект
      

     Попытка
      

     ОБ_АДОКонект.Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source="+Стр_КаталогДанных+";Extended Properties='text;FMT=Delimited;HDR=NO'");
      

     Исключение
      

     Сообщить("Невозможно открыть соединение!"+ОписаниеОшибки(),СтатусСообщения.Важное);
      

     Возврат Ложь;
      

     КонецПопытки;
      

      

     Стр_SQL = "S_elect * FR OM "+Стр_таблицаШапки;
      

      

     Попытка
      

     ОБ_АДОРекордсетШапка=ОБ_АДОКонект.Execute(Стр_SQL); 
      

     Исключение
      

     Сообщить("Ошибка выполнения запроса """+Стр_SQL+"""!"+ОписаниеОшибки(),СтатусСообщения.Важное);
      

     Возврат Ложь; 
      

     КонецПопытки;
      

      

     Пока НЕ ОБ_АДОРекордсетШапка.EOF Цикл
      

      

     // Заказ
      

      

     Стр_НомерЗаказа = ОБ_АДОРекордсетШапка.Fields("NumberNote").Value;
      

     Стр_КодКА= ОБ_АДОРекордсетШапка.Fields("StoreNum").Value;
      

      

     Д_ДатаЗаказа= ОБ_АДОРекордсетШапка.Fields("DataNote").Value;
      

     Д_ДатаДоставки= ОБ_АДОРекордсетШапка.Fields("DataDev").Value;
      

     Д_ДатаСбора= ОБ_АДОРекордсетШапка.Fields("DataDes").Value;
      

     Ч_КоличествоСтрок = ОБ_АДОРекордсетШапка.Fields("CountLine").Value;
      

      

     Сообщить("Заказ № "+Стр_НомерЗаказа+" от " +Д_ДатаЗаказа+ " Код контрагента: "+Стр_КодКА+" Дата доставки: "+Д_ДатаДоставки);
      

      

     // Обработка строк заказа
      

     Стр_SQL = "S_elect * FROM "+Стр_ТаблицаСтрок+" WH ERE NumberNote='"+Стр_НомерЗаказа+"'";
      

     Попытка
      

     ОБ_АДОРекордсетСтроки=ОБ_АДОКонект.Execute(Стр_SQL); 
      

     Исключение
      

     Сообщить("Ошибка выполнения запроса """+Стр_SQL+"""!"+ОписаниеОшибки(),СтатусСообщения.Важное);
      

     Возврат Ложь; 
      

     КонецПопытки;
      

      

     Сч=0;
      

     Сообщить(" № Артикул Количество");
      

     Пока НЕ ОБ_АДОРекордсетСтроки.EOF Цикл
      

     //Заполняем таб часть документа
      

     Сч=Сч+1;
      

     Стр_Артикул=СокрЛП(ОБ_АДОРекордсетСтроки.Fields("Articul").Value);
      

     Ч_Количество=ОБ_АДОРекордсетСтроки.Fields("Counts").Value;
      

     Сообщить(""+Сч+" " +Стр_Артикул+ " "+Ч_Количество);
      

     ОБ_АДОРекордсетСтроки.MoveNext();
      

     КонецЦикла;
      

     ОБ_АДОРекордсетШапка.MoveNext();
      

     КонецЦикла;
      

     КонецЦикла;
      

     Возврат Истина;
      

    КонецФункции