初始导入

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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
Êþº¾3
Þ    
1    
2
x
3
4

5
6    
7
8

3    
9    
:    
;
<
=
>    
?    
@

A
B

A
C    
D

A
E    
F

G
H

A
I

A
J

G
K

L
M
N

O
'
P

Q
R
S
T
U
O
V
!
3
W
!
X
!
Y

Z
[
'
\
U
]

^
_
`
!
a
b

c
d

A
e
f
!
g

h
U
i
j
6
3
k
8
l
6
m

n
o
6
p

n
q
U
r
s    
t
u

t
v

n
w

n
x
U
y
z
U
{

A
{
U
|
U
}
U
~
U

U
€
U

U
‚
U
ƒ
U
„
U
…
U
†
U
‡
U
ˆ
U
‰
U
Š
U
‹
U
Œ
U

U
Ž
U

U

U
‘
U
’
U
“
U
”
U
•
U
–
U
—
U
˜
U
™
U
š
U
›
U
œ
U

U
ž
U
Ÿ
U
 
U
¡
U
¢
U
£
U
¤
U
¥
U
¦
U
§
U
¨
U
©
U
ª
U
«
¬
­
InnerClasses
logger
Lorg/slf4j/Logger;
isClose
Ljava/lang/ThreadLocal;
    Signature
,Ljava/lang/ThreadLocal<Ljava/lang/Boolean;>;
state

I

connection
Ljava/sql/Connection;
dataSourceService
7Lcom/codingapi/tx/datasource/service/DataSourceService;
runnable
(Lcom/codingapi/tx/datasource/ICallClose;
TLcom/codingapi/tx/datasource/ICallClose<Lcom/codingapi/tx/datasource/ILCNResource;>;

maxOutTime
groupId
Ljava/lang/String;
waitTask
(Lcom/codingapi/tx/framework/task/TxTask;
readOnly

Z
<init>
w(Ljava/sql/Connection;Lcom/codingapi/tx/datasource/service/DataSourceService;Lcom/codingapi/tx/datasource/ICallClose;)V
Code
LineNumberTable
LocalVariableTable
this
8Lcom/codingapi/tx/datasource/relational/LCNDBConnection;
transactionLocal
.Lcom/codingapi/tx/aop/bean/TxTransactionLocal;
    taskGroup
+Lcom/codingapi/tx/framework/task/TaskGroup;
LocalVariableTypeTable
£(Ljava/sql/Connection;Lcom/codingapi/tx/datasource/service/DataSourceService;Lcom/codingapi/tx/datasource/ICallClose<Lcom/codingapi/tx/datasource/ILCNResource;>;)V
commit
()V

Exceptions
rollback
closeConnection
close
txTransactionLocal
hasGroup
 StackMapTable
®
rollbackConnection
transaction

e
Ljava/sql/SQLException;
timer
Ljava/util/Timer;
rs
j
s

getGroupId
()Ljava/lang/String;
getWaitTask
*()Lcom/codingapi/tx/framework/task/TxTask;
 setAutoCommit
(Z)V

autoCommit
setReadOnly
createStatement
()Ljava/sql/Statement;
prepareStatement
0(Ljava/lang/String;)Ljava/sql/PreparedStatement;
sql
prepareCall
0(Ljava/lang/String;)Ljava/sql/CallableStatement;
    nativeSQL
&(Ljava/lang/String;)Ljava/lang/String;
 getAutoCommit
()Z
isClosed
getMetaData
()Ljava/sql/DatabaseMetaData;

isReadOnly

setCatalog
(Ljava/lang/String;)V
catalog

getCatalog
setTransactionIsolation
(I)V
level
getTransactionIsolation
()I
getWarnings
()Ljava/sql/SQLWarning;
 clearWarnings
(II)Ljava/sql/Statement;
 resultSetType
resultSetConcurrency
2(Ljava/lang/String;II)Ljava/sql/PreparedStatement;
2(Ljava/lang/String;II)Ljava/sql/CallableStatement;

getTypeMap
()Ljava/util/Map;
9()Ljava/util/Map<Ljava/lang/String;Ljava/lang/Class<*>;>;

setTypeMap
(Ljava/util/Map;)V
map
Ljava/util/Map;
7Ljava/util/Map<Ljava/lang/String;Ljava/lang/Class<*>;>;
:(Ljava/util/Map<Ljava/lang/String;Ljava/lang/Class<*>;>;)V
setHoldability
holdability
getHoldability
setSavepoint
()Ljava/sql/Savepoint;
((Ljava/lang/String;)Ljava/sql/Savepoint;
name
(Ljava/sql/Savepoint;)V
    savepoint
Ljava/sql/Savepoint;
releaseSavepoint
(III)Ljava/sql/Statement;
resultSetHoldability
3(Ljava/lang/String;III)Ljava/sql/PreparedStatement;
3(Ljava/lang/String;III)Ljava/sql/CallableStatement;
1(Ljava/lang/String;I)Ljava/sql/PreparedStatement;
autoGeneratedKeys
2(Ljava/lang/String;[I)Ljava/sql/PreparedStatement;
 columnIndexes
[I
C(Ljava/lang/String;[Ljava/lang/String;)Ljava/sql/PreparedStatement;
columnNames
[Ljava/lang/String;

createClob
()Ljava/sql/Clob;

createBlob
()Ljava/sql/Blob;
createNClob
()Ljava/sql/NClob;
createSQLXML
()Ljava/sql/SQLXML;
isValid
(I)Z
timeout
 setClientInfo
'(Ljava/lang/String;Ljava/lang/String;)V
value
¯
(Ljava/util/Properties;)V

properties
Ljava/util/Properties;
 getClientInfo
()Ljava/util/Properties;
 createArrayOf
7(Ljava/lang/String;[Ljava/lang/Object;)Ljava/sql/Array;
typeName
elements
[Ljava/lang/Object;
createStruct
8(Ljava/lang/String;[Ljava/lang/Object;)Ljava/sql/Struct;

attributes
    setSchema
schema
    getSchema
abort
"(Ljava/util/concurrent/Executor;)V
executor
Ljava/util/concurrent/Executor;
setNetworkTimeout
#(Ljava/util/concurrent/Executor;I)V
milliseconds
getNetworkTimeout
unwrap
%(Ljava/lang/Class;)Ljava/lang/Object;
iface
Ljava/lang/Class;
Ljava/lang/Class<TT;>;
1<T:Ljava/lang/Object;>(Ljava/lang/Class<TT;>;)TT;
isWrapperFor
(Ljava/lang/Class;)Z
Ljava/lang/Class<*>;
(Ljava/lang/Class<*>;)Z

access$000
b(Lcom/codingapi/tx/datasource/relational/LCNDBConnection;)Lcom/codingapi/tx/framework/task/TxTask;
x0

access$100
q(Lcom/codingapi/tx/datasource/relational/LCNDBConnection;)Lcom/codingapi/tx/datasource/service/DataSourceService;

SourceFile
LCNDBConnection.java…†Ž‘Ÿ
6com/codingapi/tx/datasource/relational/LCNDBConnection
°
±
²{|
java/lang/ThreadLocal}~‚
init lcn connection ! 
³
´Éƒ„‡ˆ
®
µ
¶±²‹Œ
·ÐŠ‚
¸
¹
º
»²
¼²
½
¾
¿
À´
commit label£Ÿ
Á
Â
Ã
Ä
rollback label
Å£
Ä
Æ
java/lang/StringBuilder
lcnConnection closed groupId:
Ç
È
ɲ
Ê
Ë
java/lang/Boolean
ÌÃÄÃ¢Ÿ
&now transaction is readOnly , groupId:
now transaction state is 
Ç
Í
 , (1:commit,0:rollback) groupId:¨Ÿ
rollback transaction ,groupId:
ÎÃ
connection hasGroup -> 
Ç
Ï
П¡Ÿ
java/util/Timer
8com/codingapi/tx/datasource/relational/LCNDBConnection$1‘
Ñ
Ò
Ó
Ô
՟
֟
×ÐžŸ
java/sql/SQLException
Ø
Ù
Ú
ÛÐ
ÜÍ
ݟµ¶
setReadOnly - >¸¶¹º»¼¾¿ÀÁÂÃÅÆÇÃÈÉ˲ÌÍÏÐÑÒӟ¹Ô»×¾ØÙÚÜÝâÍäÐåæåç¡éìé¹í»ï¾ð»ñ»ó»öùúûüýþÿ








Á


 



É
²




Ð
 
!
&
'
@com/codingapi/tx/datasource/relational/AbstractTransactionThread
4com/codingapi/tx/datasource/relational/LCNConnection
,com/codingapi/tx/aop/bean/TxTransactionLocal
java/sql/SQLClientInfoException
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
org/slf4j/Logger
debug
current
0()Lcom/codingapi/tx/aop/bean/TxTransactionLocal;
 getMaxTimeOut
0com/codingapi/tx/framework/task/TaskGroupManager
getInstance
4()Lcom/codingapi/tx/framework/task/TaskGroupManager;
getKid
getType

createTask
Q(Ljava/lang/String;Ljava/lang/String;)Lcom/codingapi/tx/framework/task/TaskGroup;
)com/codingapi/tx/framework/task/TaskGroup

getCurrent
valueOf
(Z)Ljava/lang/Boolean;
set
(Ljava/lang/Object;)V
&com/codingapi/tx/datasource/ICallClose
java/sql/Connection
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
get
()Ljava/lang/Object;
booleanValue
(I)Ljava/lang/StringBuilder;
isHasIsGroup
(Z)Ljava/lang/StringBuilder;
 startRunnable
;(Lcom/codingapi/tx/datasource/relational/LCNDBConnection;)V
schedule
(Ljava/util/TimerTask;J)V
&com/codingapi/tx/framework/task/TxTask
    awaitTask
cancel
getState
)com/codingapi/tx/framework/task/TaskState
connectionError
+Lcom/codingapi/tx/framework/task/TaskState;
getCode
setState
remove!x
y
{|}~
€B‚ƒ„…†‡ˆ
‰Š‚‹ŒŽ>
‘’“
o*·*¸µ*»Y·µ    *µ
*µ*´¹ *+µ*-µ*,µ
¸:*¶µ*¶µ¸¶¶¶:*¶µ±”>2 !/"3-42576<7A8J9S<e=n>•>o–—oƒ„
o…†o‡ˆA.˜™e
š›œ
o‡‰
žŸ“Z
 *´¹ *µ
*¶*´    ¸¶±”EGIKM•
 –— 
?
¡Ÿ“Z
 *´¹ *µ
*¶*´    ¸¶±”RTVXY•
 –— 
?¢Ÿ“i
3*´*¹*´¹ 
*´»!Y·"#¶$*´¶$¶%¹ ±”\
]^2_•
3–— 
?
£Ÿ“
žò*´    ¶&Æ*´    ¶&À'¶(™±*´Æ*´¹)
™±*´™'*¶**´»!Y·"+¶$*´¶$¶%¹ ±*´»!Y·",¶$*´
¶-.¶$*´¶$¶%¹ *´
š**¶/*¶**´»!Y·"0¶$*´¶$¶%¹ *´
 9¸L+Æ
+¶1§=™ *´»!Y·"2¶$¶3¶%¹ ±*¶4±”Vdeh.i/l6m:nYoZr…tŒvw”y³{»|¿}Ì~Ѐìíƒñ†• ¿2¤™
Ì%¥ò–—¦    *ûXü§@
ü!
ù 
?¨Ÿ“8


*´¹5
±”
Š    ‹•

–— 
?
©Ÿ“
f*´Ç*¶/±»6Y·7L+»8Y*·9*´…¶:*´¶;+¶<*´¶== *´¹>
§*¶/§N*´²@¶A¶B*´¶C±
8MP?”BŽ‘–˜%¢,¤0¦8ª=«I­M¶P²Qµ^¹e»•*Q ª«f–—R¬­
8.®‚¦ý<¯
B°  
?
±²
“/

*´°”
¾•
–—
³´
“/

*´°”
•
–—
µ¶“W*´Æ *´¹D±”ÇÈʕ–—·
¦
 
?
¸¶“˜9™7*µ*´»!Y·"E¶$¶3¶%¹ *´¹F¸M,¶G±”ÏР   Ñ%Ò/Ô3Õ8ו 3¤™9–—9
¦
8 
?
¹º“4


*´¹H
°”
ߕ

–— 
?
»¼“?*´+¹I°”
ä•–—½Œ
 
?
¾¿“?*´+¹J°”
é•–—½Œ
 
?
ÀÁ“?*´+¹K°”
î•–—½Œ
 
?
ÂÓ4


*´¹L
¬”
ô•

–— 
?
ÄÓ4


*´¹)
¬”
ú•

–— 
?
ÅÆ“4


*´¹M
°”
ÿ•

–— 
?
ÇÓ4


*´¹N
¬”

•

–— 
?
ÈÉ“C*´+¹O±”
 
 

•–—ʌ
 
?
˲“4


*´¹P
°”

•

–— 
?
ÌÍ“C*´¹Q±”
 

•–—΂
 
?
ÏГ4


*´¹R
¬”

•

–— 
?
ÑÒ“4


*´¹S
°”

•

–— 
?
ӟ“8


*´¹T
±”

#    
$•

–— 
?
¹Ô“J*´¹U°”

(• –—Ղ
ւ 
?
»×“U *´+¹V°”

-•* –— ½Œ
 Ղ ւ 
?
¾Ø“U *´+¹W°”

2•* –— ½Œ
 Ղ ւ 
?
ÙÚ“4


*´¹X
°”

7•

–— 
?Û
ÜÝ“U*´+¹Y±”

<

=•–—Þß
œ
Þà
 
?á
âÍ“C*´¹Z±”

A

B•–—ã‚
 
?
äГ4


*´¹[
¬”

F•

–— 
?
åæ“4


*´¹\
°”

K•

–— 
?
åç“?*´+¹]°”

P•–—èŒ
 
?
¡é“C*´+¹^±”

U

V•–—êë
 
?
ìé“C*´+¹_±”

Z

[•–—êë
 
?
¹í“U *´¹`°”

