A implementação de um consumidor Simple

Artigo
08/01/2011

Os tópicos a seguir mostram como editar os arquivos criados pelo Assistente de aplicativo do MFC e ATL OLE DB consumidor Wizard para criar um consumidor simple. Este exemplo tem as seguintes partes:

"Recuperando dados com o consumidor" mostra como implementar o código no consumidor que lê todos os dados, linha por linha de uma tabela de banco de dados.
"Adicionando o suporte de indicador para o consumidor" mostra como adicionar suporte de indicador para o consumidor.
"Adicionando suporte a XML para o consumidor" mostra como modificar o código do consumidor de dados como dados XML recuperados do conjunto de linhas de saída.

Observação
Você pode usar o aplicativo de consumidor descrito nesta seção para testar os provedores de MyProv e o provedor de exemplo.

Observação
Para criar um aplicativo do consumidor para testar o MyProv (o mesmo provedor descrito em aprimorando o provedor de somente leitura simples), você deve incluir o suporte de indicador, conforme descrito em "Indicador de adicionando suporte para o consumidor".

Observação
Para criar um aplicativo do consumidor para testar o provedor, deixar o suporte de indicador, descrito em "Adicionar indicador oferecem suporte para o consumidor" e vá para "Adicionando suporte a XML para o consumidor".

Recuperar dados com o consumidor.

Para modificar o aplicativo de console para usar o consumidor do OLE DB

No MyCons.cpp, altere o código principal inserindo texto em negrito, da seguinte maneira:

// MyCons.cpp : Defines the entry point for the console application.
//
#include "stdafx.h"
#include "Products.h"
...
int main(int argc, char* argv[])
{
   HRESULT hr = CoInitialize(NULL);

   // Instantiate rowset
   CProducts rs;

   hr = rs.OpenAll();
   ATLASSERT( SUCCEEDED( hr ) );
   hr = rs.MoveFirst();

   // Iterate through the rowset
   while( SUCCEEDED(hr) && hr != DB_S_ENDOFROWSET )
   {
      // Print out the column information for each row
      printf("Product ID: %d, Name: %s, Unit Price: %d, Quantity per Unit: %d, Units in Stock %d, Reorder Level %d\n", 
            rs.m_ProductID, rs.m_ProductName, rs.m_UnitPrice, rs.m_QuantityPerUnit, rs.m_UnitsInStock, rs.m_ReorderLevel );
      hr = rs.MoveNext();
   }

   rs.Close();
   rs.ReleaseCommand();

   CoUninitialize();

   return 0;
}

Adicionar suporte de indicador ao consumidor

Um indicador é uma coluna que identifica exclusivamente as linhas da tabela. Geralmente é a coluna de chave, mas nem sempre; é específico do provedor. Esta seção mostra como adicionar suporte de indicador. Para fazer isso, você precisa fazer o seguinte na classe de registro de usuário:

Instancie os indicadores. Esses são objetos do tipo CBookmark.
Solicitar uma coluna de indicador do provedor, definindo a DBPROP_IRowsetLocate propriedade.
Adicionar uma entrada de indicador para o mapa de coluna usando o BOOKMARK_ENTRY macro.

As etapas anteriores oferecem suporte de indicador e um objeto de indicador com o qual trabalhar. Este exemplo de código demonstra um indicador da seguinte maneira:

Abra um arquivo para gravação.
Conjunto de linhas dados para o arquivo de saída linha por linha.
Move o cursor de conjunto de linhas para o indicador chamando MoveToBookmark.
A linha favorito, acrescentá-lo até o final do arquivo de saída.

Observação
Se você usar esse aplicativo de consumidor para testar o aplicativo de provedor de exemplo de provedor, deixe o suporte de indicador descrito nesta seção.

Para instanciar o indicador

O acessador precisa conter um objeto do tipo CBookmark. O nSize parâmetro especifica o tamanho do buffer de indicador em bytes (geralmente 4 para plataformas de 32 bits) e 8 para plataformas de 64 bits. Adicione a declaração a seguir para os membros de dados de coluna na classe de registro de usuário:
```
//////////////////////////////////////////////////////////////////////
// Products.h
class CProductsAccessor
{
public:
   CBookmark<4> m_bookmark;   // Add bookmark declaration
   LONG m_ProductID;
   ...
```

Para solicitar uma coluna de indicador do provedor

Adicione o seguinte código na GetRowsetProperties método na classe de registro do usuário:

// Set the DBPROP_IRowsetLocate property.
void GetRowsetProperties(CDBPropSet* pPropSet)
{
   pPropSet->AddProperty(DBPROP_CANFETCHBACKWARDS, true, DBPROPOPTIONS_OPTIONAL);
   pPropSet->AddProperty(DBPROP_CANSCROLLBACKWARDS, true, DBPROPOPTIONS_OPTIONAL);
   // Add DBPROP_IRowsetLocate property to support bookmarks
   pPropSet->AddProperty(DBPROP_IRowsetLocate, true);
}

Para adicionar uma entrada de indicador para o mapa de coluna

Adicione a seguinte entrada para o mapa de coluna na classe de registro de usuário:

