besqlx

type Client interface {
	DB() *sqlx.DB
	ConnectPostgres() error
	ConnectMySQL() error
	Connect() error

	NewUpdateHelper() *UpdateHelper

	NamedExec(paramQuery, valueQuery string, arg interface{}) (sql.Result, grerrors.Error)
	DeleteExec(arg interface{}, whereQuery string, values ...interface{}) grerrors.Error
	Get(dest interface{}, query string, args ...interface{}) grerrors.Error
	Select(model interface{}, dest interface{}, qb SelectQueryBuilder) grerrors.Error
	Count(model interface{}, whereQuery string, args []interface{}) (int64, grerrors.Error)
	SelectWithCount(model interface{}, dest interface{}, qb SelectQueryBuilder, values ...int64) (int64, grerrors.Error)
}

type Config struct {
	DatabaseDriver         string `json:"database_driver" mapstructure:"database_driver"`
	DatabaseUrl            string `json:"database_url" mapstructure:"database_url"`
	DatabasePort           string `json:"database_port" mapstructure:"database_port"`
	DatabaseName           string `json:"database_name" mapstructure:"database_name"`
	DatabaseUsername       string `json:"database_username" mapstructure:"database_username"`
	DatabasePassword       string `json:"database_password" mapstructure:"database_password"`
	DatabaseLogEnabled     bool   `json:"database_log_enabled" mapstructure:"database_log_enabled"`
	DatabaseDisableSSLMode bool   `json:"database_disable_ssl_mode" mapstructure:"database_disable_ssl_mode"`
}

type IDModel struct {
	Id        string       `db:"id"`
	CreatedAt sql.NullTime `db:"created_at"`
	UpdatedAt sql.NullTime `db:"updated_at"`
	DeletedAt sql.NullTime `db:"deleted_at"`
}

type SelectQueryBuilder struct {
	SelectQuery  string        `json:"select_query"`
	WhereQuery   string        `json:"where_query"`
	OrderByQuery *string       `json:"order_by_query"`
	Limit        *int64        `json:"limit"`
	Page         *int64        `json:"page"`
	Args         []interface{} `json:"args"`
}

type UpdateHelper struct {
	// contains filtered or unexported fields
}

type WhereOperator string

type WhereQueryBuilder interface {
	Where(fieldName string, value interface{}, op WhereOperator)
	BuildQuery() (string, []interface{})
}