msb-public
/
paopao-ce
mirror of https://github.com/rocboss/paopao-ce
1
0
Code Issues Projects Releases Wiki Activity

sqlx: implement some logic WIP %20

Browse Source
r/paopao-ce-plus
Michael Li 2 years ago
parent ece7bd2676
commit a68d3816ed
No known key found for this signature in database
8 changed files with 306 additions and 291 deletions
Show Stats Download Patch File Download Diff File

2
go.mod
Unescape View File

@ -7,7 +7,7 @@ require (
github.com/afocus/captcha v0.0.0-20191010092841-4bd1f21c8868
github.com/alimy/cfg v0.4.0
github.com/alimy/mir/v4 v4.0.0
github.com/alimy/yesql v1.3.0
github.com/alimy/yesql v1.4.0
github.com/aliyun/aliyun-oss-go-sdk v2.2.7+incompatible
github.com/allegro/bigcache/v3 v3.1.0
github.com/bufbuild/connect-go v1.9.0

4
go.sum
Unescape View File

@ -127,8 +127,8 @@ github.com/alimy/cfg v0.4.0 h1:SslKPndmxRViT1ePWLmNsEq7okYP0GVeuowQlRWZPkw=
github.com/alimy/cfg v0.4.0/go.mod h1:rOxbasTH2srl6StAjNF5Vyi8bfrdkl3fLGmOYtSw81c=
github.com/alimy/mir/v4 v4.0.0 h1:MzGfmoLjjvR69jbZEmpKJO3tUuqB0RGRv1UWPbtukBg=
github.com/alimy/mir/v4 v4.0.0/go.mod h1:d58dBvw2KImcVbAUANrciEV/of0arMNsI9c/5UNCMMc=
github.com/alimy/yesql v1.3.0 h1:4/p097ZvFMlIzm1CWYy1q+eBQH0DcqlB+/UxKTHsj30=
github.com/alimy/yesql v1.3.0/go.mod h1:Y0FdRIwIbJyTv56wSX+MpaIHiAW1PyKTDYO6K/er4JY=
github.com/alimy/yesql v1.4.0 h1:8q5PgUnLR1u9vi5Y9cLj1/cuie2I/4ShpCOp2jE1V6A=
github.com/alimy/yesql v1.4.0/go.mod h1:Y0FdRIwIbJyTv56wSX+MpaIHiAW1PyKTDYO6K/er4JY=
github.com/aliyun/aliyun-oss-go-sdk v2.2.7+incompatible h1:KpbJFXwhVeuxNtBJ74MCGbIoaBok2uZvkD7QXp2+Wis=
github.com/aliyun/aliyun-oss-go-sdk v2.2.7+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
github.com/allegro/bigcache/v3 v3.1.0 h1:H2Vp8VOvxcrB91o86fUSVJFqeuz8kpyyB02eH3bSzwk=

2
internal/dao/jinzhu/dbr/comment.go
Unescape View File

@ -79,7 +79,7 @@ func (c *Comment) List(db *gorm.DB, conditions *ConditionsT, offset, limit int)
db = db.Offset(offset).Limit(limit)
}
if c.PostID > 0 {
db = db.Where("id = ?", c.PostID)
db = db.Where("post_id = ?", c.PostID)
}
for k, v := range *conditions {

52
internal/dao/sakila/authority.go
Unescape View File

@ -7,9 +7,11 @@ package sakila
import (
"github.com/jmoiron/sqlx"
"github.com/rocboss/paopao-ce/internal/core"
"github.com/rocboss/paopao-ce/internal/core/cs"
"github.com/rocboss/paopao-ce/internal/core/ms"
"github.com/rocboss/paopao-ce/internal/dao/sakila/yesql/cc"
"github.com/rocboss/paopao-ce/pkg/debug"
"github.com/rocboss/paopao-ce/pkg/types"
"github.com/sirupsen/logrus"
)
var (
@ -22,32 +24,50 @@ type authorizationManageSrv struct {
}
func (s *authorizationManageSrv) IsAllow(user *ms.User, action *ms.Action) bool {
// TODO
debug.NotImplemented()
return false
// user is activation if had bind phone
isActivation := (len(user.Phone) != 0)
isFriend := s.isFriend(user.ID, action.UserId)
// TODO: just use defaut act authorization chek rule now
return action.Act.IsAllow(user, action.UserId, isFriend, isActivation)
}
func (s *authorizationManageSrv) MyFriendSet(userId int64) ms.FriendSet {
// TODO
debug.NotImplemented()
return nil
var ids []string
if err := s.q.MyFriendSet.Get(&ids, userId); err != nil {
logrus.Warnf("get my FriendSet error: %s", err)
return ms.FriendSet{}
}
resp := make(ms.FriendSet, len(ids))
for _, id := range ids {
resp[id] = types.Empty{}
}
return resp
}
func (s *authorizationManageSrv) BeFriendFilter(userId int64) ms.FriendFilter {
// TODO
debug.NotImplemented()
return nil
var ids []int64
if err := s.q.BeFriendIds.Get(&ids, userId); err != nil {
logrus.Warnf("get my BeFriendFilter error: %s", err)
return ms.FriendFilter{}
}
resp := make(ms.FriendFilter, len(ids))
for _, id := range ids {
resp[id] = types.Empty{}
}
return resp
}
func (s *authorizationManageSrv) BeFriendIds(userId int64) ([]int64, error) {
// TODO
debug.NotImplemented()
return nil, nil
func (s *authorizationManageSrv) BeFriendIds(userId int64) (res []int64, err error) {
err = s.q.BeFriendIds.Get(&res, userId)
return
}
func (s *authorizationManageSrv) isFriend(userId int64, friendId int64) bool {
// TODO
debug.NotImplemented()
var status int8
err := s.q.IsFriend.Get(&status, userId, friendId)
if err == nil || status == cs.ContactStatusAgree {
return true
}
return false
}

31
internal/dao/sakila/comments.go
Unescape View File

@ -5,6 +5,7 @@
package sakila
import (
"strings"
"time"
"github.com/jmoiron/sqlx"
@ -31,23 +32,22 @@ type commentManageSrv struct {
q *cc.CommentManage
}
func (s *commentSrv) GetComments(r *ms.ConditionsT, offset, limit int) ([]*ms.Comment, error) {
res := []*ms.Comment{}
(*r)["limit"], (*r)["offset"] = limit, offset
err := s.q.GetComments.Select(&res, r)
return res, err
func (s *commentSrv) GetComments(r *ms.ConditionsT, offset, limit int) (res []*ms.Comment, err error) {
order := (*r)["ORDER"].(string)
postId := (*r)["post_id"]
stmt := strings.Replace(s.q.GetComments, "%order%", order, 1)
err = s.db.Select(&res, stmt, postId, limit, offset)
return
}
func (s *commentSrv) GetCommentByID(id int64) (*ms.Comment, error) {
res := &ms.Comment{}
err := s.q.GetCommentById.Get(res, id)
return res, err
func (s *commentSrv) GetCommentByID(id int64) (res *ms.Comment, err error) {
err = s.q.GetCommentById.Get(res, id)
return
}
func (s *commentSrv) GetCommentReplyByID(id int64) (*ms.CommentReply, error) {
res := &ms.CommentReply{}
err := s.q.GetCommentById.Get(res, id)
return res, err
func (s *commentSrv) GetCommentReplyByID(id int64) (res *ms.CommentReply, err error) {
err = s.q.GetCommentReplyById.Get(res, id)
return
}
func (s *commentSrv) GetCommentCount(r *ms.ConditionsT) (res int64, err error) {
@ -55,9 +55,8 @@ func (s *commentSrv) GetCommentCount(r *ms.ConditionsT) (res int64, err error) {
return
}
func (s *commentSrv) GetCommentContentsByIDs(ids []int64) ([]*ms.CommentContent, error) {
res := []*ms.CommentContent{}
err := s.inSelect(&res, s.q.GetCommentContentsByIds, ids)
func (s *commentSrv) GetCommentContentsByIDs(ids []int64) (res []*ms.CommentContent, err error) {
err = s.inSelect(&res, s.q.GetCommentContentsByIds, ids)
return res, err
}

8
internal/dao/sakila/messages.go
Unescape View File

@ -10,7 +10,6 @@ import (
"github.com/rocboss/paopao-ce/internal/core/ms"
"github.com/rocboss/paopao-ce/internal/dao/jinzhu/dbr"
"github.com/rocboss/paopao-ce/internal/dao/sakila/yesql/cc"
"github.com/rocboss/paopao-ce/pkg/debug"
)
var (
@ -46,10 +45,9 @@ func (s *messageSrv) GetMessageByID(id int64) (*ms.Message, error) {
return res, err
}
func (s *messageSrv) ReadMessage(message *ms.Message) error {
// TODO
debug.NotImplemented()
return nil
func (s *messageSrv) ReadMessage(message *ms.Message) (err error) {
_, err = s.q.ReadMessage.Exec(message)
return
}
func (s *messageSrv) GetMessages(r *ms.ConditionsT, offset, limit int) ([]*ms.MessageFormated, error) {

466
internal/dao/sakila/yesql/cc/yesql.go
Unescape View File

@ -1,6 +1,6 @@
// Code generated by Yesql. DO NOT EDIT.
// versions:
// - Yesql v1.3.0
// - Yesql v1.4.0
package cc
@ -12,139 +12,139 @@ import (
)
const (
_BeFriendFilter_AuthorizationManage = `SELECT * FROM @user WHERE username=?`
_BeFriendIds_AuthorizationManage = `SELECT * FROM @user WHERE username=?`
_MyFriendSet_AuthorizationManage = `SELECT * FROM @user WHERE username=?`
_GetCommentById_Comment = `SELECT * FROM @user WHERE username=?`
_GetCommentContentsByIds_Comment = `SELECT * FROM @user WHERE username=?`
_GetCommentCount_Comment = `SELECT * FROM @user WHERE username=?`
_GetCommentReplyById_Comment = `SELECT * FROM @user WHERE username=?`
_GetCommentThumbs_Comment = `SELECT * FROM @user WHERE username=?`
_GetComments_Comment = `SELECT * FROM @user WHERE username=?`
_GetCommmentRepliesByIds_Comment = `SELECT * FROM @user WHERE username=?`
_GetUsersByIds_Comment = `SELECT * FROM @user WHERE username=?`
_CreateComment_CommentManage = `SELECT * FROM @user WHERE username=?`
_CreateCommentContent_CommentManage = `SELECT * FROM @user WHERE username=?`
_CreateCommentReply_CommentManage = `SELECT * FROM @user WHERE username=?`
_CreateThumbsUpComment_CommentManage = `SELECT * FROM @user WHERE username=?`
_DeleteComment_CommentManage = `SELECT * FROM @user WHERE username=?`
_DeleteCommentReply_CommentManage = `SELECT * FROM @user WHERE username=?`
_DeleteCommentThumbs_CommentManage = `SELECT * FROM @user WHERE username=?`
_DeleteReplyThumbs_CommentManage = `SELECT * FROM @user WHERE username=?`
_GetCommentReplyThumb_CommentManage = `SELECT * FROM @user WHERE username=?`
_GetTweetCommentThumb_CommentManage = `SELECT * FROM @user WHERE username=?`
_ThumbsDownComment_CommentManage = `SELECT * FROM @user WHERE username=?`
_ThumbsDownReply_CommentManage = `SELECT * FROM @user WHERE username=?`
_ThumbsUpReply_CommentManage = `SELECT * FROM @user WHERE username=?`
_UpdateCommentThumbsCount_CommentManage = `SELECT * FROM @user WHERE username=?`
_UpdateThumbsUpComment_CommentManage = `SELECT * FROM @user WHERE username=?`
_AddFriend_ContactManager = `SELECT * FROM @user WHERE username=?`
_DelFriend_ContactManager = `SELECT * FROM @user WHERE username=?`
_GetContacts_ContactManager = `SELECT * FROM @user WHERE username=?`
_GetUserFriend_ContactManager = `SELECT * FROM @user WHERE username=?`
_RejectFriend_ContactManager = `SELECT * FROM @user WHERE username=?`
_RequestingFriend_ContactManager = `SELECT * FROM @user WHERE username=?`
_TotalContactsById_ContactManager = `SELECT * FROM @user WHERE username=?`
_UserInfo_FollowIndexA = `SELECT * FROM @user WHERE username=?`
_UserInfo_FollowIndex = `SELECT * FROM @user WHERE username=?`
_UserInfo_FriendIndexA = `SELECT * FROM @user WHERE username=?`
_UserInfo_FriendIndex = `SELECT * FROM @user WHERE username=?`
_UserInfo_LightIndexA = `SELECT * FROM @user WHERE username=?`
_UserInfo_LightIndex = `SELECT * FROM @user WHERE username=?`
_CreateMessage_Message = `SELECT * FROM @user WHERE username=?`
_GetMessageById_Message = `SELECT * FROM @user WHERE username=?`
_GetMessageCount_Message = `SELECT * FROM @user WHERE username=?`
_GetMessages_Message = `SELECT * FROM @user WHERE username=?`
_GetUnreadCount_Message = `SELECT * FROM @user WHERE username=?`
_ReadMessage_Message = `SELECT * FROM @user WHERE username=?`
_CreatePhoneCaptcha_Security = `SELECT * FROM @user WHERE username=?`
_GetLatestPhoneCaptcha_Security = `SELECT * FROM @user WHERE username=?`
_SendPhoneCaptcha_Security = `SELECT * FROM @user WHERE username=?`
_UsePhoneCaptcha_Security = `SELECT * FROM @user WHERE username=?`
_UserInfo_SimpleIndexA = `SELECT * FROM @user WHERE username=?`
_UserInfo_SimpleIndex = `SELECT * FROM @user WHERE username=?`
_DecrTagsById_TopicA = `UPDATE @tag SET quote_num=quote_num-1, modified_on=? WHERE id IN (?)`
_HotTags_TopicA = `SELECT t.id id, t.user_id user_id, t.tag tag, t.quote_num quote_num, u.id, u.nickname, u.username, u.status, u.avatar, u.is_admin FROM @tag t JOIN @user u ON t.user_id = u.id WHERE t.is_del = 0 AND t.quote_num > 0 ORDER BY t.quote_num DESC LIMIT ? OFFSET ?`
_IncrTagsById_TopicA = `UPDATE @tag SET quote_num=quote_num+1, is_del=0, modified_on=? WHERE id IN (?)`
_InsertTag_TopicA = `INSERT INTO @tag (user_id, tag, created_on, modified_on, quote_num) VALUES (?, ?, ?, ?, 1)`
_NewestTags_TopicA = `SELECT t.id id, t.user_id user_id, t.tag tag, t.quote_num quote_num, u.id, u.nickname, u.username, u.status, u.avatar, u.is_admin FROM @tag t JOIN @user u ON t.user_id = u.id WHERE t.is_del = 0 AND t.quote_num > 0 ORDER BY t.id DESC LIMIT ? OFFSET ?`
_TagsByIdA_TopicA = `SELECT id FROM @tag WHERE id IN (?) AND is_del = 0 AND quote_num > 0`
_TagsByIdB_TopicA = `SELECT id, user_id, tag, quote_num FROM @tag WHERE id IN (?)`
_TagsByKeywordA_TopicA = `SELECT id, user_id, tag, quote_num FROM @tag WHERE is_del = 0 ORDER BY quote_num DESC LIMIT 6`
_TagsByKeywordB_TopicA = `SELECT id, user_id, tag, quote_num FROM @tag WHERE is_del = 0 AND tag LIKE ? ORDER BY quote_num DESC LIMIT 6`
_TagsForIncr_TopicA = `SELECT id, user_id, tag, quote_num FROM @tag WHERE tag IN (?)`
_AttachmentByTweetId_TweetA = `SELECT * FROM @user WHERE username=?`
_FavoriteByTweetId_TweetA = `SELECT * FROM @user WHERE username=?`
_ReactionByTweetId_TweetA = `SELECT * FROM @user WHERE username=?`
_TweetInfoById_TweetA = `SELECT * FROM @user WHERE username=?`
_TweetItemById_TweetA = `SELECT * FROM @user WHERE username=?`
_UserFavorites_TweetA = `SELECT * FROM @user WHERE username=?`
_UserInfo_TweetA = `SELECT * FROM @user WHERE username=?`
_UserReactions_TweetA = `SELECT * FROM @user WHERE username=?`
_UserTweetsByAdmin_TweetA = `SELECT * FROM @user WHERE username=?`
_UserTweetsByFriend_TweetA = `SELECT * FROM @user WHERE username=?`
_UserTweetsByGuest_TweetA = `SELECT * FROM @user WHERE username=?`
_UserTweetsBySelf_TweetA = `SELECT * FROM @user WHERE username=?`
_GetPostAttachmentBill_Tweet = `SELECT * FROM @user WHERE username=?`
_GetPostById_Tweet = `SELECT * FROM @user WHERE username=?`
_GetPostContentById_Tweet = `SELECT * FROM @user WHERE username=?`
_GetPostContetnsByIds_Tweet = `SELECT id, user_id, tag, quote_num FROM @tag WHERE tag IN (?)`
_GetPostCount_Tweet = `SELECT * FROM @user WHERE username=?`
_GetPosts_Tweet = `SELECT * FROM @user WHERE username=?`
_GetUserPostCollection_Tweet = `SELECT * FROM @user WHERE username=?`
_GetUserPostCollectionCount_Tweet = `SELECT * FROM @user WHERE username=?`
_GetUserPostCollections_Tweet = `SELECT * FROM @user WHERE username=?`
_GetUserPostStar_Tweet = `SELECT * FROM @user WHERE username=?`
_GetUserPostStarCount_Tweet = `SELECT * FROM @user WHERE username=?`
_GetUserPostStars_Tweet = `SELECT * FROM @user WHERE username=?`
_UserInfo_TweetHelpA = `SELECT * FROM @user WHERE username=?`
_GetPostContentByIds_TweetHelp = `SELECT * FROM @user WHERE username=?`
_GetUsersByIds_TweetHelp = `SELECT * FROM @user WHERE username=?`
_UserInfo_TweetManageA = `SELECT * FROM @user WHERE username=?`
_AddAttachment_TweetManage = `SELECT * FROM @user WHERE username=?`
_AddPost_TweetManage = `SELECT * FROM @user WHERE username=?`
_AddPostCollection_TweetManage = `SELECT * FROM @user WHERE username=?`
_AddPostContent_TweetManage = `SELECT * FROM @user WHERE username=?`
_AddPostStar_TweetManage = `SELECT * FROM @user WHERE username=?`
_DelPost_TweetManage = `SELECT * FROM @user WHERE username=?`
_DelPostCollection_TweetManage = `SELECT * FROM @user WHERE username=?`
_DelPostStar_TweetManage = `SELECT * FROM @user WHERE username=?`
_LockPost_TweetManage = `SELECT * FROM @user WHERE username=?`
_StickPost_TweetManage = `SELECT * FROM @user WHERE username=?`
_UpdatePost_TweetManage = `SELECT * FROM @user WHERE username=?`
_VisiblePost_TweetManage = `SELECT * FROM @user WHERE username=?`
_AddUser_UserManage = `SELECT * FROM @user WHERE username=?`
_GetUserById_UserManage = `SELECT * FROM @user WHERE username=?`
_GetUserByPhone_UserManage = `SELECT * FROM @user WHERE username=?`
_GetUserByUsername_UserManage = `SELECT * FROM @user WHERE username=?`
_GetUsersByIds_UserManage = `SELECT * FROM @user WHERE username=?`
_GetUsersByKeyword_UserManage = `SELECT * FROM @user WHERE username=?`
_UpdateUser_UserManage = `SELECT * FROM @user WHERE username=?`
_CreateRecharge_Wallet = `SELECT * FROM @user WHERE username=?`
_GetRechargeById_Wallet = `SELECT * FROM @user WHERE username=?`
_GetUserWalletBillCount_Wallet = `SELECT * FROM @user WHERE username=?`
_GetUserWalletBills_Wallet = `SELECT * FROM @user WHERE username=?`
_HandlePostAttachementBought_Wallet = `SELECT * FROM @user WHERE username=?`
_HandleRechargeSuccess_Wallet = `SELECT * FROM @user WHERE username=?`
_AuthorizationManage_BeFriendIds = `SELECT user_id FROM @contact WHERE friend_id=? AND status=2 AND is_del=0`
_AuthorizationManage_IsFriend = `SELECT status FROM @contact WHERE user_id=? AND friend_id=? AND is_del=0`
_AuthorizationManage_MyFriendSet = `SELECT friend_id FROM @contact WHERE user_id=? AND status=2 AND is_del=0`
_Comment_GetCommentById = `SELECT * FROM @comment WHERE id=? AND is_del=0`
_Comment_GetCommentContentsByIds = `SELECT * FROM @comment_content WHERE comment_id IN ?`
_Comment_GetCommentCount = `SELECT count(*) FROM @comment WHERE post_id=:post_id AND is_del=0`
_Comment_GetCommentReplyById = `SELECT * FROM @comment_reply WHERE id=? AND is_del=0`
_Comment_GetCommentThumbs = `SELECT * FROM @tweet_comment_thumbs WHERE user_id=? AND tweet_id=?`
_Comment_GetComments = `SELECT * FROM @comment WHERE post_id=? AND is_del=0 ORDER BY %order% LIMIT ? OFFSET ?`
_Comment_GetCommmentRepliesByIds = `SELECT * FROM @comment_reply WHERE comment_id IN ? ORDER BY id ASC`
_Comment_GetUsersByIds = `SELECT id, nickname, username, status, avatar, is_admin FROM @user WHERE id IN ?`
_CommentManage_CreateComment = `SELECT * FROM @user WHERE username=?`
_CommentManage_CreateCommentContent = `SELECT * FROM @user WHERE username=?`
_CommentManage_CreateCommentReply = `SELECT * FROM @user WHERE username=?`
_CommentManage_CreateThumbsUpComment = `SELECT * FROM @user WHERE username=?`
_CommentManage_DeleteComment = `SELECT * FROM @user WHERE username=?`
_CommentManage_DeleteCommentReply = `SELECT * FROM @user WHERE username=?`
_CommentManage_DeleteCommentThumbs = `SELECT * FROM @user WHERE username=?`
_CommentManage_DeleteReplyThumbs = `SELECT * FROM @user WHERE username=?`
_CommentManage_GetCommentReplyThumb = `SELECT * FROM @user WHERE username=?`
_CommentManage_GetTweetCommentThumb = `SELECT * FROM @user WHERE username=?`
_CommentManage_ThumbsDownComment = `SELECT * FROM @user WHERE username=?`
_CommentManage_ThumbsDownReply = `SELECT * FROM @user WHERE username=?`
_CommentManage_ThumbsUpReply = `SELECT * FROM @user WHERE username=?`
_CommentManage_UpdateCommentThumbsCount = `SELECT * FROM @user WHERE username=?`
_CommentManage_UpdateThumbsUpComment = `SELECT * FROM @user WHERE username=?`
_ContactManager_AddFriend = `SELECT * FROM @user WHERE username=?`
_ContactManager_DelFriend = `SELECT * FROM @user WHERE username=?`
_ContactManager_GetContacts = `SELECT * FROM @user WHERE username=?`
_ContactManager_GetUserFriend = `SELECT * FROM @user WHERE username=?`
_ContactManager_RejectFriend = `SELECT * FROM @user WHERE username=?`
_ContactManager_RequestingFriend = `SELECT * FROM @user WHERE username=?`
_ContactManager_TotalContactsById = `SELECT * FROM @user WHERE username=?`
_FollowIndexA_UserInfo = `SELECT * FROM @user WHERE username=?`
_FollowIndex_UserInfo = `SELECT * FROM @user WHERE username=?`
_FriendIndexA_UserInfo = `SELECT * FROM @user WHERE username=?`
_FriendIndex_UserInfo = `SELECT * FROM @user WHERE username=?`
_LightIndexA_UserInfo = `SELECT * FROM @user WHERE username=?`
_LightIndex_UserInfo = `SELECT * FROM @user WHERE username=?`
_Message_CreateMessage = `SELECT * FROM @user WHERE username=?`
_Message_GetMessageById = `SELECT * FROM @user WHERE username=?`
_Message_GetMessageCount = `SELECT * FROM @user WHERE username=?`
_Message_GetMessages = `SELECT * FROM @user WHERE username=?`
_Message_GetUnreadCount = `SELECT * FROM @user WHERE username=?`
_Message_ReadMessage = `SELECT * FROM @user WHERE username=?`
_Security_CreatePhoneCaptcha = `SELECT * FROM @user WHERE username=?`
_Security_GetLatestPhoneCaptcha = `SELECT * FROM @user WHERE username=?`
_Security_SendPhoneCaptcha = `SELECT * FROM @user WHERE username=?`
_Security_UsePhoneCaptcha = `SELECT * FROM @user WHERE username=?`
_SimpleIndexA_UserInfo = `SELECT * FROM @user WHERE username=?`
_SimpleIndex_UserInfo = `SELECT * FROM @user WHERE username=?`
_TopicA_DecrTagsById = `UPDATE @tag SET quote_num=quote_num-1, modified_on=? WHERE id IN (?)`
_TopicA_HotTags = `SELECT t.id id, t.user_id user_id, t.tag tag, t.quote_num quote_num, u.id, u.nickname, u.username, u.status, u.avatar, u.is_admin FROM @tag t JOIN @user u ON t.user_id = u.id WHERE t.is_del = 0 AND t.quote_num > 0 ORDER BY t.quote_num DESC LIMIT ? OFFSET ?`
_TopicA_IncrTagsById = `UPDATE @tag SET quote_num=quote_num+1, is_del=0, modified_on=? WHERE id IN (?)`
_TopicA_InsertTag = `INSERT INTO @tag (user_id, tag, created_on, modified_on, quote_num) VALUES (?, ?, ?, ?, 1)`
_TopicA_NewestTags = `SELECT t.id id, t.user_id user_id, t.tag tag, t.quote_num quote_num, u.id, u.nickname, u.username, u.status, u.avatar, u.is_admin FROM @tag t JOIN @user u ON t.user_id = u.id WHERE t.is_del = 0 AND t.quote_num > 0 ORDER BY t.id DESC LIMIT ? OFFSET ?`
_TopicA_TagsByIdA = `SELECT id FROM @tag WHERE id IN (?) AND is_del = 0 AND quote_num > 0`
_TopicA_TagsByIdB = `SELECT id, user_id, tag, quote_num FROM @tag WHERE id IN (?)`
_TopicA_TagsByKeywordA = `SELECT id, user_id, tag, quote_num FROM @tag WHERE is_del = 0 ORDER BY quote_num DESC LIMIT 6`
_TopicA_TagsByKeywordB = `SELECT id, user_id, tag, quote_num FROM @tag WHERE is_del = 0 AND tag LIKE ? ORDER BY quote_num DESC LIMIT 6`
_TopicA_TagsForIncr = `SELECT id, user_id, tag, quote_num FROM @tag WHERE tag IN (?)`
_TweetA_AttachmentByTweetId = `SELECT * FROM @user WHERE username=?`
_TweetA_FavoriteByTweetId = `SELECT * FROM @user WHERE username=?`
_TweetA_ReactionByTweetId = `SELECT * FROM @user WHERE username=?`
_TweetA_TweetInfoById = `SELECT * FROM @user WHERE username=?`
_TweetA_TweetItemById = `SELECT * FROM @user WHERE username=?`
_TweetA_UserFavorites = `SELECT * FROM @user WHERE username=?`
_TweetA_UserInfo = `SELECT * FROM @user WHERE username=?`
_TweetA_UserReactions = `SELECT * FROM @user WHERE username=?`
_TweetA_UserTweetsByAdmin = `SELECT * FROM @user WHERE username=?`
_TweetA_UserTweetsByFriend = `SELECT * FROM @user WHERE username=?`
_TweetA_UserTweetsByGuest = `SELECT * FROM @user WHERE username=?`
_TweetA_UserTweetsBySelf = `SELECT * FROM @user WHERE username=?`
_Tweet_GetPostAttachmentBill = `SELECT * FROM @user WHERE username=?`
_Tweet_GetPostById = `SELECT * FROM @user WHERE username=?`
_Tweet_GetPostContentById = `SELECT * FROM @user WHERE username=?`
_Tweet_GetPostContetnsByIds = `SELECT id, user_id, tag, quote_num FROM @tag WHERE tag IN (?)`
_Tweet_GetPostCount = `SELECT * FROM @user WHERE username=?`
_Tweet_GetPosts = `SELECT * FROM @user WHERE username=?`
_Tweet_GetUserPostCollection = `SELECT * FROM @user WHERE username=?`
_Tweet_GetUserPostCollectionCount = `SELECT * FROM @user WHERE username=?`
_Tweet_GetUserPostCollections = `SELECT * FROM @user WHERE username=?`
_Tweet_GetUserPostStar = `SELECT * FROM @user WHERE username=?`
_Tweet_GetUserPostStarCount = `SELECT * FROM @user WHERE username=?`
_Tweet_GetUserPostStars = `SELECT * FROM @user WHERE username=?`
_TweetHelpA_UserInfo = `SELECT * FROM @user WHERE username=?`
_TweetHelp_GetPostContentByIds = `SELECT * FROM @user WHERE username=?`
_TweetHelp_GetUsersByIds = `SELECT * FROM @user WHERE username=?`
_TweetManageA_UserInfo = `SELECT * FROM @user WHERE username=?`
_TweetManage_AddAttachment = `SELECT * FROM @user WHERE username=?`
_TweetManage_AddPost = `SELECT * FROM @user WHERE username=?`
_TweetManage_AddPostCollection = `SELECT * FROM @user WHERE username=?`
_TweetManage_AddPostContent = `SELECT * FROM @user WHERE username=?`
_TweetManage_AddPostStar = `SELECT * FROM @user WHERE username=?`
_TweetManage_DelPost = `SELECT * FROM @user WHERE username=?`
_TweetManage_DelPostCollection = `SELECT * FROM @user WHERE username=?`
_TweetManage_DelPostStar = `SELECT * FROM @user WHERE username=?`
_TweetManage_LockPost = `SELECT * FROM @user WHERE username=?`
_TweetManage_StickPost = `SELECT * FROM @user WHERE username=?`
_TweetManage_UpdatePost = `SELECT * FROM @user WHERE username=?`
_TweetManage_VisiblePost = `SELECT * FROM @user WHERE username=?`
_UserManage_AddUser = `SELECT * FROM @user WHERE username=?`
_UserManage_GetUserById = `SELECT * FROM @user WHERE username=?`
_UserManage_GetUserByPhone = `SELECT * FROM @user WHERE username=?`
_UserManage_GetUserByUsername = `SELECT * FROM @user WHERE username=?`
_UserManage_GetUsersByIds = `SELECT * FROM @user WHERE username=?`
_UserManage_GetUsersByKeyword = `SELECT * FROM @user WHERE username=?`
_UserManage_UpdateUser = `SELECT * FROM @user WHERE username=?`
_Wallet_CreateRecharge = `SELECT * FROM @user WHERE username=?`
_Wallet_GetRechargeById = `SELECT * FROM @user WHERE username=?`
_Wallet_GetUserWalletBillCount = `SELECT * FROM @user WHERE username=?`
_Wallet_GetUserWalletBills = `SELECT * FROM @user WHERE username=?`
_Wallet_HandlePostAttachementBought = `SELECT * FROM @user WHERE username=?`
_Wallet_HandleRechargeSuccess = `SELECT * FROM @user WHERE username=?`
)
type AuthorizationManage struct {
yesql.Namespace `yesql:"authorization_manage"`
BeFriendFilter *sqlx.Stmt `yesql:"be_friend_filter"`
BeFriendIds *sqlx.Stmt `yesql:"be_friend_ids"`
IsFriend *sqlx.Stmt `yesql:"is_friend"`
MyFriendSet *sqlx.Stmt `yesql:"my_friend_set"`
}
type Comment struct {
yesql.Namespace `yesql:"comment"`
GetCommentContentsByIds string `yesql:"get_comment_contents_by_ids"`
GetComments string `yesql:"get_comments"`
GetCommmentRepliesByIds string `yesql:"get_commment_replies_by_ids"`
GetUsersByIds string `yesql:"get_users_by_ids"`
GetCommentById *sqlx.Stmt `yesql:"get_comment_by_id"`
GetCommentReplyById *sqlx.Stmt `yesql:"get_comment_reply_by_id"`
GetCommentThumbs *sqlx.Stmt `yesql:"get_comment_thumbs"`
GetCommentCount *sqlx.NamedStmt `yesql:"get_comment_count"`
GetComments *sqlx.NamedStmt `yesql:"get_comments"`
}
type CommentManage struct {
@ -211,10 +211,10 @@ type Message struct {
yesql.Namespace `yesql:"message"`
GetMessageById *sqlx.Stmt `yesql:"get_message_by_id"`
GetUnreadCount *sqlx.Stmt `yesql:"get_unread_count"`
ReadMessage *sqlx.Stmt `yesql:"read_message"`
CreateMessage *sqlx.NamedStmt `yesql:"create_message"`
GetMessageCount *sqlx.NamedStmt `yesql:"get_message_count"`
GetMessages *sqlx.NamedStmt `yesql:"get_messages"`
ReadMessage *sqlx.NamedStmt `yesql:"read_message"`
}
type Security struct {
@ -342,13 +342,13 @@ func BuildAuthorizationManage(p yesql.PreparexBuilder, ctx ...context.Context) (
c = context.Background()
}
obj = &AuthorizationManage{}
if obj.BeFriendFilter, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_BeFriendFilter_AuthorizationManage))); err != nil {
if obj.BeFriendIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AuthorizationManage_BeFriendIds))); err != nil {
return
}
if obj.BeFriendIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_BeFriendIds_AuthorizationManage))); err != nil {
if obj.IsFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AuthorizationManage_IsFriend))); err != nil {
return
}
if obj.MyFriendSet, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_MyFriendSet_AuthorizationManage))); err != nil {
if obj.MyFriendSet, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AuthorizationManage_MyFriendSet))); err != nil {
return
}
return
@ -362,23 +362,21 @@ func BuildComment(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Comment
c = context.Background()
}
obj = &Comment{
GetCommentContentsByIds: p.QueryHook(_GetCommentContentsByIds_Comment),
GetCommmentRepliesByIds: p.QueryHook(_GetCommmentRepliesByIds_Comment),
GetUsersByIds: p.QueryHook(_GetUsersByIds_Comment),
GetCommentContentsByIds: p.QueryHook(_Comment_GetCommentContentsByIds),
GetComments: p.QueryHook(_Comment_GetComments),
GetCommmentRepliesByIds: p.QueryHook(_Comment_GetCommmentRepliesByIds),
GetUsersByIds: p.QueryHook(_Comment_GetUsersByIds),
}
if obj.GetCommentById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetCommentById_Comment))); err != nil {
if obj.GetCommentById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentById))); err != nil {
return
}
if obj.GetCommentReplyById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetCommentReplyById_Comment))); err != nil {
if obj.GetCommentReplyById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentReplyById))); err != nil {
return
}
if obj.GetCommentThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetCommentThumbs_Comment))); err != nil {
if obj.GetCommentThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentThumbs))); err != nil {
return
}
if obj.GetCommentCount, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_GetCommentCount_Comment))); err != nil {
return
}
if obj.GetComments, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_GetComments_Comment))); err != nil {
if obj.GetCommentCount, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentCount))); err != nil {
return
}
return
@ -392,49 +390,49 @@ func BuildCommentManage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *C
c = context.Background()
}
obj = &CommentManage{}
if obj.DeleteComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DeleteComment_CommentManage))); err != nil {
if obj.DeleteComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteComment))); err != nil {
return
}
if obj.DeleteCommentReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DeleteCommentReply_CommentManage))); err != nil {
if obj.DeleteCommentReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteCommentReply))); err != nil {
return
}
if obj.DeleteCommentThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DeleteCommentThumbs_CommentManage))); err != nil {
if obj.DeleteCommentThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteCommentThumbs))); err != nil {
return
}
if obj.DeleteReplyThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DeleteReplyThumbs_CommentManage))); err != nil {
if obj.DeleteReplyThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteReplyThumbs))); err != nil {
return
}
if obj.GetCommentReplyThumb, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetCommentReplyThumb_CommentManage))); err != nil {
if obj.GetCommentReplyThumb, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_GetCommentReplyThumb))); err != nil {
return
}
if obj.GetTweetCommentThumb, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetTweetCommentThumb_CommentManage))); err != nil {
if obj.GetTweetCommentThumb, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_GetTweetCommentThumb))); err != nil {
return
}
if obj.ThumbsDownComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ThumbsDownComment_CommentManage))); err != nil {
if obj.ThumbsDownComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_ThumbsDownComment))); err != nil {
return
}
if obj.ThumbsDownReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ThumbsDownReply_CommentManage))); err != nil {
if obj.ThumbsDownReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_ThumbsDownReply))); err != nil {
return
}
if obj.ThumbsUpReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ThumbsUpReply_CommentManage))); err != nil {
if obj.ThumbsUpReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_ThumbsUpReply))); err != nil {
return
}
if obj.UpdateCommentThumbsCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UpdateCommentThumbsCount_CommentManage))); err != nil {
if obj.UpdateCommentThumbsCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_UpdateCommentThumbsCount))); err != nil {
return
}
if obj.CreateComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CreateComment_CommentManage))); err != nil {
if obj.CreateComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateComment))); err != nil {
return
}
if obj.CreateCommentContent, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CreateCommentContent_CommentManage))); err != nil {
if obj.CreateCommentContent, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateCommentContent))); err != nil {
return
}
if obj.CreateCommentReply, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CreateCommentReply_CommentManage))); err != nil {
if obj.CreateCommentReply, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateCommentReply))); err != nil {
return
}
if obj.CreateThumbsUpComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CreateThumbsUpComment_CommentManage))); err != nil {
if obj.CreateThumbsUpComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateThumbsUpComment))); err != nil {
return
}
if obj.UpdateThumbsUpComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_UpdateThumbsUpComment_CommentManage))); err != nil {
if obj.UpdateThumbsUpComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_UpdateThumbsUpComment))); err != nil {
return
}
return
@ -448,25 +446,25 @@ func BuildContactManager(p yesql.PreparexBuilder, ctx ...context.Context) (obj *
c = context.Background()
}
obj = &ContactManager{}
if obj.AddFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddFriend_ContactManager))); err != nil {
if obj.AddFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_AddFriend))); err != nil {
return
}
if obj.DelFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DelFriend_ContactManager))); err != nil {
if obj.DelFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_DelFriend))); err != nil {
return
}
if obj.GetContacts, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetContacts_ContactManager))); err != nil {
if obj.GetContacts, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_GetContacts))); err != nil {
return
}
if obj.GetUserFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserFriend_ContactManager))); err != nil {
if obj.GetUserFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_GetUserFriend))); err != nil {
return
}
if obj.RejectFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_RejectFriend_ContactManager))); err != nil {
if obj.RejectFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_RejectFriend))); err != nil {
return
}
if obj.RequestingFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_RequestingFriend_ContactManager))); err != nil {
if obj.RequestingFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_RequestingFriend))); err != nil {
return
}
if obj.TotalContactsById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TotalContactsById_ContactManager))); err != nil {
if obj.TotalContactsById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_TotalContactsById))); err != nil {
return
}
return
@ -480,7 +478,7 @@ func BuildFollowIndex(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Fol
c = context.Background()
}
obj = &FollowIndex{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_FollowIndex))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowIndex_UserInfo))); err != nil {
return
}
return
@ -494,7 +492,7 @@ func BuildFollowIndexA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Fo
c = context.Background()
}
obj = &FollowIndexA{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_FollowIndexA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowIndexA_UserInfo))); err != nil {
return
}
return
@ -508,7 +506,7 @@ func BuildFriendIndex(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Fri
c = context.Background()
}
obj = &FriendIndex{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_FriendIndex))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FriendIndex_UserInfo))); err != nil {
return
}
return
@ -522,7 +520,7 @@ func BuildFriendIndexA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Fr
c = context.Background()
}
obj = &FriendIndexA{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_FriendIndexA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FriendIndexA_UserInfo))); err != nil {
return
}
return
@ -536,7 +534,7 @@ func BuildLightIndex(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Ligh
c = context.Background()
}
obj = &LightIndex{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_LightIndex))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_LightIndex_UserInfo))); err != nil {
return
}
return
@ -550,7 +548,7 @@ func BuildLightIndexA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Lig
c = context.Background()
}
obj = &LightIndexA{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_LightIndexA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_LightIndexA_UserInfo))); err != nil {
return
}
return
@ -564,22 +562,22 @@ func BuildMessage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Message
c = context.Background()
}
obj = &Message{}
if obj.GetMessageById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetMessageById_Message))); err != nil {
if obj.GetMessageById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetMessageById))); err != nil {
return
}
if obj.GetUnreadCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUnreadCount_Message))); err != nil {
if obj.GetUnreadCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetUnreadCount))); err != nil {
return
}
if obj.ReadMessage, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ReadMessage_Message))); err != nil {
if obj.CreateMessage, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Message_CreateMessage))); err != nil {
return
}
if obj.CreateMessage, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CreateMessage_Message))); err != nil {
if obj.GetMessageCount, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Message_GetMessageCount))); err != nil {
return
}
if obj.GetMessageCount, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_GetMessageCount_Message))); err != nil {
if obj.GetMessages, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Message_GetMessages))); err != nil {
return
}
if obj.GetMessages, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_GetMessages_Message))); err != nil {
if obj.ReadMessage, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Message_ReadMessage))); err != nil {
return
}
return
@ -593,16 +591,16 @@ func BuildSecurity(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Securi
c = context.Background()
}
obj = &Security{}
if obj.GetLatestPhoneCaptcha, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetLatestPhoneCaptcha_Security))); err != nil {
if obj.GetLatestPhoneCaptcha, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Security_GetLatestPhoneCaptcha))); err != nil {
return
}
if obj.SendPhoneCaptcha, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_SendPhoneCaptcha_Security))); err != nil {
if obj.SendPhoneCaptcha, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Security_SendPhoneCaptcha))); err != nil {
return
}
if obj.CreatePhoneCaptcha, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CreatePhoneCaptcha_Security))); err != nil {
if obj.CreatePhoneCaptcha, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Security_CreatePhoneCaptcha))); err != nil {
return
}
if obj.UsePhoneCaptcha, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_UsePhoneCaptcha_Security))); err != nil {
if obj.UsePhoneCaptcha, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Security_UsePhoneCaptcha))); err != nil {
return
}
return
@ -616,7 +614,7 @@ func BuildSimpleIndex(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Sim
c = context.Background()
}
obj = &SimpleIndex{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_SimpleIndex))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_SimpleIndex_UserInfo))); err != nil {
return
}
return
@ -630,7 +628,7 @@ func BuildSimpleIndexA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Si
c = context.Background()
}
obj = &SimpleIndexA{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_SimpleIndexA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_SimpleIndexA_UserInfo))); err != nil {
return
}
return
@ -644,25 +642,25 @@ func BuildTopicA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *TopicA,
c = context.Background()
}
obj = &TopicA{
DecrTagsById: p.QueryHook(_DecrTagsById_TopicA),
IncrTagsById: p.QueryHook(_IncrTagsById_TopicA),
TagsByIdA: p.QueryHook(_TagsByIdA_TopicA),
TagsByIdB: p.QueryHook(_TagsByIdB_TopicA),
TagsForIncr: p.QueryHook(_TagsForIncr_TopicA),
DecrTagsById: p.QueryHook(_TopicA_DecrTagsById),
IncrTagsById: p.QueryHook(_TopicA_IncrTagsById),
TagsByIdA: p.QueryHook(_TopicA_TagsByIdA),
TagsByIdB: p.QueryHook(_TopicA_TagsByIdB),
TagsForIncr: p.QueryHook(_TopicA_TagsForIncr),
}
if obj.HotTags, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_HotTags_TopicA))); err != nil {
if obj.HotTags, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TopicA_HotTags))); err != nil {
return
}
if obj.InsertTag, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_InsertTag_TopicA))); err != nil {
if obj.InsertTag, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TopicA_InsertTag))); err != nil {
return
}
if obj.NewestTags, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_NewestTags_TopicA))); err != nil {
if obj.NewestTags, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TopicA_NewestTags))); err != nil {
return
}
if obj.TagsByKeywordA, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TagsByKeywordA_TopicA))); err != nil {
if obj.TagsByKeywordA, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TopicA_TagsByKeywordA))); err != nil {
return
}
if obj.TagsByKeywordB, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TagsByKeywordB_TopicA))); err != nil {
if obj.TagsByKeywordB, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TopicA_TagsByKeywordB))); err != nil {
return
}
return
@ -676,39 +674,39 @@ func BuildTweet(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Tweet, er
c = context.Background()
}
obj = &Tweet{
GetPostContetnsByIds: p.QueryHook(_GetPostContetnsByIds_Tweet),
GetPostContetnsByIds: p.QueryHook(_Tweet_GetPostContetnsByIds),
}
if obj.GetPostAttachmentBill, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetPostAttachmentBill_Tweet))); err != nil {
if obj.GetPostAttachmentBill, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostAttachmentBill))); err != nil {
return
}
if obj.GetPostById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetPostById_Tweet))); err != nil {
if obj.GetPostById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostById))); err != nil {
return
}
if obj.GetPostContentById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetPostContentById_Tweet))); err != nil {
if obj.GetPostContentById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostContentById))); err != nil {
return
}
if obj.GetPostCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetPostCount_Tweet))); err != nil {
if obj.GetPostCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostCount))); err != nil {
return
}
if obj.GetPosts, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetPosts_Tweet))); err != nil {
if obj.GetPosts, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPosts))); err != nil {
return
}
if obj.GetUserPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserPostCollection_Tweet))); err != nil {
if obj.GetUserPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostCollection))); err != nil {
return
}
if obj.GetUserPostCollectionCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserPostCollectionCount_Tweet))); err != nil {
if obj.GetUserPostCollectionCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostCollectionCount))); err != nil {
return
}
if obj.GetUserPostCollections, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserPostCollections_Tweet))); err != nil {
if obj.GetUserPostCollections, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostCollections))); err != nil {
return
}
if obj.GetUserPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserPostStar_Tweet))); err != nil {
if obj.GetUserPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStar))); err != nil {
return
}
if obj.GetUserPostStarCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserPostStarCount_Tweet))); err != nil {
if obj.GetUserPostStarCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStarCount))); err != nil {
return
}
if obj.GetUserPostStars, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserPostStars_Tweet))); err != nil {
if obj.GetUserPostStars, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStars))); err != nil {
return
}
return
@ -722,40 +720,40 @@ func BuildTweetA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *TweetA,
c = context.Background()
}
obj = &TweetA{}
if obj.AttachmentByTweetId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AttachmentByTweetId_TweetA))); err != nil {
if obj.AttachmentByTweetId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_AttachmentByTweetId))); err != nil {
return
}
if obj.FavoriteByTweetId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FavoriteByTweetId_TweetA))); err != nil {
if obj.FavoriteByTweetId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_FavoriteByTweetId))); err != nil {
return
}
if obj.ReactionByTweetId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ReactionByTweetId_TweetA))); err != nil {
if obj.ReactionByTweetId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_ReactionByTweetId))); err != nil {
return
}
if obj.TweetInfoById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetInfoById_TweetA))); err != nil {
if obj.TweetInfoById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_TweetInfoById))); err != nil {
return
}
if obj.TweetItemById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetItemById_TweetA))); err != nil {
if obj.TweetItemById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_TweetItemById))); err != nil {
return
}
if obj.UserFavorites, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserFavorites_TweetA))); err != nil {
if obj.UserFavorites, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserFavorites))); err != nil {
return
}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_TweetA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserInfo))); err != nil {
return
}
if obj.UserReactions, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserReactions_TweetA))); err != nil {
if obj.UserReactions, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserReactions))); err != nil {
return
}
if obj.UserTweetsByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserTweetsByAdmin_TweetA))); err != nil {
if obj.UserTweetsByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserTweetsByAdmin))); err != nil {
return
}
if obj.UserTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserTweetsByFriend_TweetA))); err != nil {
if obj.UserTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserTweetsByFriend))); err != nil {
return
}
if obj.UserTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserTweetsByGuest_TweetA))); err != nil {
if obj.UserTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserTweetsByGuest))); err != nil {
return
}
if obj.UserTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserTweetsBySelf_TweetA))); err != nil {
if obj.UserTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetA_UserTweetsBySelf))); err != nil {
return
}
return
@ -763,8 +761,8 @@ func BuildTweetA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *TweetA,
func BuildTweetHelp(p yesql.PreparexBuilder) (obj *TweetHelp, err error) {
obj = &TweetHelp{
GetPostContentByIds: p.QueryHook(_GetPostContentByIds_TweetHelp),
GetUsersByIds: p.QueryHook(_GetUsersByIds_TweetHelp),
GetPostContentByIds: p.QueryHook(_TweetHelp_GetPostContentByIds),
GetUsersByIds: p.QueryHook(_TweetHelp_GetUsersByIds),
}
return
}
@ -777,7 +775,7 @@ func BuildTweetHelpA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Twee
c = context.Background()
}
obj = &TweetHelpA{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_TweetHelpA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetHelpA_UserInfo))); err != nil {
return
}
return
@ -791,40 +789,40 @@ func BuildTweetManage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Twe
c = context.Background()
}
obj = &TweetManage{}
if obj.AddAttachment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddAttachment_TweetManage))); err != nil {
if obj.AddAttachment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddAttachment))); err != nil {
return
}
if obj.AddPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddPost_TweetManage))); err != nil {
if obj.AddPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPost))); err != nil {
return
}
if obj.AddPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddPostCollection_TweetManage))); err != nil {
if obj.AddPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostCollection))); err != nil {
return
}
if obj.AddPostContent, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddPostContent_TweetManage))); err != nil {
if obj.AddPostContent, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostContent))); err != nil {
return
}
if obj.AddPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddPostStar_TweetManage))); err != nil {
if obj.AddPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostStar))); err != nil {
return
}
if obj.DelPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DelPost_TweetManage))); err != nil {
if obj.DelPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPost))); err != nil {
return
}
if obj.DelPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DelPostCollection_TweetManage))); err != nil {
if obj.DelPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostCollection))); err != nil {
return
}
if obj.DelPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_DelPostStar_TweetManage))); err != nil {
if obj.DelPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostStar))); err != nil {
return
}
if obj.LockPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_LockPost_TweetManage))); err != nil {
if obj.LockPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_LockPost))); err != nil {
return
}
if obj.StickPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_StickPost_TweetManage))); err != nil {
if obj.StickPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_StickPost))); err != nil {
return
}
if obj.UpdatePost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UpdatePost_TweetManage))); err != nil {
if obj.UpdatePost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_UpdatePost))); err != nil {
return
}
if obj.VisiblePost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_VisiblePost_TweetManage))); err != nil {
if obj.VisiblePost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_VisiblePost))); err != nil {
return
}
return
@ -838,7 +836,7 @@ func BuildTweetManageA(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Tw
c = context.Background()
}
obj = &TweetManageA{}
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserInfo_TweetManageA))); err != nil {
if obj.UserInfo, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManageA_UserInfo))); err != nil {
return
}
return
@ -852,24 +850,24 @@ func BuildUserManage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *User
c = context.Background()
}
obj = &UserManage{
GetUsersByIds: p.QueryHook(_GetUsersByIds_UserManage),
GetUsersByIds: p.QueryHook(_UserManage_GetUsersByIds),
}
if obj.AddUser, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AddUser_UserManage))); err != nil {
if obj.AddUser, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_AddUser))); err != nil {
return
}
if obj.GetUserById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserById_UserManage))); err != nil {
if obj.GetUserById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUserById))); err != nil {
return
}
if obj.GetUserByPhone, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserByPhone_UserManage))); err != nil {
if obj.GetUserByPhone, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUserByPhone))); err != nil {
return
}
if obj.GetUserByUsername, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserByUsername_UserManage))); err != nil {
if obj.GetUserByUsername, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUserByUsername))); err != nil {
return
}
if obj.GetUsersByKeyword, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUsersByKeyword_UserManage))); err != nil {
if obj.GetUsersByKeyword, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUsersByKeyword))); err != nil {
return
}
if obj.UpdateUser, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UpdateUser_UserManage))); err != nil {
if obj.UpdateUser, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_UpdateUser))); err != nil {
return
}
return
@ -883,22 +881,22 @@ func BuildWallet(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Wallet,
c = context.Background()
}
obj = &Wallet{}
if obj.CreateRecharge, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CreateRecharge_Wallet))); err != nil {
if obj.CreateRecharge, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_CreateRecharge))); err != nil {
return
}
if obj.GetRechargeById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetRechargeById_Wallet))); err != nil {
if obj.GetRechargeById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetRechargeById))); err != nil {
return
}
if obj.GetUserWalletBillCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserWalletBillCount_Wallet))); err != nil {
if obj.GetUserWalletBillCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetUserWalletBillCount))); err != nil {
return
}
if obj.GetUserWalletBills, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_GetUserWalletBills_Wallet))); err != nil {
if obj.GetUserWalletBills, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetUserWalletBills))); err != nil {
return
}
if obj.HandlePostAttachementBought, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_HandlePostAttachementBought_Wallet))); err != nil {
if obj.HandlePostAttachementBought, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_HandlePostAttachementBought))); err != nil {
return
}
if obj.HandleRechargeSuccess, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_HandleRechargeSuccess_Wallet))); err != nil {
if obj.HandleRechargeSuccess, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_HandleRechargeSuccess))); err != nil {
return
}
return

