static-analysis-v1

Summary:

- Change interface to support AOT static analysis.

Author: general-kroll-4-life

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.1.4-beta03
+	github.com/stackql/any-sdk v0.1.5-alpha03
 	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

@@ -484,8 +484,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.1.4-beta03 h1:hEpVc04jQ2BgfiyIxBVB1K4cyzjlc2BL6dH/Of4jRMU=
-github.com/stackql/any-sdk v0.1.4-beta03/go.mod h1:AKS/g28y7m4SWL/YW8veE9MCNy8XJgaicVibemVE9e8=
+github.com/stackql/any-sdk v0.1.5-alpha03 h1:AVjRNU84M/ciSgsYgx13+pxIrCNdfs4QHCn20ZeT75o=
+github.com/stackql/any-sdk v0.1.5-alpha03/go.mod h1:AKS/g28y7m4SWL/YW8veE9MCNy8XJgaicVibemVE9e8=
 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/discovery/discovery.go

@@ -0,0 +1,65 @@
+package persistence
+
+import (
+	"github.com/stackql/any-sdk/anysdk"
+	"github.com/stackql/any-sdk/public/discovery"
+	"github.com/stackql/stackql/internal/stackql/sql_system"
+	"github.com/stackql/stackql/pkg/name_mangle"
+)
+
+var (
+	_ discovery.PersistenceSystem = &SQLPersistenceSystem{}
+)
+
+type SQLPersistenceSystem struct {
+	sqlSystem       sql_system.SQLSystem
+	viewNameMangler name_mangle.NameMangler
+}
+
+func NewSQLPersistenceSystem(sqlSystem sql_system.SQLSystem) *SQLPersistenceSystem {
+	return &SQLPersistenceSystem{
+		sqlSystem:       sqlSystem,
+		viewNameMangler: name_mangle.NewViewNameMangler(),
+	}
+}
+
+func (s *SQLPersistenceSystem) GetSystemName() string {
+	return s.sqlSystem.GetName()
+}
+
+func (s *SQLPersistenceSystem) HandleExternalTables(providerName string, externalTables map[string]anysdk.SQLExternalTable) error {
+	for _, tbl := range externalTables {
+		err := s.sqlSystem.RegisterExternalTable(
+			providerName,
+			tbl,
+		)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func (s *SQLPersistenceSystem) HandleViewCollection(viewCollection []anysdk.View) error {
+	for i, view := range viewCollection {
+		viewNameNaive := view.GetNameNaive()
+		viewName := s.viewNameMangler.MangleName(viewNameNaive, i)
+		_, viewExists := s.sqlSystem.GetViewByName(viewName)
+		if !viewExists {
+			// TODO: resolve any possible data race
+			err := s.sqlSystem.CreateView(viewName, view.GetDDL(), true, view.GetRequiredParamNames())
+			if err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}
+
+func (s *SQLPersistenceSystem) CacheStoreGet(key string) ([]byte, error) {
+	return s.sqlSystem.GetSQLEngine().CacheStoreGet(key)
+}
+
+func (s *SQLPersistenceSystem) CacheStorePut(key string, value []byte, expiration string, ttl int) error {
+	return s.sqlSystem.GetSQLEngine().CacheStorePut(key, value, expiration, ttl)
+}

internal/stackql/persistence/persistence_system.go

@@ -10,7 +10,7 @@ import (
 	"github.com/stackql/any-sdk/pkg/dto"
 	"github.com/stackql/any-sdk/pkg/logging"
 	"github.com/stackql/any-sdk/pkg/netutils"
-	"github.com/stackql/stackql/internal/stackql/discovery"
+	"github.com/stackql/any-sdk/public/discovery"
 	"github.com/stackql/stackql/internal/stackql/docparser"
 	"github.com/stackql/stackql/internal/stackql/internal_data_transfer/internaldto"
 	"github.com/stackql/stackql/internal/stackql/methodselect"