U {i+@sbddlZddlZddlZddlZGdddZedkr^ddlmZeddZedZ ee dS) Nc@seZdZdZd*eeedddZeeddd Zd d Zd+ee e d ddZ ddZ dgfddZ gfee dddZee dddZd,ee dddZd-ee dddZee dd d!d"Zed#d$d%Zd&d'Zd(d)ZdS).gn_mysqlz0Classe generica para uso do banco de dados mysqlF)clientedbdebugcCs,d|_|r(||_||_||_|||dS)Nznow())resetvadWorldsrrrconnectByCliente)selfrrrr ;/home/www/html/webservice/gn_integracao/generic/gn_mysql.py__init__ s zgn_mysql.__init__)rrc sd|d}t|}|fdd}|d}|d}|ddd }|d d td } |d |d }|ddd } |ddd } |ddd } |ddd } |j||||| | | | | d W5QRXdS)Nz/user/bindib/aplicativos/z/appConfig.inicsR|d}z$|d}|dt|ddWS|ddYSXdS)N=type rdefaultr)splitgetstr)keykwargsZ split_keyrestdadosr r get_config#s z-gn_mysql.connectByCliente..get_configusuariosenhahost localhost)rport )rrrssl_carssl_certssl_keyssl_verify_certF) ruserpasswdrrr!r"r#r$)loweropenreadintpydb_connection)r rrpathZ_configrrrrrr!r"r#r$r rr rs        zgn_mysql.connectByClientecKstj|d|dd|d|d|d|dd|d drt|d d|d d|d d|d d d dndd|_dS)Nrrr r%r&r autocommitTr!r"r#r$F)cacertrZ verify_certcheck_hostname)rrr%r&rr-ssl)pymysqlconnectrconexao)r rr r r r+Hs"       zgn_mysql.pydb_connectionr )sqlparamsreturncCs$d}|||\}}|s|S|S)z Metodo para select @param {String} sql - sql a ser executado @return {Array} retorno - array com os dados do retorno do sql F) executesqlfetchall)r r5r6 resultadoresulterrorr r r select\s zgn_mysql.selectc Ksd|dg}|}d|ddg}|dd}|rDd|pFd}d |d |d |}||\}}|rt|Sd |kr|d d kr|piS|SdS)N AND where,fields*tablerzWHERE zSELECT z FROM  Z onlyFirstT)joinrr8Zfetchoner9) r rr?Z where_queryrArCr5r;r<r r r simple_selects  zgn_mysql.simple_selectz1=1cCs*d|}d|dd|}||S)Nr>z DELETE FROM z WHERE )rEr8)r rCr?Z query_andr5r r r deletes zgn_mysql.delete)rCdatacCst|tr g}|D]F}||}|jt|}||jkrDd|d}||d|qd|dd|dd|d}||S) Receme um objeto ou array de objetos e monta o insert no banco Arguments: table {str} -- Tabela que serao inseridos os dados data {[{}]} -- objeto com os dados, tambem aceita um array de objetos 'r z UPDATE z SET r@z WHERE 1=1 AND r>z isinstancelistr4Z escape_stringrrappendrEr8)r rCrHr?Zupdatescolvalr5r r r updates    zgn_mysql.updatecCst|tr g}g}|D]F}||}|jt|}||jkrHd|d}||||qd|dd|dd|d}||S)rIrJz INSERT INTO z ( r@z' ) VALUES( z ) rK)r rCrHinsertvaluesrOrPr5r r r rRs$      zgn_mysql.insert)r5r6c CsB|g}|jtjj"}||||W5QRSQRXdSN)r4cursorr2cursors DictCursorZcallprocr9)r r5r6argsrUr r r callProcs zgn_mysql.callProcc Cs|jtjjd}z |s$||n |||Wn<tjk rn}zd|fWYW5QRSd}~XYnXW5QRX|dfS)NF)r4rUr2rVrWZexecuteError)r r5r6rUZ MySQLErrorr r r r8s 4zgn_mysql.executesqlN)rCarrr7cCs|D]}|||qdS)z INSERE UMA LISTA TODO: melhorias de insert hoje faz de um a um o insert, implementar para fazer todos de uma vez, usar parametro no insert para dizer se deve ou nao inserir N)rR)r rCr[rRr r r insertListszgn_mysql.insertList)r7cCsh|D]^}t||tjr*t||||<n t||tjrJt||||<||||\}||<q|SrT)rLdecimalDecimalfloatdatetimedaterfixTypes_customization)r rowrr r r fixTypesszgn_mysql.fixTypescCs||fSrTr )r namevaluer r r rb(szgn_mysql.fixTypes_customizationcCs|jdS)z%Destrutor fecha a conexao com o bancoN)r4close)r r r r __del__+szgn_mysql.__del__)rrF)r )r )r )__name__ __module__ __qualname____doc__rboolr rr+tuplerMr=rFrGrQrRrYr8r\objectrdrbrhr r r r r s /( #$ r__main__)pprintZ JVMALDANERZebs_app_pedidos3zSELECT * FROM TBCONDPGTO) r2r] configparserr`rrirqbancor=r:r r r r s*