// Set a bookmark entry in the column map.
BEGIN_COLUMN_MAP(CProductsAccessor)
   BOOKMARK_ENTRY(m_bookmark)   // Add bookmark entry
   COLUMN_ENTRY_LENGTH_STATUS(1, m_ProductID, m_dwProductIDLength, m_dwProductIDStatus)
   COLUMN_ENTRY_LENGTH_STATUS(2, m_ProductName, m_dwProductNameLength, m_dwProductNameStatus)
...
END_COLUMN_MAP()

Para usar um indicador em seu código principal

No arquivo MyCons.cpp do aplicativo de console você anteriormente criado, altere o código principal para ler o seguinte. Para utilizar indicadores, o código principal precisa instanciar seu próprio objeto bookmark (myBookmark); Este é um indicador diferente no acessador (m_bookmark).

///////////////////////////////////////////////////////////////////////
// MyCons.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include "Products.h" 
#include <iostream>
#include <fstream>
using namespace std;

int _tmain(int argc, _TCHAR* argv[])
{
   HRESULT hr = CoInitialize(NULL);

   // Instantiate rowset
   CProducts rs;

   hr = rs.OpenAll();
   hr = rs.MoveFirst();

   // Cast CURRENCY m_UnitPrice to a long value
   LONGLONG lPrice = rs.m_UnitPrice.int64;

   // Open file output.txt for writing in overwrite mode
   ofstream outfile( "C:\\output.txt", ios::out );

   if (!outfile)      // Test for invalid file
      return -1;

   // Instantiate a bookmark object myBookmark for the main code
   CBookmark<4> myBookmark;
   int nCounter = 0;

   // Iterate through the rowset and output column data to output.txt row by row
   // In the file, mark the beginning of this set of data:
   outfile << "initial row dump" << endl;
   while( SUCCEEDED(hr) && hr != DB_S_ENDOFROWSET )
   {
      nCounter++;
      if( nCounter == 5 )
         myBookmark = rs.bookmark;
      // Output the column information for each row:
      outfile << rs.m_ProductID << rs.m_ProductName << lPrice << rs.m_QuantityPerUnit << rs.m_UnitsInStock << rs.m_ReorderLevel << endl;
      hr = rs.MoveNext();
   }

   // Move cursor to bookmark
   hr = rs.MoveToBookmark(myBookmark);

   // Iterate through the rowset and output column data to output.txt row by row
   // In the file, mark the beginning of this set of data:
   outfile << "row dump starting from bookmarked row" << endl;
   while( SUCCEEDED(hr) && hr != DB_S_ENDOFROWSET )
   {
      // Output the column information for each row
      outfile << rs.m_ProductID << rs.m_ProductName << lPrice << rs.m_QuantityPerUnit << rs.m_UnitsInStock << rs.m_ReorderLevel << endl;
      hr = rs.MoveNext();
   }

   rs.CloseAll();
   CoUninitialize();

   return 0;
}

Para obter mais informações sobre marcadores, consulte Usando marcadores. Exemplos de indicadores também são mostrados na Atualizando conjuntos de linhas.

Adicionando suporte a XML para o consumidor.

Conforme discutido em Acessando dados de XML, há duas maneiras para recuperar os dados XML de uma fonte de dados: usando CStreamRowset ou CXMLAccessor. Este exemplo usa CStreamRowset, que é mais eficiente, mas você precisa ter o SQL Server 2000 de execução no computador em que você executar esse aplicativo de exemplo.

Para modificar a classe de comando para herdar de CStreamRowset

No aplicativo de consumidor previamente criada, alterar seu CCommand a declaração para especificar CStreamRowset como o conjunto de registros de classe da seguinte maneira:
```
class CProducts : public CCommand<CAccessor<CProductsAccessor>, CStreamRowset >
```

Para modificar o código principal para recuperar e os dados XML de saída.

No arquivo MyCons.cpp do aplicativo de console você anteriormente criado, altere o código principal para ler o seguinte:

///////////////////////////////////////////////////////////////////////
// MyCons.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include "Products.h" 
#include <iostream>
#include <fstream>
using namespace std;

int _tmain(int argc, _TCHAR* argv[])
{
   HRESULT hr = CoInitialize(NULL);

   // Instantiate rowset
   CProducts rs;

   // Add variable declarations for the Read method to handle sequential stream data
   CHAR buffer[1001];  // Pointer to buffer into which data stream is read
   ULONG cbRead;       // Actual number of bytes read from the data stream

   hr = rs.OpenAll();

   // Open file output.txt for writing in overwrite mode
   ofstream outfile( "C:\\output.txt", ios::out );

   if (!outfile)      // Test for invalid file
      return -1;

   // The following loop reads 1000 bytes of the data stream at a time 
   // until it reaches the end of the data stream
   for (;;)
   {
      // Read sequential stream data into buffer
      HRESULT hr = rs.m_spStream->Read(buffer, 1000, &cbRead);
      if (FAILED (hr))
         break;
      // Output buffer to file
      buffer[cbRead] = 0;
      outfile << buffer;
      // Test for end of data stream
      if (cbRead < 1000)
         break;
   }

   rs.CloseAll();
   CoUninitialize();

   return 0;
}

Consulte também

Conceitos

A criação de um consumidor de BD OLE usando um assistente

Compartilhar via