Runtime : Support multiple schemas with one live connection

proto/gen/rill/runtime/v1/runtime.swagger.yaml

@@ -120,6 +120,14 @@ paths:
           in: query
           required: false
           type: string
+        - name: database
+          in: query
+          required: false
+          type: string
+        - name: dbSchema
+          in: query
+          required: false
+          type: string
         - name: table
           in: query
           required: false
@@ -711,6 +719,10 @@ paths:
             properties:
               connector:
                 type: string
+              database:
+                type: string
+              dbSchema:
+                type: string
               table:
                 type: string
               path:
@@ -1065,6 +1077,14 @@ paths:
           in: query
           required: false
           type: string
+        - name: database
+          in: query
+          required: false
+          type: string
+        - name: dbSchema
+          in: query
+          required: false
+          type: string
         - name: priority
           in: query
           required: false
@@ -1831,6 +1851,14 @@ paths:
           in: query
           required: false
           type: string
+        - name: database
+          in: query
+          required: false
+          type: string
+        - name: dbSchema
+          in: query
+          required: false
+          type: string
         - name: limit
           in: query
           required: false
@@ -1946,6 +1974,14 @@ paths:
           in: query
           required: false
           type: string
+        - name: database
+          in: query
+          required: false
+          type: string
+        - name: dbSchema
+          in: query
+          required: false
+          type: string
         - name: priority
           in: query
           required: false
@@ -4340,6 +4376,12 @@ definitions:
       connector:
         type: string
         title: Connector containing the table
+      database:
+        type: string
+        title: Name of the database where table is located (optional)
+      dbSchema:
+        type: string
+        title: Name of the database schema where table is located (optional)
       table:
         type: string
         title: Name of the table the metrics view is based on
@@ -5530,6 +5572,10 @@ definitions:
         type: string
       connector:
         type: string
+      database:
+        type: string
+      dbSchema:
+        type: string
       tableName:
         type: string
         title: Required
@@ -5550,6 +5596,10 @@ definitions:
         type: string
       connector:
         type: string
+      database:
+        type: string
+      dbSchema:
+        type: string
       tableName:
         type: string
       priority:
@@ -5572,6 +5622,8 @@ definitions:
     properties:
       database:
         type: string
+      dbSchema:
+        type: string
       name:
         type: string
       hasUnsupportedDataTypes:
@@ -5584,6 +5636,10 @@ definitions:
         type: string
       connector:
         type: string
+      database:
+        type: string
+      dbSchema:
+        type: string
       tableName:
         type: string
       limit:

proto/rill/runtime/v1/api.proto

@@ -504,6 +504,8 @@ message UnpackEmptyResponse {}
 message GenerateMetricsViewFileRequest {
   string instance_id = 1 [(validate.rules).string = {pattern: "^[_\\-a-zA-Z0-9]+$"}];
   string connector = 2;
+  string database = 6;
+  string db_schema = 7;
   string table = 3;
   string path = 4;
   bool use_ai = 5;

proto/rill/runtime/v1/connectors.proto

@@ -183,6 +183,7 @@ message OLAPListTablesResponse {
 
 message TableInfo {
   string database = 1;
+  string db_schema = 4;
   string name = 2;
   // has_unsupported_data_types indicates if the underlying table has any column with an unsupported OLAP engine datatype
   bool has_unsupported_data_types = 3;
@@ -191,6 +192,8 @@ message TableInfo {
 message OLAPGetTableRequest {
   string instance_id = 1;
   string connector = 2;
+  string database = 4;
+  string db_schema = 5;
   string table = 3;
 }
 

proto/rill/runtime/v1/queries.proto

@@ -938,6 +938,8 @@ message TimeSeriesValue {
 message TableCardinalityRequest {
   string instance_id = 1;
   string connector = 4;
+  string database = 5;
+  string db_schema = 6;
   // Required
   string table_name = 2 [(validate.rules).string.min_len = 1];
   int32 priority = 3;
@@ -951,6 +953,8 @@ message TableCardinalityResponse {
 message TableColumnsRequest {
   string instance_id = 1;
   string connector = 4;
+  string database = 5;
+  string db_schema = 6;
   string table_name = 2 [(validate.rules).string.min_len = 1];
   int32 priority = 3;
 }
@@ -972,6 +976,8 @@ message ProfileColumn {
 message TableRowsRequest {
   string instance_id = 1;
   string connector = 5;
+  string database = 6;
+  string db_schema = 7;
   string table_name = 2 [(validate.rules).string.min_len = 1];
   int32 limit = 3 [(validate.rules).int32.gte = 0];
   int32 priority = 4;

proto/rill/runtime/v1/resources.proto

@@ -179,6 +179,10 @@ message MetricsViewSpec {
   }
   // Connector containing the table
   string connector = 1;
+  // Name of the database where table is located (optional)
+  string database = 21;
+  // Name of the database schema where table is located (optional)
+  string db_schema = 22;
   // Name of the table the metrics view is based on
   string table = 2;
   // User friendly label for the dashboard

runtime/compilers/rillv1/parse_metrics_view.go

@@ -21,6 +21,8 @@ type MetricsViewYAML struct {
 	DisplayName        string           `yaml:"display_name"` // Backwards compatibility
 	Description        string           `yaml:"description"`
 	Model              string           `yaml:"model"`
+	Database           string           `yaml:"database"`
+	DBSchema           string           `yaml:"db_schema"`
 	Table              string           `yaml:"table"`
 	TimeDimension      string           `yaml:"timeseries"`
 	Watermark          string           `yaml:"watermark"`
@@ -416,6 +418,8 @@ func (p *Parser) parseMetricsView(node *Node) error {
 
 	spec.Connector = node.Connector
 	spec.Table = table
+	spec.DbSchema = tmp.DBSchema
+	spec.Database = tmp.Database
 	spec.Title = tmp.Title
 	spec.Description = tmp.Description
 	spec.TimeDimension = tmp.TimeDimension