Method getDatabases

backend/plugin/db/cockroachdb/cockroachdb.go:197–220

getDatabases gets all databases of an instance.

(ctx context.Context)

// getDatabases gets all databases of an instance.
func (d *Driver) getDatabases(ctx context.Context) ([]*storepb.DatabaseSchemaMetadata, error) {
	var databases []*storepb.DatabaseSchemaMetadata
	if err := crdb.Execute(func() error {
		rows, err := d.db.QueryContext(ctx, "SELECT datname, pg_encoding_to_char(encoding), datcollate FROM pg_database;")
		if err != nil {
			return err
		}
		defer rows.Close()

		for rows.Next() {
			database := &storepb.DatabaseSchemaMetadata{}
			if err := rows.Scan(&database.Name, &database.CharacterSet, &database.Collation); err != nil {
				return err
			}
			databases = append(databases, database)
		}
		err = rows.Err()
		return err
	}); err != nil {
		return nil, err
	}

	return databases, nil
}

func (d *Driver) getVersion(ctx context.Context) (string, error) {
	// https://www.cockroachlabs.com/docs/v25.1/cluster-settings#setting-version