- Unit tests working.

Author: general-kroll-4-life

go.mod

@@ -16,7 +16,7 @@ require (
 	github.com/spf13/cobra v1.4.0
 	github.com/spf13/pflag v1.0.5
 	github.com/spf13/viper v1.10.1
-	github.com/stackql/any-sdk v0.2.2-alpha08
+	github.com/stackql/any-sdk v0.2.2-alpha10
 	github.com/stackql/go-suffix-map v0.0.1-alpha01
 	github.com/stackql/psql-wire v0.1.1-beta23
 	github.com/stackql/stackql-parser v0.0.15-alpha06

go.sum

@@ -461,8 +461,8 @@ github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/spf13/viper v1.10.1 h1:nuJZuYpG7gTj/XqiUwg8bA0cp1+M2mC3J4g5luUYBKk=
 github.com/spf13/viper v1.10.1/go.mod h1:IGlFPqhNAPKRxohIzWpI5QEy4kuI7tcl5WvR+8qy1rU=
-github.com/stackql/any-sdk v0.2.2-alpha08 h1:EmjP9s6+Blys3I9oH0mfXcexKDOibKv9j/GdQqVLleU=
-github.com/stackql/any-sdk v0.2.2-alpha08/go.mod h1:m1o5TCfyKkdt2bREB3itwPv1MhM+lk4eu24KpPohFoY=
+github.com/stackql/any-sdk v0.2.2-alpha10 h1:L6vUM9zccvclI00MHC82zjQ1EoAWopJlMlSCgJHtKtQ=
+github.com/stackql/any-sdk v0.2.2-alpha10/go.mod h1:m1o5TCfyKkdt2bREB3itwPv1MhM+lk4eu24KpPohFoY=
 github.com/stackql/go-suffix-map v0.0.1-alpha01 h1:TDUDS8bySu41Oo9p0eniUeCm43mnRM6zFEd6j6VUaz8=
 github.com/stackql/go-suffix-map v0.0.1-alpha01/go.mod h1:QAi+SKukOyf4dBtWy8UMy+hsXXV+yyEE4vmBkji2V7g=
 github.com/stackql/psql-wire v0.1.1-beta23 h1:1ayYMjZArfDcIMyEOKnm+Bp1zRCISw8pguvTFuUhhVQ=

internal/stackql/dependencyplanner/dependencyplanner.go

@@ -408,7 +408,7 @@ func (dp *standardDependencyPlanner) processOrphan(
 	} else {
 		// Persist SQL mirror table here prior to generating insert DML
 		drmCfg := dp.handlerCtx.GetDrmConfig()
-		ddl, ddlErr := drmCfg.GenerateDDL(anTab, opStore, 0, false, false)
+		ddl, ddlErr := drmCfg.GenerateDDL(anTab, nil, nil, nil, opStore, 0, false, false)
 		if ddlErr != nil {
 			return nil, nil, ddlErr
 		}
@@ -529,6 +529,14 @@ func (dp *standardDependencyPlanner) processAcquire(
 	if err != nil {
 		return util.NewAnnotatedTabulation(nil, nil, "", ""), nil, err
 	}
+	svc, err := annotationCtx.GetTableMeta().GetService()
+	if err != nil {
+		return util.NewAnnotatedTabulation(nil, nil, "", ""), nil, err
+	}
+	resource, rscErr := annotationCtx.GetTableMeta().GetResource()
+	if rscErr != nil {
+		return util.NewAnnotatedTabulation(nil, nil, "", ""), nil, rscErr
+	}
 	m, err := annotationCtx.GetTableMeta().GetMethod()
 	if err != nil {
 		return util.NewAnnotatedTabulation(nil, nil, "", ""), nil, err
@@ -558,6 +566,9 @@ func (dp *standardDependencyPlanner) processAcquire(
 		annotationCtx.GetTableMeta().GetAlias()).WithParameters(annotationCtx.GetParameters())
 
 	discoGenID, err := docparser.OpenapiStackQLTabulationsPersistor(
+		prov,
+		svc,
+		resource,
 		m,
 		[]util.AnnotatedTabulation{anTab},
 		dp.primitiveComposer.GetSQLEngine(),

internal/stackql/docparser/doc_parser.go

@@ -34,6 +34,9 @@ func TranslateServiceKeyIqlToGenericProvider(serviceKey string) string {
 }
 
 func OpenapiStackQLTabulationsPersistor(
+	prov anysdk.Provider,
+	svc anysdk.Service,
+	resource anysdk.Resource,
 	m anysdk.OperationStore,
 	tabluationsAnnotated []util.AnnotatedTabulation,
 	dbEngine sqlengine.SQLEngine,
@@ -65,7 +68,7 @@ func OpenapiStackQLTabulationsPersistor(
 		return discoveryGenerationID, err
 	}
 	for _, tblt := range tabluationsAnnotated {
-		ddl, ddlErr := drmCfg.GenerateDDL(tblt, m, discoveryGenerationID, false, true)
+		ddl, ddlErr := drmCfg.GenerateDDL(tblt, prov, svc, resource, m, discoveryGenerationID, false, true)
 		if ddlErr != nil {
 			displayErr := fmt.Errorf("error generating DDL: %w", err)
 			logging.GetLogger().Infoln(displayErr.Error())

internal/stackql/drm/drm_cfg.go

@@ -15,6 +15,7 @@ import (
 	"github.com/stackql/any-sdk/pkg/streaming"
 	"github.com/stackql/any-sdk/public/discovery"
 	sdk_persistence "github.com/stackql/any-sdk/public/persistence"
+	"github.com/stackql/any-sdk/public/radix_tree_address_space"
 	"github.com/stackql/any-sdk/public/sqlengine"
 	"github.com/stackql/stackql/internal/stackql/internal_data_transfer/internaldto"
 	"github.com/stackql/stackql/internal/stackql/internal_data_transfer/relationaldto"
@@ -46,7 +47,7 @@ type Config interface {
 	) (map[string]map[string]interface{}, map[int]map[int]interface{})
 	GetCurrentTable(internaldto.HeirarchyIdentifiers) (internaldto.DBTable, error)
 	GetRelationalType(string) string
-	GenerateDDL(util.AnnotatedTabulation, anysdk.OperationStore, int, bool, bool) ([]string, error)
+	GenerateDDL(util.AnnotatedTabulation, anysdk.Provider, anysdk.Service, anysdk.Resource, anysdk.OperationStore, int, bool, bool) ([]string, error)
 	GetControlAttributes() sqlcontrol.ControlAttributes
 	GetGolangValue(string) interface{}
 	GetGolangSlices([]typing.ColumnMetadata) ([]interface{}, []string)
@@ -108,6 +109,7 @@ type staticDRMConfig struct {
 	typCfg                 typing.Config
 	analyzerFactoryFactory discovery.StaticAnalyzerFactoryFactory
 	persistenceSystem      sdk_persistence.PersistenceSystem
+	registryAPI            anysdk.RegistryAPI
 }
 
 func (dc *staticDRMConfig) GetSQLSystem() sql_system.SQLSystem {
@@ -412,8 +414,12 @@ func (dc *staticDRMConfig) getParserTableName(
 }
 
 func (dc *staticDRMConfig) inferColType(col util.Column) string {
-	relationalType := textStr
 	schema := col.GetSchema()
+	return dc.inferColTypeFromSchema(schema)
+}
+
+func (dc *staticDRMConfig) inferColTypeFromSchema(schema anysdk.Schema) string {
+	relationalType := textStr
 	if schema != nil && schema.GetType() != "" {
 		relationalType = dc.GetRelationalType(schema.GetType())
 	}
@@ -446,6 +452,9 @@ func (dc *staticDRMConfig) genRelationalTableFromExternalSQLTable(
 
 func (dc *staticDRMConfig) genRelationalTable(
 	tabAnn util.AnnotatedTabulation,
+	prov anysdk.Provider,
+	svc anysdk.Service,
+	resource anysdk.Resource,
 	m anysdk.OperationStore,
 	discoveryGenerationID int,
 	isNilResponseAlloed bool,
@@ -478,17 +487,45 @@ func (dc *staticDRMConfig) genRelationalTable(
 		relationalColumn := typing.NewRelationalColumn(colName, colType).WithWidth(colWidth)
 		relationalTable.PushBackColumn(relationalColumn)
 	}
+	//nolint:lll // acceptable
+	method, isOpenApiMethod := m.(anysdk.StandardOperationStore)
+	if isOpenApiMethod {
+		addressSpaceFormulator := radix_tree_address_space.NewAddressSpaceFormulator(
+			radix_tree_address_space.NewAddressSpaceGrammar(),
+			prov,
+			svc,
+			resource,
+			method,
+			method.GetProjections(),
+		)
+		addressSpaceErr := addressSpaceFormulator.Formulate()
+		if addressSpaceErr != nil {
+			return nil, addressSpaceErr
+		}
+		// TODO: use address space
+		addressSpace := addressSpaceFormulator.GetAddressSpace()
+		if addressSpace == nil {
+			return nil, fmt.Errorf("failed to obtain address space")
+		}
+	}
+	// analyzer, analyzerErr := methodAnalyzerFactory.CreateMethodAggregateStaticAnalyzer(
+	// 	path.Join(dc.registryAPI.GetLocalProviderDocPath("", ""),
+
+	// )
 	return relationalTable, nil
 }
 
 func (dc *staticDRMConfig) GenerateDDL(
 	tabAnn util.AnnotatedTabulation,
+	prov anysdk.Provider,
+	svc anysdk.Service,
+	resource anysdk.Resource,
 	m anysdk.OperationStore,
 	discoveryGenerationID int,
 	dropTable bool,
 	isNilResponseAlloed bool,
 ) ([]string, error) {
-	relationalTable, err := dc.genRelationalTable(tabAnn, m, discoveryGenerationID, isNilResponseAlloed)
+	relationalTable, err := dc.genRelationalTable(tabAnn, prov, svc, resource, m, discoveryGenerationID, isNilResponseAlloed)
 	if err != nil {
 		return nil, err
 	}

internal/stackql/primitivegenerator/unary_selection.go

@@ -17,6 +17,7 @@ import (
 	"github.com/stackql/stackql-parser/go/vt/sqlparser"
 )
 
+//nolint:funlen // apathy
 func (pb *standardPrimitiveGenerator) assembleUnarySelectionBuilder(
 	pbi planbuilderinput.PlanBuilderInput,
 	handlerCtx handler.HandlerContext,
@@ -40,14 +41,24 @@ func (pb *standardPrimitiveGenerator) assembleUnarySelectionBuilder(
 	if err != nil {
 		return err
 	}
-
+	svc, err := tbl.GetService()
+	if err != nil {
+		return err
+	}
+	resource, err := tbl.GetResource()
+	if err != nil {
+		return err
+	}
 	method, err := tbl.GetMethod()
 	if err != nil {
 		return err
 	}
-
 	_, err = docparser.OpenapiStackQLTabulationsPersistor(
-		method, []util.AnnotatedTabulation{annotatedInsertTabulation},
+		prov,
+		svc,
+		resource,
+		method,
+		[]util.AnnotatedTabulation{annotatedInsertTabulation},
 		pb.PrimitiveComposer.GetSQLEngine(),
 		prov.GetName(),
 		handlerCtx.GetNamespaceCollection(),