GolangでMySQLデータベースのバックアップを実装する方法

OpFlag構造体型{
  Tables bool //テーブル構造 Datum bool //テーブル構造とデータ Views bool //ビュー Funcs bool //関数とストアドプロシージャ}

 len(os.Args) > 1 の場合 {
    フラグ = common.OpFlag{
      表: 偽、
      データ: 偽、
      閲覧数: false、
      関数: false、
    }
    switch os.Args[1] { //パラメータを受け入れる case "table":
      flag.Tables = true //パラメータケース「data」に応じて識別子を設定します。
      flag.Tables = true
      flag.Datum = true
    ケース「ビュー」:
      flag.Views = true
    ケース "関数":
      flag.Funcs = true
    デフォルト: // パラメータが正しくありません。エラーを報告してログを終了します。致命的("引数はテーブル、データ、ビュー、または関数内になければなりません。")
    }
  }else{ //パラメータなし、すべてのフラグはデフォルトでエクスポートされます = common.OpFlag{
      表: 真、
      データ: true、
      閲覧数: true、
      関数: true、
    }
  }
  err := backUp.Export(flag) パラメータに従ってデータベースをバックアップします

var configs インターフェース{}
  fr, err := os.Open("./configs.json")
  err != nil の場合 {
    エラーを返す
  }
  デコーダー:= json.NewDecoder(fr) // 設定ファイルを解析します err = デコーダー.Decode(&configs)
  confs := configs.(map[文字列]インターフェース{})
  workDir := confs["workDir"].(文字列)
  ch := make(chan string) //キーのチャネル変数、値 := range confs {
    strings.HasPrefix(キー、"db_") の場合 {
      dbConf := 値.(map[文字列]インターフェース{})
      dbConn := common.DbConnFields{ //データベース構成 DbHost: dbConf["db_host"].(文字列),
        DbPort: int(dbConf["db_port"].(float64))、
        DbUser: dbConf["db_user"].(文字列)、
        DbPass: dbConf["db_pass"].(文字列)、
        DbName: dbConf["db_name"].(文字列)、
        DbCharset: dbConf["db_charset"].(文字列)、
      }
      if dbConf["file_alias"] != nil { //SQLバックアップファイルの名前を生成します dbConn.FileAlias ​​= dbConf["file_alias"].(string)
      }
      go ExportOne(dbConn, workDir, ch, flag) //コルーチンを作成する}
  }
  for key := range confs { //メインプロセスをブロックし、すべてのコルーチンが作業を完了するまで待機します if strings.HasPrefix(key, "db_") {
      fmt.Print(<-ch) 関数は、
    }
  }
  nilを返す

{
  "db_name1": {
    "db_host": "192.168.1.8",
    「db_port」: 3306,
    "db_user": "ルート",
    "db_pass": "123456",
    "db_name": "name1",
    "db_charset": "utf8mb4",
    "file_alias": "ファイル名1"
  },
  "db_name2": {
    "db_host": "ローカルホスト",
    「db_port」: 3306,
    "db_user": "ルート",
    "db_pass": "123456",
    "db_name": "name2",
    "db_charset": "utf8mb4"
  },
  "データベース方言": "mysql",
  "作業ディレクトリ": "/home/zhoutk/gocodes/goTools/"
}

ファイル名:= フィールド.FileAlias
  setSqlHeader(fields, fileName) //エクスポートファイルの説明を設定します if flag.Tables { //テーブルがtrueに設定されている場合、テーブル構造をエクスポートします err := exportTables(fileName, fields, flag) //特定のアルゴリズムについては、ソースコードを参照してください if err != nil {
      ch <- fmt.Sprintln("エラー: ", fields.DbName, "\t エクスポート テーブルがスローされました, \t", err)
      戻る
    }
  }
  if flag.Views { //ビューがtrueに設定されている場合、ビューをエクスポートします err := exportViews(fileName, fields) //具体的なアルゴリズムについては、ソースコードまたはPythonアルゴリズムを参照してください if err != nil {
      ch <- fmt.Sprintln("エラー: ", fields.DbName, "\t エクスポート ビューがスローされました, \t", err)
      戻る
    }
  }
  if flag.Funcs { //関数がtrueに設定されている場合、関数とストアドプロシージャをエクスポートします err := exportFuncs(fileName, fields) //具体的なアルゴリズムについては、ソースコードを参照してください if err != nil {
      ch <- fmt.Sprintln("エラー: ", fields.DbName, "\t export funcs throw, \t", err)
      戻る
    }
  }
  //エクスポートが完了しました。チャネルに情報を入力します。 ch <- fmt.Sprintln("エクスポート ", fields.DbName, "\t 成功 \t", time.Now().Format("2006-01-02 15:04:05"))

func ExecuteWithDbConn(sql 文字列、値 [] インターフェース {}、フィールド common.DbConnFields) (map [文字列] インターフェース {}、エラー) {
  rs := make(map[文字列]インターフェース{})
  dao、err := mysql.Open("mysql", fields.DbUser + ":"+fields.DbPass+"@tcp("+fields.DbHost+":"+
    strconv.Itoa(fields.DbPort)+")/"+fields.DbName+"?charset="+fields.DbCharset)
  dao.Close() を延期する
  err != nil の場合 {
    rs["コード"] = 204
    rsを返す、エラー
  }
  stmt、err := dao.Prepare(sql)
  err != nil の場合 {
    rs["コード"] = 204
    rsを返す、エラー
  }
  行、エラー:= stmt.Query(値...)
  err != nil の場合 {
    rs["コード"] = 204
    rsを返す、エラー
  }
  columns, err := rows.Columns() //フィールド名を取得します vs := make([]mysql.RawBytes, len(columns))
  スキャン:= make([]interface{}, len(列))
  for i := range vs { // プリセット値アドレス scans[i] = &vs[i]
  }
  var result []map[文字列]インターフェース{}
  行のNext() {
    _ = rows.Scan(scans...) //値の列を入力します each := make(map[string]interface{})
    i, col := 範囲 vs {
      列がnilの場合{
        each[columns[i]] = FilterHolder(string(col)) //Filter/xfffd
      }それ以外{
        各[列[i]] = nil
      }
    }
    結果 = append(結果、それぞれ)
  }
  rs["コード"] = 200
  //データ、_ := json.Marshal(結果)
  rs["行"] = 結果
  rsを返す、エラー
}

git クローン https://github.com/zhoutk/goTools
cd goツール
取りに行く
main.go を実行します
ビルド main.go
./main #データベースのすべてをエクスポート
./main テーブル #テーブルをエクスポート
./main data #テーブルとデータをエクスポート
./メインビュー #エクスポートビュー
./main funcs #export 関数とストアド プロシージャ