Method getDatabaseNames

backend/plugin/db/hive/sync.go:76–89

(ctx context.Context)

}

func (d *Driver) getDatabaseNames(ctx context.Context) ([]string, error) {
	var databaseNames []string
	result, err := d.queryStatementWithLimit(ctx, "SHOW DATABASES", 0)
	if err != nil {
		return nil, errors.Wrap(err, "failed to get version from instance")
	}
	for _, row := range result.Rows {
		if row == nil || len(row.Values) == 0 {
			return nil, errors.New("row values have zero length")
		}
		databaseNames = append(databaseNames, row.Values[0].GetStringValue())
	}
	return databaseNames, nil
}

func (d *Driver) listTablesNames(ctx context.Context, databaseName string) ([]string, error) {
	result, err := d.queryStatementWithLimit(ctx, fmt.Sprintf("SHOW TABLES FROM %s", databaseName), 0)