ÿØÿà JFIF 

  
 
  ÿÛ „ 
 !.%+&8&+/1555$;@;4?.451
4,$,44444444444414444444444444444444444444444444444444ÿÀ  á á
" 

ÿÄ   



           
 ÿÄ ? 
    
 !1AQaq"2‘¡±ÁðBRbrÑá#‚’¢²3S CñÿÄ 
 

             
ÿÄ ! 
 
 
       
!1QAa‘2ÿÚ 
  ? 5˜Z¯V¦cø)›t/? z¨±>Õ5€¶‹Á¤·¼z¼Ü¬+ñ®v¤¨_ˆR­BFn©—˜ý®ç̝P8gýt·ÉSTŦˆìät?þé¼íìN/Þa)ì–í6ô…
Ï¿øÃj´¿KÇü]ÿ ªô¹-eKànëÕHTx}ýSÜ›ÿ ”7Ø×&µ<¦  ¥ÑO¶[Ù¯ä¨ÞÃÿ PZ-¬;#õ|•
oaÿ ©CìÞz3˜öː/¤­ñTûIØ}š^   mÓ%ªxˆ¥ÉŸu=Z+ISe¿45™¼u;ú&WØ÷€æßQ™®{|
íx*TC“#ZŠìZ§²‹ 6pv…³¿¡äª*áZÐ%ÒOáˆo"x«OHk
w±æ+¬V(kMúŸ5Vö«$ ÁrÏbàb57/luR ¸ÑÛj Òµì`Ðœq­û žICÀ
Ê•©4€Âcà¨Ï€O´<èÐ:›ù(Ë^L8þ‘ÍÌ#¸Ð_Ì©ÙK(Öz 4¬û+¸;ü’V’84‘¬ÃŽ:[â‡ÔÌáõp¢~§ªlæ£ö{®G>J¼"°‡7¯ÆÉèßû ‹É‹§ÁòÃýâßî
^ƾÙõ‹×óH#«LP½ïX=xÑÍ$|W?•~•îëÔ©ª‹
{ÝT…Kÿ ”hûâá)J*ö˜–ÔU;iÇ€/ ÆþjóZ\ýwØ=Ìm
ºèËL9 ýè
Æð/¨’¥öo=nË.%Îì   ŽÕ¯È|{Oj²ƒE6e/ßdÄõ²Ìâ1O®ò×TsəԸhOMýíMˆ¿¼H˜l²,7Â¥#MF/Úf°Ö½± ¸–dr‹NýÊ íjqx{œÉ ä-È    ¦
øÄër¨q°ð
†nцýÑÄÆ’mä…n<0È™;ÁÝá¯ÁZƒ7FÀmì­ É&9ˆîéi¶ùN§Y•ÃZãAâ?•‡©‰ , ó¾IŸŠc1 4â&y­&pŠ­6;M À 0¹qç»p.á …ŸÅáK@<u %Ü6ÓtIÌpÓr»söfeÁ0O…­´Kƒ&ñ™\©<+,~)‹
ºHÐ*×µ&†ž‘Æ÷ÚŸ
1ßjC5Oh´‡›

Ø×ë æâ“Þà

ÒT]§n{ºöB³ ¦ ̹Â8Êï¦MÉ<„¨s¹¶ì7Ì”æR$Ncà! /éþäRM÷Gƒ¿É$
¦oà>%6·y6ƒ‰3?”úºŽ‰éX5ªPT §µ!=Mž«Ú½‹ÅgÂSâÉaþÓoö–¯ÁÔìR>5éÿ üs¶ÆUcÌ  kÇR
]ÿ ù¬¼«VŽ;Â|‡~¢¦”ÏÅ°æ
{L™Õ°Óv¹ò¸írŽ¡×¢CÃ!íVÕ {¶»sŒNPg/
"uÕbkm²“$ďå¿é¹§°½æz¯6 †s¿!s–wÚÝ“™Œ°.ûj>·+™Òa…©Œ&rÝÎtÛë긪Ît’LAVp%c Úý[ÄzJ¾ÇàXXç@˜ó<êL]·T˜¾¥1Ó©V‡g´æ½¦Ý@¹óø!_@´ÞâSÁ —S3™•& ]@JHÚý©ZŽ €×æÔr»Áf!‡yÞ4Mv*èÓã_{‘åóUuљØ«Oïé*®EvÑ
Œ÷‡U \"㪒ÍK+À 4“M¡ï:0¥5í!'<@î´”>Ç»&Z–ïCCV˜Ì5Šo&îhè.žû
|ÓK©h$s6KìŒëã)¹hI¦GïOåóI;ììü#É$Š0…Ææ¥TØ.5­¾gn´ “ÂÖ\:hœ89G)J@„}œ:’Ò{/Š"¦_Æ×7Æ3VÇŠÊa]ÚŒÙ€Ä–=®uÁßâACZƒ§§£Qnâ:«,×{tyø¬iÛcœÜÄ€H½ÄÍCk´÷šß
.W'b¤Íåh]÷€=,Žv×cÚEÚHXJX¶îo¨FÒtèöŸ>ªª6[J®Fµ£sGÁeqõfe\íjÒÐïÄÐGˆe1Ø‹.Ø”‘Ëuø
Y­ˆÜŽG|zùªüMpDnQWÄ”%JŠ™)â*p@Örš«ÕT2Ð%ˆG#ª„
·¤!°ŸOTÂT¸aÚ%4&h™LµšØüÐ.F¿²ÐÞ_Ç‚¾ÅÃaÜ÷09Æ 
q€öy˜v‡85õN÷]¬äѼóS{°_MŽ¬úÔ#°Ç¸0åÞè2ëôPcvÆw9®ií1Ä8F™˜à‰´+‰Ik1òÝ7“Ñ×ÒsÝ\x‚h`ÞÑ`ó"|µEcý£n˜h`}GÞ  !±ù²Ápü²
ß6
0ïi󜵩SÈÇ7˜-ÕURO˜¦´f$ªž-Í6(œ}<„ éc øs]ŽŽ„*—¾
ìdŽ„)méª\¿êÎIg¾ØÞ~I#C/¼¼´EÁÈŽi8“©õådô·>euä ƒ'Ê×लR1ÉJE1ÐAát`t;ÇР%Ý<‡¥„ÍÆ`×Oyó)õiI€ñQaŸ4Ûù\áàaÃÔ¹HÃu¹*k€¦<„eS‡&õÏ
B!ŽhüÞ`yj}mªf×\¿
Ç~æ­9‡û\՞Ǖg²1Žû5V7 !àöšm°
c`ܬøÇìµÒ'P"?…´Ö,"§^•õŽ¨sÔ)6˜sæéÍR¼
ò|Sl”‹7 nPW

