Skip to content

Commit ea50923

Browse files
datasttaxdatasttax
authored
test mongo merge #71238 example file
1 parent 6afb729 commit ea50923

File tree

1 file changed

+181
-0
lines changed

1 file changed

+181
-0
lines changed

‎examples/build2_mongo.py

+181
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,181 @@
1+
import uuid
2+
from cassandra.cluster import Cluster
3+
import time
4+
5+
# Start Cassandra
6+
cluster = Cluster(['127.0.0.1'])
7+
session = cluster.connect()
8+
session.execute('use empleados')
9+
10+
# Funciones de Cargar datos
11+
12+
# Q1
13+
def cargar_empleados_por_habilidad_y_deporte():
14+
nombre_empleado= input('Nombre Empleado: ')
15+
apellido_empleado= input('Apellido Empleado: ')
16+
descripcion_habilidad= input('Descripcion Habilidad: ')
17+
nombre_deporte= input('Nombre Deporte: ')
18+
19+
session.execute("""INSERT INTO empleados_por_habilidad_y_deporte (id_empleado, nombre_empleado, apellido_empleado, descripcion_habilidad, nombre_deporte) VALUES (%s, %s, %s, %s, %s)""", (uuid(), nombre_empleado, apellido_empleado, descripcion_habilidad, nombre_deporte))
20+
21+
# Funciones de Mostrar datos
22+
23+
# Q1
24+
def mostrar_empleados_por_habilidad_y_deporte():
25+
rows = session.execute("""SELECT * FROM empleados_por_habilidad_y_deporte;""")
26+
27+
for row in rows:
28+
print(row)
29+
30+
# Funciones de Queries
31+
32+
# Q1
33+
def empleados_por_habilidad_y_deporte():
34+
rows = session.execute("""SELECT * FROM empleados_por_habilidad_y_deporte WHERE descripcion_habilidad='Liderazgo' AND nombre_deporte='Futbol';""")
35+
for row in rows:
36+
print(row)
37+
38+
39+
40+
# App ----------------------------------------------------------
41+
def menu():
42+
43+
print('Bienvenido, eliga una opcion')
44+
print('--------------------------------------')
45+
print('1. Cargar datos')
46+
print('2. Mostrar contendo')
47+
print('--------------------------------------')
48+
print('3. Ejecutar Q1')
49+
print('4. Ejecutar Q2')
50+
print('5. Ejecutar Q3')
51+
print('6. Ejecutar Q4')
52+
print('7. Ejecutar Q5')
53+
print('8. Ejecutar Q6')
54+
print('9. Ejecutar Q7')
55+
print('10. Ejecutar Q8')
56+
print()
57+
opcion = input('opcion: ')
58+
if opcion == '1' :
59+
60+
print("Seleccione la estructura")
61+
print('--------------------------------------')
62+
print('1. empleados_por_habilidad_y_deporte')
63+
print('2. trabajos_previos_por_habilidad')
64+
print('3. deportes_por_trabajos_previos_entre_fechas')
65+
print('4. empleados_por_deporte_de_riesgo_desde_fecha')
66+
print('5. habilidades_por_empleado')
67+
print('6. deportes_por_trabajo')
68+
print('7. empleados_por_trabajo_deporte_federado')
69+
print('8. empleados_por_habilidad_y_trabajo_previo_entre_fechas')
70+
print()
71+
72+
opcion = input('opcion: ')
73+
74+
if opcion == '1' :
75+
cargar_empleados_por_habilidad_y_deporte()
76+
print('Carga realizada.')
77+
time.sleep(5)
78+
menu()
79+
80+
elif opcion == '2' :
81+
cargar_trabajos_previos_por_habilidad()
82+
83+
elif opcion == '3' :
84+
cargar_deportes_por_trabajos_previos_entre_fechas()
85+
86+
elif opcion == '4' :
87+
cargar_empleados_por_deporte_de_riesgo_desde_fecha()
88+
89+
elif opcion == '5' :
90+
cargar_habilidades_por_empleado()
91+
92+
elif opcion == '6' :
93+
cargar_deportes_por_trabajo()
94+
95+
elif opcion == '7' :
96+
cargar_empleados_por_trabajo_deporte_federado()
97+
98+
elif opcion == '8' :
99+
cargar_empleados_por_habilidad_y_trabajo_previo_entre_fechas()
100+
101+
else:
102+
print("opcion incorrecta")
103+
time.sleep(5)
104+
menu()
105+
106+
elif opcion == '2' :
107+
108+
print("Seleccione la estructura")
109+
print('--------------------------------------')
110+
print('1. empleados_por_habilidad_y_deporte')
111+
print('2. trabajos_previos_por_habilidad')
112+
print('3. deportes_por_trabajos_previos_entre_fechas')
113+
print('4. empleados_por_deporte_de_riesgo_desde_fecha')
114+
print('5. habilidades_por_empleado')
115+
print('6. deportes_por_trabajo')
116+
print('7. empleados_por_trabajo_deporte_federado')
117+
print('8. empleados_por_habilidad_y_trabajo_previo_entre_fechas')
118+
print()
119+
120+
opcion = input('opcion: ')
121+
122+
if opcion == '1' :
123+
mostrar_empleados_por_habilidad_y_deporte()
124+
time.sleep(5)
125+
menu()
126+
127+
elif opcion == '2' :
128+
mostrar_trabajos_previos_por_habilidad()
129+
130+
elif opcion == '3' :
131+
mostrar_deportes_por_trabajos_previos_entre_fechas()
132+
133+
elif opcion == '4' :
134+
mostrar_empleados_por_deporte_de_riesgo_desde_fecha()
135+
136+
elif opcion == '5' :
137+
mostrar_habilidades_por_empleado()
138+
139+
elif opcion == '6' :
140+
mostrar_deportes_por_trabajo()
141+
142+
elif opcion == '7' :
143+
mostrar_empleados_por_trabajo_deporte_federado()
144+
145+
elif opcion == '8' :
146+
mostrar_empleados_por_habilidad_y_trabajo_previo_entre_fechas()
147+
148+
else:
149+
print("opcion incorrecta")
150+
menu()
151+
152+
elif opcion == '3' :
153+
empleados_por_habilidad_y_deporte()
154+
time.sleep(5)
155+
menu()
156+
157+
elif opcion == '4' :
158+
trabajos_previos_por_habilidad()
159+
160+
elif opcion == '5' :
161+
deportes_por_trabajos_previos_entre_fechas()
162+
163+
elif opcion == '6' :
164+
empleados_por_deporte_de_riesgo_desde_fecha()
165+
166+
elif opcion == '7' :
167+
habilidades_por_empleado()
168+
169+
elif opcion == '8' :
170+
deportes_por_trabajo()
171+
172+
elif opcion == '9' :
173+
empleados_por_trabajo_deporte_federado()
174+
175+
elif opcion == '10' :
176+
empleados_por_habilidad_y_trabajo_previo_entre_fechas()
177+
178+
179+
180+
# Run program
181+
menu()

0 commit comments

Comments
 (0)