sqlx: tweet logic is implemented complete. WIP %85

internal/dao/jinzhu/dbr/post_collection.go

@@ -13,7 +13,7 @@ import (
 
 type PostCollection struct {
 	*Model
-	Post   *Post `json:"-"`
+	Post   *Post `db:"post" json:"-"`
 	PostID int64 `db:"post_id" json:"post_id"`
 	UserID int64 `db:"user_id" json:"user_id"`
 }

internal/dao/jinzhu/dbr/post_star.go

@@ -13,7 +13,7 @@ import (
 
 type PostStar struct {
 	*Model
-	Post   *Post `json:"-"`
+	Post   *Post `db:"post" json:"-"`
 	PostID int64 `json:"post_id"`
 	UserID int64 `json:"user_id"`
 }

internal/dao/sakila/tweets.go

@@ -225,9 +225,32 @@ func (s *tweetManageSrv) DeletePost(post *ms.Post) (mediaContents []string, err
 	return
 }
 
-func (s *tweetManageSrv) deleteCommentByPostId(tx *sqlx.Tx, postId int64) ([]string, error) {
-	// TODO
-	return nil, nil
+func (s *tweetManageSrv) deleteCommentByPostId(tx *sqlx.Tx, postId int64) (mediaContents []string, err error) {
+	var commentIds []int64
+	// 获取推文的所有评论id
+	err = tx.Stmtx(s.q.CommentIdsByPostId).Select(&commentIds, postId)
+	if err != nil {
+		return nil, err
+	}
+	// 获取评论的媒体内容
+	err = s.inSelectx(tx, &mediaContents, s.q.CommentMediaFromCommentIds, commentIds)
+	if err != nil {
+		return nil, err
+	}
+	// 删评论
+	now := time.Now().Unix()
+	if _, err = tx.Stmtx(s.q.DelCommentByPostId).Exec(now, postId); err != nil {
+		return nil, err
+	}
+	// 删评论内容
+	if _, err = s.inExecx(tx, s.q.DelCommentContentByCommentIds, now, commentIds); err != nil {
+		return nil, err
+	}
+	// 删评论的评论
+	if _, err = s.inExecx(tx, s.q.DelReplyByCommentIds, now, commentIds); err != nil {
+		return nil, err
+	}
+	return
 }
 
 func (s *tweetManageSrv) LockPost(r *ms.Post) error {
@@ -332,44 +355,39 @@ func (s *tweetSrv) GetPostCount(c ms.ConditionsT) (res int64, err error) {
 	return
 }
 
-func (s *tweetSrv) GetUserPostStar(postID, userID int64) (*ms.PostStar, error) {
-	res := &ms.PostStar{}
-	err := s.q.GetUserPostStar.Get(res, postID, userID)
-	return res, err
+func (s *tweetSrv) GetUserPostStar(postID, userID int64) (res *ms.PostStar, err error) {
+	err = s.q.GetUserPostStar.Get(res, postID, userID, userID)
+	return
 }
 
-func (s *tweetSrv) GetUserPostStars(userID int64, offset, limit int) ([]*ms.PostStar, error) {
-	res := []*ms.PostStar{}
-	err := s.q.GetUserPostStar.Select(&res, userID, limit, offset)
-	return res, err
+func (s *tweetSrv) GetUserPostStars(userID int64, offset, limit int) (res []*ms.PostStar, err error) {
+	err = s.q.GetUserPostStar.Select(&res, userID, userID, limit, offset)
+	return
 }
 
 func (s *tweetSrv) GetUserPostStarCount(userID int64) (res int64, err error) {
-	err = s.q.GetUserPostStarCount.Get(&res, userID)
+	err = s.q.GetUserPostStarCount.Get(&res, userID, userID)
 	return
 }
 
-func (s *tweetSrv) GetUserPostCollection(postID, userID int64) (*ms.PostCollection, error) {
-	res := &ms.PostCollection{}
-	err := s.q.GetUserPostCollection.Get(res, postID, userID)
-	return res, err
+func (s *tweetSrv) GetUserPostCollection(postID, userID int64) (res *ms.PostCollection, err error) {
+	err = s.q.GetUserPostCollection.Get(res, postID, userID, userID)
+	return
 }
 
-func (s *tweetSrv) GetUserPostCollections(userID int64, offset, limit int) ([]*ms.PostCollection, error) {
-	res := []*ms.PostCollection{}
-	err := s.q.GetUserPostCollections.Select(&res, userID, limit, offset)
+func (s *tweetSrv) GetUserPostCollections(userID int64, offset, limit int) (res []*ms.PostCollection, err error) {
+	err = s.q.GetUserPostCollections.Select(&res, userID, userID, limit, offset)
 	return res, err
 }
 
 func (s *tweetSrv) GetUserPostCollectionCount(userID int64) (res int64, err error) {
-	err = s.q.GetUserPostCollectionCount.Get(&res)
+	err = s.q.GetUserPostCollectionCount.Get(&res, userID, userID)
 	return
 }
 
-func (s *tweetSrv) GetPostAttatchmentBill(postID, userID int64) (*ms.PostAttachmentBill, error) {
-	res := &ms.PostAttachmentBill{}
-	err := s.q.GetPostAttachmentBill.Get(res, postID, userID)
-	return res, err
+func (s *tweetSrv) GetPostAttatchmentBill(postID, userID int64) (res *ms.PostAttachmentBill, err error) {
+	err = s.q.GetPostAttachmentBill.Get(res, postID, userID)
+	return
 }
 
 func (s *tweetSrv) GetPostContentsByIDs(ids []int64) (res []*ms.PostContent, err error) {
@@ -377,10 +395,9 @@ func (s *tweetSrv) GetPostContentsByIDs(ids []int64) (res []*ms.PostContent, err
 	return
 }
 
-func (s *tweetSrv) GetPostContentByID(id int64) (*ms.PostContent, error) {
-	res := &ms.PostContent{}
-	err := s.q.GetPostContentById.Get(res, id)
-	return res, err
+func (s *tweetSrv) GetPostContentByID(id int64) (res *ms.PostContent, err error) {
+	err = s.q.GetPostContentById.Get(res, id)
+	return
 }
 
 func (s *tweetSrvA) TweetInfoById(id int64) (*cs.TweetInfo, error) {

internal/dao/sakila/yesql/cc/yesql.go

@@ -91,17 +91,17 @@ const (
 	_TweetA_UserTweetsBySelf                   = `SELECT * FROM @user WHERE username=?`
 	_Tweet_GetAnyPostCount                     = `SELECT count(*) FROM @post WHERE visibility IN (?)`
 	_Tweet_GetAnyPosts                         = `SELECT * FROM @post WHERE visibility IN (?) AND is_del=0 LIMIT ? OFFSET ?`
-	_Tweet_GetPostAttachmentBill             = `SELECT * FROM @user WHERE username=?`
+	_Tweet_GetPostAttachmentBill               = `SELECT * FROM @post_attachment_bill WHERE post_id=? AND user_id=? AND is_del=0`
 	_Tweet_GetPostById                         = `SELECT * FROM @post WHERE id=? AND is_del=0`
-	_Tweet_GetPostContentById                = `SELECT * FROM @user WHERE username=?`
+	_Tweet_GetPostContentById                  = `SELECT * FROM @post_content WHERE id=? AND is_del=0`
 	_Tweet_GetPostContentsByIds                = `SELECT * FROM @post_content WHERE post_id IN (?) AND is_del=0`
-	_Tweet_GetUserPostCollection             = `SELECT * FROM @user WHERE username=?`
-	_Tweet_GetUserPostCollectionCount        = `SELECT * FROM @user WHERE username=?`
-	_Tweet_GetUserPostCollections            = `SELECT * FROM @user WHERE username=?`
+	_Tweet_GetUserPostCollection               = `SELECT 	s.*, 	P.ID "post.id", 	P.user_id "post.user_id", 	P.comment_count "post.comment_count", 	P.collection_count "post.collection_count", 	P.upvote_count "post.upvote_count", 	P.share_count "post.share_count", 	P.visibility "post.visibility", 	P.is_top "post.is_top", 	P.is_essence "post.is_essence", 	P.is_lock "post.is_lock", 	P.latest_replied_on "post.latest_replied_on", 	P.tags "post.tags", 	P.attachment_price "post.attachment_price", 	P.ip "post.ip", 	P.ip_loc "post.ip_loc", 	P.is_del "post.is_del", 	P.created_on "post.created_on", 	P.modified_on "post.modified_on", 	P.deleted_on "post.deleted_on" FROM 	@post_collection s 	JOIN @post P ON s.post_id = P.ID WHERE 	s.post_id = ? 	AND s.user_id = ? 	AND s.is_del = 0 	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) ORDER BY 	P.ID DESC`
+	_Tweet_GetUserPostCollectionCount          = `SELECT count(*) FROM 	@post_collection s 	JOIN @post P ON s.post_id = P.ID WHERE 	s.user_id = ? 	AND s.is_del = 0 	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) )`
+	_Tweet_GetUserPostCollections              = `SELECT 	s.*, 	P.ID "post.id", 	P.user_id "post.user_id", 	P.comment_count "post.comment_count", 	P.collection_count "post.collection_count", 	P.upvote_count "post.upvote_count", 	P.share_count "post.share_count", 	P.visibility "post.visibility", 	P.is_top "post.is_top", 	P.is_essence "post.is_essence", 	P.is_lock "post.is_lock", 	P.latest_replied_on "post.latest_replied_on", 	P.tags "post.tags", 	P.attachment_price "post.attachment_price", 	P.ip "post.ip", 	P.ip_loc "post.ip_loc", 	P.is_del "post.is_del", 	P.created_on "post.created_on", 	P.modified_on "post.modified_on", 	P.deleted_on "post.deleted_on" FROM 	@post_collection s 	JOIN @post P ON s.post_id = P.ID WHERE 	s.user_id = ? 	AND s.is_del = 0 	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) ORDER BY s.ID DESC, 	P.ID DESC LIMIT ? OFFSET ?`
 	_Tweet_GetUserPostCount                    = `SELECT count(*) FROM @post WHERE user_id=? AND visibility IN (?)`
-	_Tweet_GetUserPostStar                   = `SELECT * FROM @user WHERE username=?`
-	_Tweet_GetUserPostStarCount              = `SELECT * FROM @user WHERE username=?`
-	_Tweet_GetUserPostStars                  = `SELECT * FROM @user WHERE username=?`
+	_Tweet_GetUserPostStar                     = `SELECT 	s.*, 	P.ID "post.id", 	P.user_id "post.user_id", 	P.comment_count "post.comment_count", 	P.collection_count "post.collection_count", 	P.upvote_count "post.upvote_count", 	P.share_count "post.share_count", 	P.visibility "post.visibility", 	P.is_top "post.is_top", 	P.is_essence "post.is_essence", 	P.is_lock "post.is_lock", 	P.latest_replied_on "post.latest_replied_on", 	P.tags "post.tags", 	P.attachment_price "post.attachment_price", 	P.ip "post.ip", 	P.ip_loc "post.ip_loc", 	P.is_del "post.is_del", 	P.created_on "post.created_on", 	P.modified_on "post.modified_on", 	P.deleted_on "post.deleted_on" FROM 	@post_star s 	JOIN @post P ON s.post_id = P.ID WHERE 	s.post_id = ? 	AND s.user_id = ? 	AND s.is_del = 0 	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) ORDER BY 	P.ID DESC`
+	_Tweet_GetUserPostStarCount                = `SELECT count(*) FROM 	@post_star s 	JOIN @post P ON s.post_id = P.ID WHERE 	s.user_id = ? 	AND s.is_del = 0 	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) )`
+	_Tweet_GetUserPostStars                    = `SELECT 	s.*, 	P.ID "post.id", 	P.user_id "post.user_id", 	P.comment_count "post.comment_count", 	P.collection_count "post.collection_count", 	P.upvote_count "post.upvote_count", 	P.share_count "post.share_count", 	P.visibility "post.visibility", 	P.is_top "post.is_top", 	P.is_essence "post.is_essence", 	P.is_lock "post.is_lock", 	P.latest_replied_on "post.latest_replied_on", 	P.tags "post.tags", 	P.attachment_price "post.attachment_price", 	P.ip "post.ip", 	P.ip_loc "post.ip_loc", 	P.is_del "post.is_del", 	P.created_on "post.created_on", 	P.modified_on "post.modified_on", 	P.deleted_on "post.deleted_on" FROM 	@post_star s 	JOIN @post P ON s.post_id = P.ID WHERE 	s.user_id = ? 	AND s.is_del = 0 	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) ORDER BY s.ID DESC, 	P.ID DESC LIMIT ? OFFSET ?`
 	_Tweet_GetUserPosts                        = `SELECT * FROM @post WHERE user_id=? AND visibility IN (?) ORDER BY latest_replies_on DESC LIMIT ? OFFSET ?`
 	_TweetHelpA_UserInfo                       = `SELECT * FROM @user WHERE username=?`
 	_TweetHelp_GetPostContentByIds             = `SELECT id, post_id, content, type, sort FROM @post_content WHERE post_id IN (?) AND is_del=0`
@@ -112,9 +112,14 @@ const (
 	_TweetManage_AddPostCollection             = `INSERT INTO @post_collection (post_id, user_id, created_on) VALUES (?, ?, ?)`
 	_TweetManage_AddPostContent                = `INSERT INTO @post_content (post_id, user_id, content, type, sort, created_on) VALUES (:post_id, :user_id, :content, :type, :sort, :created_on)`
 	_TweetManage_AddPostStar                   = `INSERT INTO @post_star (post_id, user_id, created_on) VALUES (?, ?, ?)`
+	_TweetManage_CommentIdsByPostId            = `SELECT id FROM @comment WHERE post_id=? AND is_del=0`
+	_TweetManage_CommentMediaFromCommentIds    = `SELECT content FROM @comment_content WHERE comment_id IN (?) AND type=3 AND is_del=0`
+	_TweetManage_DelCommentByPostId            = `UPDATE @comment SET deleted_on=?, is_del=1 WHERE post_id=? AND is_del=0`
+	_TweetManage_DelCommentContentByCommentIds = `UPDATE @comment_content SET deleted_on=?, is_del=1 WHERE comment_id IN (?) AND is_del=0`
 	_TweetManage_DelPostById                   = `UPDATE @post SET is_del=1, deleted_on=? WHERE id=? AND is_del=0`
 	_TweetManage_DelPostCollection             = `UPDATE @post_collection SET is_del=1, deleted_on=? WHERE id=? AND is_del=0`
 	_TweetManage_DelPostStar                   = `UPDATE @post_star SET is_del=1, deleted_on=? WHERE id=? AND is_del=0`
+	_TweetManage_DelReplyByCommentIds          = `UPDATE @comment_reply SET deleted_on=?, is_del=1 WHERE comment_id IN (?) AND is_del=0`
 	_TweetManage_LockPost                      = `UPDATE @post SET is_lock=1-is_lock, modified_on=? WHERE id=? AND is_del=0`
 	_TweetManage_MediaContentByPostId          = `SELECT content FROM post_content WHERE post_id=? AND is_del=0 AND type IN (3, 4, 5, 7, 8)`
 	_TweetManage_StickPost                     = `UPDATE @post SET is_top=1-is_top, modified_on=? WHERE id=? AND is_del=0`
@@ -317,9 +322,14 @@ type TweetHelpA struct {
 
 type TweetManage struct {
 	yesql.Namespace               `yesql:"tweet_manage"`
+	CommentMediaFromCommentIds    string          `yesql:"comment_media_from_comment_ids"`
+	DelCommentContentByCommentIds string          `yesql:"del_comment_content_by_comment_ids"`
+	DelReplyByCommentIds          string          `yesql:"del_reply_by_comment_ids"`
 	AddAttachment                 *sqlx.Stmt      `yesql:"add_attachment"`
 	AddPostCollection             *sqlx.Stmt      `yesql:"add_post_collection"`
 	AddPostStar                   *sqlx.Stmt      `yesql:"add_post_star"`
+	CommentIdsByPostId            *sqlx.Stmt      `yesql:"comment_ids_by_post_id"`
+	DelCommentByPostId            *sqlx.Stmt      `yesql:"del_comment_by_post_id"`
 	DelPostById                   *sqlx.Stmt      `yesql:"del_post_by_id"`
 	DelPostCollection             *sqlx.Stmt      `yesql:"del_post_collection"`
 	DelPostStar                   *sqlx.Stmt      `yesql:"del_post_star"`
@@ -839,7 +849,11 @@ func BuildTweetManage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Twe
 	} else {
 		c = context.Background()
 	}
-	obj = &TweetManage{}
+	obj = &TweetManage{
+		CommentMediaFromCommentIds:    p.QueryHook(_TweetManage_CommentMediaFromCommentIds),
+		DelCommentContentByCommentIds: p.QueryHook(_TweetManage_DelCommentContentByCommentIds),
+		DelReplyByCommentIds:          p.QueryHook(_TweetManage_DelReplyByCommentIds),
+	}
 	if obj.AddAttachment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddAttachment))); err != nil {
 		return
 	}
@@ -849,6 +863,12 @@ func BuildTweetManage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Twe
 	if obj.AddPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostStar))); err != nil {
 		return
 	}
+	if obj.CommentIdsByPostId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_CommentIdsByPostId))); err != nil {
+		return
+	}
+	if obj.DelCommentByPostId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelCommentByPostId))); err != nil {
+		return
+	}
 	if obj.DelPostById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostById))); err != nil {
 		return
 	}

