PostgreSQL · Retrieve

Choose the columns to read

Which columns come back, in three scenarios: the ones you ask for (plus the id); all of them; and how an empty value differs from a NULL one.

Set up for this page

Besides the sample itself, it uses SampleContext.cs (the dbContext every sample is given); SampleOutput.cs (Step and Show, which print), in the files below.

Before scenario 1 the sample runs this, so the service and the rows the scenarios use are there:

Set up
var service = new ArxPgDbService(connectionString, ArxSchemaCatalog.Create()
    .Table("account", ArxIdColumn.Generated<long>("id"))
    .Build());
var account = new ArxEntity("account");
account["name"] = "Columns Ltd";
account["account_number"] = "ACC-R301";
account["website"] = "";
ArxRecordId id = await service.CreateAsync(account);

1 Some columns

The columns asked for; the id comes too, so the entity can be updated or deleted later.

Already in scope: service (ArxPgDbService), id (ArxRecordId)

C#
var read = await service.RetrieveAsync("account", id, new ArxColumnSet("name", "account_number")) ?? throw new InvalidOperationException("The account record isn't there.");

Console.WriteLine($"{string.Join(", ", read.Attributes.Select(x => x.Key))}");

Check it in the database

SQL

Run it in any SQL tool connected to the database, after the code has run.

SELECT id, name, account_number
FROM account
WHERE account_number = 'ACC-R301';

Expect: 1 row, Columns Ltd: the three attributes Retrieve returned.

2 All columns

No column set (or ArxColumnSet.All): every column of the table.

Already in scope: service (ArxPgDbService), id (ArxRecordId)

C#
var read = await service.RetrieveAsync("account", id) ?? throw new InvalidOperationException("The account record isn't there.");

Console.WriteLine($"{read.Attributes.Count} attributes, status {read["status"]}");

Check it in the database

SQL

Run it in any SQL tool connected to the database, after the code has run.

SELECT count(*)
FROM information_schema.columns
WHERE table_name = 'account';

Expect: 16, the number of attributes Retrieve returned.

3 Empty and NULL

An empty website is "", a missing one is null, and both are attributes: nothing is dropped.

Already in scope: service (ArxPgDbService), id (ArxRecordId)

C#
var read = await service.RetrieveAsync("account", id, new ArxColumnSet("website", "annual_revenue")) ?? throw new InvalidOperationException("The account record isn't there.");

Console.WriteLine($"website \"{read["website"]}\", annual_revenue {(read["annual_revenue"] == null ? "null" : read["annual_revenue"])}, both present: {read.Contains("website") && read.Contains("annual_revenue")}");

Check it in the database

SQL

Run it in any SQL tool connected to the database, after the code has run.

SELECT website = '' AS empty_website, annual_revenue IS NULL AS no_revenue
FROM account
WHERE account_number = 'ACC-R301';

Expect: 1 row, t, t.

Run the complete sample

The code above comes from one program, built in a fresh project and run against the database. To run it yourself, here is every file and step.

The program, its files and how to run it

Run it locally

  1. .NET SDK: .NET SDK 10.0.100 or later 10.0.x (target net10.0).
  2. Create the project:
    Terminal
    dotnet new console -n ArxSample -f net10.0
    cd ArxSample
  3. Install the packages:
    Terminal
    dotnet add package ARX.SDK.PostgreSql --version 1.0.0-rc.1
  4. Database: a PostgreSQL 16 (tested with 16.15) database with the sample schema.
  5. Configuration: set ARX_SAMPLES_POSTGRESQL to its connection string. Nothing is hard-coded.
  6. Source code: replace Program.cs and add the 3 other files below, with the file names shown.
  7. Run it:
    Terminal
    dotnet run
  8. Expected output: below.

The files

Program.cs

Runs the sample. Generated for this page; it reads the connection string from the environment.

using ArxSamples.PostgreSql;
using ArxSamples.PostgreSql.Operations.Retrieve.Basics;

// The connection string comes from the environment, never from the code (see "Configure the connection").
var connectionString = Environment.GetEnvironmentVariable("ARX_SAMPLES_POSTGRESQL")
    ?? throw new InvalidOperationException("Set the ARX_SAMPLES_POSTGRESQL environment variable to your PostgreSQL connection string.");

await new Basic2_ChooseTheColumns().RunAsync(new SampleContext(connectionString));
Basic2_ChooseTheColumns.cs

The sample, as it is in the repository.

using ARX.SDK.PostgreSql.Services;
using ARX.SDK.Services;

using static ArxSamples.PostgreSql.SampleOutput;

namespace ArxSamples.PostgreSql.Operations.Retrieve.Basics;

/// <summary>
/// Which columns come back, in three scenarios: the ones you ask for (plus the id); all of them; and how an empty value
/// differs from a NULL one.
/// </summary>
public sealed class Basic2_ChooseTheColumns : ISample
{
    public string Name => "retrieve-basics-2-choose-the-columns";

    public string Title => "Choose the columns to read";

