Как работать с ATL OLE DB Consumer wizard?

@NewNoob · Регистрация: 29.05.2015

Author24 — интернет-сервис помощи студентам

Здраствуйте! Я на форуме первый раз.
Я пишу простенькую програму на MFC доступ к базе данных должен быть OLE DB. целую неделю борюсь с OLE DB, не могу разобраться как с ней работать. Я использую ATL OLE DB Consumer wizard что бы сгенерировать клиента, так же я понимаю как зделать Insert(), для чего MoveFirst(), MoveNext() etc.
То есть более менее основу понимаю но... Я не понимаю как например мне получить количество строк в таблице, а так же получить строку по Id SQL запросами. До этого я юзал цикл типа MoveNext(), если конец тогда уже знаю количество, так же искал Id доставая и сравнивая все строки по Id, конечно же это тупо так как не оптимизировано. Я знаю что например что б достать нужную строку по Id мне надо в метод Open() запихнуть SQL запрос, но я не знаю и не понимаю как.Вроде не дурак, но дойти не могу сам.
Пожалуйста помогите мне, я уже все прогуглил что можна, так же задавал вопросы на codeproject и stackoverflow но там тихо, перечитал MSDN иформацию но не вкурил все равно.Подходят ссылки или собственые примеры.Английский отличный.Всем спасибо!
П.С. Извините за плохой русский.

@vxg · 24.10.2012, 00:26

может поможет чем-то
1 вытаскивал разное из базы в программу на MSVC++

C++

// adodb_port_test.cpp : Defines the entry point for the console application.
//
 
#include "stdafx.h"
 
//beg
 
#import "c:\program files\common files\system\ado\msadox.dll"
#import "c:\program files\common files\system\ado\msado25.tlb" rename("EOF", "EndOfFile")
 
void *catalog_create(BSTR connection_string)
{
    ADOX::_CatalogPtr *catalog = 0;
    try
    {
        catalog = new ADOX::_CatalogPtr("ADOX.Catalog");
        (*catalog)->PutActiveConnection(connection_string);
    }
    catch (...)
    {
        delete catalog;
        catalog = 0;
    }
    return catalog;
}
 
void catalog_destroy(void *catalog)
{
    delete (ADOX::_CatalogPtr *)catalog;
}
 
long catalog_get_tables_count(void *catalog)
{
    long res = 0;
    try
    {
        res = (*(ADOX::_CatalogPtr *)catalog)->Tables->Count;
    }
    catch (...)
    {}
    return res;
}
 
bool catalog_get_table_name(void *catalog, long tables_count, BSTR *table_name)
{
    bool res = true;
    ADOX::_CatalogPtr &_catalog = *(ADOX::_CatalogPtr *)catalog;
    try
    {
        for (long i = 0L; i < tables_count; i++)
            table_name[i] = SysAllocString(_catalog->Tables->Item[i]->Name);
    }
    catch (...)
    {
        res = false;
        for (long i = 0L; i < tables_count; i++)
        {
            SysFreeString(table_name[i]);
            table_name[i] = 0;
        }
    }
    return res;
}
 
void *connection_create(BSTR connection_string, BSTR user, BSTR password)
{
    ADODB::_ConnectionPtr *connection = 0;
    try
    {
        connection = new ADODB::_ConnectionPtr("ADODB.Connection");
        (*connection)->Open(connection_string, user, password, ADODB::adConnectUnspecified);
    }
    catch (...)
    {
        delete connection;
        connection = 0;
    }
    return connection;
}
 
void connection_destroy(void *connection)
{
    delete (ADODB::_ConnectionPtr *)connection;
}
 
void *recordset_create_by_table_name(BSTR source, void *connection)
{
    ADODB::_RecordsetPtr *recordset = 0;
    try
    {
        recordset = new ADODB::_RecordsetPtr("ADODB.Recordset");
        (*recordset)->Open(source, ((ADODB::_ConnectionPtr *)connection)->GetInterfacePtr(), ADODB::adOpenForwardOnly, ADODB::adLockReadOnly, ADODB::adCmdTable);
    }
    catch (...)
    {
        delete recordset;
        recordset = 0;
    }
    return recordset;
}
 
void *recordset_create_by_cmd(BSTR source, void *connection)
{
    ADODB::_RecordsetPtr *recordset = 0;
    try
    {
        recordset = new ADODB::_RecordsetPtr("ADODB.Recordset");
        (*recordset)->Open(source, ((ADODB::_ConnectionPtr *)connection)->GetInterfacePtr(), ADODB::adOpenForwardOnly, ADODB::adLockReadOnly, ADODB::adCmdText);
    }
    catch (...)
    {
        delete recordset;
        recordset = 0;
    }
    return recordset;
}
 
void recordset_destroy(void *recordset)
{
    delete (ADODB::_RecordsetPtr *)recordset;
}
 
long recordset_get_fields_count(void *recordset)
{
    long res = 0;
    try
    {
        res = (*(ADODB::_RecordsetPtr *)recordset)->Fields->Count;
    }
    catch (...)
    {}
    return res;
}
 
