xg

jyBXSubscribe/rpc/bxsubscribe.go

@@ -39,9 +39,6 @@ func main() {
 	conf.MustLoad(*logFile, &IC.Logc)
 	IC.InitC()
 
-	log.Println(IC.MainMysql)
-	log.Println(IC.MainMysql.FindOne("contract", map[string]interface{}{"id": 1}, "", ""))
-	log.Println(IC.CkJy.SelectBySql("select bitmapToArray(infoids) infoids, userid from jianyu.sub_recommend_list where userid = ?", "1001"))
 	go func() {
 		err := endless.ListenAndServe(":"+MC.InterfaceToStr(IC.C.Webrpcport), nil, func() {})
 		if err != nil {

jyBXSubscribe/rpc/init/db.go

@@ -132,12 +132,3 @@ func EsInit(es *entity.EsStruct) {
 		elastic.NewEs(es.Version, es.Addr, es.Size, es.UserName, es.Password)
 	}
 }
-
-// clickhouse init
-func CkInit(ck *entity.Mysql) {
-	if ck.JyCk.Address != "" {
-		logx.Info("--初始化 jy clickhouse--")
-		CkJy = mysql.NewInit(mysql.CLICKHOUSE, fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8mb4", ck.JyCk.UserName, ck.JyCk.Password, ck.JyCk.Address, ck.JyCk.DbName),
-			ck.JyCk.MaxOpenConns, ck.JyCk.MaxIdleConns)
-	}
-}