_•* –— Ղ
 ւ î‚ 
?
»ï“a*´+¹a°”

d•4–—½Œ
Ղւî‚ 
?
¾ð“a*´+¹b°”

i•4–—½Œ
Ղւî‚ 
?
»ñ“J*´+¹c°”

n• –—½Œ
ò‚ 
?
»ó“J*´+,¹d°”

s• –—½Œ
ôõ 
?
»ö“J*´+,¹e°”

x• –—½Œ
÷ø 
?
ùú“4


*´¹f
°”

}•

–— 
?
ûü“4


*´¹g
°”

‚•

–— 
?
ýþ“4


*´¹h
°”

‡•

–— 
?
ÿ
“4


*´¹i
°”

Υ

–— 
?



“?*´¹j¬”

‘•–—
‚
 
?


“N*´+,¹k±”

–
—• –—èŒ

Œ 




“C*´+¹l±”

›

œ•–—
    


 



Á“?*´+¹m°”

 •–—èŒ
 
?


“4


*´¹n
°”

¥•

–— 
?

 
“J*´+,¹o°”

ª• –—
Œ


 
?


“J*´+,¹p°”

¯• –—
Œ


 
?

É“C*´+¹q±”

´

µ•–—
Œ
 
?

²“4


*´¹r
°”

¹•

–— 
?


“C*´+¹s±”

¾

¿•–—


 
?


“N*´+¹t±”

Ã
ĕ –—



‚ 
?

Г4


*´¹u
¬”

ȕ

–— 
?

 
!“Q*´+¹v°”

͕–—
"
#
œ

"
$
 
?
%

&
'“Q*´+¹w¬”

ҕ–—
"
#
œ

"
(
 
?
)
*
+
“/

*´°”
•

,—
-
.
“/

*´
°”
•

,—
/
0z

8