mirror of
https://github.com/usememos/memos.git
synced 2025-02-11 08:50:40 +01:00
chore: retire tag store
This commit is contained in:
Steven
parent
d0655ece53
commit
292861be16
@ -1,64 +0,0 @@
|
||||
package mysql
|
||||
|
||||
import (
|
||||
"context"
|
||||
"strings"
|
||||
|
||||
"github.com/usememos/memos/store"
|
||||
)
|
||||
|
||||
func (d *DB) UpsertTag(ctx context.Context, upsert *store.Tag) (*store.Tag, error) {
|
||||
stmt := "INSERT INTO `tag` (`name`, `creator_id`) VALUES (?, ?) ON DUPLICATE KEY UPDATE `name` = ?"
|
||||
if _, err := d.db.ExecContext(ctx, stmt, upsert.Name, upsert.CreatorID, upsert.Name); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return upsert, nil
|
||||
}
|
||||
|
||||
func (d *DB) ListTags(ctx context.Context, find *store.FindTag) ([]*store.Tag, error) {
|
||||
where, args := []string{"1 = 1"}, []any{}
|
||||
|
||||
if find.CreatorID != 0 {
|
||||
where, args = append(where, "`creator_id` = ?"), append(args, find.CreatorID)
|
||||
}
|
||||
|
||||
query := "SELECT `name`, `creator_id` FROM `tag` WHERE " + strings.Join(where, " AND ") + " ORDER BY name ASC"
|
||||
rows, err := d.db.QueryContext(ctx, query, args...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer rows.Close()
|
||||
|
||||
list := []*store.Tag{}
|
||||
for rows.Next() {
|
||||
tag := &store.Tag{}
|
||||
if err := rows.Scan(
|
||||
&tag.Name,
|
||||
&tag.CreatorID,
|
||||
); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
list = append(list, tag)
|
||||
}
|
||||
|
||||
if err := rows.Err(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return list, nil
|
||||
}
|
||||
|
||||
func (d *DB) DeleteTag(ctx context.Context, delete *store.DeleteTag) error {
|
||||
where, args := []string{"`name` = ?", "`creator_id` = ?"}, []any{delete.Name, delete.CreatorID}
|
||||
stmt := "DELETE FROM `tag` WHERE " + strings.Join(where, " AND ")
|
||||
result, err := d.db.ExecContext(ctx, stmt, args...)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if _, err = result.RowsAffected(); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
@ -1,70 +0,0 @@
|
||||
package postgres
|
||||
|
||||
import (
|
||||
"context"
|
||||
"strings"
|
||||
|
||||
"github.com/usememos/memos/store"
|
||||
)
|
||||
|
||||
func (d *DB) UpsertTag(ctx context.Context, upsert *store.Tag) (*store.Tag, error) {
|
||||
stmt := "INSERT INTO tag (name, creator_id) VALUES ($1, $2) ON CONFLICT (name, creator_id) DO UPDATE SET name = $3"
|
||||
if _, err := d.db.ExecContext(ctx, stmt, upsert.Name, upsert.CreatorID, upsert.Name); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return upsert, nil
|
||||
}
|
||||
|
||||
func (d *DB) ListTags(ctx context.Context, find *store.FindTag) ([]*store.Tag, error) {
|
||||
where, args := []string{"1 = 1"}, []any{}
|
||||
|
||||
if find.CreatorID != 0 {
|
||||
where, args = append(where, "creator_id = "+placeholder(len(args)+1)), append(args, find.CreatorID)
|
||||
}
|
||||
|
||||
query := `
|
||||
SELECT
|
||||
name,
|
||||
creator_id
|
||||
FROM tag
|
||||
WHERE ` + strings.Join(where, " AND ") + `
|
||||
ORDER BY name ASC
|
||||
`
|
||||
rows, err := d.db.QueryContext(ctx, query, args...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer rows.Close()
|
||||
|
||||
list := []*store.Tag{}
|
||||
for rows.Next() {
|
||||
tag := &store.Tag{}
|
||||
if err := rows.Scan(
|
||||
&tag.Name,
|
||||
&tag.CreatorID,
|
||||
); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
list = append(list, tag)
|
||||
}
|
||||
|
||||
if err := rows.Err(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return list, nil
|
||||
}
|
||||
|
||||
func (d *DB) DeleteTag(ctx context.Context, delete *store.DeleteTag) error {
|
||||
where, args := []string{"name = $1", "creator_id = $2"}, []any{delete.Name, delete.CreatorID}
|
||||
stmt := `DELETE FROM tag WHERE ` + strings.Join(where, " AND ")
|
||||
result, err := d.db.ExecContext(ctx, stmt, args...)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if _, err = result.RowsAffected(); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
@ -1,80 +0,0 @@
|
||||
package sqlite
|
||||
|
||||
import (
|
||||
"context"
|
||||
"strings"
|
||||
|
||||
"github.com/usememos/memos/store"
|
||||
)
|
||||
|
||||
func (d *DB) UpsertTag(ctx context.Context, upsert *store.Tag) (*store.Tag, error) {
|
||||
stmt := `
|
||||
INSERT INTO tag (
|
||||
name, creator_id
|
||||
)
|
||||
VALUES (?, ?)
|
||||
ON CONFLICT(name, creator_id) DO UPDATE
|
||||
SET
|
||||
name = EXCLUDED.name
|
||||
`
|
||||
if _, err := d.db.ExecContext(ctx, stmt, upsert.Name, upsert.CreatorID); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
tag := upsert
|
||||
return tag, nil
|
||||
}
|
||||
|
||||
func (d *DB) ListTags(ctx context.Context, find *store.FindTag) ([]*store.Tag, error) {
|
||||
where, args := []string{"1 = 1"}, []any{}
|
||||
|
||||
if find.CreatorID != 0 {
|
||||
where, args = append(where, "`creator_id` = ?"), append(args, find.CreatorID)
|
||||
}
|
||||
|
||||
query := `
|
||||
SELECT
|
||||
name,
|
||||
creator_id
|
||||
FROM tag
|
||||
WHERE ` + strings.Join(where, " AND ") + `
|
||||
ORDER BY name ASC
|
||||
`
|
||||
rows, err := d.db.QueryContext(ctx, query, args...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer rows.Close()
|
||||
|
||||
list := []*store.Tag{}
|
||||
for rows.Next() {
|
||||
tag := &store.Tag{}
|
||||
if err := rows.Scan(
|
||||
&tag.Name,
|
||||
&tag.CreatorID,
|
||||
); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
list = append(list, tag)
|
||||
}
|
||||
|
||||
if err := rows.Err(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return list, nil
|
||||
}
|
||||
|
||||
func (d *DB) DeleteTag(ctx context.Context, delete *store.DeleteTag) error {
|
||||
where, args := []string{"name = ?", "creator_id = ?"}, []any{delete.Name, delete.CreatorID}
|
||||
stmt := `DELETE FROM tag WHERE ` + strings.Join(where, " AND ")
|
||||
result, err := d.db.ExecContext(ctx, stmt, args...)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if _, err = result.RowsAffected(); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
@ -67,11 +67,6 @@ type Driver interface {
|
||||
UpdateIdentityProvider(ctx context.Context, update *UpdateIdentityProvider) (*IdentityProvider, error)
|
||||
DeleteIdentityProvider(ctx context.Context, delete *DeleteIdentityProvider) error
|
||||
|
||||
// Tag model related methods.
|
||||
UpsertTag(ctx context.Context, upsert *Tag) (*Tag, error)
|
||||
ListTags(ctx context.Context, find *FindTag) ([]*Tag, error)
|
||||
DeleteTag(ctx context.Context, delete *DeleteTag) error
|
||||
|
||||
// Inbox model related methods.
|
||||
CreateInbox(ctx context.Context, create *Inbox) (*Inbox, error)
|
||||
ListInboxes(ctx context.Context, find *FindInbox) ([]*Inbox, error)
|
||||
|
||||
31
store/tag.go
31
store/tag.go
@ -1,31 +0,0 @@
|
||||
package store
|
||||
|
||||
import (
|
||||
"context"
|
||||
)
|
||||
|
||||
type Tag struct {
|
||||
Name string
|
||||
CreatorID int32
|
||||
}
|
||||
|
||||
type FindTag struct {
|
||||
CreatorID int32
|
||||
}
|
||||
|
||||
type DeleteTag struct {
|
||||
Name string
|
||||
CreatorID int32
|
||||
}
|
||||
|
||||
func (s *Store) UpsertTag(ctx context.Context, upsert *Tag) (*Tag, error) {
|
||||
return s.driver.UpsertTag(ctx, upsert)
|
||||
}
|
||||
|
||||
func (s *Store) ListTags(ctx context.Context, find *FindTag) ([]*Tag, error) {
|
||||
return s.driver.ListTags(ctx, find)
|
||||
}
|
||||
|
||||
func (s *Store) DeleteTag(ctx context.Context, delete *DeleteTag) error {
|
||||
return s.driver.DeleteTag(ctx, delete)
|
||||
}
|
||||
@ -1,39 +0,0 @@
|
||||
package teststore
|
||||
|
||||
import (
|
||||
"context"
|
||||
"testing"
|
||||
|
||||
"github.com/stretchr/testify/require"
|
||||
|
||||
"github.com/usememos/memos/store"
|
||||
)
|
||||
|
||||
func TestTagStore(t *testing.T) {
|
||||
ctx := context.Background()
|
||||
ts := NewTestingStore(ctx, t)
|
||||
user, err := createTestingHostUser(ctx, ts)
|
||||
require.NoError(t, err)
|
||||
tag, err := ts.UpsertTag(ctx, &store.Tag{
|
||||
CreatorID: user.ID,
|
||||
Name: "test_tag",
|
||||
})
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, "test_tag", tag.Name)
|
||||
require.Equal(t, user.ID, tag.CreatorID)
|
||||
tags, err := ts.ListTags(ctx, &store.FindTag{
|
||||
CreatorID: user.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, 1, len(tags))
|
||||
require.Equal(t, tag, tags[0])
|
||||
err = ts.DeleteTag(ctx, &store.DeleteTag{
|
||||
Name: "test_tag",
|
||||
CreatorID: user.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
tags, err = ts.ListTags(ctx, &store.FindTag{})
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, 0, len(tags))
|
||||
ts.Close()
|
||||
}
|
||||
Loading…
x
Reference in New Issue
Block a user