From fb5fbd6df52c1ea15d79311f550d3689a0cc85a2 Mon Sep 17 00:00:00 2001 From: Maciek Mika Date: Fri, 3 Mar 2023 09:26:56 +0100 Subject: [PATCH] feat(strm-2321): add snowflake dataconnector support --- go.mod | 2 +- go.sum | 6 ++---- pkg/entity/data_connector/jdbc_connection.go | 2 ++ 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/go.mod b/go.mod index 087902b..358c2ee 100644 --- a/go.mod +++ b/go.mod @@ -22,7 +22,7 @@ require ( github.com/spf13/cobra v1.6.1 github.com/spf13/pflag v1.0.5 github.com/spf13/viper v1.13.0 - github.com/strmprivacy/api-definitions-go/v2 v2.77.2-0.20230209161708-5cb1fd5f7480 + github.com/strmprivacy/api-definitions-go/v2 v2.80.0 github.com/trietsch/oauth2cli v1.13.1-0.20221209222543-0e76591d5463 golang.org/x/oauth2 v0.3.0 golang.org/x/sync v0.1.0 diff --git a/go.sum b/go.sum index 74a7950..e3631d7 100644 --- a/go.sum +++ b/go.sum @@ -281,10 +281,8 @@ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/ github.com/stretchr/testify v1.7.4/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= -github.com/strmprivacy/api-definitions-go/v2 v2.77.1 h1:ME/ai6GN+c8Sf1Ou8Ep/q+IZoisBeCu9arJGuJkcxKo= -github.com/strmprivacy/api-definitions-go/v2 v2.77.1/go.mod h1:w/9E4kfnf9vtE43sj8O/vR8h7VzHKxxMhYSbv66iwWY= -github.com/strmprivacy/api-definitions-go/v2 v2.77.2-0.20230209161708-5cb1fd5f7480 h1:JMad3B5+AidxwtP/bPBQ+nxHJ8F8JbDEMZDuZYWeCso= -github.com/strmprivacy/api-definitions-go/v2 v2.77.2-0.20230209161708-5cb1fd5f7480/go.mod h1:w/9E4kfnf9vtE43sj8O/vR8h7VzHKxxMhYSbv66iwWY= +github.com/strmprivacy/api-definitions-go/v2 v2.80.0 h1:1JypgCij1gyGhoeRN5ghVDeK+FsQqSS4z16WKCDp5Jo= +github.com/strmprivacy/api-definitions-go/v2 v2.80.0/go.mod h1:w/9E4kfnf9vtE43sj8O/vR8h7VzHKxxMhYSbv66iwWY= github.com/subosito/gotenv v1.4.1 h1:jyEFiXpy21Wm81FBN71l9VoMMV8H8jG+qIK3GCpY6Qs= github.com/subosito/gotenv v1.4.1/go.mod h1:ayKnFf/c6rvx/2iiLrJUk1e6plDbT3edrFNGqEflhK0= github.com/thoas/go-funk v0.9.1 h1:O549iLZqPpTUQ10ykd26sZhzD+rmR5pWhuElrhbC20M= diff --git a/pkg/entity/data_connector/jdbc_connection.go b/pkg/entity/data_connector/jdbc_connection.go index 2794e48..f072f5f 100644 --- a/pkg/entity/data_connector/jdbc_connection.go +++ b/pkg/entity/data_connector/jdbc_connection.go @@ -58,6 +58,8 @@ func determineDatabaseType(jdbcUrl string) entities.DatabaseType { databaseType = entities.DatabaseType_BIGQUERY case strings.Contains(jdbcUrl, "mysql"): databaseType = entities.DatabaseType_MYSQL + case strings.Contains(jdbcUrl, "snowflake"): + databaseType = entities.DatabaseType_SNOWFLAKE default: common.CliExit(errors.New(fmt.Sprintf("Unknown jdbc url (supported types: %s, %s, %s)", entities.DatabaseType_MYSQL.String(),