base

Documentation

Overview

共享事件结构定义

功能性方法文件

Index

• Constants
• Variables
• func AskSwapSort(s string) string
• func Exec(e *Event)
• func HttpPostByte(url string, param []byte, head map[string]string) ([]byte, error)
• func LoadByQuery(e *Event)
• func Quick(arr []int)
• func ValToFloat(v interface{}) float64
• func ValToInt(v interface{}) (int, error)
• type DbConfig
  • func (d *DbConfig) MySqlConn() (err error)
  • func (d *DbConfig) PSqlConn() (err error)
• type Engine
  • func (e *Engine) GetParam(def interface{}) error
  • func (e *Engine) OutErr(data interface{})
  • func (e *Engine) OutList(data interface{})
  • func (e *Engine) OutSuccess()
• type Event
  • func NewEvent(s func(event *Event)) *Event
  • func (e *Event) BuildDataMode(mode interface{}, data []map[string]interface{}) (list []interface{})
  • func (e *Event) ExecByPsql(sql string, val []interface{}) (sql.Result, error)
  • func (e *Event) Push(data interface{})
  • func (e *Event) QueryByPsql() (objs interface{}, total int, err error)
  • func (e *Event) Rsp() interface{}
  • func (e *Event) SetHandel(s func(event *Event))
  • func (e *Event) SetSm(sm *SqlModify)
• type EventQueue
  • func NewEventQueue(l int) *EventQueue
  • func (eq *EventQueue) Post(e *Event)
• type Handle
• type LogLevel
• type Logger
  • func NewLogger() *Logger
  • func (l *Logger) Err(content ...interface{})
  • func (l *Logger) Info(content ...interface{})
  • func (l *Logger) SaveFile()
  • func (l *Logger) Waring(content ...interface{})
• type MySql
  • func (m *MySql) Begin() (tx *sql.Tx, err error)
  • func (m *MySql) Insert(sql string, val []interface{}) error
  • func (m *MySql) Ping() error
• type PSql
  • func (p *PSql) Begin() (*sql.Tx, error)
  • func (p *PSql) GetDB() *sql.DB
  • func (p *PSql) Insert(sql string, val []interface{}) error
  • func (p *PSql) PgQueryList(sql string, val ...interface{}) (list []map[string][]byte, total int, err error)
• type SqlDiff
• type SqlModify
  • func (sm *SqlModify) And(c string, diff SqlDiff, val ...interface{}) *SqlModify
  • func (sm *SqlModify) MysqlLimit() string
  • func (sm *SqlModify) MysqlQuery() (list []map[string]interface{}, total int, err error)
  • func (sm *SqlModify) MysqlQueryBuild() (string, []interface{})
  • func (sm *SqlModify) Or(c string, diff SqlDiff, val ...interface{}) *SqlModify
  • func (sm *SqlModify) PgQueryList(db *sql.DB, sql string, val ...interface{}) (list []map[string]interface{}, total int, err error)
  • func (sm *SqlModify) PsqlLimit() string
  • func (sm *SqlModify) PsqlQueryBuild() (string, []interface{})
  • func (sm *SqlModify) SetPage(p int) *SqlModify
  • func (sm *SqlModify) SetSize(s int) *SqlModify
  • func (sm *SqlModify) SetSwapObj(f SwapObj) *SqlModify
  • func (sm *SqlModify) SetTable(table string) *SqlModify
• type SwapObj

Constants

const (
	EnPage = "SQL_CALC_FOUND_ROWS" //开启分页
)

Variables

var ShowLevel = map[LogLevel]string{
	Waring: "Waring",
	Info:   "Info",
	Err:    "Err",
}

Functions

func AskSwapSort

func AskSwapSort(s string) string

字符串中的问号转$序号

func Exec

func Exec(e *Event)

func HttpPostByte

func HttpPostByte(url string, param []byte, head map[string]string) ([]byte, error)

func LoadByQuery

func LoadByQuery(e *Event)

func Quick

func Quick(arr []int)

func ValToFloat

func ValToFloat(v interface{}) float64

数据转浮点

func ValToInt

func ValToInt(v interface{}) (int, error)

数据转int

Types

type DbConfig

type DbConfig struct {
	Host            string
	Port            int
	User            string
	Pwd             string
	DbName          string
	MaxOpenConn     int
	MaxIdleConn     int
	ConnMaxLifetime int
}

数据库连接配置

func (*DbConfig) MySqlConn

func (d *DbConfig) MySqlConn() (err error)

func (*DbConfig) PSqlConn

func (d *DbConfig) PSqlConn() (err error)

type Engine

type Engine struct {
	Req  *http.Request
	Res  http.ResponseWriter
	Log  *Logger
	Data map[string]string
}

func (*Engine) GetParam

func (e *Engine) GetParam(def interface{}) error

func (*Engine) OutErr

func (e *Engine) OutErr(data interface{})

func (*Engine) OutList