    public async Task RunAsync(SampleContext dbContext)
    {
        var service = new ArxPgDbService(dbContext.ConnectionString, ArxSchemaCatalog.Create()
            .Table("account", ArxIdColumn.Generated<long>("id"))
            .Build());

        var account = new ArxEntity("account");
        account["name"] = "Columns Ltd";
        account["account_number"] = "ACC-R301";
        account["website"] = "";
        ArxRecordId id = await service.CreateAsync(account);

        await Scenario1_SomeColumnsAsync(service, id);

        await Scenario2_AllColumnsAsync(service, id);

        await Scenario3_EmptyIsNotNullAsync(service, id);
    }

    /// <summary>1. The columns asked for; the id comes too, so the entity can be updated or deleted later.</summary>
    private static async Task Scenario1_SomeColumnsAsync(ArxPgDbService service, ArxRecordId id)
    {
        Step("1. Some columns");

        var read = await service.RetrieveAsync("account", id, new ArxColumnSet("name", "account_number")) ?? throw new InvalidOperationException("The account record isn't there.");

        Show($"{string.Join(", ", read.Attributes.Select(x => x.Key))}");

        /* ===========================================================
         * [DIRECT QUERY CHECK]
         * -----------------------------------------------------------
         * SELECT id, name, account_number
         * FROM account
         * WHERE account_number = 'ACC-R301';
         * -- Expect: 1 row, Columns Ltd: the three attributes Retrieve returned.
         * ===========================================================
         */
    }

    /// <summary>2. No column set (or <c>ArxColumnSet.All</c>): every column of the table.</summary>
    private static async Task Scenario2_AllColumnsAsync(ArxPgDbService service, ArxRecordId id)
    {
        Step("2. All columns");

        var read = await service.RetrieveAsync("account", id) ?? throw new InvalidOperationException("The account record isn't there.");

        Show($"{read.Attributes.Count} attributes, status {read["status"]}");

        /* ===========================================================
         * [DIRECT QUERY CHECK]
         * -----------------------------------------------------------
         * SELECT count(*)
         * FROM information_schema.columns
         * WHERE table_name = 'account';
         * -- Expect: 16, the number of attributes Retrieve returned.
         * ===========================================================
         */
    }

    /// <summary>3. An empty website is "", a missing one is null, and both are attributes: nothing is dropped.</summary>
    private static async Task Scenario3_EmptyIsNotNullAsync(ArxPgDbService service, ArxRecordId id)
    {
        Step("3. Empty and NULL");

        var read = await service.RetrieveAsync("account", id, new ArxColumnSet("website", "annual_revenue")) ?? throw new InvalidOperationException("The account record isn't there.");

        Show($"website \"{read["website"]}\", annual_revenue {(read["annual_revenue"] == null ? "null" : read["annual_revenue"])}, both present: {read.Contains("website") && read.Contains("annual_revenue")}");

        /* ===========================================================
         * [DIRECT QUERY CHECK]
         * -----------------------------------------------------------
         * SELECT website = '' AS empty_website, annual_revenue IS NULL AS no_revenue
         * FROM account
         * WHERE account_number = 'ACC-R301';
         * -- Expect: 1 row, t, t.
         * ===========================================================
         */
    }
}
SampleContext.cs

What every sample is given: the connection string (and the ISample interface the samples implement).

namespace ArxSamples.PostgreSql;

/// <summary>One documentation sample: a scenario a real application has, shown end to end.</summary>
public interface ISample
{
    /// <summary>The name to run it alone: <c>dotnet run -- &lt;name&gt;</c>.</summary>
    string Name { get; }

    /// <summary>One line on what it shows.</summary>
    string Title { get; }

    Task RunAsync(SampleContext dbContext);
}

/// <summary>
/// What a sample is given. Every sample gets the connection string; the application's service and catalog
/// (SampleContext.Application.cs) and the plain Npgsql read-back helper (SampleContext.Direct.cs) live in their own
/// files, so a sample needs only the files it uses.
/// </summary>
public sealed partial class SampleContext
{
    public SampleContext(string connectionString)
    {
        ConnectionString = connectionString;
    }

    public string ConnectionString { get; }
}
SampleOutput.cs

How the samples print: Step for each scenario, Show for what it did, ShowError for an error caught on purpose.

using ARX.SDK;

namespace ArxSamples.PostgreSql;

/// <summary>How the samples print: a numbered step for each scenario, then what it did.</summary>
public static class SampleOutput
{
    /// <summary>The start of a scenario: <c>Step("1. By the id Create returned")</c>.</summary>
    public static void Step(string text) => Console.WriteLine($"  > {text}");

    /// <summary>What the scenario did.</summary>
    public static void Show(string text) => Console.WriteLine($"      {text}");

    /// <summary>An ARX error the scenario caught on purpose.</summary>
    public static void ShowError(ArxException exception)
        => Console.WriteLine($"      caught {exception.GetType().Name}: {exception.Message}");
}

Expected output

What dotnet run printed when the sample was verified, on a freshly created sample schema. Ids differ when the tables already hold rows.

Output
  > 1. Some columns
      name, account_number, id
  > 2. All columns
      17 attributes, status ACTIVE
  > 3. Empty and NULL
      website "", annual_revenue null, both present: True