32
internal/dao/sakila/yesql/yesql.sql
Unescape View File

@ -2,56 +2,56 @@
-- authorization_manage sql dml
--------------------------------------------------------------------------------
-- name: be_friend_filter@authorization_manage
-- prepare: stmt
SELECT * FROM @user WHERE username=?
-- name: be_friend_ids@authorization_manage
-- prepare: stmt
SELECT * FROM @user WHERE username=?
SELECT user_id FROM @contact WHERE friend_id=? AND status=2 AND is_del=0;
-- name: my_friend_set@authorization_manage
-- prepare: stmt
SELECT * FROM @user WHERE username=?
SELECT friend_id FROM @contact WHERE user_id=? AND status=2 AND is_del=0;
-- name: is_friend@authorization_manage
-- prepare: stmt
SELECT status FROM @contact WHERE user_id=? AND friend_id=? AND is_del=0;
--------------------------------------------------------------------------------
-- comment sql dml
--------------------------------------------------------------------------------
-- name: get_comments@comment
-- prepare: named_stmt
SELECT * FROM @user WHERE username=?
-- prepare: raw
SELECT * FROM @comment WHERE post_id=? AND is_del=0 ORDER BY %order% LIMIT ? OFFSET ?;
-- name: get_comment_by_id@comment
-- prepare: stmt
SELECT * FROM @user WHERE username=?
SELECT * FROM @comment WHERE id=? AND is_del=0;
-- name: get_comment_count@comment
-- prepare: named_stmt
SELECT * FROM @user WHERE username=?
SELECT count(*) FROM @comment WHERE post_id=:post_id AND is_del=0;
-- name: get_comment_reply_by_id@comment
-- prepare: stmt
SELECT * FROM @user WHERE username=?
SELECT * FROM @comment_reply WHERE id=? AND is_del=0;
-- name: get_comment_contents_by_ids@comment
-- prepare: raw
-- clause: in
SELECT * FROM @user WHERE username=?
SELECT * FROM @comment_content WHERE comment_id IN ?;
-- name: get_commment_replies_by_ids@comment
-- prepare: raw
-- clause: in
SELECT * FROM @user WHERE username=?
SELECT * FROM @comment_reply WHERE comment_id IN ? ORDER BY id ASC;
-- name: get_users_by_ids@comment
-- prepare: raw
-- clause: in
SELECT * FROM @user WHERE username=?
SELECT id, nickname, username, status, avatar, is_admin FROM @user WHERE id IN ?;
-- name: get_comment_thumbs@comment
-- prepare: stmt
SELECT * FROM @user WHERE username=?
SELECT * FROM @tweet_comment_thumbs WHERE user_id=? AND tweet_id=?;
--------------------------------------------------------------------------------
-- comment_manage sql dml
@ -166,7 +166,7 @@ SELECT * FROM @user WHERE username=?
SELECT * FROM @user WHERE username=?
-- name: read_message@message
-- prepare: stmt
-- prepare: named_stmt
SELECT * FROM @user WHERE username=?
-- name: get_messages@message

Write Preview
Loading…
Cancel
Save