Gòú÷½§O¯‡„l¡kSÞŒr½PÊ@æ¢pŽ-mÿ #Ÿ˜Àº¶Áä¦;ïÔæ$1££`“Õ>„—·ž)ß
ð
³ñ#Ï Ô$¶œ‰ÊE‹À;÷º
¯«P:Ñ”8–IÊtpÞ3ª“>ê“þës4ò2OÏÕ­±zô†Õ§‰.÷ä¸;¿˜“'œ›žª}«Œ{ª±Ì 9ÔóÞÕ‡0
$íWV3Üì¬
—@kÝ4@¿r¼±½¬™›?øØæ´'Áé®CË3-g$˜ö‡×auÚi´Žp/êÛæF›Ú2v‹ã¿¿,nB1̨ƃqÞa5͝@&Æû“él÷ \C²½UÍc ¯k×¢U
ÖéQå™—-r    wô ÞÏ<Ò=&=ÿ Ôê Òêˈt,i—;LîÜ á¸*ÚÃ1$êL•LÍ <É)ýÐà’
;F™{ƒ™˜€&'}‚ãÄK`¡ÞT@I;®žZóè‚s’7®°›+§O­Åq©é»²9<Ô
J ¼9O’HL»Ùïì¸rk¼Ž_ý‘TŸu[²ßÚŒ·ü÷B%¯E ŸÔX5êO´Ç•€’I0 É<mÆÈJoúáõóQâØòÙaÙt:  ·=|Ôaz]a1cÉŸ1
4˜à3΍}GFøí7/B«vεŕL=Ðr1ÕšnwH›óÞ¢ºö{)´4€æZç^ÿ yÑ:_([¿ipqQÊ^âÆe;»½“¦º|¢ÀTçèrú1”óTÃ’u¦CG¤ ¡
Š­7ë

·i“¿z»n
ö¼±ù^ö<‹çu7¸ÈlvZðÛAUXje•
dLÞH ÚosÇr`È™‡pÊeÇ4@x7´)ö†Ótœ~i‘Ï[x@äUÃæ­m·e´x
°t¸·²5'žªža   =ÖÌåzϘ'-´ˆpž3§ò‡k  Ý'‰ýÑï¦3ºdè“{eiÔõNkîšECEΠ¥ÃT9ãqÃâŸîɐ8z \?€    >JX` 
ñ¹õ%;µŸD‘«´€àwÒ™UûئžÖö\×®×´8 ½‡ºÐÆÓ§?Àkmœ=;d5*@-ì0F Rªýš[Ü6âö̃ڸr*KA9· u*µæ£?U¸Âêí†8@¦X4 e-ò„0s{ HâUpU?¼mñRa°®a%Ð'tÉ×’\¾ÊÉ]t›h>·(Ë@R¼¡Ãt h}’O÷au<+nT…Ö…MӐ??Óe95 q>í/;&JSû °¯ÊéÞøƒ*Ã2½Ài&:nôUl=¾¿5eˆ3”ñc|Ú2V”>„»&eE;«ÚäC
p¢Ûúy 9š[ŒÌx¼擼A&DåÒ¯ˆ¤ÀÌ;"˜ÏQä¸åhÊ}Ûq«Û0WžÒ|»€ø®öCm5•\ÇÀ§Pe3£]0ÃàLDÉ‰1øªxjgwT‚÷¿LΨK‹›ùs—xˆÜ±µ
kæ¸f‰‰ÜGk/LÛØ6d9ò¶ùA{ƒA3š/¬D¬khÓk‰`˜"㯒r¿±Óã jx‡°e}<Ñø\3y:'À•/h½Í€Ç4~g ?Û(¼]v‘ªlKÎâ~?O‚W%{Ì:“'©úNq¾›úo(X’¥¯ˆ
nFê{Ç€ü?º'ë
ø‹ì
Þ09ŒÌç9Æ —ËC`j@ÓÄ(+a‹un¸#ÂꟋ{K`‘ÑÍÍ'à´»/Û,KW;Þ4²þð ï Nm|~fGÏ(…³Ã)«1ö­Õ
¥‡¨©ƒÃ™ü-s=à=U66Ï«Ýc蓦W¹íž®›nÔ%êÇìŒ<#Ü×84ån®Ð ÒåOC`  ñânÑs‡¢ç 1õ%Îhì½Ã½® e:ݼUZo
™`  
ÅZŸŒÊ«ê1ÏÄo$q¹Þ€©ˆhÐÉä¯ñ[!…Ú˜àJ:x2$Íß&PåT£6ç—
‡Í*4Ýšçjÿ ‰É nófÐ ó(L5C•åÆ\rMÒ@ò
}y-W}™üýVù—ú¢=Ù”c®‘< M ž
´Phr¦©TD ‘ù.$´÷O‡‘V2Æò.=IUŒ=ž‡â¬i™aþÓåÙ?òUø'ØÖ•.~* šTŒ!•-×áºTâ®ä#õü'´ eýlYÅÓeÕKÂrT"CÚ@u!Óxƒ{š3€}1¿(r}%«nËamjÑ%ÑNEò
v  ˜à  σöK³,*º.àzù¨™Ó ÚçâU¦*¿ 9{%Ö¹ njûdaXöb)  kÛƱûÓ\°M7ˆÂ=û›ç¿Ã‚­V»Cg–8ÙêE-j)k$º`Ã-ùEýeBÆÇ]c¡°ñty&Òd0nõ'¡W+ƒ*|–ø<K\%¦cÏÄ#N,Úú‘¤òÒÛõ ’¶§‰Ì
ú•dçb31Ð\7‡ëÚw82
‰KÝkÚñ'¢Ž…[&¼ÌAÔzHàP *اoßreÁY¥Ñ¾ãE|&QbKg]ã„þê*b;R³Öi‹  ±î$£ÈTm¶k÷ˆ
¦»Ù¹i¦¨6 h%Á'Ú
J   \F±â+‹b/Å9ñå5Àë­nˆRv«¯#„&î„$º’@:‘Ôrø+,àq‘秬*Úg´>µFa\GQªEAÔp5\Ǽ·¼Ç8·õ -â§Ú[
‡
uZeÖ 3}×d'+¹:ð+K†Û®s!Ï$úe€<Û”x)1»a­¡LC]¸µík…ÚàA»AYº{†ªS[¦5HÒ7ù
--,ísòDØ€èk   ÞÀîÜò@â(  ËNˆë›4ô½•/¦o‡€Û7
ê•ÆêòðÜy
'Án½µ á˜ݦ  ndeo…[ì¶Ê,¥R³Ä=À±—–ß;£™´ñSâ*g§”ïaið‘Jå~™ÓÞß³Õ¢»8x埒²52>AÊb&-÷\7´éÄù€T˜,w;3{ï˜k…à¹ÄqÀ«œ{
€\
ˆ¾[´¨јr &Úé„Ívˆ±8†¿]|¬ņ4I×pÞS1ÈÖz‰#Ìv‡G!YNògñ:màTz¢Ý1ô©^O=~ë|5Bã™ç•¼µõ•bÆ@úÕS¬ÈŒ#¬zünrŸ
û”
Z²•ï›èðV"ÁHÚý©wÝ €7¼Ìu1hÑa3Éä û f$o¿É ™Ú›ÝçnpÒ3äÌ3†Í§,Äï]$‰/pê†«À¼
¸e9­Æê_C]žƒ·ý·frÁN«,E=›Çq
-‰öŒ:aÏ¿±í&£Í:-}
84‘ÿ eƒQÑeëSsuiA
³g㟥ú£?ÿ ʼn*”“÷aühe:ÊWa@ÒÞk±eØ]
F Ô—r.åä˜@ö¥ªZoÐýYL·¥S²G/‡ñ
<~*ZÆ´è>JlòàÛƽÿ 窘ìGN¢:I®KšJp/`íIÁÀõ#Ä-€ö­šµŒoF4|ÆQØÆ@Ì|£Ô…¢À{9˜è½Üó›€ôYÒÎYsið;ís¤€à²ˆ‚4qÉVŒI$  ‰"°   æµ8cXGjœˏ¡Aâý•ËÜ¢ûïe·çLx']á"oÅÎê3¯Ç—¹”ó0nå‚âg{Œñ>
S´˜îè°g238‚ãköÝfÚd´6Ò€;ò÷±¢™¼›º¢Æ'¥Ðx'e¬ç
]bÈÆV¢ó‹kýBO
ðÊâ$Ÿ!×T
3Mýמ
žìٍàÌü‘8÷€àæØ8æ©6‰©L´«…oãpð„~Çk‰!ñ;‹”ÛžÍ àž±z Ÿôû øŸÝužÏ;ÿ #|u6™Þ¬ÚˆÐõA4¶â|ôl|Ê2ŽÇ¤ÝÅÇY.<#Aí.k§hóF‚”Y;
M½Ö4hŸ4&›­¿tès´%FìL¥£Ãk‰ÇT¤haÁ¤ÚxfÉ`ÑìË›>i 3t‚:,–+^÷´–{Û–Nxi"x‘Ûg
î¨>¥Õ܁ùZH,2Û“:8xÊ¢Çí9.É-Ìâã-=çjwµS˜dütžçwýGòú®®ûº_ˆýx$–¡ãøO
EÚÛÏ÷R„×w+3£Á£öUMyR²¹âŒ°š›¸Ñãò9§Ó_Dl+Ùßc›úšGÅÌc†Ž!Ko=¶.‘Îÿ c²(2®V mª.ÿ ¹B›¹å ù„öŸSV>™ü¯$y:G¢Z×àøúdî¹û­·ýÇ´:•c LÍõi_‹ö+ÎæGÊè>OŠ•äž´§Þ{X}¨1ÚTc›»Qþ•êô°t¿OP?eæ~É{5]•ÙR£r5†nZ\ã@
&îJõ ¾àC°þV>fé¥/ü5ñÊIº_é5;e­h<@
Ä&æÃëE%;X,ÒãÆÞ`Oò¦kŸm#˜!ÀyÄ¢|
óLšò¥Ä`
¶R=|ÈCâh5ò3DˆïF†ðÒ#ÅìÛœ?¸yhBãœí
ZxßÎÄhºRK„`Þödvײ™ÀÈÑÒgŒuYw³%†ƒÓzõ ÖÏp‚dH®¦A´ù§»ÓÇMæ~)ˆð‡û:ù&Ä •vGD´À 
n
Ý
‡¼Ö8Fö   óáà£~Ë¥x`oK|Ä?fxiØü%pìR>éò+Û±éÎ>núlFŤ'tq8LZÏvÃ?„¡ß±È⽆¯³íü@x|PöUäèØã¡ð‚ŒAìÏ"vÍwóŸÍ{ ý0.z    È•Ö{,N¡£¡ŸKÕÙž>Ýœþ ÍÀ<n^Àïe€Þgn¹”ÜiQê
9Ú±‡„è]ËA¿‚MJìiÓxŒn-ÄS6!ÓæÑû*jÎWøìšÇ뙦gj~+?\,Ö7ÁÕÊ”G™q6TF)óCç<ÓšÂUé†gW=àà“hóR³ÊQì<!÷ÇpR1¯u„De,è­vvâDß~žHå‰ú£Kìní¢ÐçÅÄÅ¥Ü÷
±ÃìÇžûƒz\þÞ¨-•‹
€

¸+¶n¿^
?†[ÖWóÒX¸,0Ø:l?‰Âý«ÿ ·Dc+fÔ[ƒ›ûªšx«kæž1KI…<#'nž¶\±íÎ8¤ìK@’@J¥v)º[Ž±Æå´¼
½Ý¡ç¯ÐO¥ø®è•Óȱ߿wša©“œt‡4îyªœ&+1ÏØ:‚æƒ=/ꎔ`hm
“=©‹]°g}ì€DgUƒ8¤qCˆãáÅ,‡Ô¬ñ10HÑDÂbáÂÿ Œ»v·:uòB6»áp‰>°<×EA!Å‚D™IúOÍ
¡>ôG}Â`ÍßkÜL™Ž  Þð™
{IøF²
¹òQ3&!ÃÂÞz.d&Ï-sH¸,Ôõ˜ŽP€
77ˆÝ¼ÊëÜw   =cÕ
Ú,ØÐ5ÎYÐ)ì´öœgŒ[¤
ßv㙑8心>h]§µháYš£²ºÑ.{Ï7Sð•?´~×SÃKýJÛ˜
™Íäiúu<µX¶1õ^kâçIÑ£sZ4h>j*ÔšD:4­¿_ ÷¸
Õxæÿ ¸?Mù _•­ÊÐ ä ÷ý ÑwL
œ­ïnTkÛUÍN©ë:¦fV ¶ÜÔÜMªÅâA½–¿R×TXš-%iTÊT•‡Ù‚JôϐZxWÑè‰f‰òG º
×Õû2aZ7OU3[“×AT–ÞŒ…-‘¤”Ì 
ì&(ˆ¿­•ƒkï’:ðY¦W‘Å)“†‘˜³Åtcø˜ñTÂwÚÇ4
|üLÇªí–v-
qˆèU
qPE.†â‘˜µ Æ,ÐÅs]8¾„oúÑ i>ÜxxÈó)ƒ ´æÁâØ$À‰vžŸf$Ž|ãw;ÀÁIJ»b`
{¦Ó¤Ú$©YÀ‘n@Óïž«9J¼êG   m¤
ܯ¹ÌW4€ÐÒÅÛ‡#褕Ÿn-?í|с¥÷Ú¹¬'´ÞÜ9ÓK`hê£SÄSà?7—Wí_´…óB›»:=Ãïq`<8ñÓŒÑlú2d¬ê³£hÖ[l|$vÝro~'R®‰§°ñmY ͧäP
|PUª¹·:3Œ[Û{Xÿ ºâ@‚W–Äé u‚ ¯´*=íή.pûÒdt @
G‰¬ s¸    ëÉücr ÞæѨÊ@>¤¢Ö±.Þ'¯°ÌME[YéïĵÂCå½
Ué©Áû'Ê9%eÔðNU”ë‘ÌsD3/®+UI˜9h.WC”
빓$#:pz:YÓ ¿xž* ³$Í +$kñAŠ‹†¢
Uê>¸)_š¬÷©ßAÂÔb9ÇU ¯¾
á•9¯ÏÏ÷O÷¼¼Fähal1‰3Ì[Ïr•´UCksNÐ]R‘¸¥H+§Šé†c©vÖÞ0iÓ76s†î!§=ß
¼~Ô'°Ãmäoäš³ªøi1úÉ)³yV8CLÄØÁ‘WYïi€H6ÖÑiámø^ÈY´°Ñ7¥Û*—Ñ©L«Qƒï—Ùrÿ ›£Ð*š¸ˆL©ˆ$ˆ ÷¾D§9È®«qbqC)–ˆïv´çñsÑVT­Ø, <àïºÀO«Jý·õ 
àfPìð  .wFšir´þ’2_Y
*Æ€x\«
ì€9š@ Ž|F⇥ˆkZ@hÖÄ0t¿-<“‹qµ¾*ZL¤Ú)&BJpÓF5=$„at*Zš$’ÑtdûÝRI1    2Ž‰$€$I$#‰SÞ’H
ë¬ï;Á$¡t$’`<(ñÇt)$‡Ð.Êf¢X’Kt=Éé$‚ˆªè¢oÝëòI%Rgcª÷ŠyI%¡‰ÿ !ñ)´õ $¤ Ô’IIGÿÙ�

�j�l����dZd
dl
Z
d
dlZd
dlmZ
d
dlmZmZmZm	Z	
d
dl
Zd
dlZ
d
dlmZmZmZmZmZmZmZmZmZmZmZmZmZ
d
dlmZ
Gd�de�ZGd	�d
�ZGd�de�Z y)
z�HeatWave ML model utilities for MySQL Connector/Python.

Provides classes to manage training, prediction, scoring, and explanations
via MySQL HeatWave stored procedures.
�N)
�Enum)�Any�Dict�Optional�Union)
�VAR_NAME_SPACE�atomic_transaction�
convert_to_df�execute_sql�format_value_sql�get_random_name�
source_schema�sql_response_to_df�sql_table_from_df�sql_table_to_df�table_exists�temporary_sql_tables�
validate_name)
�MySQLConnectionAbstractc�P�eZ
dZd
ZdZdZdZdZdZdZ	dZ
ed	ee
dfd
e
fd��Zy)
�ML_TASKz/Enumeration of supported ML tasks for HeatWave.�classification�
regression�forecasting�anomaly_detection�log_anomaly_detection�recommendation�topic_modeling�task�returnc
�>�t
|t�r|S|jS)
a'

        Return the string representation of a machine learning task.

        Args:
            task (Union[str, ML_TASK]): The task to convert.
                Accepts either a task enum member (ML_TASK) or a string.

        Returns:
            str: The string value of the ML task.
        )�
