初始导入

zm

2020-05-18 a18bfacbf56b401f6e0fdae8710fbca4df8cff77

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
Êþº¾3º
)tu
t    vw
xy    z    {    |    }    ~    €
     ‚
ƒ„…†‡
ƒˆ‰Š‹
ƒŒŽ
ƒ
 
‘’
“
”•†–a—
˜™š
›œ‰žŸ
InnerClasses
pools
Ljava/util/Map;
    Signature
MLjava/util/Map<Ljava/lang/String;Lcom/codingapi/tx/datasource/ILCNResource;>;
logger
Lorg/slf4j/Logger;
dataSourceService
7Lcom/codingapi/tx/datasource/service/DataSourceService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
maxCount

I
maxWaitTime
nowCount
hasTransaction

Z
isNoTransaction
subNowCount
(Lcom/codingapi/tx/datasource/ICallClose;
TLcom/codingapi/tx/datasource/ICallClose<Lcom/codingapi/tx/datasource/ILCNResource;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
3Lcom/codingapi/tx/datasource/AbstractResourceProxy;
LocalVariableTypeTable
;Lcom/codingapi/tx/datasource/AbstractResourceProxy<TC;TT;>;
createLcnConnection
T(Ljava/lang/Object;Lcom/codingapi/tx/aop/bean/TxTransactionLocal;)Ljava/lang/Object;
6(TC;Lcom/codingapi/tx/aop/bean/TxTransactionLocal;)TC;

initDbType
loadConnection
,()Lcom/codingapi/tx/datasource/ILCNResource;
txTransactionLocal
.Lcom/codingapi/tx/aop/bean/TxTransactionLocal;
old
*Lcom/codingapi/tx/datasource/ILCNResource;
 StackMapTable ‹
createConnection
T(Lcom/codingapi/tx/aop/bean/TxTransactionLocal;Ljava/lang/Object;)Ljava/lang/Object;

e
 Ljava/lang/InterruptedException;

j

i

connection
Ljava/lang/Object;
TC;’
6(Lcom/codingapi/tx/aop/bean/TxTransactionLocal;TC;)TC;
initLCNConnection
&(Ljava/lang/Object;)Ljava/lang/Object;
 lcnConnectionž
(TC;)TC;
hasGroup
(Ljava/lang/String;)Z
group
Ljava/lang/String;
executeTransactionOperation
()Z
isNoTransactionOperation
autoNoTransactionOperation
setMaxWaitTime
(I)V
setMaxCount
‰<C:Ljava/lang/Object;T::Lcom/codingapi/tx/datasource/ILCNResource;>Ljava/lang/Object;Lcom/codingapi/tx/datasource/ILCNTransactionControl;

SourceFile
AbstractResourceProxy.java@A
&java/util/concurrent/ConcurrentHashMap,-
1com/codingapi/tx/datasource/AbstractResourceProxy¡¢£01678797:;<;
3com/codingapi/tx/datasource/AbstractResourceProxy$1@¤=> ¥¦
loadConnection -> null !§¨©ª«¬­b
(com/codingapi/tx/datasource/ILCNResource®k
6connection is had , transaction get a new connection .
loadConnection -> old !¯°±²³
java/lang/InterruptedException´AIJ
connection was overloadµ©
#lcn datasource transaction control ¶·g
lcn transaction VW
load default connection !¸¹
java/lang/Object
2com/codingapi/tx/datasource/ILCNTransactionControl
,com/codingapi/tx/aop/bean/TxTransactionLocal
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
6(Lcom/codingapi/tx/datasource/AbstractResourceProxy;)V
current
0()Lcom/codingapi/tx/aop/bean/TxTransactionLocal;
org/slf4j/Logger
debug
(Ljava/lang/String;)V

getGroupId
()Ljava/lang/String;
 java/util/Map
get
isHasConnection
setHasConnection
(Z)V
java/lang/Thread
sleep
(J)V
printStackTrace
info
#org/apache/commons/lang/StringUtils

isNotEmpty
containsKey
(Ljava/lang/Object;)Z!)
*    ,-
./0123
4
5D6787D97D:;B<;=>
.?
@A
B›
?*·
*»Y·µ*¸µ*µ*µ    *µ
*µ*µ*» Y*·µ±C&    !$#&()-+20D
?EFG
?EHIJ
.KLAMN
BçR¸L+Ç*´¹
°*´+¶¹ÀM,Æ)+¶™*´¹
°*´¹+¶,°
°C6 IKLMQ&R*T1U<V>YIZN[P]D REFNOP
&,QRG
REHSüTü(UVWB
Lq*´
*´ H>*´    ¢;6d¢+¸§
:¶*´
*´¢
*,+¶°„
§ÿԄ
§ÿç"*´
*´¢
*,+¶°*´ ¹!
°,°
%(CBbcdf%i(g*h/j:kAdGcPo[pbrmsouD>*XY/Z7 @[7qEFqOP
q\]GqEHq\^S
ü 
ü

O_úú.`abBóP*´"¹+M¸N-Æ1-¶š**´#¹-¶¸$™*´%¹*-+·&°*´'¹,°C*
{| }'‰1‹<ŒCND*PEFP\]
 Cc]?OPG PEHP\^
 Cc^S
ýCdT.e
fg
BQ*´+¹(¬C
–DEFhi
G
EH
jk
BA

*´¬C
œD
EFG
EH
lk
BA

*´¬C
¢D
EFG
EH
mA
BF
*µ±C
§¨D
EFG
EH
no
BP*µ    ±C
«¬DEF87
G
EH
po
BP*µ±C
¯°DEF67
G
EH.qrs+