From a68d3816ed91f0814614fef40702a2a184c3ae6d Mon Sep 17 00:00:00 2001 From: Michael Li Date: Tue, 1 Aug 2023 08:21:27 +0800 Subject: [PATCH] sqlx: implement some logic WIP %20 --- go.mod | 2 +- go.sum | 4 +- internal/dao/jinzhu/dbr/comment.go | 2 +- internal/dao/sakila/authority.go | 52 ++- internal/dao/sakila/comments.go | 31 +- internal/dao/sakila/messages.go | 8 +- internal/dao/sakila/yesql/cc/yesql.go | 466 +++++++++++++------------- internal/dao/sakila/yesql/yesql.sql | 32 +- 8 files changed, 306 insertions(+), 291 deletions(-) diff --git a/go.mod b/go.mod index d1c0e65f..1a548302 100644 --- a/go.mod +++ b/go.mod @@ -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 diff --git a/go.sum b/go.sum index da9c4ca7..db207893 100644 --- a/go.sum +++ b/go.sum @@ -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= diff --git a/internal/dao/jinzhu/dbr/comment.go b/internal/dao/jinzhu/dbr/comment.go index 6f2f33c3..4f673336 100644 --- a/internal/dao/jinzhu/dbr/comment.go +++ b/internal/dao/jinzhu/dbr/comment.go @@ -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 { diff --git a/internal/dao/sakila/authority.go b/internal/dao/sakila/authority.go index 688068cc..4d4a2168 100644 --- a/internal/dao/sakila/authority.go +++ b/internal/dao/sakila/authority.go @@ -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 } diff --git a/internal/dao/sakila/comments.go b/internal/dao/sakila/comments.go index 4e8f52ed..9efdcb27 100644 --- a/internal/dao/sakila/comments.go +++ b/internal/dao/sakila/comments.go @@ -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 } diff --git a/internal/dao/sakila/messages.go b/internal/dao/sakila/messages.go index 1856c496..767e949f 100644 --- a/internal/dao/sakila/messages.go +++ b/internal/dao/sakila/messages.go @@ -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) { diff --git a/internal/dao/sakila/yesql/cc/yesql.go b/internal/dao/sakila/yesql/cc/yesql.go index 2fe296d0..c9da169d 100644 --- a/internal/dao/sakila/yesql/cc/yesql.go +++ b/internal/dao/sakila/yesql/cc/yesql.go @@ -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 diff --git a/internal/dao/sakila/yesql/yesql.sql b/internal/dao/sakila/yesql/yesql.sql index 3d177a97..5603e3ab 100644 --- a/internal/dao/sakila/yesql/yesql.sql +++ b/internal/dao/sakila/yesql/yesql.sql @@ -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