importer

cgf/cgf.go

@@ -1,4 +1,4 @@
-package cgf
+package importer
 
 import (
 	"encoding/json"
@@ -9,8 +9,8 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"git.wecise.com/wecise/cgimport/cgf/reader"
 	"git.wecise.com/wecise/cgimport/odbc"
+	"git.wecise.com/wecise/cgimport/reader"
 	"git.wecise.com/wecise/util/filewalker"
 	"git.wecise.com/wecise/util/merrs"
 	"git.wecise.com/wecise/util/rc"

main.go

@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"git.wecise.com/wecise/cgimport/cgf"
+	"git.wecise.com/wecise/cgimport/importer"
 	"git.wecise.com/wecise/cgimport/odbc"
 )
 
@@ -26,7 +26,7 @@ func main() {
 	// 并发数
 	parallel := mcfg.GetInt("parallel", 10)
 	// 导入
-	filescount, recordscount, e := cgf.ImportDir(datapath, parallel)
+	filescount, recordscount, e := importer.ImportDir(datapath, parallel)
 	if e != nil {
 		panic(e)
 	}