jyps/mysql/main.go

package main

import (
	"gorm.io/gorm"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
)

var (
	Mgo     *mongodb.MongodbSim //87 环境，采集 存储的MongoDB
	MysqlDB *gorm.DB
)

func main() {
	Init()
	getDifferent()
}

// getDifferent 获取省市区信息和最新MySQL数据的不同
func getDifferent() {
	sess := Mgo.GetMgoConn()
	defer Mgo.DestoryMongoConn(sess)
	query := sess.DB("mixdata").C("address_new_2020").Find(nil).Select(nil).Iter()
	count := 0

	for tmp := make(map[string]interface{}); query.Next(tmp); count++ {

	}

}