ds-sdk/sdk/sdk.go

package sdk

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

type SDK struct {
	options      *Options
	client       *client.Client
	dbOperations db_operations.DBOperations
}

func (s *SDK) GetDBOperations() db_operations.DBOperations {
	return s.dbOperations
}

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

	options := s.options

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

	return nil
}

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

	options := s.options

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

	return nil
}

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

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

// TODO 增加Event版本的Container创建

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

	options := s.options

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

	return results, nil
}

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

	options := s.options

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

	return nil
}

func (s *SDK) DeleteSQL(name string) error {
	if strutils.IsStringEmpty(name) {
		return errors.New("没有传递SQL资源名称")
	}

	options := s.options

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

	return nil
}

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

	options := s.options

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

	return results, nil
}