From 290f5ce85b18e607f90af0cc661ea5284e145442 Mon Sep 17 00:00:00 2001 From: Jay Date: Tue, 17 Sep 2019 13:56:27 +0000 Subject: [PATCH] add command impl --- database/impl/public/command.go | 90 ++++++++++++++++++++++++++++++--- 1 file changed, 84 insertions(+), 6 deletions(-) diff --git a/database/impl/public/command.go b/database/impl/public/command.go index 18a2f8a..714b0cb 100644 --- a/database/impl/public/command.go +++ b/database/impl/public/command.go @@ -32,7 +32,7 @@ func (c *CommandImpl) Delete(key string, platform string, binding string) error sq.Eq{"key": key}, sq.Eq{"platform": platform}, sq.Eq{"binding": binding}, - }) + }).ToSql() if err != nil { return err } @@ -44,22 +44,100 @@ func (c *CommandImpl) Delete(key string, platform string, binding string) error return nil } +// GetByKey - func (c *CommandImpl) GetByKey(key string) ([]pubmodel.Command, error) { - panic("not implemented") + query, args, err := sq.Select("key", "platform", "binding", "require_manage", "require_init", "value", "ctime", "mtime"). + From(`"public"."command"`).Where(sq.Eq{"key": key}).ToSql() + if err != nil { + return nil, err + } + query = x.Rebind(query) + + list := make([]pubmodel.Command, 0) + err = x.Select(&list, query, args...) + if err != nil { + return nil, err + } + + return list, nil } +// GetByKeyPlatform - func (c *CommandImpl) GetByKeyPlatform(key string, platform string) ([]pubmodel.Command, error) { - panic("not implemented") + query, args, err := sq.Select("key", "platform", "binding", "require_manage", "require_init", "value", "ctime", "mtime"). + From(`"public"."command"`).Where(sq.And{ + sq.Eq{"key": key}, + sq.Eq{"platform": platform}, + }).ToSql() + if err != nil { + return nil, err + } + + query = x.Rebind(query) + list := make([]pubmodel.Command, 0) + err = x.Select(&list, query, args...) + if err != nil { + return nil, err + } + + return list, nil } +// GetByKeyPlatformBinding - func (c *CommandImpl) GetByKeyPlatformBinding(key string, platform string, binding string) ([]pubmodel.Command, error) { - panic("not implemented") + query, args, err := sq.Select("key", "platform", "binding", "require_manage", "require_init", "value", "ctime", "mtime"). + From(`"public"."command"`).Where(sq.And{ + sq.Eq{"key": key}, + sq.Eq{"platform": platform}, + sq.Eq{"binding": binding}, + }).ToSql() + if err != nil { + return nil, err + } + + query = x.Rebind(query) + list := make([]pubmodel.Command, 0) + err = x.Select(&list, query, args...) + if err != nil { + return nil, err + } + return list, nil } +// GetByPlatformBinding - func (c *CommandImpl) GetByPlatformBinding(platform string, binding string) ([]pubmodel.Command, error) { - panic("not implemented") + query, args, err := sq.Select("key", "platform", "binding", "require_manage", "require_init", "value", "ctime", "mtime"). + From(`"public"."command"`).Where(sq.And{ + sq.Eq{"platform": platform}, + sq.Eq{"binding": binding}, + }).ToSql() + if err != nil { + return nil, err + } + query = x.Rebind(query) + list := make([]pubmodel.Command, 0) + err = x.Select(&list, query, args...) + if err != nil { + return nil, err + } + return list, nil } +// GetByKeyBinding - func (c *CommandImpl) GetByKeyBinding(key string, binding string) ([]pubmodel.Command, error) { - panic("not implemented") + query, args, err := sq.Select("key", "platform", "binding", "require_manage", "require_init", "value", "ctime", "mtime"). + From(`"public"."command"`).Where(sq.And{ + sq.Eq{"key": key}, + sq.Eq{"binding": binding}, + }).ToSql() + if err != nil { + return nil, err + } + query = x.Rebind(query) + list := make([]pubmodel.Command, 0) + err = x.Select(&list, query, args...) + if err != nil { + return nil, err + } + return list, nil }