Method getVersion

backend/plugin/db/hive/sync.go:58–74

(ctx context.Context)

}

func (d *Driver) getVersion(ctx context.Context) (string, error) {
	result, err := d.queryStatementWithLimit(ctx, "SELECT VERSION()", 0)
	if err != nil {
		return "", errors.Wrap(err, "failed to get version from instance")
	}

	if len(result.Rows) == 0 || len(result.Rows[0].Values) == 0 {
		return "", errors.New("invalid version result")
	}
	// rawVersion has the format of "1.2.3 commitID".
	rawVersion := result.Rows[0].Values[0].GetStringValue()
	tokens := strings.Split(rawVersion, " ")
	if len(tokens) == 0 {
		return "", errors.Errorf("invalid version %q", rawVersion)
	}
	return tokens[0], nil
}

func (d *Driver) getDatabaseNames(ctx context.Context) ([]string, error) {
	var databaseNames []string