eQP7>eO4bW(KvGpk}Sb2I|sV0qWA*v{nYSnV?p!%?9e$+X3p<
zJG6ENb(o-bt-}WD(KUd2^iEAe9L^AnznvKm*m>
zdqhH(Mx{ZEgY-qZ6ou0&-lWTL7xGX-yh2}st%3T)i*z|OFP$NF(-qKsv_d>cS3>hs
zR$ND4h8CcL*h*JHQ|MZeqpv^<(v4z_z6vcwQ(};|LJQO5VhLRhO{G^bj&0B)^tzZs
z*FcNnzIKqVg%%Tj`WJl-TBA6MUZ(4yHHm(Dfv$%Z7iZ!#;s$8VVioP6uS07QdBnI8
zTB|5yB;SD6Ca%YK*-g;e#m)F?yBS)Ccog^QZ$i_=UfkSofz~Nr#b?2-(7MDv>Z04A
zb+yyPK#lp!|oT0lNKdY75Y}@lO$NQ-@T8|34KAg3ndC+wsXFj5F8A+nm?jQ@iFQ
z4`p9v&9RD?VV2x{@Tn@p_$I+?MAH~0+
zLk}7*^b(U5thh8iWVk|A7dnh&b?RZmh2~QXDNZareS&}~dsq~hw)
zqlPP5b)g5zcg@jbh70Y-WW@|ux9i5liW=!R7pXy{M(qMb`
zu%VTF6+i{!b(&0=-v+agwN?`xaDpwoi^HTSvnUqJ-DeVmZbXZFNViE39fEE}cqfDz
zBz))~R-D6t%uwn(hO(j^9%lxO94??0vo5F^mfNjSSD?ScKcnirMsuzQZ3d6k7u*{8
zyC9gaXsr7c)?3~k2QNZfz@O4&=cbp?8u*VLlaEpF`dxHn{5?}NmmByLCE`a(y_xl+
zrQVL8_%Tw)y<={Cp42tg=Sv+|jk$5e;5fMDB;x&2?_xVH9&E==V{RPB0_&}eIacaD
wY)?uZm!CxZIH}KJ`|%J{bVBW?r~Pj-lV%I_(3EkS?W+E@XE)~gXp#2(4~qLk;{X5v
literal 0
HcmV?d00001
diff --git a/etl-data-source/el-data-source-common/target/classes/com/etl/data/source/common/pojo/DataSourceType.class b/etl-data-source/el-data-source-common/target/classes/com/etl/data/source/common/pojo/DataSourceType.class
new file mode 100644
index 0000000000000000000000000000000000000000..43b6fe2d38617353431a9bfbc6eafab071a898a8
GIT binary patch
literal 2186
zcmb7FT~8ck6n@^>8D?1q3d=`}P>Z(G{Q#zF{V1^2(o#iXi-070(+;~67`i*N?#wp!
z+Dp^K8*h4{cQz)(w29p|G&XvpiNB*#e}r0}cV+`DtWg7d-mi1c`#jG%@9wXEZ9fKZ
z7OM#)G1Cqe7p1wRV>ZF@vNZ2V^R9H5ljc1g?kEv|Z(293Pt6-v$ti}LW`PGm)pFdxH}hVQ
zua!zu0(#l@eQVto=yHlr9^U%>vmc&3+ZEy
zlHtW>$#U1t<)G@g>%8RjzoMC8z;${K?Rg^(b;f>m0zs*YSYHq~Imp)zOY3tri@gOVxXn|_F&
z;*`stYgW8X&%D$`i=ec1JD8*Byp^)|bJgq;G4D&ITXEO?C|FI+NzDCRwu{+ONMHH+RjB5E(#u&V+`CGS&`?7>E2!TX|^Gc41Z<&~YHS2N2u*Vx5=rBw4xYq!zO5S^4?R*Ah{W4>-l^=eets{tF+!1Fj^
zpcj1xp2Lv9#Q*C618-o$z)Ki4a2hEC<8t{XMyag?yT93IYEG#rRZljvN;$=xfn}^n
z^C7D_HgdQkIaV`mU>Yg1*vlMMl=@ngitVxw$6NKvq4sG&p)$j4y?;E$3;YgB@~cYW
zA2p)w=c)q&1NmFjd&KbnQx$}TiKtW
z-i8+2%Kiv-VJuUJ7A`qy8{_9|dB%mF=SrVc$A3Y`p!zd!XuyRO^U`?y3|ucBmp}
zqq}yQEwU14h@>A=c$rmFXiwl3?#1|82JtFqDu4ZC$LM_OiK>9-7lB;BR63R0Qrjnr$BnKg$@n~A{0IlBt9Y}#PWrofkZIp)~oKW?v%-VK(cS0_wKp3?z`{2
z*EN6q!(9;7$xFXK)
z>iC|9m{->@b86SQbu)+cTGd8J7~BYbeBW!bN#N@+NReK?-{4*YRCvY
zf4Sq6Q@y^^AM`j|Yu87!*5;tq_nPhnujg$w+`C(?HfdhFMdIzJYVBrq%V{^gdV5f9
zUf!ao*J%uTRcFMjo_83x?zxRRU!HUy@p}C@8w?HUTEpq}&N}@a;?7{J;nnVUF0=mQ
zUd!v>r6InsctJzrUe=?baLQ}BX9mqJx9g{r<+W>0B7y!gJYUANX>TfC@2YflO=aIxd<{*K$#pvz8GM8<|c
z
zB~EqS-k{N^%kNvZ5^j)Q8FnLE2`@WS2`y0fLu7GjAF0AKl~9RBzpbRiTj894gx0+V
z%SmstEw{x89H_d-?-+0BZ5@-3mjsL3`aXSOKmp*~p$>$s$6aek(II8lg@tItD4%*Lr
z+Usdk{$v_&AT|{NZ^WB8(qxlqCxd^1*iWZ|&B$PCAR;(E9h{2{rgkEN6Vt)@$Y3fm
zA~-o6T!;*&k|Tms)4|2aV4i@8V0}7xCNh{uB_i0E4xWn)=CO+iPEQBVM+UzYCxc*{
zB8rJBmX@DIELtV=iV>(p6ePM8ajoNRQF-F~%_F*(Ja3QAlh|(_IX9ALBYIuQ{pOK#
zCwblxohP;5JaTR&&pV^@==;s1&b@|H(fu*@n@6q*spoWbJ?Z`Ck!wcs@OOZg_eAUo
zYGa01$NKWpkC04UTmBs~SCEWfTYesy(<@7R$ofM9^UMm3oml+?vR2{+l&->DwGw;C
z4Hbd$wsRzv?Yxx}Qa&K%tbB+xV;4x8v5QtgNX39uu!*fiHh2-{DpIfO4>3GVT-7Y8rQXjL%Q*A
zDvM>C*j_*y1B&D&jmo!#gY{_9`*{V&JD+1>S
zj7k$f%D60}|502!o;cyl_;7J;haxtL%U7YV?qTjhna|q^aaf7KV~Dhst6(R67gg;C
z8CG)WD%vUEl^VIIbrn^zb>Bsq2T}UaRkjV^WsF=Dzlxf%)4q$k52DgT*Q}lKU73-K
zr-4z2qh;4o>khgT$6w)Lmt9HXFORl4#{u++G9nZ0=O|w1M1nHWG)e=ScAYO6k7F`1hvbkj
zL4zB)U<#{2`%;XwJOJy>#V_HeL#NMT-hR{5~PGlE~CFt5~u
zGN^lKZw?Zp*tnQo1XpojC3#k;ImUPvpKUmy(7(4fmz^AdXK3B6dyS;_k8e
z&@>vRb7br|o^@ok*97!-w_zPTYFT?`(-KGxfcCw%?HmykTeltC+Z2dqmk$M$n{JKJ
zsa@N#_PWiA)jlvQ4d2+UnvFxVZOe10RJ^*~5yVan<3@<2Z4Nl)><4-fLbG=x0MTgOVdt9X
z2Biul_x;w~wq-{r``lcSvm=lxcOB1eT8DPWW{bBR$MsClb{+C!_#Lj8Zqu&0U8DJ^
z!kbR3(d`)K8P4#tmpzkherPtjjFOPaeCcrrbg$Gdo2$E$cv
z$6Hdmj71&qVO3!6eC~rHZ*=WOO?E`@mzT9`8#>C^m&*aiV&(E6K^r7-Sw|6z0@LT-
zf)0~hv(>U3_O&o>b_OPIC_D)m!uLn%fALu4t55L@5#bLh@+GpwJpq=9d9E3r4DN!v
zntKfKgAaR&Ys^<_c$u;u0I+~pcoLE~uEWMZBJ%x+@x)kTQa#2vI%=$sHGUm$gvLd`
zFy@)d|Aff+yl07#l>~W9NfIH;UBa8={6t^Wk0et1;qZih{$i{+qt)}d@1QED`6p1m
zg&IB0{|2SBlIubBj}&5iD_n|7;de}Al&6?EfnLZcJ;eJ6t*8>B6=NAyVq#B`I>BT{
z&BXd3<&?3a812;EAcwPx>&Rl68K$w19J?1`<+qThF3R&JRwyaB!lQTIb?IVPD$};xCiAq6$)t(f~7-<=LDUfBT|uu+6VM8
z%CL$s#^ZM(thCIS^5tcJLGts*m`Le8Ov-|LxR9C(WQ|*DnoAEeqfcb;ac0B1B3Sd8
RU&jXb3HsmU-$xyM{4e8#h4%me
literal 0
HcmV?d00001
diff --git a/etl-data-source/el-data-source-common/target/classes/com/etl/data/source/common/pojo/TaskManagerEntity.class b/etl-data-source/el-data-source-common/target/classes/com/etl/data/source/common/pojo/TaskManagerEntity.class
new file mode 100644
index 0000000000000000000000000000000000000000..2244273080b3759bda6d97ed2bf8ddce90d634f1
GIT binary patch
literal 3961
zcmb7H`*Rdk7XI#Jdb%g+$zvda5q#~U=0O-mR(B@^1dSSnsDSaUG&8+P!#v_l4}z|{
zvZyG^*8aRzmb+D3qE-B$rA7-%OMcNR{|+AdKlu7i-=4`l+A^jxr_Z_fJLjI~?U`?X
zI{zhrZ8+158?l%~5}uI5LXHS23MmOG3#ph`>gDr!AypwYA-<5hkfXhL0mp4yk_Bb**Rt64TYFjP*Af9nSJ%L@0Hwn
zujU;py1UBditqSdrCd|EdCy_zsB&wO|Ci%XxMzxu&>g=^dGA2`0$eum{cwIg#*iMr|FxNOlWFJ$-oRj<52
z)3^Ml4>P4D|2UEBFI~8B`SkxT|NG32xx1;_ga;PK;n$w$&9kn&bMpIBXWDUz8uM3Y_CkNIo?gE4%83q4)h#*IBTdZZ|DU?@@%tT^
z?OxgQcPR9Xj?F8?wR;15ys|r2FCB8L2OQQ*vR27E#d)Xdi5xD*{Y8&1+`cDYDP>*1
zm}U8#Y^_qS=3UmXRH~G-OO?Zw>;VR~*D14h)fx6dkVs>}^(9$6m<`fLNl>~*Ye&bT
zs+0^tqSjE*4yVGMM&<;$Kg^Ku`@&2ZHGOD&bXLOcqquVF@M!m;f=Y&{;MkB4j}4{f
zv6P#~l5ZTFaG$R`MW(9lh=&dxcJuz!*pr-*N_%65TM9?}!0TYM(GKBeLrl@*Jj=5bRF!vwi8mFjyi=YLugNYtwM8AU@$kOcy)z1l
zs#~iU*`mo77tDZ{^UO^RBu9ny$w}6d1@n;)F6?5^HXathZtSvguaM`kQ(>L>
z)p}j*u6xCT)MU6ThEcCDZR0fF67n|tYx50_l1(#LTAD484|gQ1lu~*}w~2j^F}`T9xn
z1DJ?O4M{gq>Vv{f{M=l_Eg0oO3Th2jmSR%s7VLz^Zf?OgmtxWp-PkSN*eyh{ak{a$
zc4KcPiv87%-P(=aN)+3$8@sI=yNxJzYd7|eZtNXc!?@Z0q<>+OvV1B&jq%T*J|YuC
zjx-T0_F;;=tpV7MX-Z03o3vf|6U5GSC=Wy`a|R-mdp_(?PDd(pW+Ig1oyxmFejWNlI@eQ9M
z7G3BOjR*@ZO(4@H{V|INy6jARik{Wlk;xM~4@TRGuhx!CrP$dM9hb3MJ2J6iXK%Ef
z#A@xxG>e_NXglU=?Z~8yorj|HW3ASX+yY{UZx~XJs9Iu8ldSv2iShSf#LrD!MDjl{
zdd^LJh2-AN>y(591sT@V<)Sad>!?Ydw4~=P^$%j+gl2eTYj4r?q?O5o34_?Hf`h^Sz|O!
zw)i+@YH-@(v@Pfnr>2mPIX&U@4X1B8eaERKY~Pp3Ez=I8Lc>|P&!}P?xJRxMxM4@J
z)7TF?4;W3TQJAD|m~Od2-{aI~G`hO9!RZQ=?d@$&yNt#S)7)s(Th^w|$zyckjE&`L
zozos8DQB=bb+G4}i
zRcqB6o1A)##xk#~P;}7)_eivSziGnl05d8k;pvG1k`YR@GKHB?ziotvl*kwWU3(
z>sHm#%^D-NUPS)HZv;zNnr${LRcqBPZAC}MQcPR7&01@FO?NZ{N5f?-1m#ICD#Hv-
zubWG+j+_uS&9Y2uFtfDihkp7HDVv?!LLAj-7ipR_{LriQyE|U&xH|zX6(ef9!Im5Q
zg3pYFbl=BK=8bmLRlGD%cHPuflBgfIJq5OI6e_*wAc8(9l|*?_GzpT%7u&(v?&Eeg
zX~h?NT^tUQMcqlXLaSx!OLRoX5`9QFB>ISMFq(R`DiMe%?#M|`l;~dUcD>^$MwZ8L
z7CG)mr@ll>q~bP1gM1L}$f=tgO0+CIl2}s?y;N>kD5$FfPvp?;Vnta;sC+lT@lx+Z
zUIM;3Ee|aXs8llbbD@lA6L0{zR@5aayyDWxu5z$BJbh05@}-FyYT+s2)+~m
zbLYTo<48qx>@Box;rRGihKRfV0<6KV+k-3#nLsJ;r)h6NQIG_oC7H@@qX6%SX6v`x
zUV_Y)jHna!u`IW|j-R9+YPhJyaRgcJxgAj>a0<=#f5d$!qIlPfmrm6v=y%aFML($~
zcp13Tiz9JgbmDo|&iWT?9f>!@#CtF^tIy?X`9+7*bv#QIw8b0vU!u#z=rz$KGy}ep
z&yp
z0?Rp8z_)XJ2mEP{?}G2;cpm&&jz0(A&+!-Fg&aQsFVdI8cs&GvmGf7@Xo>6|Xn;(j
zA|XdG2aSjC8c2a;kj0z76Z-d&3Bd2xf(qI5>kOAVfIh_166<{ISnx^M}(8yC7
zoo4@JN}>1{6`P}#lHDv+%Jx&@g@IuV`uJ3702hQ;vYW-qgxxHO!R5+DyU8n)7&RqM
f!$_QFhQ#YRPh$u{g?>Wfe!;<7pT
z51MFAG%@<3iQlB+Ix`b4rHP3NoW0LE`?A(Ld;0Uwr!N2|a5siH#=8)~B^{Szv{&RZ
z5yMqnlgo7-H)1d_Zs4Z0lLiXXPU)By=<@8CB3NI^(V}w0ogkbC#ObRj2+~7Ldtq(XOo6^|IWDhpJa9Hw3ON6y2)j
zcol2S_H3)+HtR*l;#t+LS)1;LYt@|>)_vYB`&Tn=rCF`9xw-CmeyIRpZ#vTnqS-hQ
zl}sNFlF*~hi>6&6oC5(5RyUlYSI9gS5bi+@!YcvI^-4}%ATH^Q>{G1Uzu13rblJ0u
z&ll}YA2we^2emVbc5PO6r(3ccr9ea~I?v({AI&e$vOE1~-Dxx{oH>NDK70kH@`cxw0mOIoXaR
zy(`kRiQBkCdKnXW3%3)*#yT^(>>Ft6cJ3P@uc1Y@b6*iz9L=_%
z`dd2M(kPcnHU9%g2Gs93wgodkptcb8Bh+n{i5%iT5tQErF@w_>V)G=%aE6*F7~y`H
z{}E)V%~^UX&aqY!QQi23xQ>zE=+kkYe+GX|aqdHOb1Wf;EcF@2laJ`?iM4P#X&yz1QVidw&1>+D`!1
zm~aaR940Dn%uPC(gHFMd-=R|TXFO)UZges?mva3~O5T?$2EnGNo6BWW`P^(S
zRdA1|c9iqj?;dBkv1!-eS1NaBZ(l`9QNiOONR_6OU(qp9IhIs;mkZKX1y>b_6)SG-
z>aBCBEJHj*h1c?{-nE^T?%}P{yR8bZ?ls)w^G=4vs&d*pG3!qH!+nPZM6SB6p^03{
z`7>^TypYB2DHAjis4Kq9W)*aEWLJug03bW0*reiGqF}Y^?iz4Z>!r00kts3mJCn!8
zoP0nJ4ree^)})i&DU&D5XPn}UVi@T*!rb=l9~s-pY2iiHeeH3PcruOHXZ(
z9Tl1=3d_%_UXWrc(_LP`;HZTp;A%PE0;~ROXoI=>@|#;1zAjIfjmObzqF|#4-^Ma5
zx3N+#591LVk7BvNn*TizHlD|@jnzomNK5GnDXo*s8mzVP0!9V8qc=&VxNY9cOi6Nd
zRVCLOvSgEud7O~TNpgB{W$BUGL>dmRjLKOm9`$XNdPx!LM4ycVSS!#P-LL3Le54Ae
zmak~=y6rv6uzE-8&$Z#?^KN!ZV5r^0P!1eN3l*FN4dPN3l4*?$$HU;7aaSJ2pR
z1iN;Lh6eO=T?T_|f+4n2YJ-h-G@}DcxDU``t3xn|A$|!-k?;b!%M0}WAJBM_f;!L$
zlx-ExdfAz*s^hHHI(O7{CK2m6>$T3Eb)8A&I?hI|b9Y_m^>{LLPBX~{rfT#Lu$oa7
zRnm#TyGtR$q=^k%FYr|Tb1J&=@8>9{2t18v>cykqZ#;@v0vqbbW8CjKiibkJ7%Cp|
z4s(yQK9>jjzlE-yANUpK=g=F^5BvgiY_NX;R`5xoY0n^+v^Mk`;z{iW+RniqN@@#;
zl@Rf?PDng$Bz1`~ZlL`f5=lL2RDkTXNsyhklBNV%A;?Tx6`(}AiJ(L}mTZ!sSO{uL
z#!4XVJfm(5CZe(jd6iAMmzS{-o0w}S&R{bqq5(bl2+vX{ec#6xN*bQSF>IxzV+<~~
zQ8JLhE^Md7mz$^^lq`J02Vy6sCVa+;-bE=!Uyvs)ru7$^P3*pnE)ygCv&3yIRbtaU
zMBdC-JY>cO?vkmxY=KO!ayl!CTAEHmnUYLS$md=iBi^H*N$-5?@J4M@(6$w=!!vA}
z)jDtv=FkF~k4Swytw}>t3oVvxr83!RJutD0fs>WgOQuBH2uw!V#NN_tMg4Z{R|+*UIyj!lL<tI(8)x
z&xj`^o{*4uB@)U5RFEQ&5WEzL-$W_j>{-X_$e^M`b7tmzGka#fIVbt^@1K7K@I2OC
zWHImJA}*z1<4q9@A{Iqlw(*wB^@@nM1^SL?S4CVC@vivZv+=%*e#|@gK-LdMTzB9*
zSaMKuuq=+i#tj9#?ym&%t#yUHvuplszfke3D}|YAGgt{4QwomkFP1+J6x>Fu5?ubM
z9?UG$DAksC4C_R>T5g_HNREwPQ83PMPoaOdT$R*ILF2N&RH0{ZwpQ{hSNuj8s>}
zSIZj;le4ATdLd|53d?@eFKpCWjZ#pcZ@pG6)N5+EYse+YT{+?;|EHQ#=q<|Ym3cBxw@jTuZwE!m2p@M2j*N^=FAgDI3~xWtsWl7h>aBw
zt0;ST1P47F67i^r$8b;~|3600!zn!D;YmE@;c3yvL>m{86Y(leE9~#^sZV&iRjw=x
zn*-6v($eJ*?rT2=*^MG19(n(+Zi1kxoan-RTK!HSXbcyuqBEuj%Pg*wb-EcbQlH
zwqI!l7kTN2$7Xup7t62LgDS80WPDnqCdWg%s$%=Q@a^f2O?5XOhxt@x`Q8~w2qDxG
z!b!N2mT)CATr*I@ALU_M=ZRBXhjMqJa>h?c{D@@E3RmO%FzgA+J|rn!ruX=h!4X=X
z4#X&q(o#ZTl(fKAlA5_6ko=BH0+PfEon9>1+zBSj?GEnm8Jx#N6kKGH2`Ms{X9qi-(?z>s^sq)mMN313D(Tf^?>sRE{yUFQEqRXh
z&SO68d1O>1PoZ}n>tXZAs7W5)XG#v5`h>No*`GW4+&3_dt^Dt>zk-?E%Krv?ZX&l0
zCp4*~<|inM#^fJJXN`N?fteLf9Ag^c>@ysvX7IY*#EaBS%pt%_)GSnR4lh%)(cnv1q~_oY_H2q;3SY95C#boY
z<~fd|-*)~&pN*6EF>K=%{yOSD4rn#?FDk#xH&!#jZ>ew&O`$-Fi{H-pptdgnbI*t02aW5#TV15>Lc%^ApV!k*kl-*xe)i-v4ujcCUaD)p9EG{Y^j
z7zR06v%QrmTH%(pvqf$hb*MKT7xY;oI+9q&8N9}mnr!%4Y6&**1{*DO9AWd%Q!{Xq
zq+Ot9;wtuIhME<&`CB*-=rGu3rPx|1^?-pLJ0XrCm~B8CV|2SBm=%L{kh{GR*zN{*
z@I5vd!W#J}OLM}%dHOX!^$Ys1-o?P+o^1>YHQU%bxKHb8(TB9|i9W3LjOhERZ{xu3
T$4^g%e(+C4Jyw_vXJ_sopLYWY
literal 0
HcmV?d00001
diff --git a/etl-data-source/el-data-source-common/target/classes/com/etl/data/source/common/pojo/until/R.class b/etl-data-source/el-data-source-common/target/classes/com/etl/data/source/common/pojo/until/R.class
new file mode 100644
index 0000000000000000000000000000000000000000..f28ca7925954fbd0d0a9d73be9bbe59d924f001b
GIT binary patch
literal 4055
zcmb_eU3U{z6x}yXGEJBQZJ}5|ln*6M2~j>op#(~4CD_uMv=s^p({u<^(wUl>;L`u#
zAMnXHUwlA>!qT<;0sbhL=iGZInUrK1sAX~Ie(tl+KIfjBzyJB;F97H8T^jqaoI(O$
zrK!2iy*mb0c(BaPU2g7i^EI!1!_9qe9`Kx%#wse@tntuJ;UTJNJc7f$bpwwL)CBhW
zcHOaR%XZy&Ja?&hT|nFv7?|>0Kd{_j*{U_{1QFstAz+l3rlzLLW!hF0h|f$GXX#V%
z)@*^k4ZkWdG`ns+vGO&`t>()?-EpgzXvdlrSnX@`tLt_pptV%lsk&Css58XkBF!Wx
z9M=g7G|Y@G)8Q!zzh~BQ?OTnFRlB}ut=4Gw(5zP>?iP7KV?7xU9yz|i*lfky$lF0J
z&!+Rf*Qi(QJk4!*Zhq5S_wo%laBBGy*&Auc`F=CRI^8SC1o18qQp|fSFrIl6<1-VB
z7bB8sSqi;lgtjkdUWa)TBE>F5$hDqfLN4$xfngz2+yM#+c&7`uoxq0jrR%mIlx)9I3j`KA#C|76hD`{;^xD0N9XAlLUtbqJG*0NBEHSq|F~
zngubD8Ixs@O{VjlBLt^t%(otp@~B{Y~ms=nRpk61y1((R+zYoNfSlfG;tl%CXO)9dwAc(
zQ5-YzCFTrlm~i2l*u=Lc3bGl*LwaTy=a-0&RQP}J=HH^MZfcYK78?s+HgeUq8r#%yH0XOXy{1_
zm!p3o2qdOUrTG%+kf7f!0{fA~L5$!4_1~f24l#_#
z{Sz3bK81_glQc6)UqRnQ_9et`)agTp+N7K`F-Cn;Z9o>|G&pX<0EUSiyddp&(ywVh>g0tsp#RqIJUZzY@1)>QSe1-edDxe^iL%2yhQR=?$8#DTy_inxl>z6?Kb4`1yG!Ii{
z7}&z@pJ2p)LA>u3_OMg&NS$yaP7UMMwnEJ_9MF0CpFnK))zIDo*`wFBX)i`hfMKe^
zbW!&H+})o4w)Xl_YCb)AX-(Q2+``cBh&{uw?8I4I^=hc}9VDXrh^7il8H=2.6.13
+
+ com.baomidou
+ mybatis-plus-boot-starter
+
com.bwie
el-data-source-common
@@ -72,6 +76,11 @@
spring-boot-starter-test
test
+
+ com.github.yulichang
+ mybatis-plus-join-boot-starter
+ 1.3.8
+
diff --git a/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/ElDataSourceServerApplication.java b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/ElDataSourceServerApplication.java
index 8d13b2f..2fbb12a 100644
--- a/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/ElDataSourceServerApplication.java
+++ b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/ElDataSourceServerApplication.java
@@ -1,9 +1,11 @@
package com.etl.data.source.server;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
+@MapperScan("com.etl.data.source.server.mapper")
public class ElDataSourceServerApplication {
public static void main(String[] args) {
diff --git a/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DataSheetController.java b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DataSheetController.java
new file mode 100644
index 0000000..a55991f
--- /dev/null
+++ b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DataSheetController.java
@@ -0,0 +1,19 @@
+package com.etl.data.source.server.controller;
+
+import com.etl.data.source.server.service.DataSheetService;
+import io.swagger.annotations.Api;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @ClassName DataSheetController
+ * @Description 描述
+ * @Author ZeZhang.Liu
+ * @Date 2024/6/25 20:35
+ */
+@RestController
+@Api(tags = "节点操作")
+public class DataSheetController {
+ @Autowired
+ private DataSheetService dataSheetService;
+}
diff --git a/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DataSourceController.java b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DataSourceController.java
new file mode 100644
index 0000000..a79fb5f
--- /dev/null
+++ b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DataSourceController.java
@@ -0,0 +1,55 @@
+package com.etl.data.source.server.controller;
+
+import com.etl.data.source.common.pojo.DataSource;
+import com.etl.data.source.common.pojo.req.DataSourceReq;
+import com.etl.data.source.common.pojo.until.R;
+import com.etl.data.source.server.service.DataSourceService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+
+/**
+ * @ClassName DataSourceController
+ * @Description 描述
+ * @Author ZeZhang.Liu
+ * @Date 2024/6/25 14:29
+ */
+@RestController
+@Api(tags = "数据源操作")
+public class DataSourceController {
+ @Autowired
+ private DataSourceService databaseService;
+
+ @PostMapping("/findDataSource")
+ @ApiOperation(value = "查询数据源")
+ public R findDateSource(@RequestBody @Valid DataSourceReq dataSourceReq) {
+ return databaseService.findDateSource(dataSourceReq);
+ }
+
+ @PostMapping("/addMysqlDataSource")
+ @ApiOperation(value = "添加数据源")
+ public R addMysqlDataSource(@RequestBody @Valid DataSource dataSource) {
+ return databaseService.addMysqlDataSource(dataSource);
+ }
+
+ @PutMapping("/updateMysqlDataSource")
+ @ApiOperation(value = "修改数据源")
+ public R updateMysqlDataSource(@RequestBody @Valid DataSource dataSource) {
+ return databaseService.updateMysqlDataSource(dataSource);
+ }
+
+ @DeleteMapping("deleteMysqlDataSource")
+ @ApiOperation(value = "删除数据源")
+ public R deleteMysqlDataSource(@RequestParam("id") Long id) {
+ return databaseService.deleteMysqlDataSource(id);
+ }
+
+ @GetMapping("/findDataSourceType")
+ @ApiOperation(value = "查询数据源类型")
+ public R findDataSourceType() {
+ return databaseService.findDataSourceType();
+ }
+}
diff --git a/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DatabaseController.java b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DatabaseController.java
index 9d1fe4d..9e0ab85 100644
--- a/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DatabaseController.java
+++ b/etl-data-source/el-data-source-server/src/main/java/com/etl/data/source/server/controller/DatabaseController.java
@@ -10,9 +10,8 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
@@ -21,14 +20,14 @@ import java.util.Map;
// 声明为一个 Spring Boot 控制器
@RestController
-@Api(tags = "数据源")
+@Api(tags = "数据源连接")
@Slf4j
public class DatabaseController {
@Autowired
private DatabaseService databaseService;
-
@PostMapping("/testDatabaseRedis")
@ApiOperation(value = "测试redis连接")
+ @Limit(key = "testDatabaseRedis", permitsPerSecond = 1, timeout = 500, msg = "当前排队人数较多,请稍后再试!")
public Result