session

Documentation

Index

• type DefaultSqlSession
  • func NewDefaultSqlSession(log logging.LogFunc, tx transaction.Transaction, e executor.Executor, ...) *DefaultSqlSession
  • func (sess *DefaultSqlSession) Begin()
  • func (sess *DefaultSqlSession) Close(rollback bool)
  • func (sess *DefaultSqlSession) Commit()
  • func (sess *DefaultSqlSession) Delete(ctx context.Context, sql string, params ...interface{}) (int64, error)
  • func (sess *DefaultSqlSession) Insert(ctx context.Context, sql string, params ...interface{}) (int64, int64, error)
  • func (sess *DefaultSqlSession) Query(ctx context.Context, result reflection.Object, sql string, ...) error
  • func (sess *DefaultSqlSession) Rollback()
  • func (sess *DefaultSqlSession) Update(ctx context.Context, sql string, params ...interface{}) (int64, error)
• type SqlSession

Types

type DefaultSqlSession

type DefaultSqlSession struct {
	Log logging.LogFunc
	// contains filtered or unexported fields
}

func NewDefaultSqlSession

func NewDefaultSqlSession(log logging.LogFunc, tx transaction.Transaction, e executor.Executor, autoCommit bool) *DefaultSqlSession

func (*DefaultSqlSession) Begin

func (sess *DefaultSqlSession) Begin()

func (*DefaultSqlSession) Close

func (sess *DefaultSqlSession) Close(rollback bool)

func (*DefaultSqlSession) Commit

func (sess *DefaultSqlSession) Commit()

func (*DefaultSqlSession) Delete

func (sess *DefaultSqlSession) Delete(ctx context.Context, sql string, params ...interface{}) (int64, error)

func (*DefaultSqlSession) Insert

func (sess *DefaultSqlSession) Insert(ctx context.Context, sql string, params ...interface{}) (int64, int64, error)

func (*DefaultSqlSession) Query

func (sess *DefaultSqlSession) Query(ctx context.Context, result reflection.Object, sql string, params ...interface{}) error

func (*DefaultSqlSession) Rollback

func (sess *DefaultSqlSession) Rollback()

func (*DefaultSqlSession) Update

func (sess *DefaultSqlSession) Update(ctx context.Context, sql string, params ...interface{}) (int64, error)

type SqlSession

type SqlSession interface {
	Close(rollback bool)

	Query(ctx context.Context, result reflection.Object, sql string, params ...interface{}) error

	Insert(ctx context.Context, sql string, params ...interface{}) (int64, int64, error)

	Update(ctx context.Context, sql string, params ...interface{}) (int64, error)

	Delete(ctx context.Context, sql string, params ...interface{}) (int64, error)

	Begin()

	Commit()

	Rollback()
}