isinstance�str�value)
rs
 �B/opt/nydus/tmp/pip-target-mjwu0ny1/lib/python/mysql/ai/ml/model.py�get_task_stringzML_TASK.get_task_stringGs���d�C� ��K��z�z��N)�__name__�
__module__�__qualname__�__doc__�CLASSIFICATION�
REGRESSION�FORECASTING�ANOMALY_DETECTION�LOG_ANOMALY_DETECTION�RECOMMENDATION�TOPIC_MODELING�staticmethodrr#r&�r'r%rr<sS��9�%�N��J��K�+��3��%�N�%�N���e�C��N�3�����r'rc
�H
�eZ
dZd
Zej
dfdedeeefde	efd�Z
defd�Zdede	e
fd	�Zde	e
fd
�Zdedefd�Zdd�Zdefd
�Zde
fd�Zdede	ede	e
ddfd�Zdedede	e
ddfd�Zdededede	e
def
d�Zdedede	e
dej2fd�Zy)�_MyModelCommona8
    Common utilities and workflow for MySQL HeatWave ML models.

    This class handles model lifecycle steps such as loading, fitting, scoring,
    making predictions, and explaining models or predictions. Not intended for
    direct instantiation, but as a superclass for heatwave model wrappers.

    Attributes:
        db_connection: MySQL connector database connection.
        task: ML task, e.g., "classification" or "regression".
        model_name: Identifier of model in MySQL.
        schema_name: Database schema used for operations and temp tables.
    N�
