server/components/import/cm/csv/db-upload.js

   1 const a1000_0x45da=['host','HI\x20Level\x20Query','@mysqldb','password','356600uhnIKx','dbPoolMin','mysql2/promise','dbPort','exports','dialectOptions','351038PaDAPj','number','dbPoolMax','13135mcVRlA','14MTBMle','441792UdAjhi','affectedRows','609115njCGUL','@mysqldb/infile-stream-factory','flags','4EETldt','29641rGPptM','Low\x20Level\x20Query','query','handleQuery','port','debug','49414ETHsEM','database','@utils/console-logger','username','options','mysqlUser','dbHost'];const a1000_0x28cc=function(_0x1a43d6,_0x17c3b1){_0x1a43d6=_0x1a43d6-0xc1;let _0x45da2d=a1000_0x45da[_0x1a43d6];return _0x45da2d;};const a1000_0x4fdfad=a1000_0x28cc;(function(_0x2d7260,_0x493e0d){const _0x1198ee=a1000_0x28cc;while(!![]){try{const _0x4a76c2=-parseInt(_0x1198ee(0xd7))*-parseInt(_0x1198ee(0xd0))+parseInt(_0x1198ee(0xc7))+parseInt(_0x1198ee(0xd4))+-parseInt(_0x1198ee(0xcd))+parseInt(_0x1198ee(0xd8))+-parseInt(_0x1198ee(0xd2))+parseInt(_0x1198ee(0xd1))*parseInt(_0x1198ee(0xde));if(_0x4a76c2===_0x493e0d)break;else _0x2d7260['push'](_0x2d7260['shift']());}catch(_0x5dfd1b){_0x2d7260['push'](_0x2d7260['shift']());}}}(a1000_0x45da,0xe72ae));const {db}=require('@mysqldb'),mysql2=require(a1000_0x4fdfad(0xc9)),{infileStreamFactory}=require(a1000_0x4fdfad(0xd5)),{consoleLogger}=require(a1000_0x4fdfad(0xe0)),{mysqlDbSettingsFactory}=require(a1000_0x4fdfad(0xc5)),{getConfig}=require('@config/get-config'),config=getConfig(),dbSettings=mysqlDbSettingsFactory({'database':config['mysqlDatabase'],'username':config[a1000_0x4fdfad(0xc1)],'password':config['mysqlPassword'],'host':config[a1000_0x4fdfad(0xc2)],'port':config[a1000_0x4fdfad(0xca)],'pool':{'max':config[a1000_0x4fdfad(0xcf)],'min':config[a1000_0x4fdfad(0xc8)],'idle':config['dbPoolIdle']}});async function lowLevelMySQL2Query(_0x1723f0){const _0xbc7305=a1000_0x4fdfad,_0x2bbcb2={'host':dbSettings[_0xbc7305(0xe2)][_0xbc7305(0xc3)],'port':dbSettings[_0xbc7305(0xe2)][_0xbc7305(0xdc)],'user':dbSettings[_0xbc7305(0xe1)],'password':dbSettings[_0xbc7305(0xc6)],'database':dbSettings[_0xbc7305(0xdf)],'timezone':dbSettings[_0xbc7305(0xe2)]['timezone'],'bigNumberStrings':![],'supportBigNumbers':!![],'flags':dbSettings[_0xbc7305(0xe2)][_0xbc7305(0xcc)][_0xbc7305(0xd6)]},_0x7e7e98=await mysql2['createConnection'](_0x2bbcb2),[_0x179644,_0x52e754]=await _0x7e7e98[_0xbc7305(0xda)]({'sql':_0x1723f0,'infileStreamFactory':infileStreamFactory});await _0x7e7e98['end'](),consoleLogger[_0xbc7305(0xdd)](_0xbc7305(0xd9),_0x179644,_0x52e754);const _0x158ee5=_0x52e754?.[_0xbc7305(0xd3)]||_0x179644?.['affectedRows'];return{'affectedRows':_0x158ee5,'results':_0x179644,'metadata':_0x52e754};}async function handleQuery(_0x26776e,_0x353931=![]){const _0x5379ca=a1000_0x4fdfad;let _0xd2b582=null;if(_0x353931){const {affectedRows:_0x245df9}=await lowLevelMySQL2Query(_0x26776e);_0xd2b582=_0x245df9;}else{const [_0x511609,_0x51a45b]=await db['sequelize'][_0x5379ca(0xda)](_0x26776e),_0x1cd8ac=typeof _0x51a45b===_0x5379ca(0xce)?_0x51a45b:typeof _0x511609===_0x5379ca(0xce)?_0x511609:_0x51a45b?.[_0x5379ca(0xd3)]||_0x511609?.['affectedRows'];consoleLogger[_0x5379ca(0xdd)](_0x5379ca(0xc4),_0x511609,_0x51a45b),_0xd2b582=_0x1cd8ac;}return _0xd2b582??NaN;}module[a1000_0x4fdfad(0xcb)][a1000_0x4fdfad(0xdb)]=handleQuery;