internal/dao/sakila/yesql/yesql.sql

@@ -358,41 +358,180 @@ SELECT count(*) FROM @post WHERE visibility IN (?);
 
 -- name: get_user_post_star@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT
+	s.*,
+	P.ID "post.id",
+	P.user_id "post.user_id",
+	P.comment_count "post.comment_count",
+	P.collection_count "post.collection_count",
+	P.upvote_count "post.upvote_count",
+	P.share_count "post.share_count",
+	P.visibility "post.visibility",
+	P.is_top "post.is_top",
+	P.is_essence "post.is_essence",
+	P.is_lock "post.is_lock",
+	P.latest_replied_on "post.latest_replied_on",
+	P.tags "post.tags",
+	P.attachment_price "post.attachment_price",
+	P.ip "post.ip",
+	P.ip_loc "post.ip_loc",
+	P.is_del "post.is_del",
+	P.created_on "post.created_on",
+	P.modified_on "post.modified_on",
+	P.deleted_on "post.deleted_on" 
+FROM
+	@post_star s
+	JOIN @post P ON s.post_id = P.ID 
+WHERE
+	s.post_id = ? 
+	AND s.user_id = ? 
+	AND s.is_del = 0 
+	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) 
+ORDER BY
+	P.ID DESC;
 
 -- name: get_user_post_stars@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT
