dao

package

v1.3.0 Latest Latest Go to latest Published: Oct 14, 2024 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/twbworld/dating

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Tx(fc func(tx *sqlx.Tx) error) (err error)
type DatingDb
type DbGroup
type FeedbackDb
- func (u *FeedbackDb) AddFeedback(f *db.Feedback, tx *sqlx.Tx) (uint, error)
type FileDb
type UserDb

Constants ¶

View Source

const (
	BaseUserId uint = 1 //"手动添加会面"用到的的虚拟用户
)

Variables ¶

View Source

var (
	DB      *sqlx.DB
	CanLock bool     //是否支持锁(FOR UPDATE)
	App     *DbGroup = new(DbGroup)
)

Functions ¶

func Tx ¶

func Tx(fc func(tx *sqlx.Tx) error) (err error)

Types ¶

type DatingDb ¶

type DatingDb struct{}

func (*DatingDb) AddDating ¶

func (d *DatingDb) AddDating(userId uint, tx *sqlx.Tx) (uint, error)

func (*DatingDb) CheckUserTime ¶

func (d *DatingDb) CheckUserTime(datingUser *common.DatingUserJoin, utId uint, tx ...*sqlx.Tx) error

func (*DatingDb) CloseDating ¶

func (d *DatingDb) CloseDating(datingIds []uint, tx *sqlx.Tx) error

func (*DatingDb) DatingUpdate ¶

func (d *DatingDb) DatingUpdate(datingId uint, res *db.DatingResult, tx *sqlx.Tx) (err error)

func (*DatingDb) GetCleanDating ¶

func (d *DatingDb) GetCleanDating(ids *[]uint, unix int64, tx ...*sqlx.Tx) error

func (*DatingDb) GetDating ¶

func (d *DatingDb) GetDating(dating *db.Dating, datingId uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetDatingAmount ¶

func (d *DatingDb) GetDatingAmount(amount *[]uint, userId uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetDatingList ¶

func (d *DatingDb) GetDatingList(datingList *[]common.DatingList, userId, lastId, limit uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetDatingUsers ¶

func (d *DatingDb) GetDatingUsers(datingUsers *[]common.DatingUser, datingId uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetUserByDatingIds ¶

func (d *DatingDb) GetUserByDatingIds(datingUserAvatar *[]common.DatingUserAvatar, datingIds []uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetUserTime ¶

func (d *DatingDb) GetUserTime(userTime *db.UserTime, datingId, UserId uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetUserTimeByDatingId ¶

func (d *DatingDb) GetUserTimeByDatingId(userTime *[]db.UserTime, datingId uint, tx ...*sqlx.Tx) error

func (*DatingDb) GetUserTimeById ¶

func (d *DatingDb) GetUserTimeById(userTime *db.UserTime, UtId uint, tx ...*sqlx.Tx) error

func (*DatingDb) JoinDating ¶

func (d *DatingDb) JoinDating(UserTime *db.UserTime, tx *sqlx.Tx) (uint, error)

func (*DatingDb) JoinUpdate ¶

func (d *DatingDb) JoinUpdate(utId uint, UserTime *db.UserTime, tx *sqlx.Tx) (err error)

func (*DatingDb) QuitDating ¶

func (d *DatingDb) QuitDating(utId uint, tx *sqlx.Tx) (err error)

type DbGroup ¶

type DbGroup struct {
	DatingDb
	UserDb
	FileDb
	FeedbackDb
}

type FeedbackDb ¶

type FeedbackDb struct{}

func (*FeedbackDb) AddFeedback ¶

func (u *FeedbackDb) AddFeedback(f *db.Feedback, tx *sqlx.Tx) (uint, error)

type FileDb ¶

type FileDb struct{}

func (*FileDb) AddFile ¶

func (u *FileDb) AddFile(f *db.File, tx *sqlx.Tx) (uint, error)

新增文件记录要先检查文件是否存在于目录, 以及不存在于数据库

func (*FileDb) GetFile ¶

func (u *FileDb) GetFile(file *db.File, fileId uint, tx ...*sqlx.Tx) error

func (*FileDb) GetFileId ¶

func (u *FileDb) GetFileId(path string, tx ...*sqlx.Tx) (uint, error)

type UserDb ¶

type UserDb struct{}

func (*UserDb) AddUser ¶

func (u *UserDb) AddUser(user *db.User, tx *sqlx.Tx) (uint, error)

func (*UserDb) GetUserById ¶

func (u *UserDb) GetUserById(user *db.User, id uint, tx ...*sqlx.Tx) error

func (*UserDb) GetUserByOpenId ¶

func (u *UserDb) GetUserByOpenId(user *db.User, openId string, tx ...*sqlx.Tx) error

func (*UserDb) UpdateSessionKey ¶

func (u *UserDb) UpdateSessionKey(userId uint, sessionKey string, tx *sqlx.Tx) (err error)

func (*UserDb) UpdateUser ¶

func (u *UserDb) UpdateUser(user *db.User, tx *sqlx.Tx) (err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL