repository.*RoomPostgres.GetAll - Code Metrics - architectv/estate-task - Measure and Improve Code Quality continuously with Scrutinizer

repository.*RoomPostgres.GetAll A
last analyzed 2021-01-10 09:18 UTC

↳ Parent: pkg/repository/room_postgres.go

Complexity

Conditions

Size

Total Lines	10
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
eloc	7
nop	2
dl	0
loc	10
ccs	6
cts	6
cp	1
crap	2
rs	10
c	0
b	0
f	0

package repository

import (
	"fmt"

	"github.com/architectv/estate-task/pkg/model"
	"github.com/jmoiron/sqlx"
)

type RoomPostgres struct {
	db *sqlx.DB
}

func NewRoomPostgres(db *sqlx.DB) *RoomPostgres {
	return &RoomPostgres{db: db}
}

func (r *RoomPostgres) Create(room *model.Room) (int, error) {
	var id int
	query := fmt.Sprintf(
		`INSERT INTO %s (description, price) VALUES ($1, $2) RETURNING id`,
		roomsTable)
	row := r.db.QueryRow(query, room.Description, room.Price)
	if err := row.Scan(&id); err != nil {
		return 0, err
	}

	return id, nil
}

func (r *RoomPostgres) Delete(id int) error {
	query := fmt.Sprintf("DELETE FROM %s WHERE id=$1", roomsTable)
	_, err := r.db.Exec(query, id)

	return err
}

func (r *RoomPostgres) GetAll(sortField string, desc bool) ([]*model.Room, error) {
	var rooms []*model.Room

	query := fmt.Sprintf("SELECT * FROM %s ORDER BY %s", roomsTable, sortField)
	if desc {
		query += " DESC"
	}
	err := r.db.Select(&rooms, query)

	return rooms, err
}

func (r *RoomPostgres) GetById(id int) (*model.Room, error) {
	room := &model.Room{}
	query := fmt.Sprintf("SELECT * FROM %s WHERE id=$1", roomsTable)
	err := r.db.Get(room, query, id)

	return room, err
}


1		package repository
2
3		import (
4		"fmt"
5
6		"github.com/architectv/estate-task/pkg/model"
7		"github.com/jmoiron/sqlx"
8		)
9
10		type RoomPostgres struct {
11		db *sqlx.DB
12		}
13
14		func NewRoomPostgres(db sqlx.DB) RoomPostgres {
15	1	return &RoomPostgres{db: db}
16		}
17
18		func (r RoomPostgres) Create(room model.Room) (int, error) {
19	1	var id int
20	1	query := fmt.Sprintf(
21		`INSERT INTO %s (description, price) VALUES ($1, $2) RETURNING id`,
22		roomsTable)
23	1	row := r.db.QueryRow(query, room.Description, room.Price)
24	1	if err := row.Scan(&id); err != nil {
25	1	return 0, err
26		}
27
28	1	return id, nil
29		}
30
31		func (r *RoomPostgres) Delete(id int) error {
32	1	query := fmt.Sprintf("DELETE FROM %s WHERE id=$1", roomsTable)
33	1	_, err := r.db.Exec(query, id)
34
35	1	return err
36		}
37
38		func (r RoomPostgres) GetAll(sortField string, desc bool) ([]model.Room, error) {
39	1	var rooms []*model.Room
40
41	1	query := fmt.Sprintf("SELECT * FROM %s ORDER BY %s", roomsTable, sortField)
42	1	if desc {
43	1	query += " DESC"
44		}
45	1	err := r.db.Select(&rooms, query)
46
47	1	return rooms, err
48		}
49
50		func (r RoomPostgres) GetById(id int) (model.Room, error) {
51	1	room := &model.Room{}
52	1	query := fmt.Sprintf("SELECT * FROM %s WHERE id=$1", roomsTable)
53	1	err := r.db.Get(room, query, id)
54
55	1	return room, err
56		}
57

architectv / estate-task

repository.*RoomPostgres.GetAll A last analyzed 2021-01-10 09:18 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

repository.*RoomPostgres.GetAll A
last analyzed 2021-01-10 09:18 UTC