RAI-12193 Let Integration service assign default DB Link schema (#64)

Author: wienleung

CHANGELOG.md

@@ -1,6 +1,10 @@
 # Changelog
 
-## v0.1.7-alpha
+## v0.1.9-alpha
+
+* Make schema flag optional when creating Snowflake database links
+
+## v0.1.8-alpha
 
 * Remove engine flag from create integration command
 * Remove is-view from create datastream command
@@ -9,6 +13,7 @@
 * Add support for updating Snowflake database links
 
 ## v0.1.6-alpha
+
 * Add Snowflake data stream status support
 * Modify Snowflake data stream create for view support
 

rai/cmds.go

@@ -849,7 +849,7 @@ func createSnowflakeDatabaseLink(cmd *cobra.Command, args []string) {
 	action := newAction(cmd)
 	integration := args[0]
 	database := action.getStringEnv("database", "SNOWSQL_DATABASE")
-	schema := action.getStringEnv("schema", "SNOWSQL_SCHEMA")
+	schema := action.getString("schema")
 	role := action.getStringEnv("role", "SNOWSQL_ROLE")
 	username := action.getStringEnv("username", "SNOWSQL_USER")
 	password := action.getStringEnv("password", "SNOWSQL_PWD")

rai/main.go

@@ -344,7 +344,7 @@ func addCommands(root *cobra.Command) {
 		Args:  cobra.ExactArgs(1),
 		Run:   createSnowflakeDatabaseLink}
 	cmd.Flags().String("database", "", "Snowflake database (default: SNOWSQL_DATABASE)")
-	cmd.Flags().String("schema", "", "Snowflake schema (default: SNOWSQL_SCHEMA)")
+	cmd.Flags().String("schema", "", "Snowflake schema (default: 'RAI')")
 	cmd.Flags().String("role", "", "Snowflake role (default: SNOWSQL_ROLE)")
 	cmd.Flags().String("username", "", "Snowflake username (default: SNOWSQL_USER)")
 	cmd.Flags().String("password", "", "Snowflake password (default: SNOWSQL_PWD)")