forked from corestoreio/parrot
-
Notifications
You must be signed in to change notification settings - Fork 0
/
user.go
51 lines (40 loc) · 1.7 KB
/
user.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
package postgres
import "github.com/parrot-translate/parrot/parrot-api/model"
func (db *PostgresDB) GetUserByEmail(email string) (*model.User, error) {
u := model.User{}
row := db.QueryRow("SELECT id, name, email, password FROM users WHERE email = $1", email)
err := row.Scan(&u.ID, &u.Name, &u.Email, &u.Password)
if err != nil {
return nil, parseError(err)
}
return &u, nil
}
func (db *PostgresDB) GetUserByID(id string) (*model.User, error) {
u := model.User{}
row := db.QueryRow("SELECT id, name, email, password FROM users WHERE id = $1", id)
err := row.Scan(&u.ID, &u.Name, &u.Email, &u.Password)
if err != nil {
return nil, parseError(err)
}
return &u, nil
}
func (db *PostgresDB) CreateUser(u model.User) (*model.User, error) {
row := db.QueryRow("INSERT INTO users (name, email, password) VALUES($1, $2, $3) RETURNING id, name, email", u.Name, u.Email, u.Password)
err := row.Scan(&u.ID, &u.Name, &u.Email)
return &u, parseError(err)
}
func (db *PostgresDB) UpdateUserPassword(u model.User) (*model.User, error) {
row := db.QueryRow("UPDATE users SET password = $1 WHERE id = $2 RETURNING id, name, email", u.Password, u.ID)
err := row.Scan(&u.ID, &u.Name, &u.Email)
return &u, parseError(err)
}
func (db *PostgresDB) UpdateUserName(u model.User) (*model.User, error) {
row := db.QueryRow("UPDATE users SET name = $1 WHERE id = $2 RETURNING id, name, email", u.Name, u.ID)
err := row.Scan(&u.ID, &u.Name, &u.Email)
return &u, parseError(err)
}
func (db *PostgresDB) UpdateUserEmail(u model.User) (*model.User, error) {
row := db.QueryRow("UPDATE users SET email = $1 WHERE id = $2 RETURNING id, name, email", u.Email, u.ID)
err := row.Scan(&u.ID, &u.Name, &u.Email)
return &u, parseError(err)
}