Documentation ¶
Index ¶
- Constants
- type IMicroblogPostgres
- type MicroBlogPostgres
- func (microblogPostgres *MicroBlogPostgres) BeginTx(ctx context.Context) (tx *sql.Tx, err error)
- func (microblogPostgres *MicroBlogPostgres) CommitTx(tx *sql.Tx) (err error)
- func (microblogPostgres *MicroBlogPostgres) CreatePost(owner *userEntities.User, text string) (err error)
- func (microblogPostgres *MicroBlogPostgres) DislikePost(ID string, user *userEntities.User) (err error)
- func (microblogPostgres *MicroBlogPostgres) GetAllPosts() (posts []*entities.MicroBlog, err error)
- func (microblogPostgres *MicroBlogPostgres) GetAllPostsByUserID(userID string) (posts []*entities.MicroBlog, err error)
- func (microblogPostgres *MicroBlogPostgres) GetPostByID(ID string, internal bool) (post *entities.MicroBlog, err error)
- func (microblogPostgres *MicroBlogPostgres) LikePost(ID string, user *userEntities.User) (err error)
- func (microblogPostgres *MicroBlogPostgres) Open() (DB *sql.DB, err error)
- func (microblogPostgres *MicroBlogPostgres) RollbackTx(tx *sql.Tx) (err error)
Constants ¶
View Source
const ( GetPostByIDDML = `SELECT id, user_id, text, visit_count FROM "microblog" WHERE id = $1` CountLikesDislikesByIDDML = `SELECT count(status) AS count FROM microblog_tracking WHERE microblog_id = $1 AND status = $2` IncrementViewDML = `UPDATE microblog SET visit_count = visit_count + 1 WHERE id = $1` )
View Source
const (
GetAllPostByUserIDDML = `SELECT id, user_id, text FROM "microblog" WHERE user_id = $1 order by creation_date DESC`
)
View Source
const (
GetAllPostDML = `SELECT id, user_id, text FROM "microblog" order by creation_date DESC`
)
View Source
const (
LikeOrDislikeDML = `UPDATE microblog_tracking SET status = $1 WHERE microblog_id = $2 AND user_id = $3`
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IMicroblogPostgres ¶
type IMicroblogPostgres interface { CreatePost(owner *userEntities.User, text string) (err error) GetPostByID(ID string, internal bool) (post *entities.MicroBlog, err error) GetAllPosts() (posts []*entities.MicroBlog, err error) GetAllPostsByUserID(userID string) (posts []*entities.MicroBlog, err error) LikePost(ID string, user *userEntities.User) (err error) DislikePost(ID string, user *userEntities.User) (err error) interfaces.IPostgres }
func NewMicroblogPostgres ¶
func NewMicroblogPostgres() (microblogPostgres IMicroblogPostgres, err error)
type MicroBlogPostgres ¶
type MicroBlogPostgres struct {
*commonEntities.Postgres
}
func (*MicroBlogPostgres) CommitTx ¶
func (microblogPostgres *MicroBlogPostgres) CommitTx(tx *sql.Tx) (err error)
func (*MicroBlogPostgres) CreatePost ¶
func (microblogPostgres *MicroBlogPostgres) CreatePost(owner *userEntities.User, text string) (err error)
func (*MicroBlogPostgres) DislikePost ¶
func (microblogPostgres *MicroBlogPostgres) DislikePost(ID string, user *userEntities.User) (err error)
func (*MicroBlogPostgres) GetAllPosts ¶
func (microblogPostgres *MicroBlogPostgres) GetAllPosts() (posts []*entities.MicroBlog, err error)
func (*MicroBlogPostgres) GetAllPostsByUserID ¶
func (microblogPostgres *MicroBlogPostgres) GetAllPostsByUserID(userID string) (posts []*entities.MicroBlog, err error)
func (*MicroBlogPostgres) GetPostByID ¶
func (*MicroBlogPostgres) LikePost ¶
func (microblogPostgres *MicroBlogPostgres) LikePost(ID string, user *userEntities.User) (err error)
func (*MicroBlogPostgres) Open ¶
func (microblogPostgres *MicroBlogPostgres) Open() (DB *sql.DB, err error)
func (*MicroBlogPostgres) RollbackTx ¶
func (microblogPostgres *MicroBlogPostgres) RollbackTx(tx *sql.Tx) (err error)
Click to show internal directories.
Click to hide internal directories.