connection

Documentation

Index

• type Connection
• type MysqlConnection
  • func (c *MysqlConnection) Exec(ctx context.Context, sqlStr string, params ...interface{}) (common.Result, error)
  • func (c *MysqlConnection) Prepare(sqlStr string) (statement.Statement, error)
  • func (c *MysqlConnection) Query(ctx context.Context, result reflection.Object, sqlStr string, ...) error
• type MysqlStatement
  • func (s *MysqlStatement) Close()
  • func (s *MysqlStatement) Exec(ctx context.Context, params ...interface{}) (common.Result, error)
  • func (s *MysqlStatement) Query(ctx context.Context, result reflection.Object, params ...interface{}) error

Types

type Connection

type Connection interface {
	Prepare(sql string) (statement.Statement, error)
	Query(ctx context.Context, result reflection.Object, sql string, params ...interface{}) error
	Exec(ctx context.Context, sql string, params ...interface{}) (common.Result, error)
}

type MysqlConnection

type MysqlConnection sql.DB

func (*MysqlConnection) Exec

func (c *MysqlConnection) Exec(ctx context.Context, sqlStr string, params ...interface{}) (common.Result, error)

func (*MysqlConnection) Prepare

func (c *MysqlConnection) Prepare(sqlStr string) (statement.Statement, error)

func (*MysqlConnection) Query

func (c *MysqlConnection) Query(ctx context.Context, result reflection.Object, sqlStr string, params ...interface{}) error

type MysqlStatement

type MysqlStatement sql.Stmt

func (*MysqlStatement) Close

func (s *MysqlStatement) Close()

func (*MysqlStatement) Exec

func (s *MysqlStatement) Exec(ctx context.Context, params ...interface{}) (common.Result, error)

func (*MysqlStatement) Query

func (s *MysqlStatement) Query(ctx context.Context, result reflection.Object, params ...interface{}) error