mysqldump

README

Go MYSQL Dump

Create MYSQL dumps in Go without the mysqldump CLI as a dependency.

Simple Example

package main

import (
	"database/sql"
	"fmt"

	"github.com/JamesStewy/go-mysqldump"
	_ "github.com/go-sql-driver/mysql"
)

func main() {
	// Open connection to database
  username := "your-user"
  password := "your-pw"
  hostname := "your-hostname"
  port := "your-port"
	dbname := "your-db"

  dumpDir := "dumps"  // you should create this directory
  dumpFilenameFormat := fmt.Sprintf("%s-20060102T150405", dbname)   // accepts time layout string and add .sql at the end of file

	db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s:%s)/%s", username, password, hostname, port, dbname))
	if err != nil {
		fmt.Println("Error opening database: ", err)
		return
	}

	// Register database with mysqldump
	dumper, err := mysqldump.Register(db, dumpDir, dumpFilenameFormat)
	if err != nil {
		fmt.Println("Error registering databse:", err)
		return
	}

	// Dump database to file
	resultFilename, err := dumper.Dump()
	if err != nil {
		fmt.Println("Error dumping:", err)
		return
	}
	fmt.Printf("File is saved to %s", resultFilename)

	// Close dumper and connected database
	dumper.Close()
}

Documentation

Overview

Create MYSQL dumps in Go without the 'mysqldump' CLI as a dependancy.

Example

This example uses the mysql driver (https://github.com/go-sql-driver/mysql) to connect to a mysql instance.

package main

import (
    "database/sql"
    "fmt"

    "github.com/jamf/go-mysqldump"
    "github.com/go-sql-driver/mysql"
)

func main() {
    // Open connection to database
    config := mysql.NewConfig()
    config.User = "your-user"
    config.Passwd = "your-pw"
    config.DBName = "your-db"
    config.Net = "tcp"
    config.Addr = "your-hostname:your-port"

    dumpDir := "dumps"  // you should create this directory
    dumpFilenameFormat := fmt.Sprintf("%s-20060102T150405", dbname)   // accepts time layout string and add .sql at the end of file

    db, err := sql.Open("mysql", config.FormatDNS())
    if err != nil {
        fmt.Println("Error opening database: ", err)
        return
    }

    // Register database with mysqldump
    dumper, err := mysqldump.Register(db, dumpDir, dumpFilenameFormat)
    if err != nil {
        fmt.Println("Error registering databse:", err)
        return
    }

    // Dump database to file
    resultFilename, err := dumper.Dump()
    if err != nil {
        fmt.Println("Error dumping:", err)
        return
    }
    fmt.Printf("File is saved to %s", resultFilename)

    // Close dumper, connected database and file stream.
    dumper.Close()
}

Index

• Constants
• func Dump(db *sql.DB, out io.Writer, a ...interface{}) error
• type Data
  • func Register(db *sql.DB, gzipdump bool, a ...interface{}) (*Data, string, error)
  • func (d *Data) Close() error
  • func (data *Data) Dump(a ...interface{}) error

Constants

const (
	// Version of this plugin for easy reference
	Version = "0.5.1"
)

Functions

func Dump

func Dump(db *sql.DB, out io.Writer, a ...interface{}) error

Dump Creates a MYSQL dump from the connection to the stream.

Types

type Data

type Data struct {
	Out              io.Writer
	ZOut             *zip.Writer
	ZFile            *os.File
	DBName           string
	UseDB            bool
	Connection       *sql.DB
	IgnoreTables     []string
	GzipDump         bool
	PrintTables      bool
	MaxAllowedPacket int
	LockTables       bool
	FileName         string
	DropDB           bool
	// contains filtered or unexported fields
}

Data struct to configure dump behavior

Out:              Stream to wite to
Connection:       Database connection to dump
IgnoreTables:     Mark sensitive tables to ignore
MaxAllowedPacket: Sets the largest packet size to use in backups
LockTables:       Lock all tables for the duration of the dump
UseDB: Insert use db into dumpfile

func Register

func Register(db *sql.DB, gzipdump bool, a ...interface{}) (*Data, string, error)

Register a new dumper.

db: Database that will be dumped (https://golang.org/pkg/database/sql/#DB).
dir: Path to the directory where the dumps will be stored.
format: Format to be used to name each dump file. Uses time.Time.Format (https://golang.org/pkg/time/#Time.Format). format appended with '.sql'.

func (*Data) Close

func (d *Data) Close() error

Close the dumper. Will also close the database the dumper is connected to as well as the out stream if it has a Close method.

Not required.

func (*Data) Dump

func (data *Data) Dump(a ...interface{}) error

Dump data using struct. fname is the name of the file to dump to.