db

Documentation

Index

• Constants
• Variables
• func CheckDbConnection() (err error)
• func CombineDBSql(input ...interface{}) string
• func CreateListParams(inputList []string, prefix string) (filterSql string, filterParam []interface{})
• func DBCtx(transactionId string) context.Context
• func GetDatabaseEngine(inputConfig *models.DatabaseConfig) (engine *xorm.Engine, err error)
• func InitDatabase() error
• func InitWorkflowDatabase() error
• func NewDBCtx(transactionId string) context.Context
• func NewNullString(s string) sql.NullString
• func QueryCount(sql string, params ...interface{}) int
• func Transaction(actions []*ExecAction, ctx context.Context) error
• type ExecAction
  • func GetDeleteTableExecAction(tableName string, primeKey string, primeKeyVal string) (action *ExecAction, err error)
  • func GetInsertTableExecAction(tableName string, data interface{}, transNullStr map[string]string) (action *ExecAction, err error)
  • func GetUpdateTableExecActionV2(tableName string, primeKey string, primeKeyVal string, data interface{}, ...) (action *ExecAction, err error)

Constants

const DBTransactionId = "transactionId"

Variables

var (
	MysqlEngine         *xorm.Engine
	WorkflowMysqlEngine *xorm.Engine
)

Functions

func CheckDbConnection

func CheckDbConnection() (err error)

func CombineDBSql

func CombineDBSql(input ...interface{}) string

func CreateListParams

func CreateListParams(inputList []string, prefix string) (filterSql string, filterParam []interface{})

func DBCtx

func DBCtx(transactionId string) context.Context

func GetDatabaseEngine

func GetDatabaseEngine(inputConfig *models.DatabaseConfig) (engine *xorm.Engine, err error)

func InitDatabase

func InitDatabase() error

func InitWorkflowDatabase

func InitWorkflowDatabase() error

func NewDBCtx

func NewDBCtx(transactionId string) context.Context

func NewNullString

func NewNullString(s string) sql.NullString

func QueryCount

func QueryCount(sql string, params ...interface{}) int

func Transaction

func Transaction(actions []*ExecAction, ctx context.Context) error

Types

type ExecAction

type ExecAction struct {
	Sql            string
	Param          []interface{}
	CheckAffectRow bool
}

func GetDeleteTableExecAction

func GetDeleteTableExecAction(tableName string, primeKey string, primeKeyVal string) (action *ExecAction, err error)

func GetInsertTableExecAction

func GetInsertTableExecAction(tableName string, data interface{}, transNullStr map[string]string) (action *ExecAction, err error)

func GetUpdateTableExecActionV2

func GetUpdateTableExecActionV2(tableName string, primeKey string, primeKeyVal string, data interface{},
	transNullStr map[string]string) (action *ExecAction, err error)