db_connectionr�
model_namec��
�|
|_tj|�
|_t	|
�
|_t
|j�
5}t|d
�
ddd�
|�t|j�
}t�d|��|_|j�d�|_||_
t|�

t
|j�
5}t|d|j�d�|f
��
ddd�
y#1s
w
Y

��xYw
#1s
w
Y

yxYw
)a�
        Instantiate _MyMLModelCommon.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-train.html
                A full list of supported tasks can be found under "Common ML_TRAIN Options"

        Args:
            db_connection: MySQL database connection.
            task: ML task type (default: "classification").
            model_name: Name to register the model within MySQL (default: None).

        Raises:
            ValueError: If the schema name is not valid
            DatabaseError:
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Returns:
            None
        z(CALL sys.ML_CREATE_OR_UPGRADE_CATALOG();N�
.z.scorezSET @z = %s;�
�params)r7rr&rr�schema_namer	rr
�_is_model_name_availabler�	model_var�model_var_scorer8r)�selfr7rr8�cursors     r%�__init__z_MyModelCommon.__init__is���6+����+�+�D�1��	�(��7���
�� 2� 2�
3�v��� J�K�4���(��)F�)F�G�J�*�+�1�Z�L�9���"&�.�.�!1��8���$����j�!�
�� 2� 2�
3�v���%����'7�v� >�
�}�U�4�
3�4�
3��4�
3�s�
C%�>C1�%C.�1C:r c
���|j
�}
d
|
�d�}d|�d|j��}t|j�
5}t	||�
|j
dkDcddd�
S#1s
w
Y

