sdk

package
v0.7.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2024 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrDBRecordHasExist = errors.New("记录已存在")
	ErrDBRecordNotExist = errors.New("记录不存在")
)

Functions

func DestroyInstance

func DestroyInstance() error

func InitInstance

func InitInstance(token string, address string, httpPort string, grpcPort string, namespace string, dataSource string, opts ...Option) error

func IsErrorDBRecordHasExist added in v0.5.0

func IsErrorDBRecordHasExist(err error) bool

func IsErrorDBRecordNotExist added in v0.5.0

func IsErrorDBRecordNotExist(err error) bool

Types

type DataContainerDatabaseColumnSpec added in v0.2.2

type DataContainerDatabaseColumnSpec struct {
	Name        string `structs:"name"`
	Type        string `structs:"type"`
	Comment     string `structs:"comment"`
	PrimaryKey  bool   `structs:"primary_key"`
	Size        int    `structs:"size"`
	Unique      bool   `structs:"unique"`
	NotNull     bool   `structs:"not_null"`
	Index       bool   `structs:"index"`
	UniqueIndex string `structs:"unique_index"`
	Default     any    `structs:"default"`
}

type DataContainerDatabaseSpec added in v0.2.1

type DataContainerDatabaseSpec struct {
	TableName string                            `structs:"table_name"`
	Columns   []DataContainerDatabaseColumnSpec `structs:"columns"`
}

func (*DataContainerDatabaseSpec) ToMap added in v0.2.1

func (spec *DataContainerDatabaseSpec) ToMap() map[string]any

type DataSourceDatabaseSpec added in v0.2.3

type DataSourceDatabaseSpec struct {
	Type               string `structs:"type"`
	UserName           string `structs:"user_name"`
	Password           string `structs:"password"`
	Address            string `structs:"address"`
	Port               string `structs:"port"`
	Database           string `structs:"database"`
	MaxConnections     int    `structs:"max_connections"`
	MaxIdleConnections int    `structs:"max_idle_connections"`
}

func (*DataSourceDatabaseSpec) ToMap added in v0.2.3

func (spec *DataSourceDatabaseSpec) ToMap() map[string]any

type Option

type Option func(opts *Options)

func WithTimeout

func WithTimeout(timeout time.Duration) Option

type Options

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

type SDK

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

func GetInstance

func GetInstance() *SDK

func (*SDK) CreateSQL

func (s *SDK) CreateSQL(name string, spec map[string]any) error

func (*SDK) DeleteSQL

func (s *SDK) DeleteSQL(name string) error

func (*SDK) ExecuteRawSql

func (s *SDK) ExecuteRawSql(sql string, executeParams map[string]any) ([]map[string]any, error)

func (*SDK) ExecuteSql

func (s *SDK) ExecuteSql(name string, executeParams map[string]any) ([]map[string]any, error)

func (*SDK) Transaction added in v0.4.1

func (s *SDK) Transaction(txFunc TxFunc) error

type SqlSpec added in v0.2.1

type SqlSpec struct {
	Transaction bool   `structs:"transaction"`
	Clauses     string `structs:"clauses"`
}

func (*SqlSpec) ToMap added in v0.2.1

func (spec *SqlSpec) ToMap() map[string]any

type Transaction added in v0.4.1

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

func (*Transaction) ExecuteRawSql added in v0.4.1

func (tx *Transaction) ExecuteRawSql(sql string, executeParams map[string]any) ([]map[string]any, error)

func (*Transaction) ExecuteSql added in v0.4.1

func (tx *Transaction) ExecuteSql(name string, executeParams map[string]any) ([]map[string]any, error)

type TxFunc added in v0.4.1

type TxFunc func(tx *Transaction) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL