2026-08-09 10:43:45 +08:00
|
|
|
package impl
|
|
|
|
|
|
|
|
|
|
import (
|
2026-08-09 12:41:08 +08:00
|
|
|
"bsm/full/module/base/mgt/internal/models"
|
2026-08-10 11:35:48 +08:00
|
|
|
|
2026-08-09 10:43:45 +08:00
|
|
|
"git.apinb.com/bsm-sdk/core/conf"
|
|
|
|
|
"git.apinb.com/bsm-sdk/core/printer"
|
|
|
|
|
coreTypes "git.apinb.com/bsm-sdk/core/types"
|
|
|
|
|
"git.apinb.com/bsm-sdk/core/vars"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
func WithDatabases(cfg *conf.DBConf, opts *coreTypes.SqlOptions) {
|
|
|
|
|
if cfg == nil || len(cfg.Source) == 0 {
|
|
|
|
|
panic("No Database Source Found !")
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// print inform.
|
|
|
|
|
printer.Info("[BSM - %s] Databases: %v", vars.ServiceKey, cfg)
|
|
|
|
|
|
|
|
|
|
err := models.New(cfg.Driver, cfg.Source, opts)
|
|
|
|
|
if err != nil {
|
|
|
|
|
printer.Error("Database Init Failed !")
|
|
|
|
|
panic(err)
|
|
|
|
|
}
|
2026-08-10 11:35:48 +08:00
|
|
|
DBService = models.DBService
|
2026-08-09 10:43:45 +08:00
|
|
|
return
|
|
|
|
|
}
|