feat: improvements in structures

2020-10-01 08:30:36 -03:00
parent 7560bd19a3
commit c008dbab29
18 changed files with 554 additions and 81 deletions
@@ -0,0 +1,76 @@
+package book
+
+import (
+	"strings"
+
+	"github.com/eminetto/clean-architecture-go-v2/domain"
+	"github.com/eminetto/clean-architecture-go-v2/domain/entity"
+)
+
+//InmemRepo in memory repo
+type InmemRepo struct {
+	m map[entity.ID]*entity.Book
+}
+
+//NewInmemRepository create new repository
+func NewInmemRepository() *InmemRepo {
+	var m = map[entity.ID]*entity.Book{}
+	return &InmemRepo{
+		m: m,
+	}
+}
+
+//Create a book
+func (r *InmemRepo) Create(e *entity.Book) (entity.ID, error) {
+	r.m[e.ID] = e
+	return e.ID, nil
+}
+
+//Get a book
+func (r *InmemRepo) Get(id entity.ID) (*entity.Book, error) {
+	if r.m[id] == nil {
+		// return nil, fmt.Errorf("not found")
+		return nil, domain.ErrNotFound
+	}
+	return r.m[id], nil
+}
+
+//Update a book
+func (r *InmemRepo) Update(e *entity.Book) error {
+	_, err := r.Get(e.ID)
+	if err != nil {
+		return err
+	}
+	r.m[e.ID] = e
+	return nil
+}
+
+//Search books
+func (r *InmemRepo) Search(query string) ([]*entity.Book, error) {
+	var d []*entity.Book
+	for _, j := range r.m {
+		if strings.Contains(strings.ToLower(j.Title), query) {
+			d = append(d, j)
+		}
+	}
+	return d, nil
+}
+
+//List books
+func (r *InmemRepo) List() ([]*entity.Book, error) {
+	var d []*entity.Book
+	for _, j := range r.m {
+		d = append(d, j)
+	}
+	return d, nil
+}
+
+//Delete a book
+func (r *InmemRepo) Delete(id entity.ID) error {
+	if r.m[id] == nil {
+		// return fmt.Errorf("not found")
+		return domain.ErrNotFound
+	}
+	r.m[id] = nil
+	return nil
+}
@@ -0,0 +1,127 @@
+package book
+
+import (
+	"database/sql"
+	"time"
+
+	"github.com/eminetto/clean-architecture-go-v2/domain/entity"
+)
+
+//MySQLRepo mysql repo
+type MySQLRepo struct {
+	db *sql.DB
+}
+
+//NewMySQLRepository create new repository
+func NewMySQLRepository(db *sql.DB) *MySQLRepo {
+	return &MySQLRepo{
+		db: db,
+	}
+}
+
+//Create a book
+func (r *MySQLRepo) Create(e *entity.Book) (entity.ID, error) {
+	stmt, err := r.db.Prepare(`
+		insert into book (id, title, author, pages, quantity, created_at) 
+		values(?,?,?,?,?,?)`)
+	if err != nil {
+		return e.ID, err
+	}
+	_, err = stmt.Exec(
+		e.ID,
+		e.Title,
+		e.Author,
+		e.Pages,
+		e.Quantity,
+		time.Now().Format("2006-01-02"),
+	)
+	if err != nil {
+		return e.ID, err
+	}
+	err = stmt.Close()
+	if err != nil {
+		return e.ID, err
+	}
+	return e.ID, nil
+}
+
+//Get a book
+func (r *MySQLRepo) Get(id entity.ID) (*entity.Book, error) {
+	stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book where id = ?`)
+	if err != nil {
+		return nil, err
+	}
+	var b entity.Book
+	rows, err := stmt.Query(id)
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		err = rows.Scan(&b.ID, &b.Title, &b.Author, &b.Pages, &b.Quantity, &b.CreatedAt)
+	}
+	return &b, nil
+}
+
+//Update a book
+func (r *MySQLRepo) Update(e *entity.Book) error {
+	e.UpdatedAt = time.Now()
+	_, err := r.db.Exec("update book set title = ?, author = ?, pages = ?, quantity = ?, updated_at = ? where id = ?", e.Title, e.Author, e.Pages, e.Quantity, e.UpdatedAt.Format("2006-01-02"), e.ID)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+//Search books
+func (r *MySQLRepo) Search(query string) ([]*entity.Book, error) {
+	stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book where title like ?`)
+	if err != nil {
+		return nil, err
+	}
+	var books []*entity.Book
+	rows, err := stmt.Query("%" + query + "%")
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		var b entity.Book
+		err = rows.Scan(&b.ID, &b.Title, &b.Author, &b.Pages, &b.Quantity, &b.CreatedAt)
+		if err != nil {
+			return nil, err
+		}
+		books = append(books, &b)
+	}
+
+	return books, nil
+}
+
+//List books
+func (r *MySQLRepo) List() ([]*entity.Book, error) {
+	stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book`)
+	if err != nil {
+		return nil, err
+	}
+	var books []*entity.Book
+	rows, err := stmt.Query()
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		var b entity.Book
+		err = rows.Scan(&b.ID, &b.Title, &b.Author, &b.Pages, &b.Quantity, &b.CreatedAt)
+		if err != nil {
+			return nil, err
+		}
+		books = append(books, &b)
+	}
+	return books, nil
+}
+
+//Delete a book
+func (r *MySQLRepo) Delete(id entity.ID) error {
+	_, err := r.db.Exec("delete from book where id = ?", id)
+	if err != nil {
+		return err
+	}
+	return nil
+}
@@ -0,0 +1,81 @@
+package user
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/eminetto/clean-architecture-go-v2/domain"
+	"github.com/eminetto/clean-architecture-go-v2/domain/entity"
+)
+
+//IRepo in memory repo
+type IRepo struct {
+	m map[entity.ID]*entity.User
+}
+
+//NewInmemRepository create new repository
+func NewInmemRepository() *IRepo {
+	var m = map[entity.ID]*entity.User{}
+	return &IRepo{
+		m: m,
+	}
+}
+
+//Create an user
+func (r *IRepo) Create(e *entity.User) (entity.ID, error) {
+	r.m[e.ID] = e
+	return e.ID, nil
+}
+
+//Get an user
+func (r *IRepo) Get(id entity.ID) (*entity.User, error) {
+	if r.m[id] == nil {
+		// return nil, fmt.Errorf("not found")
+		return nil, domain.ErrNotFound
+	}
+	return r.m[id], nil
+}
+
+//Update an user
+func (r *IRepo) Update(e *entity.User) error {
+	_, err := r.Get(e.ID)
+	if err != nil {
+		return err
+	}
+	r.m[e.ID] = e
+	return nil
+}
+
+//Search users
+func (r *IRepo) Search(query string) ([]*entity.User, error) {
+	var d []*entity.User
+	for _, j := range r.m {
+		if strings.Contains(strings.ToLower(j.FirstName), query) {
+			d = append(d, j)
+		}
+	}
+	if len(d) == 0 {
+		// return nil, fmt.Errorf("not found")
+		return nil, domain.ErrNotFound
+	}
+
+	return d, nil
+}
+
+//List users
+func (r *IRepo) List() ([]*entity.User, error) {
+	var d []*entity.User
+	for _, j := range r.m {
+		d = append(d, j)
+	}
+	return d, nil
+}
+
+//Delete an user
+func (r *IRepo) Delete(id entity.ID) error {
+	if r.m[id] == nil {
+		return fmt.Errorf("not found")
+	}
+	r.m[id] = nil
+	return nil
+}
@@ -0,0 +1,178 @@
+package user
+
+import (
+	"database/sql"
+	"fmt"
+	"time"
+
+	"github.com/eminetto/clean-architecture-go-v2/domain/entity"
+)
+
+//MySQLRepo mysql repo
+type MySQLRepo struct {
+	db *sql.DB
+}
+
+//NewMySQLRepoRepository create new repository
+func NewMySQLRepoRepository(db *sql.DB) *MySQLRepo {
+	return &MySQLRepo{
+		db: db,
+	}
+}
+
+//Create an user
+func (r *MySQLRepo) Create(e *entity.User) (entity.ID, error) {
+	stmt, err := r.db.Prepare(`
+		insert into user (id, email, password, first_name, last_name, created_at) 
+		values(?,?,?,?,?,?)`)
+	if err != nil {
+		return e.ID, err
+	}
+	_, err = stmt.Exec(
+		e.ID,
+		e.Email,
+		e.Password,
+		e.FirstName,
+		e.LastName,
+		time.Now().Format("2006-01-02"),
+	)
+	if err != nil {
+		return e.ID, err
+	}
+	err = stmt.Close()
+	if err != nil {
+		return e.ID, err
+	}
+	return e.ID, nil
+}
+
+//Get an user
+func (r *MySQLRepo) Get(id entity.ID) (*entity.User, error) {
+	return getUser(id, r.db)
+}
+
+func getUser(id entity.ID, db *sql.DB) (*entity.User, error) {
+	stmt, err := db.Prepare(`select id, email, first_name, last_name, created_at from user where id = ?`)
+	if err != nil {
+		return nil, err
+	}
+	var u entity.User
+	rows, err := stmt.Query(id)
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		err = rows.Scan(&u.ID, &u.Email, &u.FirstName, &u.LastName, &u.CreatedAt)
+	}
+	stmt, err = db.Prepare(`select book_id from book_user where user_id = ?`)
+	if err != nil {
+		return nil, err
+	}
+	rows, err = stmt.Query(id)
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		var i entity.ID
+		err = rows.Scan(&i)
+		u.Books = append(u.Books, i)
+	}
+	return &u, nil
+}
+
+//Update an user
+func (r *MySQLRepo) Update(e *entity.User) error {
+	e.UpdatedAt = time.Now()
+	_, err := r.db.Exec("update user set email = ?, password = ?, first_name = ?, last_name = ?, updated_at = ? where id = ?", e.Email, e.Password, e.FirstName, e.LastName, e.UpdatedAt.Format("2006-01-02"), e.ID)
+	if err != nil {
+		return err
+	}
+	_, err = r.db.Exec("delete from book_user where user_id = ?", e.ID)
+	if err != nil {
+		return err
+	}
+	for _, b := range e.Books {
+		_, err := r.db.Exec("insert into book_user values(?,?,?)", e.ID, b, time.Now().Format("2006-01-02"))
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+//Search users
+func (r *MySQLRepo) Search(query string) ([]*entity.User, error) {
+	stmt, err := r.db.Prepare(`select id from user where name like ?`)
+	if err != nil {
+		return nil, err
+	}
+	defer stmt.Close()
+	var ids []entity.ID
+	rows, err := stmt.Query()
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		var i entity.ID
+		err = rows.Scan(&i)
+		if err != nil {
+			return nil, err
+		}
+		ids = append(ids, i)
+	}
+	if len(ids) == 0 {
+		return nil, fmt.Errorf("not found")
+	}
+	var users []*entity.User
+	for _, id := range ids {
+		u, err := getUser(id, r.db)
+		if err != nil {
+			return nil, err
+		}
+		users = append(users, u)
+	}
+	return users, nil
+}
+
+//List users
+func (r *MySQLRepo) List() ([]*entity.User, error) {
+	stmt, err := r.db.Prepare(`select id from user`)
+	if err != nil {
+		return nil, err
+	}
+	defer stmt.Close()
+	var ids []entity.ID
+	rows, err := stmt.Query()
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		var i entity.ID
+		err = rows.Scan(&i)
+		if err != nil {
+			return nil, err
+		}
+		ids = append(ids, i)
+	}
+	if len(ids) == 0 {
+		return nil, fmt.Errorf("not found")
+	}
+	var users []*entity.User
+	for _, id := range ids {
+		u, err := getUser(id, r.db)
+		if err != nil {
+			return nil, err
+		}
+		users = append(users, u)
+	}
+	return users, nil
+}
+
+//Delete an user
+func (r *MySQLRepo) Delete(id entity.ID) error {
+	_, err := r.db.Exec("delete from user where id = ?", id)
+	if err != nil {
+		return err
+	}
+	return nil
+}