mysqlmondule

Documentation

Index

• type DBExecute
• type DBResult
• type DataSetList
  • func (ds *DataSetList) UnMarshal(args ...interface{}) error
• type MySQLModule
  • func (m *MySQLModule) Begin() (*Tx, error)
  • func (m *MySQLModule) Exec(strSql string, args ...interface{}) (*DBResult, error)
  • func (m *MySQLModule) Init(url string, userName string, password string, dbname string, maxConn int) error
  • func (m *MySQLModule) Query(strQuery string, args ...interface{}) (*DataSetList, error)
  • func (m *MySQLModule) SetQuerySlowTime(slowDuration time.Duration)
• type PingExecute
• type SyncFun
• type Tx
  • func (slf *Tx) Commit() error
  • func (slf *Tx) Exec(strSql string, args ...interface{}) (*DBResult, error)
  • func (slf *Tx) Query(strQuery string, args ...interface{}) (*DataSetList, error)
  • func (slf *Tx) Rollback() error

Types

type DBExecute

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

type DBResult

type DBResult struct {
	LastInsertID int64
	RowsAffected int64

	RowInfo map[string][]interface{} //map[fieldname][row]sql.NullString
	// contains filtered or unexported fields
}

DBResult ...

type DataSetList

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

func (*DataSetList) UnMarshal

func (ds *DataSetList) UnMarshal(args ...interface{}) error

type MySQLModule

type MySQLModule struct {
	service.Module
	// contains filtered or unexported fields
}

DBModule ...

func (*MySQLModule) Begin

func (m *MySQLModule) Begin() (*Tx, error)

Begin starts a transaction.

func (*MySQLModule) Exec

func (m *MySQLModule) Exec(strSql string, args ...interface{}) (*DBResult, error)

Exec ...

func (*MySQLModule) Init

func (m *MySQLModule) Init(url string, userName string, password string, dbname string, maxConn int) error

func (*MySQLModule) Query

func (m *MySQLModule) Query(strQuery string, args ...interface{}) (*DataSetList, error)

func (*MySQLModule) SetQuerySlowTime

func (m *MySQLModule) SetQuerySlowTime(slowDuration time.Duration)

type PingExecute

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

type SyncFun

type SyncFun func()

type Tx

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

Tx ...

func (*Tx) Commit

func (slf *Tx) Commit() error

Commit commits the transaction.

func (*Tx) Exec

func (slf *Tx) Exec(strSql string, args ...interface{}) (*DBResult, error)

Exec executes a query that doesn't return rows.

func (*Tx) Query

func (slf *Tx) Query(strQuery string, args ...interface{}) (*DataSetList, error)

QueryEx executes a query that return rows.

func (*Tx) Rollback

func (slf *Tx) Rollback() error

Rollback aborts the transaction.