Atividades de acesso a base de dados

As atividades de acesso a base de dados permitem que você acesse um base de dados em um fluxo de trabalho. Essas atividades permitem acessar bancos de dados para recuperar ou modificar informações e usar ADO.NET para acessar o banco de dados.

Atividades de base de dados

As seções a seguir detalham a lista de atividades incluídas no exemplo DbActivities.

DbUpdate

Executa uma consulta SQL que gerencia uma alteração na base de dados (inserção, atualização, exclusão, e outras alterações).

Essa classe executa seu trabalho de forma assíncrona (deriva de AsyncCodeActivity e usa seus recursos assíncronas).

Informações de conexão podem ser configuradas definindo um nome invariável do provedor (ProviderName) e a cadeia de conexão (ConnectionString) ou usando apenas um nome da configuração da cadeia de conexão (ConfigFileSectionName) do arquivo de configuração do aplicativo.

A consulta a ser executada é configurada em sua propriedade Sql e os parâmetros são passados através da coleção Parameters.

Após DbUpdate é executado, o número de registros afetados é retornado na propriedade de AffectedRecords .

Public class DbUpdate: AsyncCodeActivity
{
    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DefaultValue(null)]
    public InArgument<string> ProviderName { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DependsOn("ProviderName")]
    [DefaultValue(null)]
    public InArgument<string> ConnectionString { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConfigFileSectionName")]
    [DefaultValue(null)]
    public InArgument<string> ConfigName { get; set; }

    [DefaultValue(null)]
    public CommandType CommandType { get; set; }

    [RequiredArgument]
    public InArgument<string> Sql { get; set; }

    [DependsOn("Sql")]
    [DefaultValue(null)]
    public IDictionary<string, Argument> Parameters { get; }

    [DependsOn("Parameters")]
    public OutArgument<int> AffectedRecords { get; set; }
}

DbQueryScalar

Executa uma consulta que recupera um único valor de base de dados.

Essa classe executa seu trabalho de forma assíncrona (deriva de AsyncCodeActivity<TResult> e usa seus recursos assíncronas).

Informações de conexão podem ser configuradas definindo um nome invariável do provedor (ProviderName) e a cadeia de conexão (ConnectionString) ou usando apenas um nome da configuração da cadeia de conexão (ConfigFileSectionName) do arquivo de configuração do aplicativo.

A consulta a ser executada é configurada em sua propriedade Sql e os parâmetros são passados através da coleção Parameters.

Após a execução de DbQueryScalar, o escalar é retornado no argumento Result out (do tipo TResult, que é definido na classe base AsyncCodeActivity<TResult>).

public class DbQueryScalar<TResult> : AsyncCodeActivity<TResult>
{
    // public arguments
    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DefaultValue(null)]
    public InArgument<string> ProviderName { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DependsOn("ProviderName")]
    [DefaultValue(null)]
    public InArgument<string> ConnectionString { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConfigFileSectionName")]
    [DefaultValue(null)]
    public InArgument<string> ConfigName { get; set; }

    [DefaultValue(null)]
    public CommandType CommandType { get; set; }

    [RequiredArgument]
    public InArgument<string> Sql { get; set; }

    [DependsOn("Sql")]
    [DefaultValue(null)]
    public IDictionary<string, Argument> Parameters { get; }
}

DbQuery

Executa uma consulta que recupera uma lista de objetos. Após a execução da consulta, uma função de mapeamento é executada (pode ser Func<TResult><DbDataReader, TResult> ou um ActivityFunc<TResult><DbDataReader, TResult>). Essa função de mapeamento pega um registro em DbDataReader e o mapeia para o objeto a ser retornado.

Informações de conexão podem ser configuradas definindo um nome invariável do provedor (ProviderName) e a cadeia de conexão (ConnectionString) ou usando apenas um nome da configuração da cadeia de conexão (ConfigFileSectionName) do arquivo de configuração do aplicativo.

A consulta a ser executada é configurada em sua propriedade Sql e os parâmetros são passados através da coleção Parameters.

Os resultados da consulta SQL são recuperados usando DbDataReader. A atividade itera através de DbDataReader e mapeia as linhas em DbDataReader em uma instância de TResult. O usuário de DbQuery deve fornecer o código de mapeamento e isso pode ser feito de duas maneiras: usando um Func<TResult><DbDataReader, TResult> ou um ActivityFunc<TResult><DbDataReader, TResult>. No primeiro caso, o mapa é feito em um único pulso de execução. Portanto, é mais rápido, mas isto não pode ser serializado em XAML. No último caso, o mapa é executado em vários pulsos. Portanto, pode ser mais lento, mas pode ser serializado para XAML e ser criado declarativamente (quaisquer atividades existentes podem participar no mapeamento).

