main.go

/*
 TODO:
 * Fix races with a read write lock.
 * Check S3 first if backup pre-exists.  If it does and was not complete,
   auto-resume by reading a "metadata.json" file.  Which contains:
   - the tidb-snapshot
   - min/max/primary key/rows-per-file of tables included in backup.
 * Add MySQL compatibility with FTWRL, followed by START TRANSACTION WITH CONSISTENT SNAPSHOT.
 * Backup TiDB views (last)
 * Keep trx's open for dump (for mysql compat, optimization)

LIMITATIONS:
* Does not backup users.  Waiting on TIDB #7733.
* Not efficient at finding Primary Key.  Waiting on TiDB #7714.
* Files may not be equal in size (may be fixed in TIDB #7714)
* Server does not expose version in easily parsable format (TIDB #7736)
*/

package main

import (
	"flag"
	"os"
	"time"

	"github.com/pingcap/errors"
	"go.uber.org/zap"
)

var startTime = time.Now()

func panicError(err error) {
	if err != nil {
		panic(err)
	}
}

func main() {
	logCfg := zap.NewDevelopmentConfig()
	logInit, err := logCfg.Build()
	panicError(err)
	log := logInit.Sugar()

	cfg := NewConfig()
	err = cfg.Parse(os.Args[1:])
	switch errors.Cause(err) {
	case nil:
	case flag.ErrHelp:
		os.Exit(0)
	default:
		log.Error("parse cmd flags err %s\n", err)
		os.Exit(2)
	}

	level := zap.AtomicLevel{}
	err = level.UnmarshalText([]byte(cfg.LogLevel))
	panicError(err)
	logCfg.Level = level
	logLeveled, err := logCfg.Build()
	zap.ReplaceGlobals(logLeveled)
	if d, err := NewDumper(cfg); err == nil {
		d.Dump() // start main loop.
	}
	t := time.Now()
	zap.S().Infof("Completed in %s seconds.", t.Sub(startTime))
}