139 lines
3.7 KiB
Go
139 lines
3.7 KiB
Go
package cmd
|
|
|
|
import (
|
|
"fmt"
|
|
"regexp"
|
|
"strings"
|
|
|
|
pgDatabase "git.ipao.vip/rogeecn/atomctl/pkg/postgres"
|
|
"git.ipao.vip/rogeecn/atomctl/pkg/utils/gomod"
|
|
"github.com/go-jet/jet/v2/generator/metadata"
|
|
"github.com/go-jet/jet/v2/generator/postgres"
|
|
"github.com/go-jet/jet/v2/generator/template"
|
|
pg "github.com/go-jet/jet/v2/postgres"
|
|
_ "github.com/lib/pq"
|
|
"github.com/pkg/errors"
|
|
"github.com/samber/lo"
|
|
log "github.com/sirupsen/logrus"
|
|
"github.com/spf13/cobra"
|
|
"github.com/spf13/viper"
|
|
)
|
|
|
|
func CommandGenModel(root *cobra.Command) {
|
|
cmd := &cobra.Command{
|
|
Use: "model",
|
|
Aliases: []string{"m"},
|
|
Short: "Generate jet models",
|
|
RunE: commandGenModelE,
|
|
}
|
|
|
|
root.AddCommand(cmd)
|
|
}
|
|
|
|
func commandGenModelE(cmd *cobra.Command, args []string) error {
|
|
if err := gomod.Parse("go.mod"); err != nil {
|
|
return errors.Wrap(err, "parse go.mod")
|
|
}
|
|
|
|
_, dbConf, err := pgDatabase.GetDB(cmd.Flag("config").Value.String())
|
|
if err != nil {
|
|
return errors.Wrap(err, "get db")
|
|
}
|
|
|
|
type Transformer struct {
|
|
Ignores []string `mapstructure:"ignores"`
|
|
Types map[string]map[string]string `mapstructure:"types"`
|
|
}
|
|
|
|
v := viper.New()
|
|
v.SetConfigType("yaml")
|
|
v.SetConfigFile("database/transform.yaml")
|
|
|
|
if err := v.ReadInConfig(); err != nil {
|
|
return err
|
|
}
|
|
|
|
var conf Transformer
|
|
if err := v.Unmarshal(&conf); err != nil {
|
|
return err
|
|
}
|
|
|
|
jsonReg := regexp.MustCompile(`Json\[\[?\]?(\w+)\]`)
|
|
builtinTypes := []string{
|
|
"string",
|
|
"int", "int8", "int16", "int32", "int64", "uint", "uint8", "uint16", "uint32", "uint64",
|
|
"float32", "float64",
|
|
"bool",
|
|
}
|
|
|
|
return postgres.GenerateDSN(
|
|
dbConf.DSN(),
|
|
dbConf.Schema,
|
|
"database/models",
|
|
template.Default(pg.Dialect).
|
|
UseSchema(func(schema metadata.Schema) template.Schema {
|
|
return template.
|
|
DefaultSchema(schema).
|
|
UseSQLBuilder(
|
|
template.DefaultSQLBuilder().UseTable(func(table metadata.Table) template.TableSQLBuilder {
|
|
tbl := template.DefaultTableSQLBuilder(table)
|
|
|
|
if lo.Contains(conf.Ignores, table.Name) {
|
|
tbl.Skip = true
|
|
log.Infof("Skip table %s", table.Name)
|
|
}
|
|
return tbl
|
|
}),
|
|
).
|
|
UseModel(
|
|
template.
|
|
DefaultModel().
|
|
UseTable(func(table metadata.Table) template.TableModel {
|
|
tbl := template.DefaultTableModel(table)
|
|
if lo.Contains(conf.Ignores, table.Name) {
|
|
tbl.Skip = true
|
|
log.Infof("Skip table %s", table.Name)
|
|
return tbl
|
|
}
|
|
|
|
return tbl.UseField(func(column metadata.Column) template.TableModelField {
|
|
defaultTableModelField := template.DefaultTableModelField(column)
|
|
defaultTableModelField = defaultTableModelField.UseTags(fmt.Sprintf(`json:"%s"`, column.Name))
|
|
|
|
if schema.Name != dbConf.Schema {
|
|
return defaultTableModelField
|
|
}
|
|
|
|
fields, ok := conf.Types[table.Name]
|
|
if !ok {
|
|
return defaultTableModelField
|
|
}
|
|
|
|
toType, ok := fields[column.Name]
|
|
if !ok {
|
|
return defaultTableModelField
|
|
}
|
|
|
|
// toType = jsonReg.ReplaceAllString(toType, "fields.$1")
|
|
if jsonReg.MatchString(toType) {
|
|
matches := jsonReg.FindStringSubmatch(toType)
|
|
if len(matches) == 2 && !lo.Contains(builtinTypes, matches[1]) {
|
|
toType = strings.Replace(toType, matches[1], "fields."+matches[1], 1)
|
|
}
|
|
}
|
|
|
|
defaultTableModelField = defaultTableModelField.
|
|
UseType(template.Type{
|
|
Name: fmt.Sprintf("fields.%s", toType),
|
|
ImportPath: fmt.Sprintf("%s/database/fields", gomod.GetModuleName()),
|
|
})
|
|
|
|
log.Infof("Convert table %s field %s type to : %s", table.Name, column.Name, toType)
|
|
return defaultTableModelField
|
|
})
|
|
}),
|
|
)
|
|
}),
|
|
)
|
|
}
|