yxYw
)a%

        Deletes the model from the model catalog if present

        Raises:
            DatabaseError:
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Returns:
            Whether the model was deleted
        �
ML_SCHEMA_�.MODEL_CATALOGzDELETE FROM � WHERE model_handle = @rN)�	_get_userr?r	r7r�rowcount)rA�current_user�qualified_model_catalog�delete_modelrBs     r%�
_delete_modelz_MyModelCommon._delete_model�su���~�~�'��$.�|�n�N�"K���2�3�
4%�%)�^�^�$4�

6�	�
 �� 2� 2�
3�v����-��?�?�Q�&�4�
3�
3�s�A#�#A,c	�
�d
tdtfd�}|j�}d|�d�}d|�d�}t|j�
5}t	|||
f
��
t|�
}|jrd	}nS|jd
��
}	tj|	�
d}
|
j�D��cic]\}}|||�
��}}}|cd	d	d	�
Sc
c}}w#1s
w
Y

y	xYw
)
a�

        Retrieves the model info from the model_catalog

        Args:
            model_var: The model alias to retrieve

        Returns:
            The model info from the model_catalog (None if the model is not present in the catalog)

        Raises:
            DatabaseError:
                If a database connection issue occurs.
                If an operational error occurs during execution.
        �elemr c
��t
|t�r	tj|�
}|S|S#tj$r
Y|SwxYw
�
N)r"r#�json�loads�JSONDecodeError)
rOs
 r%�process_colz3_MyModelCommon._get_model_info.<locals>.process_col�sI���$��$���:�:�d�+�D��K�4�K���+�+�
���K�
�s�+�A�

ArErF�SELECT * FROM z WHERE model_handle = %sr;N�records)
�orientr)rrHr	r7rr�empty�to_jsonrRrS�items)
rAr8rUrJrK�model_existsrB�
model_info_df�result�unprocessed_result�unprocessed_result_json�keyrOs
             r%�_get_model_infoz_MyModelCommon._get_model_info�s��� 	�c�	�c�	��~�~�'��$.�|�n�N�"K���4�5�5M�N�	� �� 2� 2�
3�v����j�]�C�.�v�6�M��"�"���%2�%:�%:�)�%:�%L�"�*.�*�*�5G�*H��*K�'�&=�%B�%B�%D��%D�	��T���T�*�*�%D���
�4�
3���4�
3�s�A'C�)C
�<C�
C�Cc
�8�|j
|j�
S)
a�

        Checks if the model name is available.
        Model info is present in the catalog only if the model was previously fitted.

        Returns:
            True if the model name is not part of the model catalog

        Raises:
            DatabaseError:
                If a database connection issue occurs.
                If an operational error occurs during execution.
        )rbr8)
