Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\admin\sqlj\MgwiSubscriber.class
?? 1 <8 <9: ; <=>? @AB CD E F GHI <JKLMN O P <Q <R "S S "TUV "V <S "WX "Y <Z[ <\ <] %^ <_ C <` <a <b <c <d <e <f <g <h <i <j <kl %m <n <o <pq <Cr %s >t %u %vw ?x <y z{ "| }~ }?? ? ????????? ? <??? ? }V <??????????? C?????????? ?????????? C?????????????????????????????????? E?? _SQL_NAME Ljava/lang/String; ConstantValue _SQL_TYPECODE I ? __onn Ljava/sql/Connection; __dataSource Ljavax/sql/DataSource; __tx !Lsqlj/runtime/ref/DefaultContext; _struct #Loracle/jpub/runtime/MutableStruct; _sqlType [I _factory [Loracle/sql/ORADataFactory; _MgwiSubscriberFactory &Loracle/mgw/admin/sqlj/MgwiSubscriber; setDataSource (Ljavax/sql/DataSource;)V Code LineNumberTable LocalVariableTable this dataSource Exceptions setDataSourceLocation (Ljava/lang/String;)V cls Ljava/lang/Class; ctx Ljava/lang/Object; meth Ljava/lang/reflect/Method; e Ljava/lang/Exception; dataSourceLocation getConnection ()Ljava/sql/Connection; release ()V closeConnection Ljava/sql/SQLException; setConnectionContext $(Lsqlj/runtime/ref/DefaultContext;)V getConnectionContext #()Lsqlj/runtime/ref/DefaultContext; getORADataFactory ()Loracle/sql/ORADataFactory; _init_struct (Z)V init Z <init> c (Ljava/sql/Connection;)V ?(Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[BLjava/lang/Integer;Ljava/lang/Integer;Loracle/mgw/admin/sqlj/MgwProperties;)V mId mProptype Ljava/lang/Integer; mSource mDestination mRule mTransformation mExceptionqueue mGuid [B mConfigstate mFlags mOptions %Loracle/mgw/admin/sqlj/MgwProperties; toDatum )(Ljava/sql/Connection;)Loracle/sql/Datum; create )(Loracle/sql/Datum;I)Loracle/sql/ORAData; d Loracle/sql/Datum; sqlType setFrom )(Loracle/mgw/admin/sqlj/MgwiSubscriber;)V o setContextFrom setValueFrom O(Loracle/mgw/admin/sqlj/MgwiSubscriber;Loracle/sql/Datum;I)Loracle/sql/ORAData; getMId ()Ljava/lang/String; setMId getMProptype ()Ljava/lang/Integer; setMProptype (Ljava/lang/Integer;)V getMSource setMSource getMDestination setMDestination getMRule setMRule getMTransformation setMTransformation getMExceptionqueue setMExceptionqueue getMGuid ()[B setMGuid ([B)V getMConfigstate setMConfigstate getMFlags setMFlags getMOptions '()Loracle/mgw/admin/sqlj/MgwProperties; setMOptions ((Loracle/mgw/admin/sqlj/MgwProperties;)V assignguid *([B)Loracle/mgw/admin/sqlj/MgwiSubscriber; theSqlTS __sJT_st %Loracle/jdbc/OracleCallableStatement; __sJT_cc __sJT_ec? OracleContext InnerClasses -Lsqlj/runtime/ExecutionContext$OracleContext; __jPt_temp _sqle _err2 _err P_GUID construct (()Loracle/mgw/admin/sqlj/MgwiSubscriber; __jPt_result ?(Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Loracle/mgw/admin/sqlj/MgwProperties;)Loracle/mgw/admin/sqlj/MgwiSubscriber; P_ID P_PROPTYPE P_SOURCE P_DESTINATION P_RULE P_TRANSFORMATION P_EXCEPTIONQUEUE P_OPTIONS deletedata deleteGuid %Loracle/jdbc/OraclePreparedStatement; entryExists '(Ljava/lang/String;)Ljava/lang/Integer; entryGuid (Ljava/lang/String;)[B insertdata isoutbound loadEntry :(Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiSubscriber; loadGuid normalizedata updatedata updateConfigstate ;(Ljava/lang/Integer;)Loracle/mgw/admin/sqlj/MgwiSubscriber; P_STATE updateFlags P_FLAGS <clinit> SourceFile MgwiSubscriber.java ? ? ? ? javax.naming.InitialContext???? lookup java/lang/Class java/lang/String?? java/lang/Object java/lang/StringBuilder ? ? java:comp/env/??? ???? javax/sql/DataSource ? ? java/lang/Exception java/sql/SQLException !Error initializing DataSource at : ? ? ? ? ? ? ? ? ? ?? ??? ?? ? sqlj/runtime/ref/DefaultContext ? ? ? ? !oracle/jpub/runtime/MutableStruct ? ? ? ? ?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? SYS.MGWI_SUBSCRIBER ?? ? ? ? ? ? ? $oracle/mgw/admin/sqlj/MgwiSubscriber oracle/sql/STRUCT ??? ????? java/lang/Integer #oracle/mgw/admin/sqlj/MgwProperties ? ??? ???????? 4BEGIN :1 .ASSIGNGUID( :2 ); END; %0oracle.mgw.admin.sqlj.MgwiSubscriber?????????????? ? ? ???? ? ? ? %1oracle.mgw.admin.sqlj.MgwiSubscriber 4BEGIN :1 := SYS.MGWI_SUBSCRIBER.CONSTRUCT() ; END; %2oracle.mgw.admin.sqlj.MgwiSubscriber %3oracle.mgw.admin.sqlj.MgwiSubscriber ?EGIN :1 := SYS.MGWI_SUBSCRIBER.CONSTRUCT( :2 , :3 , :4 , :5 , :6 , :7 , :8 , :9 ) ; END; %4oracle.mgw.admin.sqlj.MgwiSubscriber???????? SYS.MGW_PROPERTIES %5oracle.mgw.admin.sqlj.MgwiSubscriber )BEGIN :1 .DELETEDATA(); END; %6oracle.mgw.admin.sqlj.MgwiSubscriber %7oracle.mgw.admin.sqlj.MgwiSubscriber :BEGIN SYS.MGWI_SUBSCRIBER.DELETE_GUID( :1 ) ; END; %8oracle.mgw.admin.sqlj.MgwiSubscriber?? %9oracle.mgw.admin.sqlj.MgwiSubscriber BBEGIN :1 := SYS.MGWI_SUBSCRIBER.ENTRY_EXISTS( :2 ) ; END; &10oracle.mgw.admin.sqlj.MgwiSubscriber?? ?? &11oracle.mgw.admin.sqlj.MgwiSubscriber @BEGIN :1 := SYS.MGWI_SUBSCRIBER.ENTRY_GUID( :2 ) ; END; &12oracle.mgw.admin.sqlj.MgwiSubscriber &13oracle.mgw.admin.sqlj.MgwiSubscriber )BEGIN :1 .INSERTDATA(); END; &14oracle.mgw.admin.sqlj.MgwiSubscriber &15oracle.mgw.admin.sqlj.MgwiSubscriber 1BEGIN :1 := :2 .ISOUTBOUND(); END; &16oracle.mgw.admin.sqlj.MgwiSubscriber &17oracle.mgw.admin.sqlj.MgwiSubscriber @BEGIN :1 := SYS.MGWI_SUBSCRIBER.LOAD_ENTRY( :2 ) ; END; &18oracle.mgw.admin.sqlj.MgwiSubscriber &19oracle.mgw.admin.sqlj.MgwiSubscriber ?BEGIN :1 := SYS.MGWI_SUBSCRIBER.LOAD_GUID( :2 ) ; END; &20oracle.mgw.admin.sqlj.MgwiSubscriber &21oracle.mgw.admin.sqlj.MgwiSubscriber ,BEGIN :1 .NORMALIZEDATA(); END; &22oracle.mgw.admin.sqlj.MgwiSubscriber &23oracle.mgw.admin.sqlj.MgwiSubscriber )BEGIN :1 .UPDATEDATA(); END; &24oracle.mgw.admin.sqlj.MgwiSubscriber &25oracle.mgw.admin.sqlj.MgwiSubscriber <BEGIN :1 .UPDATE_CONFIGSTATE( :2 ); END; &26oracle.mgw.admin.sqlj.MgwiSubscriber &27oracle.mgw.admin.sqlj.MgwiSubscriber 6BEGIN :1 .UPDATE_FLAGS( :2 ); END; &28oracle.mgw.admin.sqlj.MgwiSubscriber &29oracle.mgw.admin.sqlj.MgwiSubscriber oracle/sql/ORADataFactory oracle/sql/ORAData +sqlj/runtime/ExecutionContext$OracleContext forName %(Ljava/lang/String;)Ljava/lang/Class; newInstance ()Ljava/lang/Object; getMethod @(Ljava/lang/String;[Ljava/lang/Class;)Ljava/lang/reflect/Method; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString java/lang/reflect/Method invoke 9(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object; getMessage close java/sql/Connection getDefaultContext 4([Ljava/lang/Object;[I[Loracle/sql/ORADataFactory;)V ;(Ljava/sql/Connection;Ljava/lang/String;)Loracle/sql/Datum; 4(Loracle/sql/STRUCT;[I[Loracle/sql/ORADataFactory;)V getJavaSqlConnection getAttribute (I)Ljava/lang/Object; setAttribute (ILjava/lang/Object;)V #sqlj/runtime/error/RuntimeRefErrors raise_NULL_CONN_CTX getExecutionContext !()Lsqlj/runtime/ExecutionContext; sqlj/runtime/ExecutionContext raiseNullExecCtx /()Lsqlj/runtime/ExecutionContext$OracleContext; getOracleContext prepareOracleCall s(Lsqlj/runtime/ref/ConnectionContextImpl;Ljava/lang/String;Ljava/lang/String;)Loracle/jdbc/OracleCallableStatement; isNew ()Z #oracle/jdbc/OracleCallableStatement registerOutParameter (IILjava/lang/String;)V setNull setORAData (ILoracle/sql/ORAData;)V setBytes (I[B)V oracleExecuteUpdate getORAData 0(ILoracle/sql/ORADataFactory;)Ljava/lang/Object; oracleClose setString (ILjava/lang/String;)V (II)V intValue ()I setInt prepareOracleStatement s(Lsqlj/runtime/ref/ConnectionContextImpl;Ljava/lang/String;Ljava/lang/String;)Loracle/jdbc/OraclePreparedStatement; #oracle/jdbc/OraclePreparedStatement getInt (I)I (I)V wasNull getBytes (I)[B ! <