Optimization.

example/dump/main.go

@@ -1,19 +1,27 @@
 package main
 
 import (
+	"database/sql"
+	"log"
 	"os"
 
-	"github.com/jarvanstack/mysqldump"
+	"github.com/notyusta/mysqldump"
 )
 
 func main() {
+	dsn := "root:rootpasswd@tcp(localhost:3306)/dbname?charset=utf8mb4&parseTime=true&loc=Asia%2FJakarta"
+	db, err := sql.Open("mysql", dsn)
+	if err != nil {
+		log.Printf("[error] %v \n", err)
+		return
+	}
 
-	dsn := "root:rootpasswd@tcp(localhost:3306)/dbname?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai"
-
+	defer db.Close()
 	f, _ := os.Create("dump.sql")
 
 	_ = mysqldump.Dump(
-		dsn,                          // DSN
+		db, // DSN
+		"test",
 		mysqldump.WithDropTable(),    // Option: Delete table before create (Default: Not delete table)
 		mysqldump.WithData(),         // Option: Dump Data (Default: Only dump table schema)
 		mysqldump.WithTables("test"), // Option: Dump Tables (Default: All tables)

example/source/main.go

@@ -1,18 +1,27 @@
 package main
 
 import (
+	"database/sql"
+	"log"
 	"os"
 
-	"github.com/jarvanstack/mysqldump"
+	"github.com/notyusta/mysqldump"
 )
 
 func main() {
 
-	dns := "root:rootpasswd@tcp(localhost:3306)/dbname?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai"
+	dsn := "root:rootpasswd@tcp(localhost:3306)/dbname?charset=utf8mb4&parseTime=true&loc=Asia%2FJakarta"
+	db, err := sql.Open("mysql", dsn)
+	if err != nil {
+		log.Printf("[error] %v \n", err)
+		return
+	}
+
 	f, _ := os.Open("dump.sql")
 
 	_ = mysqldump.Source(
-		dns,
+		db,
+		"test",
 		f,
 		mysqldump.WithMergeInsert(1000), // Option: Merge insert 1000 (Default: Not merge insert)
 		mysqldump.WithDebug(),           // Option: Print execute sql (Default: Not print execute sql)

go.mod

@@ -1,4 +1,4 @@
-module github.com/jarvanstack/mysqldump
+module github.com/notyusta/mysqldump
 
 go 1.18