Skip to content

Commit 0339812

Browse files
committed
Fix bug Repository Load
1 parent 0286003 commit 0339812

File tree

2 files changed

+6
-10
lines changed

2 files changed

+6
-10
lines changed

internal/app/app.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ func NewApp(ctx context.Context, conf Config) (*ApplicationContext, error) {
3636
return nil, err
3737
}
3838

39-
userRepository, err := NewUserClient(conf.Client, log.InfoFields) // userRepository := NewUserRepository(db)
39+
userRepository := NewUserRepository(db) // userRepository, err := NewUserClient(conf.Client, log.InfoFields)
4040
userService := NewUserService(userRepository)
4141
userHandler := NewUserHandler(userSearchBuilder.Search, userService, status, logError, validator.Validate, &action)
4242

internal/usecase/user/user_repository.go

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -24,22 +24,18 @@ type userRepository struct {
2424
}
2525

2626
func (r *userRepository) Load(ctx context.Context, id string) (*User, error) {
27-
query := "select id, username, email, phone, date_of_birth from users"
28-
rows, err := r.DB.QueryContext(ctx, query)
27+
query := "select id, username, email, phone, date_of_birth from users where id = ?"
28+
rows, err := r.DB.QueryContext(ctx, query, id)
2929
if err != nil {
3030
return nil, err
3131
}
32-
var result []User
32+
defer rows.Close()
3333
for rows.Next() {
3434
var user User
3535
err = rows.Scan(&user.Id, &user.Username, &user.Phone, &user.Email, &user.DateOfBirth)
36-
result = append(result, user)
37-
}
38-
if len(result) > 0 {
39-
return &result[0], nil
40-
} else {
41-
return nil, nil
36+
return &user, nil
4237
}
38+
return nil, nil
4339
}
4440

4541
func (r *userRepository) Create(ctx context.Context, user *User) (int64, error) {

0 commit comments

Comments
 (0)