-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.py
136 lines (82 loc) · 4.14 KB
/
main.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
"""
CONECTORES PARA DIFERENTES BANCOS DE DADOS/LAKE.
EXECUTA TODA A ORQUESTRAÇÃO DE ABERTURA DE CONEXÃO,
EXECUÇÃO DA QUERY E FECHAMENTO DA CONEXÃO.
OS CRUD'S POSSÍVEIS SÃO: SELECT, INSERT, INSERTMANY, UPDATE, DELETE, TRUNCATE.
# Arguments
params_query - Required : Parâmetros para execução da query (Tuples)
# Returns
result_query - Required : Resultado da query (Tuples)
"""
__version__ = "1.0"
__author__ = """Emerson V. Rafael (EMERVIN)"""
__data_atualizacao__ = "08/09/2021"
from dynaconf import settings
from EXECUTORES.Database_Executa_Query_Access import Executa_Query as Executa_Query_ACCESS
from EXECUTORES.Database_Executa_Query_SQLITE import Executa_Query as Executa_Query_SQLITE3
class conectores():
"""
CONECTORES PARA DIFERENTES BANCOS DE DADOS/LAKE.
EXECUTA TODA A ORQUESTRAÇÃO DE ABERTURA DE CONEXÃO,
EXECUÇÃO DA QUERY E FECHAMENTO DA CONEXÃO.
OS CRUD'S POSSÍVEIS SÃO: SELECT, INSERT, INSERTMANY, UPDATE, DELETE, TRUNCATE.
# Arguments
params_query - Required : Parâmetros para execução da query (Tuples)
# Returns
result_query - Required : Resultado da query (Tuples)
"""
def __init__(self):
self.query_types = settings.QUERY_TYPES
self.databases = settings.DATABASES
def get_query_types(self):
"""
OBTÉM TODAS AS QUERYS DISPONÍVEIS.
# Arguments
# Returns
query_types - Required : Lista as querys disponíveis (List)
"""
return self.query_types
def get_databases_available(self):
"""
OBTÉM TODAS OS TIPOS BANCOS DE DADOS DISPONÍVEIS.
# Arguments
# Returns
databases - Required : Lista as bds disponíveis (List)
"""
return self.databases
def execute_query_sqlite(self, caminho_bd, query, params_query, tipo_query):
"""
MICROSERVIÇO RESPONSÁVEL POR TODAS AS INTERAÇÕES
COM O BANCO DE DADOS (SQLITE3).
SELECT | INSERT | INSERT MANY | DELETE | UPDATE | TRUNCATE
# Arguments
caminho_banco_dados - Required : Caminho do Banco de Dados. (String)
ssql - Required : Query a ser executada. (String)
parametros - Required : Parâmetros da query. (Tuple)
tipo_query - Required : Tipo da query a ser executada. (String)
# Returns
validador_query - Required : Validador de execução da Query. (Boolean)
"""
result = Executa_Query_SQLITE3(caminho_bd, query,
params_query, tipo_query).Orquestrador_Executa_Query()
return result
def execute_query_access(self, caminho_bd, query, params_query, tipo_query, password=""):
"""
MICROSERVIÇO RESPONSÁVEL POR TODAS AS INTERAÇÕES
COM O BANCO DE DADOS (MICROSOFT ACCESS).
SELECT | INSERT | INSERT MANY | DELETE | UPDATE | TRUNCATE
# Arguments
caminho_banco_dados - Required : Caminho do Banco de Dados. (String)
ssql - Required : Query a ser executada. (String)
parametros - Required : Parâmetros da query. (Tuple)
tipo_query - Required : Tipo da query a ser executada. (String)
password - Optional : Senha de acesso ao Banco de Dados (String)
# Returns
validador_query - Required : Validador de execução da Query. (Boolean)
"""
result = Executa_Query_ACCESS(caminho_bd, query,
params_query, tipo_query,
password).Orquestrador_Executa_Query()
return result
def execute_query_sqlserver(self):
print("CONECTANDO SQLSERVER")