Восстановление базы данных Postgre SQL...

Перем ConnectionT;
Перем ConnectionK;

Процедура ПолучитьСоединениеСУбитойБазой()
	Сервер = "localhost";
	Порт = "5432";
	База = "BuhSever";
	Source = "PostgreBuhTrash";
	Пользователь = "postgres";
	Пароль = "*****";
	
	ConnectionT = Новый COMОбъект("ADODB.CONNECTION");
	ConnectionT.Provider	= "MSDASQL.1";
	ConnectionT.ConnectionString = "Driver={PostgreSQL Unicode};data source="+Source+";Server="+Сервер+";Port=" + 
	Порт+";Database="+База+";Uid="+Пользователь+";Pwd="+Пароль+";STMT="+"utf8";		
	Попытка		    
		Состояние("Подключение к базе PostgreSQL...");
		ConnectionT.open();		    
		Сообщить("База PostgreSQL Trash подключена");
	Исключение		    
		Сообщить("Не могу подключиться к базе PostgreSQL Trash");
	КонецПопытки;	

КонецПроцедуры	

Процедура ПолучитьСоединениеСКопиейБазы()
	Сервер = "localhost";
	Порт = "5432";
	База = "RestoreBuhSever";
	Source = "PostgreBuhRes";
	Пользователь = "postgres";
	Пароль = "*****";
	
	ConnectionK = Новый COMОбъект("ADODB.CONNECTION");
	ConnectionK.Provider	= "MSDASQL.1";
	ConnectionK.ConnectionString = "Driver={PostgreSQL Unicode};data source="+Source+";Server="+Сервер+";Port=" + 
	Порт+";Database="+База+";Uid="+Пользователь+";Pwd="+Пароль+";STMT="+"utf8";		
	Попытка		    
		Состояние("Подключение к базе PostgreSQL K...");
		ConnectionK.open();		    
		Сообщить("База PostgreSQL K подключена");
	Исключение		    
		Сообщить("Не могу подключиться к базе PostgreSQL K");
	КонецПопытки;	
КонецПроцедуры	

Функция ПолучитьТекстЗапросаСпискаТаблиц() 
	ТекстЗапроса = 
	"Sel ect table_name 
	|from information_schema.tables 
	|where table_schema='public'";	
	
	Возврат ТекстЗапроса;
КонецФункции

Функция ПолучитьТаблицыБазы(База,Source)
	Сервер = "localhost";
	Порт = "5432";
	//База = "BuhSever";
	Пользователь = "postgres";
	Пароль = "*****";
	
	Connection = Новый COMОбъект("ADODB.CONNECTION");
	Connection.Provider	= "MSDASQL.1";
	Connection.ConnectionString = "Driver={PostgreSQL Unicode};data source="+Source+";Server="+Сервер+";Port=" + 
	Порт+";Database="+База+";Uid="+Пользователь+";Pwd="+Пароль+";STMT="+"utf8";		
	Попытка		    
		Состояние("Подключение к базе PostgreSQL...");
		Connection.open();		    
		Сообщить("База PostgreSQL подключена");
	Исключение		    
		Сообщить("Не могу подключиться к базе PostgreSQL ");
	КонецПопытки;	
	
	НаборЗаписей = Новый ComObject("ADODB.RecordSet");
	Команда = Новый COMОбъект("ADODB.Command");
	Попытка    
		Команда.ActiveConnection = Connection;    
		Команда.CommandText = ПолучитьТекстЗапросаСпискаТаблиц();
		НаборЗаписей = Команда.Execute();    
		Сообщить("Данные получены.");
	Исключение    
		Сообщить("Нет данных.");    
		Возврат Новый ТаблицаЗначений;
	КонецПопытки;
	
	ТЗ = Новый ТаблицаЗначений;

//Добавление колонок во временную таблицу
Для НомерСтолбца = 0 По НаборЗаписей.Fields.Count - 1 Цикл                 
	ИмяСтолбца = НаборЗаписей.Fields.Item(НомерСтолбца).Name;                
	ТЗ.Колонки.Добавить(ИмяСтолбца);
КонецЦикла;

Пока НЕ НаборЗаписей.EOF Цикл        
		
	// Заполнение временной таблицы таблицы                 
	НоваяСтрока = ТЗ.Добавить();                
	Для НомерСтолбца = 0 По НаборЗаписей.Fields.Count-1 Цикл                               
		НоваяСтрока.Установить(НомерСтолбца, СокрЛП(НаборЗаписей.Fields(НомерСтолбца).Value));                
	КонецЦикла;                

	НаборЗаписей.MoveNext();
КонецЦикла; 

Возврат ТЗ;
КонецФункции	

Функция СкопироватьТаблицуИзБазыВБазу(table_name)	
	ОбработкаПрерыванияПользователя();
	
	Команда = Новый COMОбъект("ADODB.Command");
	Попытка    
		Команда.ActiveConnection = ConnectionT;    
		Команда.CommandText = "Copy "+table_name+" to 'D:/tables/"+table_name+".csv'";
		Команда.Execute(); 
	Исключение    
		Сообщить(ОписаниеОшибки());    
	КонецПопытки;
	
	Команда = Новый COMОбъект("ADODB.Command");
	Попытка    
		Команда.ActiveConnection = ConnectionK;    
		Команда.CommandText = "delete from "+table_name;
		Команда.Execute(); 
	Исключение    
		Сообщить(ОписаниеОшибки());    
	КонецПопытки;
	
	Команда = Новый COMОбъект("ADODB.Command");
	Попытка    
		Команда.ActiveConnection = ConnectionK;    
		Команда.CommandText = "Copy "+table_name+" from 'D:/tables/"+table_name+".txt'";
		Команда.Execute(); 
	Исключение    
		Сообщить(ОписаниеОшибки());    
	КонецПопытки;
	
	Состояние(table_name);
КонецФункции	

Процедура КнопкаВыполнитьНажатие(Кнопка)
	ПолучитьСоединениеСУбитойБазой();
	ПолучитьСоединениеСКопиейБазы();
	
	ТЗБитойБазы = ПолучитьТаблицыБазы("BuhSever","PostgreBuhTrash");
	ТЗКопииБазы = ПолучитьТаблицыБазы("RestoreBuhSever","PostgreBuhRes");
	
	Для Каждого СтрТЗБ из ТЗБитойБазы цикл
		Для Каждого СтрТЗК из ТЗКопииБазы цикл
			Если СтрТЗБ.table_name = СтрТЗК.table_name тогда
				СкопироватьТаблицуИзБазыВБазу(СтрТЗБ.table_name);
				Прервать;
			КонецЕсли;	
		КонецЦикла;
	КонецЦикла;			
	Сообщить("ОК");
КонецПроцедуры

@Echo off
FOR %%a IN (d:\tables\*.csv) DO (
echo %%~nxa
pgfutter.exe --host "localhost" --port "5432" --db "BuhSever" --schema "public" --table %%~na --user "postgres" --pw "ПАРОЛЬ" csv %%~nxa)