Method SyncDBSchema

backend/plugin/db/databricks/sync.go:28–51

sync catalog.

(ctx context.Context)

// sync catalog.
func (d *Driver) SyncDBSchema(ctx context.Context) (*storepb.DatabaseSchemaMetadata, error) {
	// return nothing if no catalogs are specified.
	if d.curCatalog == "" {
		return nil, nil
	}

	// fetch table data from databricks.
	catalogMap, err := d.listCatologTables(ctx, d.curCatalog)
	if err != nil {
		return nil, err
	}

	dbMetadataMeta := storepb.DatabaseSchemaMetadata{}
	schemaMap, ok := (catalogMap)[d.curCatalog]
	if !ok {
		return nil, errors.Errorf("cannot find metadata for catalog '%s'", d.curCatalog)
	}

	dbMetadataMeta.Name = d.curCatalog
	schemas := convertToStorepbSchemas(schemaMap)
	dbMetadataMeta.Schemas = schemas

	return &dbMetadataMeta, nil
}

func (d *Driver) SyncInstance(ctx context.Context) (*db.InstanceMetadata, error) {
	instanceMetadata := &db.InstanceMetadata{}