Delphi ODAC: disecting mensajes JMS de Oracle AQ

Question

Estoy intentando evaluar ODAC para el uso de Oracle AQ. La cola de petición contiene JMS objetos como los siguientes (pero sin saltos de línea y otros espacios en blanco):

SYS.AQ$_JMS_BYTES_MESSAGE(
  SYS.AQ$_JMS_HEADER(
    'null','null','null','null','null','null',
    SYS.AQ$_JMS_USERPROPARRAY(
      SYS.AQ$_JMS_USERPROPERTY('Key1',100,'Value1','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key2',100,'Value2','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key3',100,'Value3','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key4',100,'Value4','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key5',100,'Value5','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key6',100,'Value6','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key7',100,'Value7','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key8',100,'Value8','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key9',100,'Value9','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key10',100,'Value10.0','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key11',100,'Value11','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key12',100,'Value12','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key13',100,'Value13','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key14',100,'Value14','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key15',100,'Value15','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key16',100,'Value16','null',27),
      SYS.AQ$_JMS_USERPROPERTY('Key17',100,'Value17','null',27)
    )
  ),
  4168,'null','oracle.sql.BLOB@959acc'
)

Me puede recibir el objeto subyacente (una carga útil de la cadena regresa como una cadena vacía, sino una TOraObject carga útil contiene los datos).

Estoy intentando disscect la TOraObject carga útil, y estoy buscando una tabla que convierte los valores DataType en el AttrXxxx correcta [Nombre] llamadas de propiedad.

    OraType.AttributeCount:4
    OraType.Name:"SYS"."AQ$_JMS_BYTES_MESSAGE"
    OraType.DataType:15
      Attribute[0].Name:HEADER
      Attribute[0].DataType:15
      OraType.AttributeCount:7
      OraType.Name:"SYS"."AQ$_JMS_HEADER"
      OraType.DataType:15
        Attribute[0].Name:REPLYTO
        Attribute[0].DataType:15
        OraType.AttributeCount:3
        OraType.Name:"SYS"."AQ$_AGENT"
        OraType.DataType:15
          Attribute[0].Name:NAME
          Attribute[0].DataType:1
          Attribute[1].Name:ADDRESS
          Attribute[1].DataType:1
          Attribute[2].Name:PROTOCOL
          Attribute[2].DataType:5
        Attribute[1].Name:TYPE
        Attribute[1].DataType:1
        Attribute[2].Name:USERID
        Attribute[2].DataType:1
        Attribute[3].Name:APPID
        Attribute[3].DataType:1
        Attribute[4].Name:GROUPID
        Attribute[4].DataType:1
        Attribute[5].Name:GROUPSEQ
        Attribute[5].DataType:5
        Attribute[6].Name:PROPERTIES
        Attribute[6].DataType:17
        OraType.AttributeCount:1
        OraType.Name:"SYS"."AQ$_JMS_USERPROPARRAY"
        OraType.DataType:17
          Attribute[0].Name:ELEMENT
          Attribute[0].DataType:15
          OraType.AttributeCount:5
          OraType.Name:"SYS"."AQ$_JMS_USERPROPERTY"
          OraType.DataType:15
            Attribute[0].Name:NAME
            Attribute[0].DataType:1
            Attribute[1].Name:TYPE
            Attribute[1].DataType:5
            Attribute[2].Name:STR_VALUE
            Attribute[2].DataType:1
            Attribute[3].Name:NUM_VALUE
            Attribute[3].DataType:5
            Attribute[4].Name:JAVA_TYPE
            Attribute[4].DataType:5
      Attribute[1].Name:BYTES_LEN
      Attribute[1].DataType:5
      Attribute[2].Name:BYTES_RAW
      Attribute[2].DataType:1
      Attribute[3].Name:BYTES_LOB
      Attribute[3].DataType:102

Por ensayo y error, he venido hasta ahora:

        case DataType of
          102:
            LOB := ObjectPayLoad.AttrAsLob[Name];
          15:
            AttributeOraObject := ObjectPayLoad.AttrAsObject[Name];
          17:
            AttributeOraArray := ObjectPayLoad.AttrAsArray[Name];
          else
          begin
            PayLoadAttributeAsString := ObjectPayLoad. AttrAsString[Name];
            Logger.Log('  "%s"', [PayLoadAttributeAsString]);
          end;
        end;

Una lista más completa es bienvenido: -)

Después de esto, tendrá que investigar a la inversa: la generación de la TOraObject derecha que tiene un contenido de JMS en ella. Consejos para que también son bienvenidos.

- Jeroen

Answer 1

Editar

ODAC tiene múltiples unidades que definen constantes.
El dtOraBlob constante con el valor 102 se encuentra en la unidad de OraClasses; constantes que definen valores DataType empiezan con el prefijo dt, independientemente de la unidad que define ellos.

Original: He encontrado algunas de estas constantes en la unidad MemData:

      case DataType of
        102:
          LOB := OraObject.AttrAsLob[Name];
        MemData.dtObject: // 15
        begin
          AttributeOraObject := OraObject.AttrAsObject[Name];
          LogOraObject(AttributeOraObject, Level+1);
        end;
        MemData.dtArray: // 17
        begin
          AttributeOraArray := OraObject.AttrAsArray[Name];
          LogOraArray(AttributeOraArray, Level);
        end;
        MemData.dtFloat: // 5
        begin
          AttributeFloat := OraObject.AttrAsFloat[Name];
          Logger.Log(Prefix+'"%g"', [AttributeFloat]);
        end;
        MemData.dtString: // 1
        begin
           PayLoadAttributeAsString := OraObject.AttrAsString[Name];
           Logger.Log(Prefix+'"%s"', [PayLoadAttributeAsString]);
        end;
      else
        begin
          PayLoadAttributeAsString := OraObject.AttrAsString[Name];
          Logger.Log(Prefix+'"%s"', [PayLoadAttributeAsString]);
        end;
      end;

No se puede encontrar la constante de 102, sin embargo, pero estoy bastante seguro de que es para un campo de LOB.

Cualquiera que pueda confirmar que?

- Jeroen