action

README

Database Base Action (CRUD)

How to Use

package main

import (
	"context"
	"log"
	
	"github.com/kodekoding/phastos/v2/go/database"
	"github.com/kodekoding/phastos/v2/go/database/action"
)

func main() {
	db, err := database.Connect(&database.SQLConfig{
		Username:        "root",
		Password:        "...",
		Host:            "localhost",
		Port:            "3306",
		DBName:          "...",
		Engine:          "mysql",
		MaxConnLifetime: 199,
		MaxIdleTime:     100,
		MaxOpenConn:     10,
		MaxIdleConn:     10,
	})

	if err != nil {
		log.Fatalln("error db", err.Error())
	}

	repoOrang := NewOrangRepo(db)
	orangUc := NewUc(repoOrang)

	orangUc.Insert(context.Background(), &OrangEntity{
		Nama:   "test",
		Alamat: "testing",
		Telp:   "2123xx",
	})

	result, err := orangUc.GetList(context.Background(), &OrangRequest{
		TableRequest: database.TableRequest{},
	})

	log.Printf("%#v", result.Data)
}

type (
	Orangs interface {
		Base() *action.Base
	}
	OrangRepo struct {
		base *action.Base
	}
)

func NewOrangRepo(db database.ISQL) *OrangRepo {
	return &OrangRepo{
		base: action.NewBase(db, "orang"),
	}
}

func (o *OrangRepo) Base() *action.Base {
	return o.base
}

type (
	OrangUsecases interface {
		GetList(ctx context.Context, requestData interface{}) (*database.SelectResponse, error)
		Insert(ctx context.Context, requestData interface{}) (*database.CUDResponse, error)
	}
	orangUc struct {
		orangRepo Orangs
	}

	OrangEntity struct {
		database.BaseColumn
		Nama   string `db:"nama"`
		Alamat string `db:"alamat"`
		Telp   string `db:"phone_number"`
	}
	OrangRequest struct {
		OrangEntity
		database.TableRequest
	}
)

func NewUc(repo Orangs) *orangUc {
	return &orangUc{orangRepo: repo}
}

func (o *orangUc) GetList(ctx context.Context, requestData interface{}) (*database.SelectResponse, error) {
	orangRequest := requestData.(*OrangRequest)
	var orangList []*OrangEntity
	if err := o.orangRepo.Base().GetList(ctx, &database.QueryOpts{
		IsList:        true,
		SelectRequest: &orangRequest.TableRequest,
		ResultStruct:  &orangList,
	}); err != nil {
		return nil, err
	}

	result := new(database.SelectResponse)
	result.Data = orangList
	return result, nil
}

func (o *orangUc) Insert(ctx context.Context, requestData interface{}) (*database.CUDResponse, error) {
	result, err := o.orangRepo.Base().Insert(ctx, requestData)
	if err != nil {
		return nil, err
	}
	return result, nil
}

Documentation

Index

• type Base
  • func NewBase(db database.ISQL, tableName string, isSoftDelete ...bool) *Base
• type BaseRead
  • func NewBaseRead(db database.ISQL, tableName string, isSoftDelete ...bool) *BaseRead
  • func (b *BaseRead) Count(ctx context.Context, reqData *database.TableRequest, tableName ...string) (totalData, totalFiltered int, err error)
  • func (b *BaseRead) GetDetail(ctx context.Context, opts *database.QueryOpts) error
  • func (b *BaseRead) GetDetailById(ctx context.Context, resultStruct interface{}, id interface{}, ...) error
  • func (b *BaseRead) GetList(ctx context.Context, opts *database.QueryOpts) error
• type BaseWrite
  • func NewBaseWrite(db database.ISQL, tableName string, isSoftDelete ...bool) *BaseWrite
  • func (b *BaseWrite) BulkInsert(ctx context.Context, data interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)
  • func (b *BaseWrite) BulkUpdate(ctx context.Context, data interface{}, condition map[string][]interface{}, ...) (*database.CUDResponse, error)
  • func (b *BaseWrite) Delete(ctx context.Context, condition map[string]interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)
  • func (b *BaseWrite) DeleteById(ctx context.Context, id interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)
  • func (b *BaseWrite) Insert(ctx context.Context, data interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)
  • func (b *BaseWrite) Update(ctx context.Context, data interface{}, condition map[string]interface{}, ...) (*database.CUDResponse, error)
  • func (b *BaseWrite) UpdateById(ctx context.Context, data interface{}, id interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)
  • func (b *BaseWrite) Upsert(ctx context.Context, data interface{}, condition map[string]interface{}, ...) (*database.CUDResponse, error)
• type BaseWrites

Types

type Base

type Base struct {
	BaseWrites
	common.ReadRepo
}

func NewBase

func NewBase(db database.ISQL, tableName string, isSoftDelete ...bool) *Base

type BaseRead

type BaseRead struct {
	// contains filtered or unexported fields
}

func NewBaseRead

func NewBaseRead(db database.ISQL, tableName string, isSoftDelete ...bool) *BaseRead

func (*BaseRead) Count

func (b *BaseRead) Count(ctx context.Context, reqData *database.TableRequest, tableName ...string) (totalData, totalFiltered int, err error)

func (*BaseRead) GetDetail

func (b *BaseRead) GetDetail(ctx context.Context, opts *database.QueryOpts) error

GetDetail - Query Detail with specific Query and return single data

func (*BaseRead) GetDetailById

func (b *BaseRead) GetDetailById(ctx context.Context, resultStruct interface{}, id interface{}, optionalTableName ...string) error

GetDetailById - Generate Query "SELECT * FROM <table_name | optional_table_name> WHERE id = ?"

func (*BaseRead) GetList

func (b *BaseRead) GetList(ctx context.Context, opts *database.QueryOpts) error

type BaseWrite

type BaseWrite struct {
	// contains filtered or unexported fields
}

func NewBaseWrite

func NewBaseWrite(db database.ISQL, tableName string, isSoftDelete ...bool) *BaseWrite

func (*BaseWrite) BulkInsert

func (b *BaseWrite) BulkInsert(ctx context.Context, data interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) BulkUpdate

func (b *BaseWrite) BulkUpdate(ctx context.Context, data interface{}, condition map[string][]interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) Delete

func (b *BaseWrite) Delete(ctx context.Context, condition map[string]interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) DeleteById

func (b *BaseWrite) DeleteById(ctx context.Context, id interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) Insert

func (b *BaseWrite) Insert(ctx context.Context, data interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) Update

func (b *BaseWrite) Update(ctx context.Context, data interface{}, condition map[string]interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) UpdateById

func (b *BaseWrite) UpdateById(ctx context.Context, data interface{}, id interface{}, optTrx ...*sqlx.Tx) (*database.CUDResponse, error)

func (*BaseWrite) Upsert

func (b *BaseWrite) Upsert(ctx context.Context, data interface{}, condition map[string]interface{}, opts ...interface{}) (*database.CUDResponse, error)

type BaseWrites

type BaseWrites interface {
	common.WriteRepo
}