bool recordset_get_field_name(void *recordset, long fields_count, BSTR *field_name)
{
    bool res = true;
    ADODB::_RecordsetPtr &_recordset = *(ADODB::_RecordsetPtr *)recordset;
    try
    {
        for (long i = 0L; i < fields_count; i++)
            field_name[i] = SysAllocString(_recordset->Fields->Item[i]->Name);
    }
    catch (...)
    {
        res = false;
        for (long i = 0L; i < fields_count; i++)
        {
            SysFreeString(field_name[i]);
            field_name[i] = 0;
        }
    }
    return res;
}
 
bool recordset_eof(void *recordset)
{
    bool res = true;
    try
    {
        res = (*(ADODB::_RecordsetPtr *)recordset)->EndOfFile;
    }
    catch (...)
    {}
    return res;
}
 
bool recordset_move_first(void *recordset)
{
    bool res = true;
    try
    {
        (*(ADODB::_RecordsetPtr *)recordset)->MoveFirst();
    }
    catch (...)
    {
        res = false;
    }
    return res;
}
 
bool recordset_move_next(void *recordset)
{
    bool res = true;
    try
    {
        (*(ADODB::_RecordsetPtr *)recordset)->MoveNext();
    }
    catch (...)
    {
        res = false;
    }
    return res;
}
 
bool recordset_get_field_value(void *recordset, long fields_count, VARIANT *field_value)
{
    bool res = true;
    ADODB::_RecordsetPtr &_recordset = *(ADODB::_RecordsetPtr *)recordset;
    try
    {
        for (long i = 0L; i < fields_count; i++)
            field_value[i] = _recordset->Fields->Item[i]->Value;
    }
    catch (...)
    {
        res = false;
        for (long i = 0L; i < fields_count; i++)
            VariantClear(&field_value[i]);
    }
    return res;
}
 
//end
 
#include <stdio.h>
 
int main(int argc, char* argv[])
{
    CoInitialize(0);
 
    BSTR connection_string = SysAllocString(L"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=test.mdb;");
    BSTR user = SysAllocString(L"");
    BSTR password = SysAllocString(L"");
 
    void *catalog = catalog_create(connection_string);
    long tables_count = catalog_get_tables_count(catalog);
    BSTR *table_name = new BSTR[tables_count];
    for (long i = 0L; i < tables_count; i++)
        table_name[i] = 0;
    catalog_get_table_name(catalog, tables_count, table_name);
 
    printf("tables_count = %li\n", tables_count);
    for (i = 0L; i < tables_count; i++)
        printf("%ls\n", table_name[i]);
    printf("\n");
 
    void *connection = connection_create(connection_string, user, password);
 
    void *recordset = recordset_create_by_table_name(table_name[0L], connection);
    long fields_count = recordset_get_fields_count(recordset);
    BSTR *field_name = new BSTR[fields_count];
    VARIANT *field_value = new VARIANT[fields_count];
    for (i = 0L; i < fields_count; i++)
    {
        field_name[i] = 0;
        VariantInit(&field_value[i]);
    }
    recordset_get_field_name(recordset, fields_count, field_name);
 
    printf("%ls\t", field_name[0L]);
    for (i = 1L; i < fields_count; i++)
        printf("\t%ls", field_name[i]);
    printf("\n");
 
    for (long r = 0L; r < 5L; r++)
    {
        recordset_get_field_value(recordset, fields_count, field_value);
 
        printf("%lf", field_value[0L].dblVal);
        for (long c = 1L; c < fields_count; c++)
        {
            printf("\t%f", field_value[c].fltVal);
        }
        printf("\n");
 
        recordset_move_next(recordset);
    }
 
    recordset_destroy(recordset);
    connection_destroy(connection);
    catalog_destroy(catalog);
 
    CoUninitialize();
 
    system("pause");
 
    return 0;
}

2 вытаскивал разное из базы в Excel при помощи макросов на VBA - можно очень быстро потренироваться

Visual Basic

Option Explicit
 
Public Sub extract_proc(ByVal con_s As String, ByVal rs_s As String, ByRef i As Integer, ByVal print_header As Boolean)
 
Dim con As New adodb.Connection
Call con.Open(con_s)
 
Dim rs As New adodb.Recordset
Call rs.Open(rs_s, con, adOpenForwardOnly, adLockReadOnly, adCmdText)
 
Dim j As Integer
 
If print_header Then
  For j = 1 To rs.Fields.Count
    Cells(i, j) = rs.Fields(j - 1).Name
  Next
  i = i + 1
End If
 
Do While Not rs.EOF
  For j = 1 To rs.Fields.Count
    Cells(i, j) = rs.Fields(j - 1)
  Next
  rs.MoveNext
  i = i + 1
Loop
 
rs.Close
con.Close
 
End Sub
 
Public Sub extract()
 
Cells.Clear
 
