Dapper и SQLite. Не работает проверка существует ли таблица в БД. Как исправить?

Question

[Борис Животное]

public class Storage
    {
        public Storage()
        {
        }

        public async Task Initialize()
        {
            string connectionString = $"FileName=Data.sqlite";

            SqliteConnection connection = null;
            try
            {
                await Task.Run(async () =>
                {
                    connection = new SqliteConnection(connectionString);
                    connection.Open();
                    
                    var parameters = new { TableName = "options" };
                    int result = await connection.ExecuteAsync(
                           "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=@TableName", parameters);

                    if (result < 1)
                    {
                        result = await createTables(connection);
                    }
                });
            }
            finally
            {
                if (connection is not null)
                {
                    await connection.DisposeAsync();
                }
            }
        }

        private async Task<int> createTables(SqliteConnection connection)
        {
            return await connection.ExecuteAsync(@"
create table options
(
	parameter_name text not null,
	value text not null
);
create unique index options_parameter_name_uindex
	on options (parameter_name);");
        }
    }

<Project Sdk="Microsoft.NET.Sdk">

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp3.1</TargetFramework>
    <LangVersion>9</LangVersion>
  </PropertyGroup>

  <ItemGroup>
    <PackageReference Include="Dapper" Version="2.0.90" />
    <PackageReference Include="Microsoft.Data.Sqlite" Version="5.0.6" />
  </ItemGroup>

</Project>

Запрос всегда возвращает -1. Почему и как исправить?

Answer 1

[Александр Ананьев]

Просто используйте конструкцию CREATE TABLE IF NOT EXISTS

Answer 2

[Василий Банников]

int result = await connection.ExecuteAsync(
                           "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=@TableName", parameters);

ExecuteAsync предназначен для выполнения запросов, которые ничего не возвращают.
В вашем случае же надо использовать Query<int>(...).SingleAsync()

Comments

[Борис Животное]

Понял, спасибо. Не погружался в исходники Dapper, видимо, нужно было там подсмотреть. Да и в документации видел, что используется в примере Query, но мне казалось, что нет, ExecuteAsync тоже будет работать :)

[Василий Банников]

Борис Животное, там прямо в README всё написано :)