Method getPartitions

backend/plugin/db/hive/sync.go:183–203

(ctx context.Context, databaseName, tableName string)

}

func (d *Driver) getPartitions(ctx context.Context, databaseName, tableName string) ([]*storepb.TablePartitionMetadata, error) {
	// partitions.
	partitionResult, err := d.queryStatementWithLimit(ctx, fmt.Sprintf("SHOW PARTITIONS `%s`.`%s`", databaseName, tableName), 0)
	if err != nil {
		slog.Debug("failed to get partitions", log.BBError(err))
		return nil, nil
	}
	if partitionResult == nil {
		return nil, nil
	}
	var partitions []*storepb.TablePartitionMetadata
	for _, row := range partitionResult.Rows {
		if row == nil || len(row.Values) == 0 {
			return nil, errors.New("partitions result row has zero length")
		}
		partitions = append(partitions, &storepb.TablePartitionMetadata{
			Name: row.Values[0].GetStringValue(),
		})
	}
	return partitions, nil
}

// This function gets certain database info by name.
func (d *Driver) getDatabaseInfoByName(ctx context.Context, databaseName string) (*storepb.SchemaMetadata, error) {