+	s.*,
+	P.ID "post.id",
+	P.user_id "post.user_id",
+	P.comment_count "post.comment_count",
+	P.collection_count "post.collection_count",
+	P.upvote_count "post.upvote_count",
+	P.share_count "post.share_count",
+	P.visibility "post.visibility",
+	P.is_top "post.is_top",
+	P.is_essence "post.is_essence",
+	P.is_lock "post.is_lock",
+	P.latest_replied_on "post.latest_replied_on",
+	P.tags "post.tags",
+	P.attachment_price "post.attachment_price",
+	P.ip "post.ip",
+	P.ip_loc "post.ip_loc",
+	P.is_del "post.is_del",
+	P.created_on "post.created_on",
+	P.modified_on "post.modified_on",
+	P.deleted_on "post.deleted_on" 
+FROM
+	@post_star s
+	JOIN @post P ON s.post_id = P.ID 
+WHERE
+	s.user_id = ? 
+	AND s.is_del = 0 
+	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) 
+ORDER BY
+    s.ID DESC,
+	P.ID DESC
+LIMIT ? OFFSET ?;
 
 -- name: get_user_post_star_count@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT
+    count(*) 
+FROM
+	@post_star s
+	JOIN @post P ON s.post_id = P.ID 
+WHERE
+	s.user_id = ? 
+	AND s.is_del = 0 
+	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) );
 
 -- name: get_user_post_collection@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT
