ds-sdk/sdk.go

package ds_sdk

import (
	"errors"
	"git.sxidc.com/go-tools/utils/strutils"
	"git.sxidc.com/service-supports/ds-sdk/client"
)

type SDK struct {
	options *Options
	client  *client.Client
}

func (sdk *SDK) CreateDataContainer(name string, spec map[string]any) error {
	if strutils.IsStringEmpty(name) {
		return errors.New("没有传递数据容器名称")
	}

	options := sdk.options

	err := sdk.client.CreateDataContainer(options.token, options.baseUrl,
		options.namespace, options.dataSource.Name, name, spec)
	if err != nil {
		return err
	}

	return nil
}

func (sdk *SDK) DeleteDataContainer(name string) error {
	if strutils.IsStringEmpty(name) {
		return errors.New("没有传递数据容器名称")
	}

	options := sdk.options

	err := sdk.client.DeleteDataContainer(options.token, options.baseUrl,
		options.namespace, options.dataSource.Name, name)
	if err != nil {
		return err
	}

	return nil
}

func (sdk *SDK) GetDataContainers(name string, pageNo int, pageSize int) ([]client.DataContainerInfo, error) {
	options := sdk.options

	return sdk.client.GetDataContainers(options.token, options.baseUrl,
		options.namespace, options.dataSource.Name, name, pageNo, pageSize)
}

func (sdk *SDK) ExecuteRawSql(sql string) ([]map[string]any, error) {
	if strutils.IsStringEmpty(sql) {
		return make([]map[string]any, 0), nil
	}

	options := sdk.options

	results, err := sdk.client.ExecuteRawSql(options.token, options.baseUrl,
		options.namespace, options.dataSource.Name, sql)
	if err != nil {
		return nil, err
	}

	return results, nil
}

func (sdk *SDK) ExecuteSql(name string, executeParams map[string]any) ([]map[string]any, error) {
	if strutils.IsStringEmpty(name) {
		return nil, errors.New("没有传递SQL资源名称")
	}

	options := sdk.options

	results, err := sdk.client.ExecuteSql(options.token, options.baseUrl,
		options.namespace, options.dataSource.Name, name, executeParams)
	if err != nil {
		return nil, err
	}

	return results, nil
}