session

Documentation

Index

• type Session
  • func (s *Session) Begin() error
  • func (s *Session) Commit() error
  • func (s *Session) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (s *Session) Prepare(query string) (*sql.Stmt, error)
  • func (s *Session) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (s *Session) QueryRow(query string, args ...interface{}) *sql.Row
  • func (s *Session) Rollback() error
• type SessionFactory
  • func NewSessionFactory(driverName, dataSourseName string) (*SessionFactory, error)
  • func (sf *SessionFactory) GetSession() *Session

Types

type Session

type Session struct {
	DB *sql.DB // 原生db
	// contains filtered or unexported fields
}

Session 会话

func (*Session) Begin

func (s *Session) Begin() error

Begin 开启事务

func (*Session) Commit

func (s *Session) Commit() error

Commit 提交事务

func (*Session) Exec

func (s *Session) Exec(query string, args ...interface{}) (sql.Result, error)

Exec 执行sql语句，如果已经开启事务，就以事务方式执行

func (*Session) Prepare

func (s *Session) Prepare(query string) (*sql.Stmt, error)

Prepare 预执行，如果已经开启事务，就以事务方式执行，如果没有开启事务，就以非事务方式执行

func (*Session) Query

func (s *Session) Query(query string, args ...interface{}) (*sql.Rows, error)

Query 查询数据，如果已经开启事务，就以事务方式执行，如果没有开启事务，就以非事务方式执行

func (*Session) QueryRow

func (s *Session) QueryRow(query string, args ...interface{}) *sql.Row

QueryRow 如果已经开启事务，就以事务方式执行，如果没有开启事务，就以非事务方式执行

func (*Session) Rollback

func (s *Session) Rollback() error

Rollback 回滚事务

type SessionFactory

type SessionFactory struct {
	*sql.DB
}

SessionFactory 会话工厂

func NewSessionFactory

func NewSessionFactory(driverName, dataSourseName string) (*SessionFactory, error)

NewSessionFactory 创建一个会话工厂

func (*SessionFactory) GetSession

func (sf *SessionFactory) GetSession() *Session

GetSession 获取一个Session