+	s.*,
+	P.ID "post.id",
+	P.user_id "post.user_id",
+	P.comment_count "post.comment_count",
+	P.collection_count "post.collection_count",
+	P.upvote_count "post.upvote_count",
+	P.share_count "post.share_count",
+	P.visibility "post.visibility",
+	P.is_top "post.is_top",
+	P.is_essence "post.is_essence",
+	P.is_lock "post.is_lock",
+	P.latest_replied_on "post.latest_replied_on",
+	P.tags "post.tags",
+	P.attachment_price "post.attachment_price",
+	P.ip "post.ip",
+	P.ip_loc "post.ip_loc",
+	P.is_del "post.is_del",
+	P.created_on "post.created_on",
+	P.modified_on "post.modified_on",
+	P.deleted_on "post.deleted_on" 
+FROM
+	@post_collection s
+	JOIN @post P ON s.post_id = P.ID 
+WHERE
+	s.post_id = ? 
+	AND s.user_id = ? 
+	AND s.is_del = 0 
+	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) 
+ORDER BY
+	P.ID DESC;
 
 -- name: get_user_post_collections@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT
+	s.*,
+	P.ID "post.id",
+	P.user_id "post.user_id",
+	P.comment_count "post.comment_count",
+	P.collection_count "post.collection_count",
+	P.upvote_count "post.upvote_count",
+	P.share_count "post.share_count",
+	P.visibility "post.visibility",
+	P.is_top "post.is_top",
+	P.is_essence "post.is_essence",
+	P.is_lock "post.is_lock",
+	P.latest_replied_on "post.latest_replied_on",
+	P.tags "post.tags",
+	P.attachment_price "post.attachment_price",
+	P.ip "post.ip",
+	P.ip_loc "post.ip_loc",
+	P.is_del "post.is_del",
+	P.created_on "post.created_on",
+	P.modified_on "post.modified_on",
+	P.deleted_on "post.deleted_on" 
+FROM
+	@post_collection s
+	JOIN @post P ON s.post_id = P.ID 
+WHERE
+	s.user_id = ? 
+	AND s.is_del = 0 
+	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) ) 
+ORDER BY
+    s.ID DESC,
+	P.ID DESC
+LIMIT ? OFFSET ?;
 
 -- name: get_user_post_collection_count@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT
