(ctx context.Context, databaseName string)
| 106 | } |
| 107 | |
| 108 | func (d *Driver) notFoundDatabase(ctx context.Context, databaseName string) (bool, error) { |
| 109 | dsn := getDSN(d.config.DataSource.Host, databaseName) |
| 110 | _, err := d.dbClient.GetDatabase(ctx, &databasepb.GetDatabaseRequest{Name: dsn}) |
| 111 | if status.Code(err) == codes.NotFound { |
| 112 | return true, nil |
| 113 | } |
| 114 | if err != nil { |
| 115 | return false, err |
| 116 | } |
| 117 | return false, nil |
| 118 | } |
| 119 | |
| 120 | func getTable(ctx context.Context, tx *spanner.ReadOnlyTransaction, columnMap map[db.TableKey][]*storepb.ColumnMetadata) (map[string][]*storepb.TableMetadata, error) { |
| 121 | indexMap, err := getIndex(ctx, tx) |
no test coverage detected