utils

Documentation

Index

• Constants
• func BackupMySqlDb(req *DbTaskRequest, dumpDir, dumpFilenameFormat string) (error, string)
• func BackupMySqlDb2(req *pb.DbTaskRequest, dumpDir, dumpFilenameFormat string) (error, string)
• func CreateDirIfNotExists(path ...string)
• func EXECadodbsql(req *DbTaskRequest, sql string) (err error)
• func EXECadodbsql2(req *pb.DbTaskRequest, sql string) (err error)
• func EscapeJson(s string) string
• func ExecShell(ctx context.Context, command string) (string, error)
• func FileExist(file string) bool
• func GBK2UTF8(s string) (string, bool)
• func GetDB() (*sql.DB, error)
• func InStringSlice(slice []string, element string) bool
• func JsonResponseByErr(err error) string
• func Md5(str string) string
• func RandAuthToken() string
• func RandNumber(max int) int
• func RandString(length int64) string
• func ReplaceStrings(s string, old []string, replace []string) string
• type DbTaskRequest
• type DbTaskResponse
• type DbtaskrequestFtp
• type JsonResponse
  • func (j *JsonResponse) CommonFailure(message string, err ...error) string
  • func (j *JsonResponse) Failure(code int, message string) string
  • func (j *JsonResponse) Success(message string, data interface{}) string
• type Jsonstrt
• type Mssql
  • func (m *Mssql) GetDsn() (ret string)
  • func (m *Mssql) Open() (err error)
• type Result
• type SA

Constants

const (
	SqlsT  = 1
	MysqlT = 2
)

const AppNotInstall = 801

const AuthError = 401

const FailureContent = "操作失败"

const NotFound = 404

const ResponseFailure = 1

const ResponseSuccess = 0

const ServerError = 500

const SuccessContent = "操作成功"

const UnauthorizedError = 403

Functions

func BackupMySqlDb

func BackupMySqlDb(req *DbTaskRequest, dumpDir, dumpFilenameFormat string) (error, string)

func BackupMySqlDb2

func BackupMySqlDb2(req *pb.DbTaskRequest, dumpDir, dumpFilenameFormat string) (error, string)

func CreateDirIfNotExists

func CreateDirIfNotExists(path ...string)

检测目录是否存在

func EXECadodbsql

func EXECadodbsql(req *DbTaskRequest, sql string) (err error)

func EXECadodbsql2

func EXECadodbsql2(req *pb.DbTaskRequest, sql string) (err error)

func EscapeJson

func EscapeJson(s string) string

转义json特殊字符

func ExecShell

func ExecShell(ctx context.Context, command string) (string, error)

执行shell命令，可设置执行超时时间

func FileExist

func FileExist(file string) bool

判断文件是否存在及是否有权限访问

func GBK2UTF8

func GBK2UTF8(s string) (string, bool)

GBK编码转换为UTF8

func GetDB

func GetDB() (*sql.DB, error)

func InStringSlice

func InStringSlice(slice []string, element string) bool

func JsonResponseByErr

func JsonResponseByErr(err error) string

func Md5

func Md5(str string) string

生成32位MD5摘要

func RandAuthToken

func RandAuthToken() string

func RandNumber

func RandNumber(max int) int

生成0-max之间随机数

func RandString

func RandString(length int64) string

生成长度为length的随机字符串

func ReplaceStrings

func ReplaceStrings(s string, old []string, replace []string) string

批量替换字符串

Types

type DbTaskRequest

type DbTaskRequest struct {
	Local   string
	Dbname  string
	Port    int64
	Dip     string
	Ac      string
	Pd      string
	Dtype   int32
	Sqlpath string
	Timeout int32 // 任务执行超时时间
	Id      int64 // 执行任务唯一ID
	Ftp     []*DbtaskrequestFtp
}

type DbTaskResponse

type DbTaskResponse struct {
	Output string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"` // 命令标准输出
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`   // 命令错误
}

type DbtaskrequestFtp

type DbtaskrequestFtp struct {
	Dip  string // 命令
	Port int64
	Ac   string
	Pd   string
}

type JsonResponse

type JsonResponse struct{}

func (*JsonResponse) CommonFailure

func (j *JsonResponse) CommonFailure(message string, err ...error) string

func (*JsonResponse) Failure

func (j *JsonResponse) Failure(code int, message string) string

func (*JsonResponse) Success

func (j *JsonResponse) Success(message string, data interface{}) string

type Jsonstrt

type Jsonstrt struct {
	Value string
	Label string
}

type Mssql

type Mssql struct {
	*sql.DB
	DataSource string
	Database   string
	Windows    bool
	Sa         SA
}

func (*Mssql) GetDsn

func (m *Mssql) GetDsn() (ret string)

func (*Mssql) Open

func (m *Mssql) Open() (err error)

type Result

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

type SA

type SA struct {
	User   string
	Passwd string
}