+    count(*) 
+FROM
+	@post_collection s
+	JOIN @post P ON s.post_id = P.ID 
+WHERE
+	s.user_id = ? 
+	AND s.is_del = 0 
+	AND ( visibility <> 1 OR ( visibility = 1 AND P.user_id = ? ) );
 
 -- name: get_post_attachment_bill@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT * FROM @post_attachment_bill WHERE post_id=? AND user_id=? AND is_del=0;
 
 -- name: get_post_contents_by_ids@tweet
 -- prepare: raw
 -- clause: in
-SELECT * FROM @post_content 
+SELECT * 
+FROM @post_content 
 WHERE post_id IN (?) AND is_del=0;
 
 -- name: get_post_content_by_id@tweet
 -- prepare: stmt
-SELECT * FROM @user WHERE username=?
+SELECT * FROM @post_content WHERE id=? AND is_del=0;
 
 --------------------------------------------------------------------------------
 -- tweet_manage sql dml
@@ -460,6 +599,29 @@ VALUES (:post_id, :user_id, :content, :type, :sort, :created_on);
 INSERT INTO @attachment (user_id, file_size, img_width, img_height, type, content, created_on)
 VALUES (?, ?, ?, ?, ?, ?, ?);
 
+-- name: comment_ids_by_post_id@tweet_manage
+-- prepare: stmt
+SELECT id FROM @comment WHERE post_id=? AND is_del=0;
+
+-- name: comment_media_from_comment_ids@tweet_manage
+-- prepare: raw
+-- clause: in
+SELECT content FROM @comment_content WHERE comment_id IN (?) AND type=3 AND is_del=0;
+
+-- name: del_comment_by_post_id@tweet_manage
+-- prepare: stmt
+UPDATE @comment SET deleted_on=?, is_del=1 WHERE post_id=? AND is_del=0;
+
+-- name: del_comment_content_by_comment_ids@tweet_manage
+-- prepare: raw
+-- clause: in
+UPDATE @comment_content SET deleted_on=?, is_del=1 WHERE comment_id IN (?) AND is_del=0;
+
+-- name: del_reply_by_comment_ids@tweet_manage
+-- prepare: raw
+-- clause: in
+UPDATE @comment_reply SET deleted_on=?, is_del=1 WHERE comment_id IN (?) AND is_del=0;
+
 --------------------------------------------------------------------------------
 -- tweet_help sql dml
 --------------------------------------------------------------------------------