pss/user/repository/sqlUserRepository.go

package repository

import (
	"database/sql"
	"log"
	"pss/domain"
)

type sqlUserRepository struct {
	Conn *sql.DB
}

func NewUserRepository(conn *sql.DB) domain.UserRepository {
	return &sqlUserRepository{conn}
}

func (repo sqlUserRepository) GetByNamePwd(name, pwd string) (domain.User, error) {
	rows, err := repo.Conn.Query("select * from pss_user where name = $1 and pwd = $2 limit 1", name, pwd)
	defer rows.Close()
	if err != nil {
		return domain.User{}, err
	}
	var user domain.User
	for rows.Next() {
		if err := rows.Scan(&user.Id, &user.Name, &user.Pwd, &user.Creator, &user.CreateAt); err != nil {
			log.Fatal(err)
		}
	}
	return user, nil
}