//+gpa-ignore
// DO NOT EDIT THIS FILE
// Generated by mro at 2022-04-12 16:29:10
package postgres

import (
	dbutil287 "gitee.com/knowgo/gpa/rt/dbutil"
	errs274 "gitee.com/knowgo/gotool/errs"
	models "gitee.com/knowgo/gpa/examples/pratics/models"
	repos89 "gitee.com/knowgo/gpa/examples/pratics/repos"
	rt728 "gitee.com/knowgo/gpa/rt"
	sql888 "database/sql"
)

type Update struct {
	p *rt728.Provider
}

func (update *Update) UpdateXuByIdAndAge(user *models.User) error {
	var err error
	
	var var2tp *dbutil287.TimeProp
	var2tp = dbutil287.NewTimeProp("DATETIME", true, update.p.GetTimezone())
	var2 := dbutil287.FormatColumnTime(update.p.GetTimeStampzFormat(),
		update.p.GetTimezone(),
		var2tp,
		user.Cret)
	var1 := `UPDATE "user" SET "name"=$1,gender=$2,oka_us_url=$3,cret=$4,url=$5 WHERE "id"=$6 And age=$7 `
	var1Params := []interface{}{user.Name, user.Gender, user.OkaUsURL, var2, user.URL}
	// where 参数 
	var1Params = append(var1Params, user.ID)
	var1Params = append(var1Params, user.Age)
	
	_, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return err
	}
	
	return nil
}

func (update *Update) FindByID(ID int64) (*repos89.Abc, error){
    var err error
	var1 := `SELECT "id","new" FROM abc WHERE "id"=$1  `
	
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, ID)
    
    var3 := update.p.Executor().QueryRow(var1, var1Params...)
    var2 := &repos89.Abc{}
    if err = var3.Scan(&var2.ID, &var2.New); err != nil {
        if err == sql888.ErrNoRows {
            return nil, rt728.ErrRowNotFound    
        }
        update.p.Logger.Error(errs274.WrapStack(err, "select error"))
        return nil, err
    }
    
	return var2, nil
}

func (update *Update) UpdateByName(user *models.User, gender bool) (int64, error) {
	user.Gender = gender
	var err error
	
	var var4tp *dbutil287.TimeProp
	var4tp = dbutil287.NewTimeProp("DATETIME", true, update.p.GetTimezone())
	var4 := dbutil287.FormatColumnTime(update.p.GetTimeStampzFormat(),
		update.p.GetTimezone(),
		var4tp,
		user.Cret)
	var1 := `UPDATE "user" SET "name"=$1,age=$2,gender=$3,oka_us_url=$4,cret=$5,url=$6 WHERE "name"=$7 `
	var1Params := []interface{}{user.Name, user.Age, user.Gender, user.OkaUsURL, var4, user.URL}
	// where 参数 
	var1Params = append(var1Params, user.Name)
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, err
	}
	return var3, nil
}

func (update *Update) UpdateByAgeAndCret(user *models.User) (int64, *models.User, error) {
	var err error
	
	
	var4tp := dbutil287.NewTimeProp("DATETIME", true, update.p.GetTimezone())
	var4 := dbutil287.FormatColumnTime(update.p.GetTimeStampzFormat(),
		update.p.GetTimezone(),
		var4tp,
		user.Cret)
	var1 := `UPDATE "user" SET "name"=$1,gender=$2,oka_us_url=$3,url=$4 WHERE age=$5 And cret=$6 `
	var1Params := []interface{}{user.Name, user.Gender, user.OkaUsURL, user.URL}
	// where 参数 
	var1Params = append(var1Params, user.Age)
	var1Params = append(var1Params, var4)
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, nil, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, nil, err
	}
	return var3, user, nil
}

func (update *Update) UpdateXByAge(age int, URL string) (int64, models.User, error) {
	var4 := &models.User{}
	var4.URL = URL
	var err error
	var1 := `UPDATE "user" SET url=$1 WHERE age=$2 `
	var1Params := []interface{}{URL}
	// where 参数 
	var1Params = append(var1Params, age)
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, models.User{}, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, models.User{}, err
	}
	return var3, *var4, nil
}

