dps-sdk/instance_command.go

package dps

import (
	"git.sxidc.com/service-supports/dps-sdk/client"
	"git.sxidc.com/service-supports/fslog"
)

func Insert(req *client.InsertRequest, tx client.Transaction) error {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return nil
	}

	var statement string
	var err error

	if tx == nil {
		statement, err = dpsClient.Insert(req)
	} else {
		statement, err = tx.InsertTx(req)
	}
	if err != nil {
		return err
	}

	fslog.Info(statement)

	return nil
}

func InsertBatch(req *client.InsertBatchRequest, tx client.Transaction) error {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return nil
	}

	var statement string
	var err error

	if tx == nil {
		statement, err = dpsClient.InsertBatch(req)
	} else {
		statement, err = tx.InsertBatchTx(req)
	}
	if err != nil {
		return err
	}

	fslog.Info(statement)

	return nil
}

func Delete(req *client.DeleteRequest, tx client.Transaction) error {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return nil
	}

	var statement string
	var err error

	if tx == nil {
		statement, err = dpsClient.Delete(req)
	} else {
		statement, err = tx.DeleteTx(req)
	}
	if err != nil {
		return err
	}

	fslog.Info(statement)

	return nil
}

func DeleteBatch(req *client.DeleteBatchRequest, tx client.Transaction) error {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return nil
	}

	var statement string
	var err error

	if tx == nil {
		statement, err = dpsClient.DeleteBatch(req)
	} else {
		statement, err = tx.DeleteBatchTx(req)
	}
	if err != nil {
		return err
	}

	fslog.Info(statement)

	return nil
}

func Update(req *client.UpdateRequest, tx client.Transaction) error {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return nil
	}

	var statement string
	var err error

	if tx == nil {
		statement, err = dpsClient.Update(req)
	} else {
		statement, err = tx.UpdateTx(req)
	}
	if err != nil {
		return err
	}

	fslog.Info(statement)

	return nil
}

func Replay(req *client.ReplayRequest) error {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return nil
	}

	var statement string
	var err error

	statement, err = dpsClient.Replay(req)
	if err != nil {
		return err
	}

	fslog.Info(statement)

	return nil
}