RecordSet.moveNext() на сервере переходит в конец выборки

[Владимир Максимов]

Ax2009. По необходимости переписал все классы CCADO...() на работу на стороне сервера, добавив везде

new InteropPermission(InteropKind::ComInterop).assert();

Однако теперь вполне стандартный код вроде

ccADORecordSet = ccADOCommand.execute();
while (!ccADORecordSet.EOF())
{
      info(any2str(ccADORecordSet.fields().itemIdx(0).value()));
      ccADORecordSet.moveNext();
}

сканирует только одну (первую) запись выборки. Первая же команда moveNext() переводит RecordSet в состояние EOF() и цикл завершается. В выборке больше одной записи. Это показывает RecordCount()

Метод ccADORecordSet.moveNext() добавил в класс ccADORecordSet по аналогии со старыми версиями Axapta. Т.е. там только собственно команда recordSet.moveNext()

В чем причина подобного поведения и как исправить?

PS: Соединение необходимо устанавливать именно на стороне сервера. Поэтому варианты выполнения на стороне клиента - не годятся.

[S.Kuskov]

А выборка точно формируется на серверной стороне? Не совсем ваш случай, но может чем-то поможет Если select на сервере а next на клиенте...

[Владимир Максимов]

Все переделанные классы CCADO имеют значение RunOn = Server. Класс, в котором выполняется обработка также имеет значение RunOn = Server. Вызов класса-обработчика выполняется через статические методы с модификатором server.

Так что, уж и не знаю, где еще "server" поставить

PS: На всякий случай проверил, что возвращает RecordSet.CursorLocation(). Он возвращает 2. По документации это

2 = adUseServer - Default, use the cursor supplied by provider or database

Поскольку AOS выступает в роли клиента, то сервер получается - это другой компьютер (база данных находится не там, где AOS). Возможно, действительно в этом причина. Правда, пока не понятно, как это исправить, ведь CursorLocation надо задать до собственно открытия RecordSet.

[raz]

У нас все работает. Сделаны серверные копии классов CCADOCommand, CCADOConnection, CCADOField, CCADOFields, CCADORecordSet. Во всех методах, где есть взаимодествие с COM добавлен new InteropPermission(InteropKind::ComInterop).assert(). Все статические методы сделаны серверными.

[Владимир Максимов]

Пока удалось выяснить, что MoveNext() не корректно интерпретирует "точку отсчета". Предположительно, он начинает отсчет с последней записи.

Однако если заменить MoveNext() на просто Move() с явным указанием отсчитывать строки от начала курсора, то все проходит корректно. Т.е. код получается примерно такой

#define.adBookmarkCurrent(0)  // от текущей записи (вот это умолчание не работает)
#define.adBookmarkFirst(1)   // от первой записи
#define.adBookmarkLast(2)   // от последней записи

