go-svc-configure/main.go

package main

import (
	"log"
	"net/http"

	"git.x2erp.com/qdy/go-base/bootstraps"
	"git.x2erp.com/qdy/go-base/middleware"
	"git.x2erp.com/qdy/go-db/factory/database"
	"git.x2erp.com/qdy/go-db/myhandle"
	"git.x2erp.com/qdy/go-db/sqldef"
	"go-micro.dev/v4/web"

	"git.x2erp.com/qdy/go-svc-configure/service"
	_ "git.x2erp.com/qdy/go-svc-configure/tables" // 导入表定义包，触发 init() 函数
)

var (
	serviceName    = "svc-configure"
	serviceVersion = "1"
)

func main() {

	// 创建服务启动器
	bootstrapper := bootstraps.NewServiceBootstrapper(serviceName, serviceVersion)

	//加载配置
	bootstrapper.InitConfig()

	//构建数据库工厂
	bootstrapper.InitDatabase()

	//创建表到数据库
	creteTabel(bootstrapper.DbFactory)

	// 启动服务，传入路由注册函数
	bootstrapper.Run(registerRoutes)

}

// 注册所有路由
func registerRoutes(webService web.Service, dbFactory *database.DBFactory) {

	// 查询yaml配置文件
	webService.Handle("/api/query/yaml", middleware.JWTAuthMiddleware(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		myhandle.QueryHandlerMap(w, r, dbFactory, service.QueryYamlConfigure)
	})))

}

func creteTabel(factory *database.DBFactory) {

	// 获取数据库连接和类型
	db := factory.GetDB()
	dbType := factory.GetDBType()

	// 创建表同步器
	syncer, err := sqldef.NewTableSyncer(db, dbType)
	if err != nil {
		log.Printf("创建 - 建立器失败: %v", err)
	}

	// 创建表
	if err := syncer.CreateTables(); err != nil {
		log.Printf("建表失败: %v", err)
	}

	log.Println("数据库表建立完成！")
}