rAs
 r%�get_model_infoz_MyModelCommon.get_model_info�s���#�#�D�O�O�4�4r'c�(�|j
|
�
d
uS)a1

        Checks if the model name is available

        Returns:
            True if the model name is not part of the model catalog

        Raises:
            DatabaseError:
                If a database connection issue occurs.
                If an operational error occurs during execution.
        N)
rb)rAr8s  r%r>z'_MyModelCommon._is_model_name_available�s���#�#�J�/�4�7�7r'c
��t
|j�
5}
d
|j�d�}t|
|�
ddd�
y#1s
w
Y

yxYw
)a
        Loads the model specified by `self.model_name` into MySQL.
        After loading, the model is ready to handle ML operations.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-model-load.html

        Raises:
            DatabaseError:
                If the model is not initialized, i.e., fit or import has not been called
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Returns:
            None
        zCALL sys.ML_MODEL_LOAD(@z, NULL);N)r	r7r?r)rArB�load_model_querys   r%�_load_modelz_MyModelCommon._load_model�s?��" �� 2� 2�
3�v�!9�$�.�.�9I��R���� 0�1�4�
3�
3�s	�<�Ac
���t
|j�
5}
|
jd
�

|
j�dj	d�
d}t|�
cddd�
S#1s
w
Y

yxYw
)a�

        Fetch the current database user (without host).

        Returns:
            The username string associated with the connection.

        Raises:
            DatabaseError:
                If a database connection issue occurs.
                If an operational error occurs during execution.
            ValueError: If the user name includes unsupported characters
        zSELECT CURRENT_USER()r�
@N)r	r7�execute�fetchone�splitr)rArBrJs   r%rHz_MyModelCommon._get_user
sV�� �� 2� 2�
3�v��N�N�2�3�!�?�?�,�Q�/�5�5�c�:�1�=�L� ��.�	4�
3�
3�s�A
A!�!A*c
�
�|j
�
t|j�
5}
|j�}d
|�d�}d|�d|j��}t|
|�
t
|
�
}|jdcddd�
S#1s
w
Y

yxYw
)a�
        Get model explanations, such as detailed feature importances.

        Returns:
            dict: Feature importances and model explainability data.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-model-explanations.html

        Raises:
            DatabaseError:
                If the model is not initialized, i.e., fit or import has not been called
                If a database connection issue occurs.
                If an operational error occurs during execution.
            ValueError:
                If the model does not exist in the model catalog.
                Should only occur if model was not fitted or was deleted.
        rErFzSELECT model_explanation FROM rG�rrN)rhr	r7rHr?rr�iloc)rArBrJrK�
explain_query�dfs      r%�
explain_modelz_MyModelCommon.explain_model#
s���&	
����
�� 2� 2�
3�v��>�>�+�L�(2�<�.��&O�#�0�1H�0I�
J
)�)-���(8�
:�
�

��
�.�#�F�+�B��7�7�4�=�4�
3�
3�s�AA>�>B�
table_name�target_column_name�optionsc�
�t
|
�

|�t
|�

d|�d�}nd}|�i}tj|�
}|j|d<|j	�
t|j�
5}t|�
\}}t|d|j�d|
�d|�d|�d	|j�d
�|��
d
d
d
�
y
#1s
w
Y

y
xYw
)a2
        Fit an ML model using a referenced SQL table and target column.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-train.html
                A full list of supported options can be found under "Common ML_TRAIN Options"

        Args:
            table_name: Name of the training data table.
            target_column_name: Name of the target/label column.
            options: Additional fit/config options (may override defaults).

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported.
                If a database connection issue occurs.
                If an operational error occurs during execution.
            ValueError: If the table or target_column name is not valid

        Returns:
            None
        N�
'�NULLrzCALL sys.ML_TRAIN('r:�', �, z, @�
)r;)r�copy�deepcopyrrMr	r7rrr=r?)rArtrurv�target_col_stringrB�placeholders�
parameterss        r%�_fitz_MyModelCommon._fitE
s���8	�j�!��)��,�-�"#�$6�#7�q� 9�� &���?��G��-�-��(���)�)��������
�� 2� 2�
3�v�'7��'@�$�L�*���
��(�(�)��:�,�c�(�)��#�n�
%����'���"�
�4�
3�
3�s
�/A
B9�9C�output_table_namec�>
�t
|
�

t
|�

|j�
t|j�
5}t	|�
\}}t|d
|j�d|
�d|j�d|j�d|�d|�d�
|��
ddd�
y#1s
w
Y

yxYw
)	a�
        Predict on a given data table and write results to an output table.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-predict-table.html
                A full list of supported options can be found under "ML_PREDICT_TABLE Options"

        Args:
            table_name: Name of the SQL table with input data.
            output_table_name: Name for the SQL output table to contain predictions.
            options: Optional prediction options.

        Returns:
            None

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported,
                or if the model is not initialized, i.e., fit or import has not
                been called
                If a database connection issue occurs.
                If an operational error occurs during execution.
            ValueError: If the table or output_table name is not valid
        zCALL sys.ML_PREDICT_TABLE('r:�', @�, 'rzr|r;N)rrhr	r7rrr=r?)rArtr�rvrBr�r�s       r%�_predictz_MyModelCommon._predict~
s���6	�j�!��'�(�����
�� 2� 2�
3�v�'7��'@�$�L�*���
��(�(�)��:�,�
7����'�
(��(�(�)��+<�*=�S�#�n���"�
�4�
3�
3�s�AB�B�metricc��
�t
|
�

t
|�

t
|�

|j�
t|j�
5}t	|�
\}}t|d
|j�d|
�d|�d|j�d|j�d|�d�
|g
|�
��
t|d	|j���
t|�
}|jd
cddd�
S#1s
w
Y