ccADORecordSet = ccADOCommand.execute();
while (!ccADORecordSet.EOF())
{

      info(any2str(ccADORecordSet.fields().itemIdx(0).value()));
      i++;
      ccADORecordSet.move(i, #adBookmarkFirst);
}

Ну, счетчик записей можно включить непосредственно в класс, так что, можно считать, проблема решена.

Правда, не понимаю причину данной проблемы. Ощущение такое, что вместо MoveNext() выполняется Move(1, 2). Ну, или "текущая" запись интерпретируется как "последняя" запись.

PS: Кстати, замечу, что при выполнении на стороне клиента ситуация получается обратная. Приведенный код приводит к тому, что цикл выполняется только один раз. Т.е. на стороне клиента надо снова использовать MoveNext().

Цитата:

Сообщение от raz

У нас все работает. Сделаны серверные копии классов CCADOCommand, CCADOConnection, CCADOField, CCADOFields, CCADORecordSet. Во всех методах, где есть взаимодествие с COM добавлен new InteropPermission(InteropKind::ComInterop).assert(). Все статические методы сделаны серверными.

А как у Вас реализован метод RecordSet.MoveNext() в переписанных классах? В оригинальных классах ведь его нет.

[Gustav]

Сталкивался с похожим поведением recordset'а при выполнении горячо любимого экспорта в Excel с помощью CopyFromRecordset (правда, на локальной машине).

Так вот, при выполнении экспорта кодом X++ нормально выводились все записи. Когда же вывод выполнялся кодом VBA внутри Excel (казалось бы!), то приходилось перед CopyFromRecordset вставлять recordSet.MoveFirst, так как без этой команды после заполнения рекордсета курсор всегда оказывался на последней записи и только ее и выводил.

Теперь, не особо вдаваясь в подробности, для гарантии всегда вставляю этот MoveFirst.

[Владимир Максимов]

Цитата:

Сообщение от Gustav

Сталкивался с похожим поведением recordset'а при выполнении горячо любимого экспорта в Excel с помощью CopyFromRecordset (правда, на локальной машине).

Так вот, при выполнении экспорта кодом X++ нормально выводились все записи. Когда же вывод выполнялся кодом VBA внутри Excel (казалось бы!), то приходилось перед CopyFromRecordset вставлять recordSet.MoveFirst, так как без этой команды после заполнения рекордсета курсор всегда оказывался на последней записи и только ее и выводил.

Теперь, не особо вдаваясь в подробности, для гарантии всегда вставляю этот MoveFirst.

Ну, я здесь не вижу противоречия. Точнее, надо уточнить как внутри себе Excel передает RecordSet в метод CopyFromRecordset(). Вполне возможно, что действительно запоминает текущее положение указателя. Ну, а раз текущей является последняя запись, то последнюю и выводит.

В данном же случае это не работает ряду причин:

1. Полученный RecordSet имеет CursorType = 0 - adOpenForwardOnly. Т.е. перемещение "назад" в принципе невозможно. Только вперед.

2. То единственное значение, которое все-таки выводится, это значение из первой записи выборки. Т.е. как раз с позиционированием все в порядке! В начале цикла указатель стоит на первой записи.

Проблема именно с перемещением на следующую запись. В данном случае возникает неоднозначность в том, относительно чего эту самую следующую запись отсчитывать. "Теряется" понятие текущей записи.

PS: Я пробовал делать MoveFirst(). Как и предполагалось - не помогает, хотя и ошибок не возникает. Просто игнорируется...

[raz]

Цитата:

Сообщение от Владимир Максимов

А как у Вас реализован метод RecordSet.MoveNext() в переписанных классах? В оригинальных классах ведь его нет.

Взято с DAX3 и дабален assert.

void moveNext()
{
    new InteropPermission(Interopkind::ComInterop).assert();
    recordSet.moveNext();
}

[alek_frm]

У нас тоже все работает.
Все классы CCADO имеют значение RunOn = Called from,
класса-обработчикa имеют значение RunOn = Server
Command in AOS configuration file : caslevel,Text,disable

[COLOR=#000000]void moveNext()
{
    recordSet.moveNext();
}[/COLOR]
[COLOR=#000000][/COLOR]

constr="Provider=SQLNCLI10;Persist Security Info=true;Data Source=xxx.xxx.xxx.xxx;Initial Catalog=PROD;User Id=sa;Password=xxx";

[Владимир Максимов]

Похоже, что это глюк установленного на сервере драйвера.

Сейчас попробовал с другим драйвером и вообще получил сообщени об ошибке при использовании Move() (полученный тип RecordSet не поддерживает относительную адресацию, что правильно в данном случае), хотя MoveNext() отработал как положено.

Проблема в том, что клиент 32-разрядный, а сервер AOS - 64-разрядный. Вот и мучаюсь с оракловыми драйверами

[Владимир Максимов]

Я скачал и установил драйвер Oracle "64-bit Oracle 10g Release 2 ODAC 10.2.0.3 for Windows x64" вот с этой страницы

64-bit Oracle Data Access Components (ODAC) Downloads

Именно с этим драйвером и возникла проблема. Может, есть какие-то особенности настройки драйвера Oracle для версии 10g?

[someOne]

Не хотите попробовать NET ? Нет проблем с запуском на стороне сервера, других глюков вроде бы тоже не замечено...

Например как то так:

static void transferFromOraWindowsUserLogin(Args _args)
{
    str  connectionstring;
    System.Data.OracleClient.OracleConnection oraDb;
    System.Data.OracleClient.OracleCommand cmd;
    System.Data.OracleClient.OracleDataReader orard;
    EmplTable   emplTable;
    emplId      emplId;
    str         user;

    ;
    connectionstring  = "Data Source = (DESCRIPTION = (ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.2)(PORT = 1521)))(CONNECT_DATA = (SERVER = DEDICATED)(SERVICE_NAME = axapta.domain.ru)));";
    connectionstring += "User Id = admin; Password = topsecret;";

    oraDb = new System.Data.OracleClient.OracleConnection(connectionstring);
    oraDb.Open();


    cmd = new System.Data.OracleClient.OracleCommand("select * from axapta.empltable", oraDb);
    cmd.set_CommandTimeout(6000);


    orard = cmd.ExecuteReader();

    while(orard.Read())
    {
        emplId = orard.GetString(0);
        user = orard.GetString(1);

    }

    info("done");

    orard.Close();
    oraDb.Close();
}

[Владимир Максимов]

Цитата:

Сообщение от someOne

Не хотите попробовать NET ?

Это чтобы вместо борьбы с одними глюками начать бороться с другими?

Цитата:

Сообщение от someOne

Нет проблем с запуском на стороне сервера, других глюков вроде бы тоже не замечено...

Например как то так:

Ну, у кого как Я например, получил сообщение

Цитата:

Объект "CLRObject" не может быть создан

При попытке создать соединение на стороне сервера. Вот и думай, чего и где надо указать, настроить, установить Я без понятия какие драйвера Oracle надо устанавливать для соединения по Net и надо ли устанавливать хоть что-то. Впрочем, на клиенте это работает, но клиент 32-разрядный.

Да, чтобы не было недоразумений немного поясню. Собственно Axapta работает на MS SQL 2005. А на Oracle 10g работает другое приложение. Вот мне и надо подключиться к базе этого "другого" приложения.

Сервер - Windows 2003 x64, клиент WinXP x32

[Pustik]

Цитата:

Сообщение от Владимир Максимов

Вот и думай, чего и где надо указать, настроить, установить Я без понятия какие драйвера Oracle надо устанавливать для соединения по Net и надо ли устанавливать хоть что-то. Впрочем, на клиенте это работает, но клиент 32-разрядный.

Полностью согласен. Net больше просит настроек, каких-то своих заточек. Кто это знает? только Microsoft. Сидеть и гадать, тоже никакого удовольствия нет. Читать документацию в 3-4 Тома????
У нас не работает, периодически(т.е. то работает, то не работает), элементарная выгрузка данных в ексель через .net
Ужас.

[someOne]

Цитата:

Сообщение от Владимир Максимов

Ну, у кого как Я например, получил сообщение Объект "CLRObject" не может быть создан

Такое сообщение может быть в случае когда на клиенте или сервере (зависит от того где именно исполняется код) не установлены ADO.NET драйвера для Oracle. Эти драйвера устанавливаются при установке клиентской части Oracle (У меня они установились при установке клиентской части Oracle при типе инсталляции "Администратор"). Также нужно иметь ввиду что после добавление в Reference Axapta ссылки на сборку NET Oracle код сможет исполнятся на сервере только после перезапуска АОС!!! До этого будете получать именно такую ошибку...

По поводу драйверов - естественно драйвер oracle нужно устанавливать в соответствии с типом ОС клиента или сервера соответственно (32 или 64 бит). На код в Аксапте это никак не влияет - один и тот же код будет без изменений работать вне зависимости от типа используемого драйвера NET (32 или 64 бит).

Цитата:

Сообщение от Pustik

элементарная выгрузка данных в ексель через .net
Ужас.

Позвольте не согласится с такой оценкой технологии NET вообще. В Вашем случае скорее причина не в net а в екселе.

Из своего опыта скажу что использование NET в Аксапта при доступе к внешним БД достаточно технологично, универсально, надежно.
Практически для любой БД имеется драйвер ADO NET для доступа к данным. Скорость работы (производительность) весьма достойна. Технические возможности обширны:
- параметризированные запросы
- управление транзакциями
- обращение к метаданным БД
- режим доступа к бд, когда результат запроса (выборки select) кешируется в в объект Net DataTable что дает возможность не держать открытое соединение с БД в момент исполнения кода а работать с копией данных результата запроса...

В общем считаю NET оптимальным средством для обращения из Axapta к любым внешним БД. Думаю тут вообще без вариантов...

[Pustik]

Цитата:

Сообщение от someOne

Позвольте не согласится с такой оценкой технологии NET вообще. В Вашем случае скорее причина не в net а в екселе.

Может быть оно и так. Но поверьте, с этой проблемой у нас борются программисты далеко не самого низкого уровня уже несколько месяцев.Я в детали и подробности не вдавался, но мнение моих коллег звучит именно так.И не доверять их мнению у меня причин нет.
Я, в свою очередь, всегда выступал, выступаю и буду выступать за развитие, за прогресс, за что-то новое.Так что против ничего не имею

[Владимир Максимов]

raz, alek_frm

Какое значение для переписанных классов у вас имеет свойство

Connection.CursorLocation()

Как выяснилось, это свойство также оказывает влияение на данную проблему. Если установить его в значение 3 - adUseClient, вместо используемого по умолчанию 2 - adUseServer, то проблема снимается.

Посмотреть это свойство можно так

Com connection;

connection = CCADOConnection.connection();
info(int2str(Connection.CursorLocation()));

Использовать существующий метод CCADORecordSet.cursorLocation() нельзя, поскольку он устанавливает, а не считывает значение.

При изменении CursorLocation на значение 3 формируемый RecordSet получает значение CursorType = 3 - adOpenStatic вместо значения по умолчанию 0 - adOpenForwardOnly.

[raz]

Цитата:

Сообщение от Владимир Максимов

raz, alek_frm

Какое значение для переписанных классов у вас имеет свойство

Connection.CursorLocation()

2

[Владимир Максимов]

А к какой базе подключаетесь (включая версию) и с какого сервера (32bit или 64bit)?

PS: Проверил. Изменение Connection.CursorLocation(3) никак не влияет на работу на стороне клиента или при использовании других серверов (и для Oracle, и для MS SQL работает нормально). Думаю, на этом и остановиться, как самом простом решении.

[alek_frm]

значение Connection.CursorLocation() = 2

AOS - 5.0.1500.4570 64 bit (Windows 2008 R2 64 bit on Hyper-V)
SQL - 10.50.1753 2008 R2 64 bit (Windows 2008 R2 64 bit on Hyper-V)

boolean  test()
{
    Com             connection2 ;
    CCADOConnection connection = new CCADOConnection();
    CCADORecordSet  rSet;
    CCADOCommand    commandRs = new CCADOCommand();
    str             sqlString;
    Voucher         _voucher;
    boolean         ret=false;
    
;
    try
    {
        connection.open(constr);
        connection2 = connection.connection();
        info(int2str(Connection2.CursorLocation()));// = 2
        rSet = new CCADORecordSet();
        sqlString = "SELECT TOP 10 LedgerVoucher FROM CUSTINVOICEJOUR";
        commandRs.activeConnection(connection);
        commandRs.commandText(sqlString);
        rSet=commandRs.execute();
        While (!RSet.EOF())
        {
            _voucher=rSet.fields().itemName("LedgerVoucher").value();
            info(_voucher);
 
            rSet.moveNext();
        }
        rSet.close();
        connection.close();
        connection=null;
        ret=true;
    }
    catch (Exception::Deadlock)
    {
        retry;
    }
    catch (Exception::Error)
    {
        connection.close();
        connection=null;
        ret=false;
    }
    return ret;
}