144 lines
3.7 KiB
Go
144 lines
3.7 KiB
Go
// Package main defines a command line interface for the sqlboiler package
|
|
package main
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/kat-co/vala"
|
|
"github.com/spf13/cobra"
|
|
"github.com/spf13/viper"
|
|
)
|
|
|
|
var (
|
|
cmdState *State
|
|
cmdConfig *Config
|
|
)
|
|
|
|
func main() {
|
|
var err error
|
|
|
|
viper.SetConfigName("sqlboiler")
|
|
|
|
configHome := os.Getenv("XDG_CONFIG_HOME")
|
|
homePath := os.Getenv("HOME")
|
|
wd, err := os.Getwd()
|
|
if err != nil {
|
|
wd = "./"
|
|
}
|
|
|
|
configPaths := []string{wd}
|
|
if len(configHome) > 0 {
|
|
configPaths = append(configPaths, filepath.Join(configHome, "sqlboiler"))
|
|
} else {
|
|
configPaths = append(configPaths, filepath.Join(homePath, ".config/sqlboiler"))
|
|
}
|
|
|
|
for _, p := range configPaths {
|
|
viper.AddConfigPath(p)
|
|
}
|
|
|
|
if err := viper.ReadInConfig(); err != nil {
|
|
fmt.Printf("Cannot read or locate config file: %s\n", err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
// Set up the cobra root command
|
|
var rootCmd = &cobra.Command{
|
|
Use: "sqlboiler [flags] <driver>",
|
|
Short: "SQL Boiler generates an ORM tailored to your database schema.",
|
|
Long: "SQL Boiler generates a Go ORM from template files, tailored to your database schema.\n" +
|
|
`Complete documentation is available at http://github.com/vattle/sqlboiler`,
|
|
Example: `sqlboiler postgres`,
|
|
PreRunE: preRun,
|
|
RunE: run,
|
|
PostRunE: postRun,
|
|
SilenceErrors: true,
|
|
SilenceUsage: true,
|
|
}
|
|
|
|
// Set up the cobra root command flags
|
|
rootCmd.PersistentFlags().StringP("output", "o", "models", "The name of the folder to output to")
|
|
rootCmd.PersistentFlags().StringP("pkgname", "p", "models", "The name you wish to assign to your generated package")
|
|
|
|
viper.SetDefault("postgres.sslmode", "require")
|
|
viper.SetDefault("postgres.port", "5432")
|
|
viper.BindPFlags(rootCmd.PersistentFlags())
|
|
viper.AutomaticEnv()
|
|
|
|
if err := rootCmd.Execute(); err != nil {
|
|
if e, ok := err.(commandFailure); ok {
|
|
fmt.Printf("%s\n", string(e))
|
|
return
|
|
}
|
|
|
|
fmt.Printf("%+v\n", err)
|
|
os.Exit(1)
|
|
}
|
|
}
|
|
|
|
type commandFailure string
|
|
|
|
func (c commandFailure) Error() string {
|
|
return string(c)
|
|
}
|
|
|
|
func preRun(cmd *cobra.Command, args []string) error {
|
|
var err error
|
|
|
|
if len(args) == 0 {
|
|
return commandFailure("Must provide a driver name.")
|
|
}
|
|
|
|
driverName := args[0]
|
|
|
|
cmdConfig = &Config{
|
|
DriverName: driverName,
|
|
OutFolder: viper.GetString("output"),
|
|
PkgName: viper.GetString("pkgname"),
|
|
}
|
|
|
|
if viper.IsSet("postgres.dbname") {
|
|
cmdConfig.Postgres = PostgresConfig{
|
|
User: viper.GetString("postgres.user"),
|
|
Pass: viper.GetString("postgres.pass"),
|
|
Host: viper.GetString("postgres.host"),
|
|
Port: viper.GetInt("postgres.port"),
|
|
DBName: viper.GetString("postgres.dbname"),
|
|
SSLMode: viper.GetString("postgres.sslmode"),
|
|
}
|
|
|
|
// Set the default SSLMode value
|
|
if cmdConfig.Postgres.SSLMode == "" {
|
|
viper.Set("postgres.sslmode", "require")
|
|
cmdConfig.Postgres.SSLMode = viper.GetString("postgres.sslmode")
|
|
}
|
|
|
|
err = vala.BeginValidation().Validate(
|
|
vala.StringNotEmpty(cmdConfig.Postgres.User, "postgres.user"),
|
|
vala.StringNotEmpty(cmdConfig.Postgres.Host, "postgres.host"),
|
|
vala.Not(vala.Equals(cmdConfig.Postgres.Port, 0, "postgres.port")),
|
|
vala.StringNotEmpty(cmdConfig.Postgres.DBName, "postgres.dbname"),
|
|
vala.StringNotEmpty(cmdConfig.Postgres.SSLMode, "postgres.sslmode"),
|
|
).Check()
|
|
|
|
if err != nil {
|
|
return commandFailure(err.Error())
|
|
}
|
|
} else if driverName == "postgres" {
|
|
return errors.New("Postgres driver requires a postgres section in your config file.")
|
|
}
|
|
|
|
cmdState, err = New(cmdConfig)
|
|
return err
|
|
}
|
|
|
|
func run(cmd *cobra.Command, args []string) error {
|
|
return cmdState.Run(true)
|
|
}
|
|
|
|
func postRun(cmd *cobra.Command, args []string) error {
|
|
return cmdState.Cleanup()
|
|
}
|