- Tests passing, soon big changes.

general-kroll-4-life · general-kroll-4-life · commit bb98e3a563ae · 2025-03-02T20:17:44.000+05:30
diff --git a/go.mod b/go.mod
@@ -19,7 +19,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.0.6-alpha18
+	github.com/stackql/any-sdk v0.1.1-alpha02
 	github.com/stackql/go-suffix-map v0.0.1-alpha01
 	github.com/stackql/psql-wire v0.1.1-alpha07
 	github.com/stackql/stackql-parser v0.0.14-alpha05
diff --git a/go.sum b/go.sum
@@ -482,8 +482,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.0.6-alpha18 h1:JLbmmlQ9dEfmeX1qPLaqkLkQ7WLmq5Fc5wmNgiiHOB4=
-github.com/stackql/any-sdk v0.0.6-alpha18/go.mod h1:4jYKpPoX2GWEK+qBnlGLvr8SUfndiYwHMIkg1dn9tFM=
+github.com/stackql/any-sdk v0.1.1-alpha02 h1:4KtB2mZ1nHig69wI/GZlKcr/c08va4JY4m+HK0UWLVw=
+github.com/stackql/any-sdk v0.1.1-alpha02/go.mod h1:4jYKpPoX2GWEK+qBnlGLvr8SUfndiYwHMIkg1dn9tFM=
 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-alpha07 h1:LQWVUlx4Bougk6dztDNG5tmXxpIVeeTSsInTj801xCs=
diff --git a/internal/stackql/planbuilder/plan_builder.go b/internal/stackql/planbuilder/plan_builder.go
@@ -637,7 +637,7 @@ func (pgb *standardPlanGraphBuilder) handleDelete(pbi planbuilderinput.PlanBuild
 		}
 		return nil
 	}
-	pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
+	pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
 	pgb.planGraphHolder.CreatePrimitiveNode(pr)
 	return nil
 }
@@ -926,7 +926,7 @@ func (pgb *standardPlanGraphBuilder) handleInsert(pbi planbuilderinput.PlanBuild
 		}
 		return nil
 	}
-	pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
+	pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
 	pgb.planGraphHolder.CreatePrimitiveNode(pr)
 	return nil
 }
@@ -991,7 +991,7 @@ func (pgb *standardPlanGraphBuilder) handleUpdate(pbi planbuilderinput.PlanBuild
 		}
 		return nil
 	}
-	pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
+	pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
 	pgb.planGraphHolder.CreatePrimitiveNode(pr)
 	return nil
 }
@@ -1034,7 +1034,7 @@ func (pgb *standardPlanGraphBuilder) handleExec(pbi planbuilderinput.PlanBuilder
 		}
 		return nil
 	}
-	pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
+	pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())
 	pgb.planGraphHolder.CreatePrimitiveNode(pr)
 	return nil
 }
diff --git a/internal/stackql/primitive/generic_primitive.go b/internal/stackql/primitive/generic_primitive.go
@@ -9,7 +9,7 @@ import (
 	"github.com/stackql/stackql/internal/stackql/provider"
 )
 
