Datasets
Models
Downloads: 1
40 lines (40 with data), 8.4 kB
3
ZSöXÄ Ń @ sö d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl
m Z d dl Z d dl
Z
d dlZdZd ZdgZd
Zd ZdZd Zd
ZG ddä dâZdS )Ú )┌TextFile)┌_CsvFile)┌ MysqlCommand)┌MysqlConnection)┌ MysqlQueries)┌PickleSerialisedNzMohsen Mesgarpourz-Copyright 2016, https://github.com/mesgarpour┌GPLz1.xzmohsen.mesgarpour@gmail.com┌ Developmentc @ sá e Zd Zeddä âZeddä âZedFddäâZedd ä âZed
d ä âZed d
ä âZ eddä âZ
eddä âZ eddä âZ edGddäâZ
eddä âZeddä âZeddä âZedHd d äâZedId d!äâZedJd#d$äâZed%d&ä âZed'd(ä âZedKd*d+äâZedLd,d-äâZedMd/d0äâZed1d2ä âZed3d4ä âZed5d6ä âZedNd7d8äâZ edOd9d:äâZ ee â e â d;fd<d=äâZ ed>d?ä âZ ed@dAä âZ!edBdCä âZ"edDdEä âZ#d S )P┌ReadersWritersc C s t â }|j| ||â |jâ S )N)r ┌set┌exists)┌path┌title┌ext┌readerę r ˙\C:\Users\eagle\Documents\GitHub\UoW_Docobo\IntegratedCare_py\ReadersWrites\ReadersWriters.py┌exists_serialised s z ReadersWriters.exists_serialisedc C s( t â }|j|â}ttj|| ddŹâdkS )NT)┌ dataframingr )r Z exists_table┌lenr
┌load_mysql_query)┌schema┌table┌queries┌queryr r r ┌ exists_mysql s
zReadersWriters.exists_mysql┌csvc C s t â }|j| ||â |jâ S )N)r r r )r
r ┌ extensionr r r r ┌
exists_csv% s zReadersWriters.exists_csvc C s t â }|j| ||â |jâ S )N)r r r )r
r r r r r r ┌ exists_text+ s zReadersWriters.exists_textc C s* t â }|j||â}ttj|| ddŹâdkS )NT)r r )r ┌
exists_columnr r
r )r r ┌columnr r r r r ┌exists_mysql_column1 s z"ReadersWriters.exists_mysql_columnc C s t â }|j| ||â |j|âS )N)r r r )r
r r! r r r r r ┌exists_csv_column7 s z ReadersWriters.exists_csv_columnc C s t â }|j| ||â |jâ S )N)r r ┌size)r
r r r r r r ┌size_serialised= s z ReadersWriters.size_serialisedc C s t tj| |ddŹd d âS )NT)r r )┌intr
┌load_mysql_table)r r r r r ┌size_mysql_tableC s z ReadersWriters.size_mysql_tablec C s t tj| |ddŹd d âS )NT)r r )r& r
r )r r r r r ┌size_mysql_queryG s z ReadersWriters.size_mysql_queryc C s t â }|j| ||â |jâ S )N)r r r$ )r
r r r r r r ┌size_csvK s zReadersWriters.size_csvc C s t â }|j| ||â |jâ S )N)r r r$ )r
r r r r r r ┌ size_textQ s zReadersWriters.size_textc C s" t â }|j| |dâ |j|â d S )N┌pickle)r r ┌save)r
r ┌objects┌writerr r r ┌save_serialisedW s z ReadersWriters.save_serialisedc C s" t â }|j| |dâ |j|â d S )N┌bz2)r r Zsave_bz2)r
r r. r/ r r r ┌save_serialised_compressed] s z)ReadersWriters.save_serialised_compressedNc
C s¬ t â }|j|â |jâ }t||jâ}|d kr8|j| â nf|d krR|j| |||â nLtj|j d | â}x6t
d|âD ](} |j| || | | d | ů ||â qrW |j â d S )Nr Ú ) r r ┌openr ┌db_session_vars┌writeZ
write_many┌math┌ceil┌shape┌range┌close)
r ┌datar r ┌batch┌db┌engine┌dbcr$ ┌ir r r ┌
save_mysqlc s
(zReadersWriters.save_mysqlFc K s6 t â }|j| ||â |dkr$|jâ |j|f|Ä d S )NF)r r ┌reset┌append)r
r r< rD r ┌kwargsr/ r r r ┌save_csvu s
zReadersWriters.save_csv┌logc C s2 t â }|j| ||â |dkr$|jâ |j|â d S )NF)r r rC rD )r
r r< rD r r/ r r r ┌ save_text} s
zReadersWriters.save_textc C s t â }|j| |dâ |jâ S )Nr, )r r ┌load)r
r r r r r ┌load_serialisedů s z ReadersWriters.load_serialisedc C s t â }|j| |dâ |jâ S )Nr1 )r r Zload_bz2)r
r r r r r ┌load_serialised_compressedő s z)ReadersWriters.load_serialised_compressedTc C s d| }t j|| |âS )NzSELECT * FROM )r
r )r r r r r r r r' Ĺ s z ReadersWriters.load_mysql_tablec
C sB t â }|j|â |jâ }t||jâ}|j| ||||â} |jâ | S )N)r r r4 r r5 ┌readr; )
r r r r= Zfloat_round_varsZ float_roundr> r? r@ ┌outputr r r r ľ s
z ReadersWriters.load_mysql_queryr c K s$ t â }|j| ||â |j||f|ÄS )N)r r rL )r
r ┌skipr r rE r r r r ┌load_csvá s zReadersWriters.load_csvc C s" t â }|j| ||â |j|â d S )N)r r rL )r
r r rN r r r r ┌ load_textŽ s zReadersWriters.load_textc C s< t â }|j|â |jâ }t||jâ}|j| |â}|jâ |S )N)r r r4 r r5 Z call_procr; )r ┌argsr r> r? r@ rM r r r ┌load_mysql_procedureČ s
z#ReadersWriters.load_mysql_procedurec C s d| }t j|| âS )NzTRUNCATE TABLE )r
r )r r r r r r ┌reset_mysql_table s z ReadersWriters.reset_mysql_tablec C s t â }|j| ||â |jâ d S )N)r r rC )r
r r r r r r ┌ reset_csv╗ s zReadersWriters.reset_csvc C s t â }|j| ||â |jâ d S )N)r r rC )r
r r r r r r ┌
reset_text┴ s zReadersWriters.reset_textz$ENGINE=InnoDB DEFAULT CHARSET=latin1c C s t â }|j| ||||||âS )N)r ┌create)r ┌columns┌types┌defaultsZ primary_keysZ unique_keys┌metar r r r ┌mysql_query_createă s z!ReadersWriters.mysql_query_createc C s t â }|j| ||âS )N)r ┌insert)r rW rX r r r r ┌mysql_query_insert═ s z!ReadersWriters.mysql_query_insertc C s t â }|j| âS )N)r ┌drop)r r r r r ┌mysql_query_dropĎ s z ReadersWriters.mysql_query_dropc C sN xHt d| d âjâ }|dkr*tdâ dS |dkr>tdâ dS td â qW d S )
NzConfirm or reject z,
>> Print 'y' to accept or 'n' to decline: ┌yZApprovedT┌nZDeclinedFz!ERROR: Invalid command 'y' or 'n')┌input┌lower┌print)┌name┌responser r r ┌question_overwriteÎ s z!ReadersWriters.question_overwritec C sl t jj| âshyt j| ddŹ W nH tk
rf } z,tjtdj|j d t
|j d ââ â W Y d d }~X nX d S )NT)┌exist_okz* - Directory creation error: {0:d}:
{1:s}r r3 ) ┌osr
r ┌makedirs┌OSError┌sys┌exit┌__name__┌formatrQ ┌str)r
┌er r r ┌create_directoriesń s
z!ReadersWriters.create_directories)r )r )N)Fr )FrG )T)TNNN)r Tr )r )rG )$rn ┌
__module__┌ __qualname__┌ staticmethodr r r r r" r# r% r( r) r* r+ r0 r2 rB rF rH rJ rK r' r rO rP rR rS rT rU ┌listr[ r] r_ rg rr r r r r r
sV
r
)ZReadersWrites._TextFiler ZReadersWrites._CsvFiler ZReadersWrites._MysqlCommandr Z ReadersWrites._MysqlConnectionr ZReadersWrites._MysqlQueriesr Z ReadersWrites._PickleSerialisedr r7 ri rl ┌
__author__┌
__copyright__┌ __credits__┌ __license__┌ __version__┌__maintainer__┌ __email__┌
__status__r
r r r r ┌<module> s"