クライアントからサーバーDBのバックアップ、リストアを行いたい

Question

前提・実現したいこと

現在、とあるデータを管理するシステムを作成しているのですが、使用するユーザーが任意のタイミングでバックアップ、リストアを行うことができる機能を追加したいと思っています。
バックアップファイルはクライアント側に保存し、リストア時にクライアントからファイルを選択し、そのファイルの内容をサーバーのDBに書き込むという処理を行いたいと思っています。
実際に作成しており、バックアップをクライアントに保存することには成功したのですが、サーバーへのリストア時にエラーが発生してしまい、上手くいきません。

発生している問題・エラーメッセージ

例外がスローされました: 'System.Exception' (mscorlib.dll の中)
System.Exception: Received unexpected backend message CopyInResponse. Please file a bug.
   場所 Npgsql.NpgsqlConnector.UnexpectedMessageReceived(BackendMessageCode received)
   場所 Npgsql.NpgsqlDataReader.<NextResult>d__44.MoveNext()
--- 直前に例外が・Xローされた場所からのスタック トレースの終わり ---
   場所 System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   場所 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   場所 Npgsql.NpgsqlDataReader.NextResult()
   場所 Npgsql.NpgsqlCommand.<ExecuteReader>d__105.MoveNext()
--- 直前に例外がスローされた場所からのスタック トレースの終わり ---
   場所 System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   場所 Npgsql.NpgsqlCommand.<ExecuteReader>d__105.MoveNext()
--- 直前に例外がスローされた場所からのスタック トレースの終わり ---
   場所 System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   場所 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   場所 Npgsql.NpgsqlCommand.<ExecuteNonQuery>d__93.MoveNext()
--- 直前に例外がスローされた場所からのスタック トレースの終わり ---
   場所 System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   場所 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   場所 Npgsql.NpgsqlCommand.ExecuteNonQuery()

ソースコード

//バックアップを行う処理
private void backup_Button(object sender, RoutedEventArgs e)
		{
			var hostNameOrIpAddr = "192.168.--.---";
			var portNo = 22;
			var userName = "root";
			var passWord = "***";
			try
			{
				// 接続情報
				// SSHクライアント生成
				ConnectionInfo info = new ConnectionInfo(hostNameOrIpAddr, portNo, userName,
					new AuthenticationMethod[] {
						new PasswordAuthenticationMethod(userName, passWord)
                    }
				);
				SshClient ssh = new SshClient(info);
				ssh.Connect();

				if (ssh.IsConnected)
				{
					var cmd = ssh.RunCommand("pg_dump -U postgres test");
					var output = cmd.Result;
					System.Windows.Forms.SaveFileDialog dlg = new System.Windows.Forms.SaveFileDialog();
					dlg.FileName = "バックアップ.txt";
					dlg.InitialDirectory = @"C:\";
					dlg.Title = "保存先のファイルを選択してください";
					dlg.RestoreDirectory = true;
					dlg.OverwritePrompt = true;
					dlg.CheckPathExists = true;
					if (dlg.ShowDialog() == DialogResult.OK)
					{
						string filename = dlg.FileName;
						Encoding enc = Encoding.GetEncoding("UTF-8");
						try
						{
							File.WriteAllText(filename, output, enc);
						}

						catch (Exception ex)
						{
							System.Windows.MessageBox.Show(ex.Message);
							return;
						}
					}
	
				}
				else
				{
					// 接続に失敗した（未接続状態である）
					System.Windows.MessageBox.Show("接続に失敗しました");
					return;
				}

				// 接続終了
				ssh.Disconnect();
			}
			catch (Exception ex) { Console.WriteLine(ex); }
		}

private void restore_button(object sender, RoutedEventArgs e)
		{
			string path;
			System.Windows.Forms.OpenFileDialog ofd = new System.Windows.Forms.OpenFileDialog();
			if (ofd.ShowDialog() == DialogResult.OK)
			{
				System.IO.Stream stream;
				stream = ofd.OpenFile();
				path = ofd.FileName;
				if (stream != null)
				{
					System.IO.StreamReader sr =
						new System.IO.StreamReader(stream);
                                        //上記のプログラムで作成したバックアップファイルを選択し、変数sqlへ
                                        //sqlの内容は下に書いています。
					sql = sr.ReadToEnd();
					sr.Close();
					stream.Close();
				}
			}
			string conn_str = "Server=198.162.--.--;Port=5432;User ID=postgres;Database=test;Password=***;Enlist=true";
			using (NpgsqlConnection conn = new NpgsqlConnection(conn_str))
			{
				conn.Open();
				using (NpgsqlCommand command = new NpgsqlCommand(@sql, conn))
				{
					try {command.ExecuteNonQuery();
						System.Windows.MessageBox.Show("リストアが完了しました");
					}
					catch (System.Exception ex)
					{ Console.WriteLine(ex); }
				}
				conn.Close();
			}
		}

