( ctx context.Context, storeInstance *store.Store, engine storepb.Engine, databaseName string, statement string, instance *store.InstanceMessage, getDatabaseMetadataFunc base.GetDatabaseMetadataFunc, listDatabaseNamesFunc base.ListDatabaseNamesFunc, getLinkedDatabaseMetadataFunc base.GetLinkedDatabaseMetadataFunc, )
| 335 | } |
| 336 | |
| 337 | func getResourcesForMSSQL( |
| 338 | ctx context.Context, |
| 339 | storeInstance *store.Store, |
| 340 | engine storepb.Engine, |
| 341 | databaseName string, |
| 342 | statement string, |
| 343 | instance *store.InstanceMessage, |
| 344 | getDatabaseMetadataFunc base.GetDatabaseMetadataFunc, |
| 345 | listDatabaseNamesFunc base.ListDatabaseNamesFunc, |
| 346 | getLinkedDatabaseMetadataFunc base.GetLinkedDatabaseMetadataFunc, |
| 347 | ) ([]base.SchemaResource, error) { |
| 348 | dataSource := utils.DataSourceFromInstanceWithType(instance, storepb.DataSourceType_READ_ONLY) |
| 349 | adminDataSource := utils.DataSourceFromInstanceWithType(instance, storepb.DataSourceType_ADMIN) |
| 350 | if dataSource == nil { |
| 351 | dataSource = adminDataSource |
| 352 | } |
| 353 | if dataSource == nil { |
| 354 | return nil, connect.NewError(connect.CodeInternal, errors.Errorf("failed to find data source for instance: %s", instance.ResourceID)) |
| 355 | } |
| 356 | return getResourcesForPostgres(ctx, storeInstance, engine, databaseName, statement, instance, "dbo", getDatabaseMetadataFunc, listDatabaseNamesFunc, getLinkedDatabaseMetadataFunc) |
| 357 | } |
| 358 | |
| 359 | func resourceExists(dbMetadata *model.DatabaseMetadata, resource base.SchemaResource) bool { |
| 360 | schema := dbMetadata.GetSchemaMetadata(resource.Schema) |
no test coverage detected