issue #12: implement insert operations

internal/storage/create_board.go

@@ -1,12 +1,37 @@
 package storage
 
-import "go.octolab.org/ecosystem/tablo/internal/model"
+import (
+	"context"
+	"database/sql"
 
-func (storage *storage) CreateBoard(board model.Board) (model.ID, error) {
-	storage.builder.
+	"github.com/Masterminds/squirrel"
+	"github.com/pkg/errors"
+
+	"go.octolab.org/ecosystem/tablo/internal/model"
+)
+
+// CreateBoard stores the board into a database.
+func (storage *storage) CreateBoard(ctx context.Context, board model.Board) (model.ID, error) {
+	var id model.ID
+	tx, err := storage.db.BeginTx(ctx, storage.tx)
+	if err != nil {
+		return id, errors.Wrap(err, "create board: cannot begin transaction")
+	}
+	defer func() { _ = tx.Rollback() }()
+	id, err = createBoard(tx, *storage.builder, board)
+	if err == nil {
+		return id, errors.Wrap(tx.Commit(), "create board: cannot commit transaction")
+	}
+	return id, err
+}
+
+func createBoard(tx *sql.Tx, builder squirrel.StatementBuilderType, board model.Board) (model.ID, error) {
+	var id model.ID
+	query := builder.
 		Insert("board").
 		Columns("title", "emoji", "description").
 		Values(board.Title, board.Emoji, board.Description).
-		Suffix(`RETURNING "id"`)
-	return "", nil
+		Suffix(`RETURNING "id"`).
+		RunWith(tx)
+	return id, errors.Wrap(query.QueryRow().Scan(&id), "create board: cannot insert data")
 }

internal/storage/create_card.go

@@ -1,7 +1,37 @@
 package storage
 
-import "go.octolab.org/ecosystem/tablo/internal/model"
+import (
+	"context"
+	"database/sql"
 
-func (storage *storage) CreateCard(card model.Card) (model.ID, error) {
-	return "", nil
+	"github.com/Masterminds/squirrel"
+	"github.com/pkg/errors"
+
+	"go.octolab.org/ecosystem/tablo/internal/model"
+)
+
+// CreateCard stores the card into a database.
+func (storage *storage) CreateCard(ctx context.Context, card model.Card) (model.ID, error) {
+	var id model.ID
+	tx, err := storage.db.BeginTx(ctx, storage.tx)
+	if err != nil {
+		return id, errors.Wrap(err, "create card: cannot begin transaction")
+	}
+	defer func() { _ = tx.Rollback() }()
+	id, err = createCard(tx, *storage.builder, card)
+	if err == nil {
+		return id, errors.Wrap(tx.Commit(), "create card: cannot commit transaction")
+	}
+	return id, err
+}
+
+func createCard(tx *sql.Tx, builder squirrel.StatementBuilderType, card model.Card) (model.ID, error) {
+	var id model.ID
+	query := builder.
+		Insert("card").
+		Columns("title", "emoji", "description").
+		Values(card.Title, card.Emoji, card.Description).
+		Suffix(`RETURNING "id"`).
+		RunWith(tx)
+	return id, errors.Wrap(query.QueryRow().Scan(&id), "create card: cannot insert data")
 }

internal/storage/create_column.go

@@ -1,7 +1,37 @@
 package storage
 
-import "go.octolab.org/ecosystem/tablo/internal/model"
+import (
+	"context"
+	"database/sql"
 
-func (storage *storage) CreateColumn(column model.Column) (model.ID, error) {
-	return "", nil
+	"github.com/Masterminds/squirrel"
+	"github.com/pkg/errors"
+
+	"go.octolab.org/ecosystem/tablo/internal/model"
+)
+
+// CreateColumn stores the column into a database.
+func (storage *storage) CreateColumn(ctx context.Context, column model.Column) (model.ID, error) {
+	var id model.ID
+	tx, err := storage.db.BeginTx(ctx, storage.tx)
+	if err != nil {
+		return id, errors.Wrap(err, "create column: cannot begin transaction")
+	}
+	defer func() { _ = tx.Rollback() }()
+	id, err = createColumn(tx, *storage.builder, column)
+	if err == nil {
+		return id, errors.Wrap(tx.Commit(), "create column: cannot commit transaction")
+	}
+	return id, err
+}
+
+func createColumn(tx *sql.Tx, builder squirrel.StatementBuilderType, column model.Column) (model.ID, error) {
+	var id model.ID
+	query := builder.
+		Insert("column").
+		Columns("title", "emoji", "description").
+		Values(column.Title, column.Emoji, column.Description).
+		Suffix(`RETURNING "id"`).
+		RunWith(tx)
+	return id, errors.Wrap(query.QueryRow().Scan(&id), "create column: cannot insert data")
 }

internal/storage/engine.go

@@ -14,7 +14,7 @@ const (
 	sqlite   = "sqlite"
 )
 
-// Engine returns related to the data source name database a handler
+// Engine returns related to the data source name a database handler
 // and a query builder or error if something went wrong.
 func Engine(dsn string) (*sql.DB, *squirrel.StatementBuilderType, error) {
 	schema, err := url.Parse(dsn)

internal/storage/storage.go

@@ -6,6 +6,8 @@ import (
 	"github.com/Masterminds/squirrel"
 )
 
+// Must returns new instance of persistent storage
+// or panic if something went wrong.
 func Must(dsn string) *storage {
 	storage, err := New(dsn)
 	if err != nil {
@@ -14,6 +16,8 @@ func Must(dsn string) *storage {
 	return storage
 }
 
+// New returns new instance of persistent storage
+// or error if something went wrong.
 func New(dsn string) (*storage, error) {
 	db, builder, err := Engine(dsn)
 	if err != nil {
@@ -24,5 +28,6 @@ func New(dsn string) (*storage, error) {
 
 type storage struct {
 	db      *sql.DB
+	tx      *sql.TxOptions
 	builder *squirrel.StatementBuilderType
 }