Dim s As String
'записи для ср. с базой ген.пр.
s = "SELECT * FROM Датчики UNION SELECT * FROM Агрегаты;"
'записи 9xx и Fx
's = "SELECT * FROM 9xx UNION SELECT * FROM Fx;"
'записи для kks_helper
's = "SELECT ID, NAMELONG, OBJTYPE FROM (SELECT * FROM sigs UNION SELECT * FROM 9xx UNION SELECT * FROM Fx);"
'все записи
's = "SELECT * FROM sigs UNION SELECT * FROM 9xx UNION SELECT * FROM Fx;"
'все записи без 9xx и Fx
's = "SELECT * FROM sigs;"
'записи для ревизии
's = "SELECT * FROM (SELECT * FROM sigs UNION SELECT * FROM 9xx UNION SELECT * FROM Fx) WHERE REV='3';"
'позиции с буквой расширения
's = "SELECT * FROM (SELECT * FROM sigs UNION SELECT * FROM 9xx UNION SELECT * FROM Fx) WHERE Len(ID)>12;"
 
Dim i As Integer
i = 1
 
Call extract_proc( _
"Provider=Microsoft.Ace.OLEDB.12.0;Data Source=" + ActiveWorkbook.path + "\БД 1.accdb;", _
s, _
i, i = 1)
 
Call extract_proc( _
"Provider=Microsoft.Ace.OLEDB.12.0;Data Source=" + ActiveWorkbook.path + "\БД 2.accdb;", _
s, _
i, i = 1)
 
Call extract_proc( _
"Provider=Microsoft.Ace.OLEDB.12.0;Data Source=" + ActiveWorkbook.path + "\БД 3.accdb;", _
s, _
i, i = 1)
 
End Sub
 
Public Sub update_proc(ByRef con As adodb.Connection, ByVal path As String, ByVal table As String)
 
Call con.Execute("INSERT INTO " & table & " SELECT STATUS, REV, OBJTYPE, SUBOBJTYPE, SIGTYPE, SIGTYPEEX, IDOEM, ID, NAMELONG, NAMESHORT, EXT, MEDIA, UNITS, MIN, MAX, NOMINAL, DIGITS, LW, LA, HW, HA, HYS, DEVTYPE, ROOT, CONNECTION, LOCATION, AREA, CABLE, WH, WL, CABINET, RACK, SLOT, CHANNEL, TERMINAL, PIDIAGRAM, XUSAGE, NOTE FROM " & table & " IN " & Chr(34) & path & Chr(34) & ";")
 
End Sub
 
Public Sub update_proc_ex(ByRef con As adodb.Connection, ByVal path As String)
 
Call update_proc(con, path, "sigs")
Call update_proc(con, path, "9xx")
Call update_proc(con, path, "Fx")
 
End Sub
 
Public Sub update_sum_db()
 
Dim con As New adodb.Connection
Call con.Open("Provider=Microsoft.Ace.OLEDB.12.0;Data Source=" & ActiveWorkbook.path & "\БД.accdb;")
 
Call con.Execute("DELETE * FROM sigs;")
Call con.Execute("DELETE * FROM 9xx;")
Call con.Execute("DELETE * FROM Fx;")
 
Call update_proc_ex(con, ActiveWorkbook.path & "\БД 1.accdb")
Call update_proc_ex(con, ActiveWorkbook.path & "\БД 2.accdb")
Call update_proc_ex(con, ActiveWorkbook.path & "\БД 3.accdb")
 
con.Close
 
End Sub

Добавлено через 50 минут
вот доки про ADO из тех времен когда еще умели писать help

@NewNoob 6 / 10 / 2 Регистрация: 29.05.2015 Сообщений: 661
		1
	Как работать с ATL OLE DB Consumer wizard? 23.10.2012, 15:56. Показов 2187. Ответов 1 Метки нет (Все метки) Здраствуйте! Я на форуме первый раз. Я пишу простенькую програму на MFC доступ к базе данных должен быть OLE DB. целую неделю борюсь с OLE DB, не могу разобраться как с ней работать. Я использую ATL OLE DB Consumer wizard что бы сгенерировать клиента, так же я понимаю как зделать Insert(), для чего MoveFirst(), MoveNext() etc. То есть более менее основу понимаю но... Я не понимаю как например мне получить количество строк в таблице, а так же получить строку по Id SQL запросами. До этого я юзал цикл типа MoveNext(), если конец тогда уже знаю количество, так же искал Id доставая и сравнивая все строки по Id, конечно же это тупо так как не оптимизировано. Я знаю что например что б достать нужную строку по Id мне надо в метод Open() запихнуть SQL запрос, но я не знаю и не понимаю как.Вроде не дурак, но дойти не могу сам. Пожалуйста помогите мне, я уже все прогуглил что можна, так же задавал вопросы на codeproject и stackoverflow но там тихо, перечитал MSDN иформацию но не вкурил все равно.Подходят ссылки или собственые примеры.Английский отличный.Всем спасибо! П.С. Извините за плохой русский. 0

	24.10.2012, 00:26

Опции темы

Как работать с ATL OLE DB Consumer wizard?

Решение