yxYw
)aI
        Evaluate model performance with a scoring metric.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-score.html
                A full list of supported options can be found under
                "Options for Recommendation Models" and
                "Options for Anomaly Detection Models"

        Args:
            table_name: Table with features and ground truth.
            target_column_name: Column of true target labels.
            metric: String name of the metric to compute.
            options: Optional dictionary of further scoring options.

        Returns:
            float: Computed score from the ML system.

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported,
                or if the model is not initialized, i.e., fit or import has not
                been called
                If a database connection issue occurs.
                If an operational error occurs during execution.
            ValueError: If the table or target_column name or metric is not valid
        zCALL sys.ML_SCORE('r:z', 'r�z, %s, @r{r|r;zSELECT @roN)rrhr	r7rrr=r?r@rrp)	rArtrur�rvrBr�r�rrs	         r%�_scorez_MyModelCommon._score�
s���D
	�j�!��(�)��f������
�� 2� 2�
3�v�'7��'@�$�L�*���
��(�(�)��:�,�
7�*�+�
,����'�(��,�,�-�R�#�n����,��,�

�
��(�4�+?�+?�*@� A�B�#�F�+�B��7�7�4�=�'4�
3�
3�s
�BC�Cc�
�t
|
�

t
|�

|�ddi
}|j�
t|j�
5}t	|�
\}}t|d|j�d|
�d|j�d|j�d|�d|�d	�
|�
�
t|d|j�d|���
t|�
}|cd
d
d
�
S#1s
w
Y

y
xYw
)a
        Produce explanations for model predictions on provided data.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-explain-table.html
                A full list of supported options can be found under "ML_EXPLAIN_TABLE Options"

        Args:
            table_name: Name of the SQL table with input data.
            output_table_name: Name for the SQL table to store explanations.
            options: Optional dictionary (default:
                {"prediction_explainer": "permutation_importance"}).

        Returns:
            DataFrame: Prediction explanations from the output SQL table.

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported,
                or if the model is not initialized, i.e., fit or import has not
                been called
                If a database connection issue occurs.
                If an operational error occurs during execution.
            ValueError: If the table or output_table name is not valid
        N�prediction_explainer�permutation_importancezCALL sys.ML_EXPLAIN_TABLE('r:r�r�rzr|r;rV)	rrhr	r7rrr=r?r)rArtr�rvrBr�r�rrs        r%�_explain_predictionsz#_MyModelCommon._explain_predictions�
s���8	�j�!��'�(��?�-�/G�H�G�����
�� 2� 2�
3�v�'7��'@�$�L�*���
��(�(�)��:�,�
7����'�
(��(�(�)��+<�*=�S�#�n���"�
�
��.��1A�1A�0B�!�DU�CV� W�X�#�F�+�B��#4�
3�
3�s
�A6C�C)r N)r(r)r*r+rr,rrr#rrC�boolrM�dictrbrdr>rhrHrsr�r��floatr��pd�	DataFramer�r4r'r%r6r6Zsr
���"%,�$:�$:�$(�	,V
�.�,V
��C��L�!�,V
��S�M�	,V
�\
'�t�'�0-�#�-�(�4�.�-�^

5����
5�8�3�8�4�8�2�*/�3�/�& !�t� !�D
7��7�%�S�M�7��$��	7�

�7�r
,��,�25�,�@H���,�	
�,�\
:!��:!� �:!��	:!�
�$��:!�
�
:!�x
5��5�25�5�@H���5�	���5r'r6c��
�eZ
dZd
Z	ddeejejfde	eejejfde	e
ddfd�Z	ddeejejfde	e
dejfd�Z	ddeejejfdeejejfd	e
de	e
def
d
�Z	ddeejejfdedejfd�Zy)
�MyModelz�
    Convenience class for managing the ML workflow using pandas DataFrames.

    Methods convert in-memory DataFrames into temp SQL tables before delegating to the
    _MyMLModelCommon routines, and automatically clean up temp resources.
    N�
X�
yrvr c�V�
�t
�
�
t
|�
c�
}t|j�
5}t|j�
5}|�mt	|t
j�r|jd}nt�
f
d��
}|�
jvrtd|�d��
�
�
j�}|||<|}nd
}�
}t||j|�\}	}
|j|j|
f�

|j|
||�
d
d
d
�
d
d
d
�
y
#1s
w
Y

�xYw
#1s
w
Y

y
xYw
)a�
        Fit a model using DataFrame inputs.

        If an 'id' column is defined in either dataframe, it will be used as the primary key.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-train.html
                A full list of supported options can be found under "Common ML_TRAIN Options"

        Args:
            X: Features DataFrame.
            y: (Optional) Target labels DataFrame or Series. If None, only X is used.
            options: Additional options to pass to training.

        Returns:
            None

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported.
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Notes:
            Combines X and y as necessary. Creates a temporary table in the schema for training,
            and deletes it afterward.
        Nrc
