golang 读取mongob数据写入sqlserver
package mainimport (
_
"bitbucket.org/miquella/mgodbc"
"database/sql"
"encoding/json"
"fmt"
"labix.org/v2/mgo"
"labix.org/v2/mgo/bson"
"os"
"runtime"
"time"
)
type serverslice struct {
Servers []string
Sqlconn string
Start string
End string
}
type user struct {
UserName string "UserName"
Password string "Password"
Email string "Email"
Phone string "Phone"
SubTimetime.Time "SubTime"
}
var config serverslice
var worker = runtime.NumCPU()
//初始化配置
func init() {
file, _ := os.Open("config.json")
defer file.Close()
buf := make([]byte, 2048)
n, _ := file.Read(buf)
err := json.Unmarshal(buf[:n], &config)
if err != nil {
panic(err)
fmt.Println(err)
}
}
func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
var chanUser = make(chan user)
// 标记完成
dones := make(chan struct{}, worker)
go readmongodb(chanUser)
for i := 0; i < worker; i++ {
go writesql(chanUser, dones)
}
awaitForCloseResult(dones)
fmt.Println("完成")
}
//读取mongodb数据
func readmongodb(chanUser chan
页:
[1]