func (e *Engine) OutList(data interface{})

func (*Engine) OutSuccess

func (e *Engine) OutSuccess()

type Event

type Event struct {
	IsWrite bool
	Eg      *Engine
	//执行的sql
	ExecSql string
	//查询时主键值,根据此值优先取缓存,执行时是参数填充
	Keys []interface{}
	// contains filtered or unexported fields
}

数据事件对象

func NewEvent

func NewEvent(s func(event *Event)) *Event

func (*Event) BuildDataMode

func (e *Event) BuildDataMode(mode interface{}, data []map[string]interface{}) (list []interface{})

func (*Event) ExecByPsql

func (e *Event) ExecByPsql(sql string, val []interface{}) (sql.Result, error)

func (*Event) Push

func (e *Event) Push(data interface{})

事件结果投递

func (*Event) QueryByPsql

func (e *Event) QueryByPsql() (objs interface{}, total int, err error)

func (*Event) Rsp

func (e *Event) Rsp() interface{}

事件结果响应

func (*Event) SetHandel

func (e *Event) SetHandel(s func(event *Event))

事件结果投递

func (*Event) SetSm

func (e *Event) SetSm(sm *SqlModify)

事件结果投递

type EventQueue

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

func NewEventQueue

func NewEventQueue(l int) *EventQueue

func (*EventQueue) Post

func (eq *EventQueue) Post(e *Event)

事件投递

type Handle

type Handle func(*Engine)

type LogLevel

type LogLevel int

const (
	Waring LogLevel = iota
	Info
	Err
)

type Logger

type Logger struct {
	//开始时间
	StartTime time.Time
	//途经路线集合
	Steps []step
}

func NewLogger

func NewLogger() *Logger

func (*Logger) Err

func (l *Logger) Err(content ...interface{})

func (*Logger) Info

func (l *Logger) Info(content ...interface{})

func (*Logger) SaveFile

func (l *Logger) SaveFile()

func (*Logger) Waring

func (l *Logger) Waring(content ...interface{})

type MySql

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

var MysqlMgr *MySql

func (*MySql) Begin

func (m *MySql) Begin() (tx *sql.Tx, err error)

func (*MySql) Insert

func (m *MySql) Insert(sql string, val []interface{}) error

func (*MySql) Ping

func (m *MySql) Ping() error

type PSql

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

var PsqlMgr *PSql

func (*PSql) Begin

func (p *PSql) Begin() (*sql.Tx, error)

func (*PSql) GetDB

func (p *PSql) GetDB() *sql.DB

func (*PSql) Insert

func (p *PSql) Insert(sql string, val []interface{}) error

func (*PSql) PgQueryList

func (p *PSql) PgQueryList(sql string, val ...interface{}) (list []map[string][]byte, total int, err error)

type SqlDiff

type SqlDiff string

const (
	//相等
	Equal SqlDiff = "="
	//小于
	Lt SqlDiff = "<"
	//大于
	Gt SqlDiff = ">"
	//大于
	Like SqlDiff = "like"
	//范围区间
	Range SqlDiff = "between"
	//在列表内
	IN SqlDiff = " IN "
	//不在列表内
	NIN SqlDiff = " NOT IN "
)

type SqlModify

type SqlModify struct {

	//数据库查询出来的数据转对象
	F SwapObj
	// contains filtered or unexported fields
}

sql编辑对象

func (*SqlModify) And

func (sm *SqlModify) And(c string, diff SqlDiff, val ...interface{}) *SqlModify

设置and条件

func (*SqlModify) MysqlLimit

func (sm *SqlModify) MysqlLimit() string

func (*SqlModify) MysqlQuery

func (sm *SqlModify) MysqlQuery() (list []map[string]interface{}, total int, err error)

mysql查询

func (*SqlModify) MysqlQueryBuild

func (sm *SqlModify) MysqlQueryBuild() (string, []interface{})

func (*SqlModify) Or

func (sm *SqlModify) Or(c string, diff SqlDiff, val ...interface{}) *SqlModify

设置or条件

func (*SqlModify) PgQueryList

func (sm *SqlModify) PgQueryList(db *sql.DB, sql string, val ...interface{}) (list []map[string]interface{}, total int, err error)

func (*SqlModify) PsqlLimit

func (sm *SqlModify) PsqlLimit() string

func (*SqlModify) PsqlQueryBuild

func (sm *SqlModify) PsqlQueryBuild() (string, []interface{})

func (*SqlModify) SetPage

func (sm *SqlModify) SetPage(p int) *SqlModify

func (*SqlModify) SetSize

func (sm *SqlModify) SetSize(s int) *SqlModify

func (*SqlModify) SetSwapObj

func (sm *SqlModify) SetSwapObj(f SwapObj) *SqlModify

func (*SqlModify) SetTable

func (sm *SqlModify) SetTable(table string) *SqlModify

type SwapObj

type SwapObj func(*Event, []map[string][]byte) interface{}