//バックアップで生成された、リストアを行うファイル
--
-- PostgreSQL database dump
--

-- Dumped from database version 10.15
-- Dumped by pg_dump version 10.15

SET statement_timeout = 0;
SET lock_timeout = 0;
SET idle_in_transaction_session_timeout = 0;
SET client_encoding = 'UTF8';
SET standard_conforming_strings = on;
SELECT pg_catalog.set_config('search_path', '', false);
SET check_function_bodies = false;
SET xmloption = content;
SET client_min_messages = warning;
SET row_security = off;

--
-- Name: plpgsql; Type: EXTENSION; Schema: -; Owner: 
--

CREATE EXTENSION IF NOT EXISTS plpgsql WITH SCHEMA pg_catalog;


--
-- Name: EXTENSION plpgsql; Type: COMMENT; Schema: -; Owner: 
--

COMMENT ON EXTENSION plpgsql IS 'PL/pgSQL procedural language';


SET default_tablespace = '';

SET default_with_oids = false;


CREATE TABLE public.master (
    
    id integer NOT NULL
);


ALTER TABLE public.master OWNER TO postgres;


COPY public.master (id) FROM stdin;
1
.

ALTER TABLE ONLY public.master
    ADD CONSTRAINT key PRIMARY KEY (id);

試したこと

どこが原因なのか調べていくうちに

COPY public.master (id) FROM stdin;
1
.

の部分を削除することで正常に動作するということが分かりました。
クライアントからこのコピー句を使うことはできないのでしょうか？
出来るだけバックアップファイル(SQL文)は変更しない状態で実行したいです。

Comments

[gentaro]

以前の質問と同様の趣旨のようです。
https://teratail.com/questions/311489
https://teratail.com/questions/311516

同じ内容で複数の質問をするのはガイドライン違反です。
https://teratail.com/help/avoid-asking

運営に質問の削除を依頼してください。
詳細な内容を付け加えたいのであれば、質問文を編集してください。

[nekosuke123]

前回のものを削除依頼させてもらいました。

[dodox86]

先の質問にも言えますが、バックアップはpg_dumpでやっているのに、リストアはpg_dumpの対であるpg_restoreを使わないというのがもう解せません。バックアップファイルはあくまでPostgreSQLのCLIであるpg_dump/pg_restoreを使うのが前提であると思います。
"COPY public.master (id) FROM stdin" のstdinは標準入力からのデータ入力を想定しているでしょうし、行頭の1や\.はそれらコマンドラインツール用の入力なのでは？

[退会済みユーザー]

> 前回のものを削除依頼させてもらいました。

それは先のスレッドでいろいろレス・アドバイスをくれた回答者・閲覧者の時間と労力を全くの無駄にするもので大変失礼な話と認識するべきです。そういうことをしていると誰もあなたを相手にしなくなりますよ。

[nekosuke123]

>dodox86
pg_restoreを使おうとは思ったのですが、pg_restoreというのはファイルを使用してリストアを行いますよね？このシステムはクライアントサーバーシステムで作っており、クライアントにバックアップファイルがあり、DBはサーバーにある状態なのですがどのようにファイルの受け渡しをすればいいのかが分からなく、中身だけ抜き取ってリストアしてしまおうという考えになっていました…。

[nekosuke123]

>SurferOnWww
すみません。次回から気を付けます。

[nekosuke123]

現在平文でバックアップをしていますが、この平文ではCOPY句が入っているため、リストアは難しいのでしょうか？
アーカイブ形式でバックアップを取るとしたとき、サーバーへバックアップファイルを受け渡すことは可能でしょうか。

[nekosuke123]

↑出来る、出来ない、分からない、どれでもいいのでアクションをいただけませんか…？

Answer 1

同様の質問とそれに関する回答及び情報がググれば出てきます。

Can Npgsql dump/restore an entire database? - StackOverflow
Feature request: database backup and restore #1397 - GitHub npgsql

Comments

[nekosuke123]

一通り読んでみたのですが、英文ということもあり、いまいち理解できませんでした。