public class DbQuery<TResult> : AsyncCodeActivity<IList<TResult>> where TResult : class
{
    // public arguments
    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DefaultValue(null)]
    public InArgument<string> ProviderName { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DependsOn("ProviderName")]
    [DefaultValue(null)]
    public InArgument<string> ConnectionString { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConfigFileSectionName")]
    [DefaultValue(null)]
    public InArgument<string> ConfigName { get; set; }

    [DefaultValue(null)]
    public CommandType CommandType { get; set; }

    [RequiredArgument]
    public InArgument<string> Sql { get; set; }

    [DependsOn("Sql")]
    [DefaultValue(null)]
    public IDictionary<string, Argument> Parameters { get; }

    [OverloadGroup("DirectMapping")]
    [DefaultValue(null)]
    public Func<DbDataReader, TResult> Mapper { get; set; }

    [OverloadGroup("MultiplePulseMapping")]
    [DefaultValue(null)]
    public ActivityFunc<DbDataReader, TResult> MapperFunc { get; set; }
}

DbQueryDataSet

Executa uma consulta que retorna DataSet. Essa classe executa seu trabalho de forma assíncrona. Deriva de AsyncCodeActivity<TResult> e usa seus recursos assíncronos.

Informações de conexão podem ser configuradas definindo um nome invariável do provedor (ProviderName) e a cadeia de conexão (ConnectionString) ou usando apenas um nome da configuração da cadeia de conexão (ConfigFileSectionName) do arquivo de configuração do aplicativo.

A consulta a ser executada é configurada em sua propriedade Sql e os parâmetros são passados através da coleção Parameters.

Após a execução de DbQueryDataSet, DataSet é retornado no argumento Result out (do tipo TResult, que é definido na classe base AsyncCodeActivity<TResult>).

public class DbQueryDataSet : AsyncCodeActivity<DataSet>
{
    // public arguments
    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DefaultValue(null)]
    public InArgument<string> ProviderName { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConnectionString")]
    [DependsOn("ProviderName")]
    [DefaultValue(null)]
    public InArgument<string> ConnectionString { get; set; }

    [RequiredArgument]
    [OverloadGroup("ConfigFileSectionName")]
    [DefaultValue(null)]
    public InArgument<string> ConfigName { get; set; }

    [DefaultValue(null)]
    public CommandType CommandType { get; set; }

    [RequiredArgument]
    public InArgument<string> Sql { get; set; }

    [DependsOn("Sql")]
    [DefaultValue(null)]
    public IDictionary<string, Argument> Parameters { get; }
}

Configurar informações de conexão

Todas as DbActivities compartilham os mesmos parâmetros de configuração. Podem ser configurados em duas maneiras:

• ConnectionString + InvariantName: Defina o nome e a cadeia de conexão invariável do provedor ADO.NET.

  Activity dbSelectCount = new DbQueryScalar<DateTime>()
  {
      ProviderName = "System.Data.SqlClient",
      ConnectionString = @"Data Source=.\SQLExpress;
                            Initial Catalog=DbActivitiesSample;
                            Integrated Security=True",
      Sql = "SELECT GetDate()"
  };
  

• ConfigName: Defina o nome da seção de configuração que contém informações de conexão.

  <connectionStrings>
      <add name="DbActivitiesSample"
            providerName="System.Data.SqlClient"
            connectionString="Data Source=.\SQLExpress;Initial Catalog=DbActivitiesSample;Integrated Security=true"/>
    </connectionStrings>
  

  Na atividade:

  Activity dbSelectCount = new DbQueryScalar<int>()
  {
      ConfigName = "DbActivitiesSample",
      Sql = "SELECT COUNT(*) FROM Roles"
  };
  

Executar esta amostra

Instruções de configuração

Este exemplo usa uma base de dados. Um script de instalação e de carregamento (Setup.cmd) é fornecido com o exemplo. Você deve executar esse arquivo usando o prompt de comando.

O script de Setup.cmd chama o arquivo de script CreateDb.sql, que contém os comandos SQL que façam o seguinte:

• Cria um base de dados chamado DbActivitiesSample.
• Cria a tabela Roles
• Cria a tabela Employees.
• Insere três registros na tabela de Roles.
• Insere doze registros na tabela Employees.

Para executar Setup.cmd

1. Abra um prompt de comando.

2. Acesse a pasta de exemplo DbActivities.

3. Digite "setup.cmd" e pressione Enter.

   Observação

   Setup.cmd tenta instalar o exemplo na instância do SQL Express em seu computador local. Se você deseja instalá-lo em outra instância do SQL Server, edite o Setup.cmd com o novo nome da instância.

Para executar a amostra

1. Abra a solução no Visual Studio.
2. Para criar a solução, pressione Ctrl+Shift+B.
3. Para executar o exemplo sem depuração, pressione Ctrl+F5.

Para desinstalar o banco de dados de exemplo, execute Cleanup.cmd na pasta de exemplo em um prompt de comando.