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

import (
	context "context"
	dbutil495 "gitee.com/knowgo/gpa/rt/dbutil"
	errs81 "gitee.com/knowgo/gotool/errs"
	models "gitee.com/knowgo/gpa/examples/pratics/models"
	rt "gitee.com/knowgo/gpa/rt"
	sql106 "database/sql"
)

type Find struct {
	p *rt.Provider
}

func (find *Find) FindA(ctx context.Context, id uint64) (*models.User, error){
    var err error
	var1 := `SELECT id as id, name name, sum(age) as Age FROM "user" WHERE id=$1 group by name `
	
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, id)
    
    var3 := find.p.Executor().QueryContextRow(ctx, var1, var1Params...)
	
    var2 := &models.User{}
    if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age); err != nil {
        if err == sql106.ErrNoRows {
            return nil, rt.ErrRowNotFound    
        }
        find.p.Logger.Error(errs81.WrapStack(err, "select error"))
        return nil, err
    }
    
	return var2, nil
}

func (find *Find) FindById(id uint64) (models.User, error){
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user" WHERE "id"=$1  `
	
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, id)
    
    var3 := find.p.Executor().QueryRow(var1, var1Params...)
    var2 := models.User{}
    var var4 dbutil495.NullTime
    if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
        if err == sql106.ErrNoRows {
            return models.User{}, rt.ErrRowNotFound    
        }
        find.p.Logger.Error(errs81.WrapStack(err, "select error"))
        return models.User{}, err
    }
    
    var2.Cret = var4.Time()
	return var2, nil
}

func (find *Find) FindUsers(nm string, from int, size int, limit rt.Limit) ([]*models.User, error){
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user" WHERE name like $1 order by id `
	if limit != nil {
		var1 += limit.LimitSQL()
	}
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, nm)
    
    var var3 *sql106.Rows
	var3, err = find.p.Executor().QueryRows(var1, var1Params...)
	if err != nil {
		find.p.Logger.Error(errs81.WrapStack(err, "select error"))
		return nil,  err
	}
	
	var3Results := []*models.User{}
	for var3.Next() {
		
        var2 := new(models.User)
        var var4 dbutil495.NullTime
        if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
            find.p.Logger.Error(errs81.WrapStack(err, "select error"))
            return nil,  err
        }
        
        var2.Cret = var4.Time()
		var3Results = append(var3Results, var2)
	}
	return var3Results, nil
}

func (find *Find) FindUsers2(nm string) ([]*models.User, error){
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user"  order by name`
	
	var var1Params []interface{}
	// where 参数 
    
    var var3 *sql106.Rows
	var3, err = find.p.Executor().QueryRows(var1, var1Params...)
	if err != nil {
		find.p.Logger.Error(errs81.WrapStack(err, "select error"))
		return nil,  err
	}
	
	var3Results := []*models.User{}
	for var3.Next() {
		
        var2 := new(models.User)
        var var4 dbutil495.NullTime
        if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
            find.p.Logger.Error(errs81.WrapStack(err, "select error"))
            return nil,  err
        }
        
        var2.Cret = var4.Time()
		var3Results = append(var3Results, var2)
	}
	return var3Results, nil
}

func (find *Find) FindUsers1(ids []uint64) ([]*models.User, error){
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user" WHERE id in (@in-1649752149) `
	
	var var1Params []interface{}
	// where 参数 
	if len(ids) <= 0 {
		err = dbutil495.NewErrParamIsEmpty("ids")
		find.p.Logger.Error(errs81.WrapStack(err, ""))
		return nil, err
	}
	var1 = dbutil495.TakeDollarPlaceHolder(var1, "@in-1649752149", len(ids), len(var1Params))
	for _, varP := range ids {
		var1Params = append(var1Params, varP)
	}
    
    var var3 *sql106.Rows
	var3, err = find.p.Executor().QueryRows(var1, var1Params...)
	if err != nil {
		find.p.Logger.Error(errs81.WrapStack(err, "select error"))
		return nil,  err
	}
	
	var3Results := []*models.User{}
	for var3.Next() {
		
        var2 := new(models.User)
        var var4 dbutil495.NullTime
        if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
            find.p.Logger.Error(errs81.WrapStack(err, "select error"))
            return nil,  err
        }
        
        var2.Cret = var4.Time()
		var3Results = append(var3Results, var2)
	}
	return var3Results, nil
}

func (find *Find) FindMapByName(name string, kg func(*models.User) (uint64, error)) (map[uint64]*models.User, error){
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user" WHERE "name"=$1  `
	
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, name)
    
    var var3 *sql106.Rows
	var3, err = find.p.Executor().QueryRows(var1, var1Params...)
	if err != nil {
		find.p.Logger.Error(errs81.WrapStack(err, "select error"))
		return nil,  err
	}
	
	var3Results := map[uint64]*models.User{}
	for var3.Next() {
		var var2Key uint64
        var2 := new(models.User)
        var var4 dbutil495.NullTime
        if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
            find.p.Logger.Error(errs81.WrapStack(err, "select error"))
            return nil,  err
        }
        
        var2.Cret = var4.Time()
		if var2Key, err = kg(var2); err != nil {
			find.p.Logger.Error(errs81.WrapStack(err, "select callback error"))
			return nil, err
		}
		var3Results[var2Key] = var2
	}
	return var3Results, nil
}

func (find *Find) FindCbById(id uint64, fn func(*models.User) (error)) error{
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user" WHERE "id"=$1  `
	
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, id)
    
    var var3 *sql106.Rows
	var3, err = find.p.Executor().QueryRows(var1, var1Params...)
	if err != nil {
		find.p.Logger.Error(errs81.WrapStack(err, "select error"))
		return  err
	}
	
	var2 := &models.User{}
	for var3.Next() {
        var var4 dbutil495.NullTime
        if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
            find.p.Logger.Error(errs81.WrapStack(err, "select error"))
            return  err
        }
        
        var2.Cret = var4.Time()
		if err = fn(var2); err != nil {
			find.p.Logger.Error(errs81.WrapStack(err, "select callback error"))
			return err
		}
	}
	return nil
}

func (find *Find) FindMapById(id uint64, fn func(*models.User) (uint64, error)) (map[uint64]*models.User, error){
    var err error
	var1 := `SELECT "id","name",age,gender,oka_us_url,cret,url FROM "user" WHERE "id"=$1  `
	
	var var1Params []interface{}
	// where 参数 
	var1Params = append(var1Params, id)
    
    var var3 *sql106.Rows
	var3, err = find.p.Executor().QueryRows(var1, var1Params...)
	if err != nil {
		find.p.Logger.Error(errs81.WrapStack(err, "select error"))
		return nil,  err
	}
	
	var3Results := map[uint64]*models.User{}
	for var3.Next() {
		var var2Key uint64
        var2 := new(models.User)
        var var4 dbutil495.NullTime
        if err = var3.Scan(&var2.ID, &var2.Name, &var2.Age, &var2.Gender, &var2.OkaUsURL, &var4, &var2.URL); err != nil {
            find.p.Logger.Error(errs81.WrapStack(err, "select error"))
            return nil,  err
        }
        
        var2.Cret = var4.Time()
		if var2Key, err = fn(var2); err != nil {
			find.p.Logger.Error(errs81.WrapStack(err, "select callback error"))
			return nil, err
		}
		var3Results[var2Key] = var2
	}
	return var3Results, nil
}