db

Documentation

Index

• type DBManager
  • func NewDBManager(db *sql.DB) *DBManager
  • func (s *DBManager) ExecTx(ctx context.Context, fn func(context.Context) error) error
  • func (s *DBManager) GetQueries(ctx context.Context) *model.Queries
  • func (s *DBManager) TestTx(ctx context.Context, fn func(ctx context.Context) error) error
• type DummyInitializer
  • func NewDummyInitializer(dbManager *DBManager, userRepo user.UserRepository, ...) *DummyInitializer
  • func (i *DummyInitializer) Initialize()
  • func (d *DummyInitializer) Opinion() error
  • func (d *DummyInitializer) TalkSession() error
  • func (d *DummyInitializer) User() error
• type Migrator
  • func NewMigrator(config *config.Config) *Migrator
  • func (m *Migrator) Down()
  • func (m *Migrator) Up()

Types

type DBManager

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

DBManager DBコネクションおよびトランザクションを管理

func NewDBManager

func NewDBManager(db *sql.DB) *DBManager

func (*DBManager) ExecTx

func (s *DBManager) ExecTx(ctx context.Context, fn func(context.Context) error) error

func (*DBManager) GetQueries

func (s *DBManager) GetQueries(ctx context.Context) *model.Queries

GetQueries トランザクションが開始されている場合はトラトランザクションを返す。そうでない場合はDBコネクションを返す。

func (*DBManager) TestTx

func (s *DBManager) TestTx(ctx context.Context, fn func(ctx context.Context) error) error

type DummyInitializer

type DummyInitializer struct {
	*DBManager
	UserRepo        user.UserRepository
	TalkSessionRepo talksession.TalkSessionRepository
	OpinionRepo     opinion.OpinionRepository
	VoteRepo        vote.VoteRepository

	TalkSessions []*talksession.TalkSession
	Users        []*user.User
	Opinions     []*opinion.Opinion
	Votes        []*vote.Vote
}

func NewDummyInitializer

func NewDummyInitializer(
	dbManager *DBManager,
	userRepo user.UserRepository,
	talkSessionRepo talksession.TalkSessionRepository,
	opinionRepo opinion.OpinionRepository,
	voteRepo vote.VoteRepository,
) *DummyInitializer

func (*DummyInitializer) Initialize

func (i *DummyInitializer) Initialize()

func (*DummyInitializer) Opinion

func (d *DummyInitializer) Opinion() error

func (*DummyInitializer) TalkSession

func (d *DummyInitializer) TalkSession() error

func (*DummyInitializer) User

func (d *DummyInitializer) User() error

type Migrator

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

func NewMigrator

func NewMigrator(config *config.Config) *Migrator

func (*Migrator) Down

func (m *Migrator) Down()

func (*Migrator) Up

func (m *Migrator) Up()