检测db是否连接

cmd/main.go

@@ -72,11 +72,31 @@ func main() {
 	_ = logger.InitLogger("file", logConfig)
 	logger.Init()
 
-	_ = initDb("InitSeoDB", util.Configs.Seo_databases.Dns)
-	_ = initDb("InitSpuDB", util.Configs.Spu_databases.Dns)
-	_ = initDb("InitGoodsDB", util.Configs.Goods_databases.Dns)
-	_ = initDb("InitSkuDB", util.Configs.Sku_databases.Dns)
-	_ = initDb("InitLxDB", util.Configs.Liexin_databases.Dns)
+	err_seo := initDb("InitSeoDB", util.Configs.Seo_databases.Dns)
+	err_spu := initDb("InitSpuDB", util.Configs.Spu_databases.Dns)
+	err_goods := initDb("InitGoodsDB", util.Configs.Goods_databases.Dns)
+	err_sku := initDb("InitSkuDB", util.Configs.Sku_databases.Dns)
+	err_lx := initDb("InitLxDB", util.Configs.Liexin_databases.Dns)
+
+	if err_goods != nil {
+		fmt.Println(err_goods)
+	}
+
+	if err_spu != nil {
+		fmt.Println(err_goods)
+	}
+
+	if err_seo != nil {
+		fmt.Println(err_seo)
+	}
+
+	if err_sku != nil {
+		fmt.Println(err_sku)
+	}
+
+	if err_lx != nil {
+		fmt.Println(err_lx)
+	}
 
 	t := &RecvPro{}
 	go rabbitmq.Recv(rabbitmq.QueueExchange{