Documentation ¶
Index ¶
- Variables
- func DestroyInstance() error
- func InitInstance(token string, address string, httpPort string, grpcPort string, ...) error
- func IsErrorDBRecordHasExist(err error) bool
- func IsErrorDBRecordNotExist(err error) bool
- func ParseSqlResultTimeStr(timeStr string) (time.Time, error)
- type DataContainerDatabaseColumnSpec
- type DataContainerDatabaseSpec
- type DataSourceDatabaseSpec
- type Option
- type Options
- type SDK
- func (s *SDK) CreateSQL(name string, spec map[string]any) error
- func (s *SDK) DeleteSQL(name string) error
- func (s *SDK) ExecuteRawSql(sql string, executeParams map[string]any) ([]SqlResult, error)
- func (s *SDK) ExecuteSql(name string, executeParams map[string]any) ([]SqlResult, error)
- func (s *SDK) Transaction(txFunc TxFunc) error
- type SqlResult
- func (result SqlResult) ColumnValueBool(columnName string) bool
- func (result SqlResult) ColumnValueFloat32(columnName string) float32
- func (result SqlResult) ColumnValueFloat64(columnName string) float64
- func (result SqlResult) ColumnValueInt(columnName string) int
- func (result SqlResult) ColumnValueInt16(columnName string) int16
- func (result SqlResult) ColumnValueInt32(columnName string) int32
- func (result SqlResult) ColumnValueInt64(columnName string) int64
- func (result SqlResult) ColumnValueInt8(columnName string) int8
- func (result SqlResult) ColumnValueString(columnName string) string
- func (result SqlResult) ColumnValueStringAsTime(columnName string) time.Time
- func (result SqlResult) ColumnValueUint(columnName string) uint
- func (result SqlResult) ColumnValueUint16(columnName string) uint16
- func (result SqlResult) ColumnValueUint32(columnName string) uint32
- func (result SqlResult) ColumnValueUint64(columnName string) uint64
- func (result SqlResult) ColumnValueUint8(columnName string) uint8
- type SqlSpec
- type Transaction
- type TxFunc
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrDBRecordHasExist = errors.New("记录已存在") ErrDBRecordNotExist = errors.New("记录不存在") )
Functions ¶
func DestroyInstance ¶
func DestroyInstance() error
func InitInstance ¶
func IsErrorDBRecordHasExist ¶ added in v0.5.0
func IsErrorDBRecordNotExist ¶ added in v0.5.0
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 SDK ¶
type SDK struct {
// contains filtered or unexported fields
}
func GetInstance ¶
func GetInstance() *SDK
func (*SDK) ExecuteRawSql ¶
func (*SDK) ExecuteSql ¶
func (*SDK) Transaction ¶ added in v0.4.1
type SqlResult ¶ added in v0.8.0
func (SqlResult) ColumnValueBool ¶ added in v0.8.0
func (SqlResult) ColumnValueFloat32 ¶ added in v0.8.0
func (SqlResult) ColumnValueFloat64 ¶ added in v0.8.0
func (SqlResult) ColumnValueInt ¶ added in v0.8.0
func (SqlResult) ColumnValueInt16 ¶ added in v0.8.0
func (SqlResult) ColumnValueInt32 ¶ added in v0.8.0
func (SqlResult) ColumnValueInt64 ¶ added in v0.8.0
func (SqlResult) ColumnValueInt8 ¶ added in v0.8.0
func (SqlResult) ColumnValueString ¶ added in v0.8.0
func (SqlResult) ColumnValueStringAsTime ¶ added in v0.8.0
func (SqlResult) ColumnValueUint ¶ added in v0.8.0
func (SqlResult) ColumnValueUint16 ¶ added in v0.8.0
func (SqlResult) ColumnValueUint32 ¶ added in v0.8.0
func (SqlResult) ColumnValueUint64 ¶ added in v0.8.0
func (SqlResult) ColumnValueUint8 ¶ added in v0.8.0
type Transaction ¶ added in v0.4.1
type Transaction struct {
// contains filtered or unexported fields
}
func (*Transaction) ExecuteRawSql ¶ added in v0.4.1
func (*Transaction) ExecuteSql ¶ added in v0.4.1
type TxFunc ¶ added in v0.4.1
type TxFunc func(tx *Transaction) error
Click to show internal directories.
Click to hide internal directories.