utils

Documentation

Index

• Constants
• Variables
• func Export(ctx context.Context, noticer notice.Noticer, cfg *driver.DbAuth, ...) error
• func Import(ctx context.Context, noticer *notice.NoticeAndProgress, cfg *driver.DbAuth, ...) error
• func RemoveAutoIncrementValue(s string) string
• func ResetAutoIncrement(sqlStructFile string) error
• func SupportedExport() bool
• func SupportedImport() bool
• type FileInfo
• type FileInfos
  • func (f *FileInfos) Add(fi *FileInfo)
• type ImportFile
  • func ParseImportFile(cacheDir string, files []string) (*ImportFile, error)
  • func (a *ImportFile) AllSqlFileNum() int
  • func (a *ImportFile) AllSqlFiles() []string
  • func (a *ImportFile) Close() error

Constants

const (
	// OpExport 导出操作
	OpExport string = `export`
	// OpImport 导入操作
	OpImport string = `import`
)

const (
	Importor = `mysql`
	Exportor = `mysqldump`
)

Variables

var Charsets = []string{
	"armscii8",
	"ascii",
	"big5",
	"binary",
	"cp1250",
	"cp1251",
	"cp1256",
	"cp1257",
	"cp850",
	"cp852",
	"cp866",
	"cp932",
	"dec8",
	"eucjpms",
	"euckr",
	"gb18030",
	"gb2312",
	"gbk",
	"geostd8",
	"greek",
	"hebrew",
	"hp8",
	"keybcs2",
	"koi8r",
	"koi8u",
	"latin1",
	"latin2",
	"latin5",
	"latin7",
	"macce",
	"macroman",
	"sjis",
	"swe7",
	"tis620",
	"ucs2",
	"ujis",
	"utf16",
	"utf16le",
	"utf32",
	"utf8",
	"utf8mb3",
	"utf8mb4",
}

Charsets MySQL 支持的字符集

var MySQLBinPaths = []string{`/usr/local/bin`, `/usr/bin`}

Functions

func Export

func Export(ctx context.Context, noticer notice.Noticer,
	cfg *driver.DbAuth, tables []string, structWriter, dataWriter interface{},
	mysqlVersion string, hasGTID bool, resetAutoIncrements ...bool) error

Export 导出SQL文件

func Import

func Import(ctx context.Context, noticer *notice.NoticeAndProgress, cfg *driver.DbAuth, cacheDir string, files []string) error

Import 导入SQL文件

func RemoveAutoIncrementValue

func RemoveAutoIncrementValue(s string) string

RemoveAutoIncrementValue AUTO_INCREMENT值

func ResetAutoIncrement

func ResetAutoIncrement(sqlStructFile string) error

ResetAutoIncrement 重置AUTO_INCREMENT值为0

func SupportedExport

func SupportedExport() bool

func SupportedImport

func SupportedImport() bool

Types

type FileInfo

type FileInfo struct {
	Start      time.Time
	End        time.Time
	Elapsed    time.Duration
	Path       string
	Size       int64
	Compressed bool
	Error      string `json:",omitempty"`
}

FileInfo 文件信息

type FileInfos

type FileInfos []*FileInfo

FileInfos 文件信息集合

func (*FileInfos) Add

func (f *FileInfos) Add(fi *FileInfo)

type ImportFile

type ImportFile struct {
	StructFiles []string
	DataFiles   []string
	// contains filtered or unexported fields
}

func ParseImportFile

func ParseImportFile(cacheDir string, files []string) (*ImportFile, error)

func (*ImportFile) AllSqlFileNum

func (a *ImportFile) AllSqlFileNum() int

func (*ImportFile) AllSqlFiles

func (a *ImportFile) AllSqlFiles() []string

func (*ImportFile) Close

func (a *ImportFile) Close() error