� �
�|�
jv
SrQ�
�columns��namer�s �r%�<lambda>zMyModel.fit.<locals>.<lambda>Us���T����%:r'zTarget column y with name z' already present in feature dataframe X)r
r	r7rr"r�r�r�r
�
ValueErrorr}rr=�appendr�)rAr�r�rvrB�temporary_tablesru�df_combined�final_df�
_rts `         r%�fitzMyModel.fit(s#
���B
�Q���q�!1��
�1�
�t�1�1�2�f� ��!3�!3�4�8H��}��a����.�)*���1��&�)8�:�*�&�&����2�$�4�5G�4H�
I
1�
1���
 �f�f�h��23��.�/�&��%)�"���-�f�d�6F�6F��Q�M�A�z��#�#�T�%5�%5�z�$B�C��I�I�j�"4�g�>�7
5�
3�2�4�4��
3�2�s$�D�B>D�D�D	�D�D(c�D���t
|
�
}
t�j�
5�t�j�
5}t	��j
|
�\}}|j
�j
|f�

t��fd
��
}|j
�j
|f�

�j|||�
t��j
|�}|djtj�
|d<|cddd�
cddd�
S#1s
w
Y

nxYw
	ddd�
y#1s
w
Y

yxYw
)a�
        Generate model predictions using DataFrame input.

        If an 'id' column is defined in either dataframe, it will be used as the primary key.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-predict-table.html
                A full list of supported options can be found under "ML_PREDICT_TABLE Options"

        Args:
            X: DataFrame containing prediction features (no labels).
            options: Additional prediction settings.

        Returns:
            DataFrame with prediction results as returned by HeatWave.

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported,
                or if the model is not initialized, i.e., fit or import has not
                been called
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Notes:
            Temporary SQL tables are created and deleted for input/output.
        c
�4��t
�
�j|�SrQ�rr=�rtrBrAs ��r%r�z!MyModel.predict.<locals>.<lambda>�����|��D�,�,�j�(�$r'�
ml_resultsN)
r
r	r7rrr=r�r
r�r�maprRrS)	rAr�rvr�r�rtr��predictionsrBs	`       @r%�predictzMyModel.predictjs����@

�!��
�
�t�1�1�2�f� ��!3�!3�4�8H�-�f�d�6F�6F�
�J�M�A�z��#�#�T�%5�%5�z�$B�C� /��!��

�#�#�T�%5�%5�7H�$I�J��M�M�*�&7��A�)�&�$�2B�2B�DU�V�K�)4�L�(A�(E�(E�d�j�j�(Q�K��%��%
5�4�
3�2�4�4��4�
3�2�2�s#�D�B4D�-	D�D		�D�Dr�c��
�
�t
�
�
t
|�
c�
}t|j�
5}t|j�
5}t	�
f
d
��
}�
j�}|||<|}	t
||j|	�\}
}|j|j|f�

|j||||�}|cddd�
cddd�
S#1s
w
Y

nxYw
	ddd�
y#1s
w
Y

yxYw
)a
        Score the model using X/y data and a selected metric.

        If an 'id' column is defined in either dataframe, it will be used as the primary key.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-score.html
                A full list of supported options can be found under
                "Options for Recommendation Models" and
                "Options for Anomaly Detection Models"

        Args:
            X: DataFrame of features.
            y: DataFrame or Series of labels.
            metric: Metric name (e.g., "balanced_accuracy").
            options: Optional ml scoring options.

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported,
                or if the model is not initialized, i.e., fit or import has not
                been called
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Returns:
            float: Computed score.
        c
� �
�|�
jv
SrQr�r�s �r%r�zMyModel.score.<locals>.<lambda>�s���d�!�)�)�>Sr'N)
r
r	r7rr
r}rr=r�r�)
rAr�r�r�rvrBr�rur�r�r�rt�scores
 `           r%r�z
MyModel.score�s����F
�Q���q�!1��
�1�
�t�1�1�2�f� ��!3�!3�4�8H�!0�1S�!T���&�&�(�K�./�K�*�+�"�H�-�f�d�6F�6F��Q�M�A�z��#�#�T�%5�%5�z�$B�C��K�K�
�,>���P�E��
5�4�
3�2�4�4��4�
3�2�2�s$�C�A2C	�6	C�	C	�C�C(c��
���t
|
�
}
t�j�
5�t�j�
5}t	��j
|
�\}}|j
�j
|f�

t��fd
��
}|j
�j
|f�

�j|||�}|cddd�
cddd�
S#1s
w
Y

nxYw
	ddd�
y#1s
w
Y

yxYw
)a
        Explain model predictions using provided data.

        If an 'id' column is defined in either dataframe, it will be used as the primary key.

        References:
            https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-explain-table.html
                A full list of supported options can be found under
                "ML_EXPLAIN_TABLE Options"

        Args:
            X: DataFrame for which predictions should be explained.
            options: Optional dictionary of explainability options.

        Returns:
            DataFrame containing explanation details (feature attributions, etc.)

        Raises:
            DatabaseError:
                If provided options are invalid or unsupported, or if the model is not initialized,
                i.e., fit or import has not been called
                If a database connection issue occurs.
                If an operational error occurs during execution.

        Notes:
            Temporary input/output tables are cleaned up after explanation.
        c
�4��t
�
�j|�SrQr�r�s ��r%r�z-MyModel.explain_predictions.<locals>.<lambda>r�r'N)	r
r	r7rrr=r�r
r�)	rAr�rvr�r�rtr��explanationsrBs	`       @r%�explain_predictionszMyModel.explain_predictions�s����@

�!��
�
�t�1�1�2�f� ��!3�!3�4�8H�.�f�d�6F�6F�
�J�M�A�z��#�#�T�%5�%5�z�$B�C� /��!��

�#�#�T�%5�%5�7H�$I�J��4�4��-�w��L� �#
5�4�
3�2�4�4��4�
3�2�2�s#�C�A8C�1	C�C
	�	C�C#rQ)r(r)r*r+rr�r��np�ndarrayrr�r�r�r#r�r�rr�r4r'r%r�r� sJ
���#'�	@
?�����r�z�z�)�*�@
?��E�"�,�,��
�
�2�3�4�@
?��$��	@
?�

�@
?�J#'�6�����r�z�z�)�*�6��$��6�
���	6�z
#'�3�����r�z�z�)�*�3�����r�z�z�)�*�3��	3�
�$��3�
�
3�p
�5 �����r�z�z�)�*�5 ��5 �
���	5 r'r�)!r+r}rR�enumr�typingrrrr�numpyr��pandasr��mysql.ai.utilsrr	r
rrr
rrrrrrr�mysql.connector.abstractsrrr6r�r4r'r%�<module>r�
sa�


�8
�

���-�-���
�
�
�
�
>�
�d�
�<C
�C
�Ll
 �n�l
 r'