Streams and BLOB escapes for large databases

.travis.yml

@@ -1,8 +1,7 @@
 language: go
 
 go:
-  - 1.6
-  - 1.7.x
+  - 1.13.x
   - master
 
 script:

README.md

@@ -6,49 +6,49 @@ Create MYSQL dumps in Go without the `mysqldump` CLI as a dependancy.
 package main
 
 import (
-	"database/sql"
-	"fmt"
+  "database/sql"
+  "fmt"
 
-	"github.com/JamesStewy/go-mysqldump"
-	_ "github.com/go-sql-driver/mysql"
+  "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"
+  // 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", 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()
+  dumpFilenameFormat := fmt.Sprintf("%s-20060102T150405", config.DBName)   // accepts time layout string and add .sql at the end of file
+
+  db, err := sql.Open("mysql", config.FormatDSN())
+  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
+  err := dumper.Dump()
+  if err != nil {
+    fmt.Println("Error dumping:", err)
+    return
+  }
+  fmt.Printf("File is saved to %s", dumpFilenameFormat)
+
+  // Close dumper, connected database and file stream.
+  dumper.Close()
 }
-
 ```
 
 [![GoDoc](https://godoc.org/github.com/JamesStewy/go-mysqldump?status.svg)](https://godoc.org/github.com/JamesStewy/go-mysqldump)

doc.go

@@ -3,44 +3,52 @@ Create MYSQL dumps in Go without the 'mysqldump' CLI as a dependancy.
 
 Example
 
-This example uses the mymysql driver (example 7 https://github.com/ziutek/mymysql) to connect to a mysql instance.
+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/JamesStewy/go-mysqldump"
-    	"github.com/ziutek/mymysql/godrv"
-    	"time"
+        "database/sql"
+        "fmt"
+
+        "github.com/JamesStewy/go-mysqldump"
+        "github.com/go-sql-driver/mysql"
     )
 
     func main() {
-        // Register the mymysql driver
-        godrv.Register("SET NAMES utf8")
-
         // Open connection to database
-        db, err := sql.Open("mymysql", "tcp:host:port*database/user/password")
-    	if err != nil {
-            fmt.Println("Error opening databse:", err)
+        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, "dumps", time.ANSIC)
+        dumper, err := mysqldump.Register(db, dumpDir, dumpFilenameFormat)
         if err != nil {
-        	fmt.Println("Error registering databse:", err)
-        	return
+            fmt.Println("Error registering databse:", err)
+            return
         }
 
         // Dump database to file
-        err = dumper.Dump()
+        resultFilename, err := dumper.Dump()
         if err != nil {
-        	fmt.Println("Error dumping:", err)
-        	return
+            fmt.Println("Error dumping:", err)
+            return
         }
+        fmt.Printf("File is saved to %s", resultFilename)
 
-        // Close dumper and connected database
+        // Close dumper, connected database and file stream.
         dumper.Close()
     }
 */