Add Expression verification API signature

accessors/spanner/expression_verify.go

@@ -0,0 +1,50 @@
+package spanneraccessor
+
+import (
+	"context"
+	"sync"
+
+	spanneradmin "github.com/GoogleCloudPlatform/spanner-migration-tool/accessors/clients/spanner/admin"
+	"github.com/GoogleCloudPlatform/spanner-migration-tool/internal"
+	"github.com/GoogleCloudPlatform/spanner-migration-tool/sources/common"
+)
+
+
+type ExpressionVerificationAccessor interface {
+	//Creates an empty staging database if it does not exist.
+	CreateStagingDb(ctx context.Context, adminClient spanneradmin.AdminClient, dbURI string) (bool, error)
+	//Initialize an empty database (or force initializes a non-empty one) with a conv object
+	InitializeStagingDb(ctx context.Context, adminClient spanneradmin.AdminClient, dbURI string, conv *internal.Conv, force bool) (bool, error)
+	//Deletes a staging database
+	DeleteStagingDb(ctx context.Context, adminClient spanneradmin.AdminClient, dbURI string) (bool, error)
+	//Internal API which verifies an expression by making a call to Spanner
+	VerifyExpression(ctx context.Context, verificationInput internal.VerificationInput, mutex *sync.Mutex) common.TaskResult[internal.VerificationResult]
+	//Batch API which parallelizes expression verification calls
+	BatchVerifyExpressions(ctx context.Context, verificationInputList []internal.VerificationInput) internal.BatchVerificationResult
+}
+
+type ExpressionVerificationAccessorImpl struct{}
+
+func (ev *ExpressionVerificationAccessorImpl) CreateStagingDb(ctx context.Context, adminClient spanneradmin.AdminClient, dbURI string) (bool, error) {
+	return true, nil
+}
+
+func (ev *ExpressionVerificationAccessorImpl) InitializeStagingDb(ctx context.Context, adminClient spanneradmin.AdminClient, dbURI string, conv *internal.Conv, force bool) (bool, error) {
+	return true, nil
+}
+
+func (ev *ExpressionVerificationAccessorImpl) DeleteStagingDb(ctx context.Context, adminClient spanneradmin.AdminClient, dbURI string) (bool, error) {
+	return true, nil
+}
+
+func (ev *ExpressionVerificationAccessorImpl) VerifyExpression(ctx context.Context, verificationInput internal.VerificationInput, mutex *sync.Mutex) common.TaskResult[internal.VerificationResult] {
+	return common.TaskResult[internal.VerificationResult]{}
+}
+
+func (ev *ExpressionVerificationAccessorImpl) BatchVerifyExpressions(ctx context.Context, verificationInputList []internal.VerificationInput) (internal.BatchVerificationResult) {
+	return internal.BatchVerificationResult{}
+}
+
+
+
+

internal/convert.go

@@ -290,6 +290,32 @@ type TableDetails struct {
 	TableName string `json:TableName`
 }
 
+type ExpressionDetail struct {
+	ReferenceElement ReferenceElement
+	Expression string
+	Type string
+	Metadata map[string]string
+}
+
+type ReferenceElement struct {
+	Id string
+	Name string
+}
+
+type VerificationInput struct {
+	DbURI string
+	ExpressionDetail ExpressionDetail
+}
+
+type VerificationResult struct {
+	Result bool
+	err error
+}
+
+type BatchVerificationResult struct {
+	VerificationResultList []VerificationResult
+}
+
 // MakeConv returns a default-configured Conv.
 func MakeConv() *Conv {
 	return &Conv{