-type HTTPRestPrimitive struct {
+type GenericPrimitive struct {
 	Provider      provider.IProvider
 	Executor      func(pc IPrimitiveCtx) internaldto.ExecutorOutput
 	Preparator    func() drm.PreparedStatementCtx
@@ -23,14 +23,14 @@ type HTTPRestPrimitive struct {
 	debugName     string
 }
 
-func NewHTTPRestPrimitive(
+func NewGenericPrimitive(
 	provider provider.IProvider,
 	executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput,
 	preparator func() drm.PreparedStatementCtx,
 	txnCtrlCtr internaldto.TxnControlCounters,
 	primitiveCtx primitive_context.IPrimitiveCtx,
 ) IPrimitive {
-	return &HTTPRestPrimitive{
+	return &GenericPrimitive{
 		Provider:      provider,
 		Executor:      executor,
 		Preparator:    preparator,
@@ -41,52 +41,52 @@ func NewHTTPRestPrimitive(
 	}
 }
 
-func (pr *HTTPRestPrimitive) WithDebugName(name string) IPrimitive {
+func (pr *GenericPrimitive) WithDebugName(name string) IPrimitive {
 	pr.debugName = name
 	return pr
 }
 
-func (pr *HTTPRestPrimitive) SetUndoLog(log binlog.LogEntry) {
+func (pr *GenericPrimitive) SetUndoLog(log binlog.LogEntry) {
 	pr.undoLog = log
 }
 
-func (pr *HTTPRestPrimitive) SetRedoLog(log binlog.LogEntry) {
+func (pr *GenericPrimitive) SetRedoLog(log binlog.LogEntry) {
 	pr.redoLog = log
 }
 
-func (pr *HTTPRestPrimitive) GetRedoLog() (binlog.LogEntry, bool) {
+func (pr *GenericPrimitive) GetRedoLog() (binlog.LogEntry, bool) {
 	return pr.redoLog, pr.redoLog != nil
 }
 
-func (pr *HTTPRestPrimitive) GetUndoLog() (binlog.LogEntry, bool) {
+func (pr *GenericPrimitive) GetUndoLog() (binlog.LogEntry, bool) {
 	return pr.undoLog, pr.undoLog != nil
 }
 
-func (pr *HTTPRestPrimitive) SetTxnID(id int) {
+func (pr *GenericPrimitive) SetTxnID(id int) {
 	if pr.TxnControlCtr != nil {
 		pr.TxnControlCtr.SetTxnID(id)
 	}
 }
 
-func (pr *HTTPRestPrimitive) IsReadOnly() bool {
+func (pr *GenericPrimitive) IsReadOnly() bool {
 	return pr.isReadOnly
 }
 
-func (pr *HTTPRestPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error {
+func (pr *GenericPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error {
 	pr.Inputs[fromID] = input
 	return nil
 }
 
-func (pr *HTTPRestPrimitive) SetInputAlias(alias string, id int64) error {
+func (pr *GenericPrimitive) SetInputAlias(alias string, id int64) error {
 	pr.InputAliases[alias] = id
 	return nil
 }
 
-func (pr *HTTPRestPrimitive) Optimise() error {
+func (pr *GenericPrimitive) Optimise() error {
 	return nil
 }
 
-func (pr *HTTPRestPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool) {
+func (pr *GenericPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool) {
 	var rv internaldto.ExecutorOutput
 	key, keyExists := pr.InputAliases[alias]
 	if !keyExists {
@@ -99,7 +99,7 @@ func (pr *HTTPRestPrimitive) GetInputFromAlias(alias string) (internaldto.Execut
 	return input, true
 }
 
-func (pr *HTTPRestPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput {
+func (pr *GenericPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput {
 	if pr.Executor != nil {
 		logging.GetLogger().Debugf("running HTTP rest primitive %s", pr.debugName)
 		op := pr.Executor(pc)
@@ -108,11 +108,11 @@ func (pr *HTTPRestPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutpu
 	return internaldto.NewExecutorOutput(nil, nil, nil, nil, nil)
 }
 
-func (pr *HTTPRestPrimitive) ID() int64 {
+func (pr *GenericPrimitive) ID() int64 {
 	return pr.id
 }
 
-func (pr *HTTPRestPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error {
+func (pr *GenericPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error {
 	pr.Executor = ex
 	return nil
 }
diff --git a/internal/stackql/primitivebuilder/delete.go b/internal/stackql/primitivebuilder/delete.go
@@ -164,7 +164,7 @@ func (ss *Delete) Build() error {
 			ss.handlerCtx.GetTypingConfig(),
 		)
 	}
-	deletePrimitive := primitive.NewHTTPRestPrimitive(
+	deletePrimitive := primitive.NewGenericPrimitive(
 		prov,
 		ex,
 		nil,
diff --git a/internal/stackql/primitivebuilder/exec.go b/internal/stackql/primitivebuilder/exec.go
@@ -163,7 +163,7 @@ func (ss *Exec) Build() error {
 			ss.handlerCtx.GetTypingConfig(),
 		)
 	}
-	execPrimitive := primitive.NewHTTPRestPrimitive(
+	execPrimitive := primitive.NewGenericPrimitive(
 		prov,
 		ex,
 		nil,
diff --git a/internal/stackql/primitivebuilder/generic_http_reversal.go b/internal/stackql/primitivebuilder/generic_http_reversal.go
@@ -112,7 +112,7 @@ func (gh *genericHTTPReversal) Build() error {
 	commentDirectives := gh.commentDirectives
 	isAwait := gh.isAwait
 	_, _, responseAnalysisErr := m.GetResponseBodySchemaAndMediaType()
-	actionPrimitive := primitive.NewHTTPRestPrimitive(
+	actionPrimitive := primitive.NewGenericPrimitive(
 		prov,
 		nil,
 		nil,
@@ -236,7 +236,7 @@ func (gh *genericHTTPReversal) Build() error {
 			}
 			for _, eI := range nullaryExecutors {
 				execInstance := eI
-				dependentInsertPrimitive := primitive.NewHTTPRestPrimitive(
+				dependentInsertPrimitive := primitive.NewGenericPrimitive(
 					prov,
 					nil,
 					nil,
diff --git a/internal/stackql/primitivebuilder/generic_http_stream_input.go b/internal/stackql/primitivebuilder/generic_http_stream_input.go
@@ -189,7 +189,7 @@ func (gh *genericHTTPStreamInput) Build() error {
 		// inverseBuilder :=
 	}
 	_, _, responseAnalysisErr := tbl.GetResponseSchemaAndMediaType()
-	actionPrimitive := primitive.NewHTTPRestPrimitive(
+	actionPrimitive := primitive.NewGenericPrimitive(
 		prov,
 		nil,
 		nil,
@@ -341,7 +341,7 @@ func (gh *genericHTTPStreamInput) Build() error {
 		}
 		for _, eI := range nullaryExecutors {
 			execInstance := eI
-			dependentInsertPrimitive := primitive.NewHTTPRestPrimitive(
+			dependentInsertPrimitive := primitive.NewGenericPrimitive(
 				prov,
 				nil,
 				nil,
diff --git a/internal/stackql/primitivebuilder/graphql_single_select_acquire.go b/internal/stackql/primitivebuilder/graphql_single_select_acquire.go
@@ -199,7 +199,7 @@ func (ss *GraphQLSingleSelectAcquire) Build() error {
 	prep := func() drm.PreparedStatementCtx {
 		return ss.insertPreparedStatementCtx
 	}
-	insertPrim := primitive.NewHTTPRestPrimitive(
+	insertPrim := primitive.NewGenericPrimitive(
 		prov,
 		ex,
 		prep,
diff --git a/internal/stackql/primitivebuilder/mono_valent_execution.go b/internal/stackql/primitivebuilder/mono_valent_execution.go
diff --git a/internal/stackql/primitivebuilder/poly_valent_execution.go b/internal/stackql/primitivebuilder/poly_valent_execution.go
diff --git a/internal/stackql/primitivebuilder/single_select_acquire.go b/internal/stackql/primitivebuilder/single_select_acquire.go
diff --git a/internal/stackql/primitivebuilder/sql_data_source_single_select_acquire.go b/internal/stackql/primitivebuilder/sql_data_source_single_select_acquire.go

Original file line number	Diff line number	Diff line change
`@@ -637,7 +637,7 @@ func (pgb *standardPlanGraphBuilder) handleDelete(pbi planbuilderinput.PlanBuild`
`637`	`637`	`}`
`638`	`638`	`return nil`
`639`	`639`	`}`
`640`		`- pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
	`640`	`+ pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
`641`	`641`	`pgb.planGraphHolder.CreatePrimitiveNode(pr)`
`642`	`642`	`return nil`
`643`	`643`	`}`
`@@ -926,7 +926,7 @@ func (pgb *standardPlanGraphBuilder) handleInsert(pbi planbuilderinput.PlanBuild`
`926`	`926`	`}`
`927`	`927`	`return nil`
`928`	`928`	`}`
`929`		`- pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
	`929`	`+ pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
`930`	`930`	`pgb.planGraphHolder.CreatePrimitiveNode(pr)`
`931`	`931`	`return nil`
`932`	`932`	`}`
`@@ -991,7 +991,7 @@ func (pgb *standardPlanGraphBuilder) handleUpdate(pbi planbuilderinput.PlanBuild`
`991`	`991`	`}`
`992`	`992`	`return nil`
`993`	`993`	`}`
`994`		`- pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
	`994`	`+ pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
`995`	`995`	`pgb.planGraphHolder.CreatePrimitiveNode(pr)`
`996`	`996`	`return nil`
`997`	`997`	`}`
`@@ -1034,7 +1034,7 @@ func (pgb *standardPlanGraphBuilder) handleExec(pbi planbuilderinput.PlanBuilder`
`1034`	`1034`	`}`
`1035`	`1035`	`return nil`
`1036`	`1036`	`}`
`1037`		`- pr := primitive.NewHTTPRestPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
	`1037`	`+ pr := primitive.NewGenericPrimitive(nil, nil, nil, nil, primitive_context.NewPrimitiveContext())`
`1038`	`1038`	`pgb.planGraphHolder.CreatePrimitiveNode(pr)`
`1039`	`1039`	`return nil`
`1040`	`1040`	`}`
Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,7 @@ import (`
`9`	`9`	`"github.com/stackql/stackql/internal/stackql/provider"`
`10`	`10`	`)`
`11`	`11`
`12`		`-type HTTPRestPrimitive struct {`
	`12`	`+type GenericPrimitive struct {`
`13`	`13`	`Provider provider.IProvider`
`14`	`14`	`Executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput`
`15`	`15`	`Preparator func() drm.PreparedStatementCtx`
`@@ -23,14 +23,14 @@ type HTTPRestPrimitive struct {`
`23`	`23`	`debugName string`
`24`	`24`	`}`
`25`	`25`
`26`		`-func NewHTTPRestPrimitive(`
	`26`	`+func NewGenericPrimitive(`
`27`	`27`	`provider provider.IProvider,`
`28`	`28`	`executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput,`
`29`	`29`	`preparator func() drm.PreparedStatementCtx,`
`30`	`30`	`txnCtrlCtr internaldto.TxnControlCounters,`
`31`	`31`	`primitiveCtx primitive_context.IPrimitiveCtx,`
`32`	`32`	`) IPrimitive {`
`33`		`- return &HTTPRestPrimitive{`
	`33`	`+ return &GenericPrimitive{`
`34`	`34`	`Provider: provider,`
`35`	`35`	`Executor: executor,`
`36`	`36`	`Preparator: preparator,`
`@@ -41,52 +41,52 @@ func NewHTTPRestPrimitive(`
`41`	`41`	`}`
`42`	`42`	`}`
`43`	`43`
`44`		`-func (pr *HTTPRestPrimitive) WithDebugName(name string) IPrimitive {`
	`44`	`+func (pr *GenericPrimitive) WithDebugName(name string) IPrimitive {`
`45`	`45`	`pr.debugName = name`
`46`	`46`	`return pr`
`47`	`47`	`}`
`48`	`48`
`49`		`-func (pr *HTTPRestPrimitive) SetUndoLog(log binlog.LogEntry) {`
	`49`	`+func (pr *GenericPrimitive) SetUndoLog(log binlog.LogEntry) {`
`50`	`50`	`pr.undoLog = log`
`51`	`51`	`}`
`52`	`52`
`53`		`-func (pr *HTTPRestPrimitive) SetRedoLog(log binlog.LogEntry) {`
	`53`	`+func (pr *GenericPrimitive) SetRedoLog(log binlog.LogEntry) {`
`54`	`54`	`pr.redoLog = log`
`55`	`55`	`}`
`56`	`56`
`57`		`-func (pr *HTTPRestPrimitive) GetRedoLog() (binlog.LogEntry, bool) {`
	`57`	`+func (pr *GenericPrimitive) GetRedoLog() (binlog.LogEntry, bool) {`
`58`	`58`	`return pr.redoLog, pr.redoLog != nil`
`59`	`59`	`}`
`60`	`60`
`61`		`-func (pr *HTTPRestPrimitive) GetUndoLog() (binlog.LogEntry, bool) {`
	`61`	`+func (pr *GenericPrimitive) GetUndoLog() (binlog.LogEntry, bool) {`
`62`	`62`	`return pr.undoLog, pr.undoLog != nil`
`63`	`63`	`}`
`64`	`64`
`65`		`-func (pr *HTTPRestPrimitive) SetTxnID(id int) {`
	`65`	`+func (pr *GenericPrimitive) SetTxnID(id int) {`
`66`	`66`	`if pr.TxnControlCtr != nil {`
`67`	`67`	`pr.TxnControlCtr.SetTxnID(id)`
`68`	`68`	`}`
`69`	`69`	`}`
`70`	`70`
`71`		`-func (pr *HTTPRestPrimitive) IsReadOnly() bool {`
	`71`	`+func (pr *GenericPrimitive) IsReadOnly() bool {`
`72`	`72`	`return pr.isReadOnly`
`73`	`73`	`}`
`74`	`74`
`75`		`-func (pr *HTTPRestPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error {`
	`75`	`+func (pr *GenericPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error {`
`76`	`76`	`pr.Inputs[fromID] = input`
`77`	`77`	`return nil`
`78`	`78`	`}`
`79`	`79`
`80`		`-func (pr *HTTPRestPrimitive) SetInputAlias(alias string, id int64) error {`
	`80`	`+func (pr *GenericPrimitive) SetInputAlias(alias string, id int64) error {`
`81`	`81`	`pr.InputAliases[alias] = id`
`82`	`82`	`return nil`
`83`	`83`	`}`
`84`	`84`
`85`		`-func (pr *HTTPRestPrimitive) Optimise() error {`
	`85`	`+func (pr *GenericPrimitive) Optimise() error {`
`86`	`86`	`return nil`
`87`	`87`	`}`
`88`	`88`
`89`		`-func (pr *HTTPRestPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool) {`
	`89`	`+func (pr *GenericPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool) {`
`90`	`90`	`var rv internaldto.ExecutorOutput`
`91`	`91`	`key, keyExists := pr.InputAliases[alias]`
`92`	`92`	`if !keyExists {`
`@@ -99,7 +99,7 @@ func (pr *HTTPRestPrimitive) GetInputFromAlias(alias string) (internaldto.Execut`
`99`	`99`	`return input, true`
`100`	`100`	`}`
`101`	`101`
`102`		`-func (pr *HTTPRestPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput {`
	`102`	`+func (pr *GenericPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput {`
`103`	`103`	`if pr.Executor != nil {`
`104`	`104`	`logging.GetLogger().Debugf("running HTTP rest primitive %s", pr.debugName)`
`105`	`105`	`op := pr.Executor(pc)`
`@@ -108,11 +108,11 @@ func (pr *HTTPRestPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutpu`
`108`	`108`	`return internaldto.NewExecutorOutput(nil, nil, nil, nil, nil)`
`109`	`109`	`}`
`110`	`110`
`111`		`-func (pr *HTTPRestPrimitive) ID() int64 {`
	`111`	`+func (pr *GenericPrimitive) ID() int64 {`
`112`	`112`	`return pr.id`
`113`	`113`	`}`
`114`	`114`
`115`		`-func (pr *HTTPRestPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error {`
	`115`	`+func (pr *GenericPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error {`
`116`	`116`	`pr.Executor = ex`
`117`	`117`	`return nil`
`118`	`118`	`}`
Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ func (ss *Delete) Build() error {`
`164`	`164`	`ss.handlerCtx.GetTypingConfig(),`
`165`	`165`	`)`
`166`	`166`	`}`
`167`		`- deletePrimitive := primitive.NewHTTPRestPrimitive(`
	`167`	`+ deletePrimitive := primitive.NewGenericPrimitive(`
`168`	`168`	`prov,`
`169`	`169`	`ex,`
`170`	`170`	`nil,`
Original file line number	Diff line number	Diff line change
`@@ -163,7 +163,7 @@ func (ss *Exec) Build() error {`
`163`	`163`	`ss.handlerCtx.GetTypingConfig(),`
`164`	`164`	`)`
`165`	`165`	`}`
`166`		`- execPrimitive := primitive.NewHTTPRestPrimitive(`
	`166`	`+ execPrimitive := primitive.NewGenericPrimitive(`
`167`	`167`	`prov,`
`168`	`168`	`ex,`
`169`	`169`	`nil,`
Original file line number	Diff line number	Diff line change
`@@ -199,7 +199,7 @@ func (ss *GraphQLSingleSelectAcquire) Build() error {`
`199`	`199`	`prep := func() drm.PreparedStatementCtx {`
`200`	`200`	`return ss.insertPreparedStatementCtx`
`201`	`201`	`}`
`202`		`- insertPrim := primitive.NewHTTPRestPrimitive(`
	`202`	`+ insertPrim := primitive.NewGenericPrimitive(`
`203`	`203`	`prov,`
`204`	`204`	`ex,`
`205`	`205`	`prep,`