func (update *Update) UpdateName(user *models.User, name string) (int64, error) {
	user.Name = name
	var err error
	
	var var4tp *dbutil287.TimeProp
	var4tp = dbutil287.NewTimeProp("DATETIME", true, update.p.GetTimezone())
	var4 := dbutil287.FormatColumnTime(update.p.GetTimeStampzFormat(),
		update.p.GetTimezone(),
		var4tp,
		user.Cret)
	var1 := `UPDATE "user" SET "name"=$1,url=$2,cret=$3 WHERE id=$4 and age>$5`
	var1Params := []interface{}{name, user.URL, var4}
	// where 参数 
	var1Params = append(var1Params, user.ID)
	var1Params = append(var1Params, user.Age)
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, err
	}
	return var3, nil
}

func (update *Update) UpdateXName(user *models.User, name string) (int64, error) {
	user.Name = name
	var err error
	
	var var4tp *dbutil287.TimeProp
	var4tp = dbutil287.NewTimeProp("DATETIME", true, update.p.GetTimezone())
	var4 := dbutil287.FormatColumnTime(update.p.GetTimeStampzFormat(),
		update.p.GetTimezone(),
		var4tp,
		user.Cret)
	var1 := `UPDATE "user" SET "name"=$1,age=$2,gender=$3,oka_us_url=$4,cret=$5,url=$6 WHERE id=$7 and age>$8`
	var1Params := []interface{}{user.Name, user.Age, user.Gender, user.OkaUsURL, var4, user.URL}
	// where 参数 
	var1Params = append(var1Params, user.ID)
	var1Params = append(var1Params, user.Age)
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, err
	}
	return var3, nil
}

func (update *Update) UpdateYName(name string) (int64, models.User, error) {
	var4 := &models.User{}
	var4.Name = name
	var err error
	var1 := `UPDATE "user" SET "name"=$1`
	var1Params := []interface{}{name}
	// where 参数 
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, models.User{}, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, models.User{}, err
	}
	return var3, *var4, nil
}

func (update *Update) Update1Name(name string, id uint64) (int64, models.User, error) {
	var4 := &models.User{}
	var4.Name = name
	var err error
	var1 := `UPDATE "user" SET "name"=$1 WHERE id=$2`
	var1Params := []interface{}{name}
	// where 参数 
	var1Params = append(var1Params, id)
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, models.User{}, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, models.User{}, err
	}
	return var3, *var4, nil
}

func (update *Update) Update2Name(user models.User, ids []uint64) (int64, error) {
	var err error
	
	var var4tp *dbutil287.TimeProp
	var4tp = dbutil287.NewTimeProp("DATETIME", true, update.p.GetTimezone())
	var4 := dbutil287.FormatColumnTime(update.p.GetTimeStampzFormat(),
		update.p.GetTimezone(),
		var4tp,
		user.Cret)
	var1 := `UPDATE "user" SET "name"=$1,age=$2,gender=$3,oka_us_url=$4,cret=$5,url=$6 WHERE id in (@in-1649752151) or name=$7`
	var1Params := []interface{}{user.Name, user.Age, user.Gender, user.OkaUsURL, var4, user.URL}
	// where 参数 
	var1Params = append(var1Params, user.Name)
	if len(ids) <= 0 {
		err = dbutil287.NewErrParamIsEmpty("ids")
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, err
	}
	var1 = dbutil287.TakeDollarPlaceHolder(var1, "@in-1649752151", len(ids), len(var1Params))
	for _, varP := range ids {
		var1Params = append(var1Params, varP)
	}
	var var2 sql888.Result
	var2, err = update.p.Executor().Exec(var1, var1Params...)
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, ""))
		return 0, err
	}
	var3, err := var2.RowsAffected()
	if err != nil {
		update.p.Logger.Error(errs274.WrapStack(err, "update error"))
		return var3, err
	}
	return var3, nil
}