本文整理汇总了Golang中github.com/husio/x/storage/pg.Getter类的典型用法代码示例。如果您正苦于以下问题:Golang Getter类的具体用法?Golang Getter怎么用?Golang Getter使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Getter类的16个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: Subscribe
func Subscribe(g pg.Getter, subscriber int64, link string) (*Subscription, error) {
now := time.Now()
var sub Subscription
err := g.Get(&sub.Source, `
INSERT INTO sources (link, created)
VALUES ($1, $2)
ON CONFLICT DO NOTHING
RETURNING *
`, link, now)
if err != nil {
return nil, pg.CastErr(err)
}
err = g.Get(&sub, `
INSERT INTO subscriptions (subscriber_id, source_id, created)
VALUES ($1, $2, $3)
ON CONFLICT DO NOTHING
RETURNING *
`, subscriber, sub.Source.SourceID, now)
if err != nil {
return nil, pg.CastErr(err)
}
return &sub, err
}
开发者ID:husio,项目名称:apps,代码行数:26,代码来源:source.go
示例2: AccountByLogin
func AccountByLogin(g pg.Getter, login, provider string) (*Account, error) {
var a Account
err := g.Get(&a, `
SELECT * FROM accounts WHERE login = $1 AND provider = $2
LIMIT 1
`, login, provider)
return &a, pg.CastErr(err)
}
开发者ID:husio,项目名称:x,代码行数:8,代码来源:storage.go
示例3: AccountByID
func AccountByID(g pg.Getter, accountID int) (*Account, error) {
var a Account
err := g.Get(&a, `
SELECT * FROM accounts WHERE account_id = $1
LIMIT 1
`, accountID)
return &a, pg.CastErr(err)
}
开发者ID:husio,项目名称:x,代码行数:8,代码来源:storage.go
示例4: NoteByID
func NoteByID(g pg.Getter, noteID int) (*Note, error) {
var n Note
err := g.Get(&n, `
SELECT * FROM notes
WHERE note_id = $1 AND (expire_at < $2 OR expire_at IS NULL)
LIMIT 1
`, noteID, time.Now())
return &n, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:9,代码来源:storage.go
示例5: UpdateNote
func UpdateNote(g pg.Getter, note Note) (*Note, error) {
err := g.Get(¬e, `
UPDATE notes
SET content = $1, is_public = $2, expire_at = $3
WHERE note_id = $4
RETURNING *
`, note.Content, note.IsPublic, note.ExpireAt, note.NoteID)
return ¬e, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:9,代码来源:storage.go
示例6: CreateNote
func CreateNote(g pg.Getter, n Note) (*Note, error) {
n.CreatedAt = time.Now()
err := g.Get(&n.NoteID, `
INSERT INTO notes (owner_id, content, expire_at, created_at, is_public)
VALUES ($1, $2, $3, $4, $5)
RETURNING note_id
`, n.OwnerID, n.Content, n.ExpireAt, time.Now(), n.IsPublic)
return &n, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:9,代码来源:storage.go
示例7: PasteByID
func PasteByID(g pg.Getter, pid int64) (*Paste, error) {
var p Paste
err := g.Get(&p, `
SELECT * FROM pastes
WHERE id = $1
LIMIT 1
`, pid)
return &p, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:9,代码来源:storage.go
示例8: CreatePaste
func CreatePaste(g pg.Getter, p Paste) (*Paste, error) {
now := time.Now()
err := g.Get(&p, `
INSERT INTO pastes (content, created, updated)
VALUES ($1, $2, $3)
RETURNING *
`, p.Content, now, now)
return &p, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:9,代码来源:storage.go
示例9: UpdatePaste
func UpdatePaste(g pg.Getter, p Paste) (*Paste, error) {
now := time.Now()
err := g.Get(&p, `
UPDATE pastes
SET content = $1, updated = $2
WHERE id = $3
RETURNING *
`, p.Content, now, p.ID)
return &p, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:10,代码来源:storage.go
示例10: TopicByID
func TopicByID(g pg.Getter, topicID int64) (*Topic, error) {
var t Topic
err := g.Get(&t, `
SELECT * FROM topics WHERE topic_id = $1 LIMIT 1
`, topicID)
if err != nil {
return &t, pg.CastErr(err)
}
return &t, nil
}
开发者ID:husio,项目名称:apps,代码行数:10,代码来源:storage.go
示例11: AccessToken
func AccessToken(g pg.Getter, accountID int) (string, error) {
var token string
err := g.Get(&token, `
SELECT access_token FROM sessions
WHERE account = $1
ORDER BY created DESC
LIMIT 1
`, accountID)
return token, pg.CastErr(err)
}
开发者ID:husio,项目名称:x,代码行数:10,代码来源:storage.go
示例12: SessionAccount
func SessionAccount(g pg.Getter, key string) (*AccountWithScopes, error) {
var a AccountWithScopes
err := g.Get(&a, `
SELECT a.account_id, a.login, a.created, s.scopes
FROM accounts a INNER JOIN sessions s ON s.account = a.account_id
WHERE s.key = $1
LIMIT 1
`, key)
return &a, pg.CastErr(err)
}
开发者ID:husio,项目名称:x,代码行数:10,代码来源:storage.go
示例13: IsNoteOwner
func IsNoteOwner(g pg.Getter, noteID, ownerID int) (bool, error) {
var isOwner bool
err := g.Get(&isOwner, `
SELECT COALESCE(sub.is_owner, false) FROM (
SELECT true AS is_owner FROM notes
WHERE note_id = $1 AND owner_id = $2
LIMIT 1
) sub
`, noteID, ownerID)
return isOwner, pg.CastErr(err)
}
开发者ID:husio,项目名称:apps,代码行数:11,代码来源:storage.go
示例14: CreateComment
func CreateComment(g pg.Getter, c Comment) (*Comment, error) {
now := time.Now()
if c.Created.IsZero() {
c.Created = now
}
c.Updated = now
var cid int64
err := g.Get(&cid, `
INSERT INTO comments (topic_id, author_id, content, created, updated)
VALUES ($1, $2, $3, $4, $5)
RETURNING comment_id
`, c.TopicID, c.AuthorID, c.Content, c.Created, c.Updated)
if err != nil {
return nil, pg.CastErr(err)
}
c.CommentID = cid
return &c, nil
}
开发者ID:husio,项目名称:apps,代码行数:20,代码来源:storage.go
示例15: CreateTopic
func CreateTopic(g pg.Getter, t Topic) (*Topic, error) {
now := time.Now()
if t.Created.IsZero() {
t.Created = now
}
t.Updated = now
var tid int64
err := g.Get(&tid, `
INSERT INTO topics (author_id, title, tags, created, updated)
VALUES ($1, $2, $3, $4, $5)
RETURNING topic_id
`, t.AuthorID, t.Title, t.Tags, t.Created, t.Updated)
if err != nil {
return nil, pg.CastErr(err)
}
t.TopicID = tid
return &t, nil
}
开发者ID:husio,项目名称:apps,代码行数:20,代码来源:storage.go
示例16: CreateSession
func CreateSession(
g pg.Getter,
account int,
key string,
accessToken string,
scopes []string,
) (string, error) {
var ok bool
err := g.Get(&ok, `
INSERT INTO sessions (key, account, created, access_token, provider, scopes)
SELECT $1, $2, $3, $4, a.provider, $5
FROM accounts a WHERE a.account_id = $2 LIMIT 1
RETURNING true
`, key, account, time.Now(), accessToken, strings.Join(scopes, " "))
if err != nil {
return "", pg.CastErr(err)
}
if !ok {
return "", pg.ErrNotFound
}
return key, nil
}
开发者ID:husio,项目名称:x,代码行数:22,代码来源:storage.go
注:本文中的github.com/husio/x/storage/pg.Getter类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论