-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathpostgre_multiple_db_mod_move_uom.py
More file actions
68 lines (61 loc) · 2.01 KB
/
postgre_multiple_db_mod_move_uom.py
File metadata and controls
68 lines (61 loc) · 2.01 KB
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
# -*- encoding: utf-8 -*-
import psycopg2
databases = ['granitoslalin',
'rocasmaresgra',
'granitosdelval',
'pizarrasdequiroga',
'penido',
'villarbacu',
'sanclodio',
'pizarrasuniversal',
'carucedo',
'aridosastariz',
'filloy',
'caborcooscuro',
'proinor',
'cuficadoscampos',
'cufica',
'graexcom',
'fidelgomez',
'dragadosdelmar',
'casayo',
'aplistone',
'intradima',
'pedrina',
'graniorega',
'leymon',
'trescunados',
'argel',
'carloslopezamil']
productos = [("AMONITA 2I DE 26X200", "kg"),
("CORDTEX 6N 4X200M", "m"),
("EXAN 25KG", "kg"),
("PÓLVORA NEGRA", "kg"),
("Polvora negra de mina No 1. ; 10 x 2,5 kg", "kg"),
("RIOCORD 100 GRS.", "m"),
("RIOCORD 12 GRS.", "m"),
("RIOCORD 12 GRS. ROLLO 125 MTS.", "m"),
("RIOCORD 6 GRS.", "m"),
("RIODIN 50x380 MM (TR)", "kg"),
("RIODIN HE 26X200 MM (152 GRS)", "kg"),
("RIODIN HE 32X200 MM (238 GRS)", "kg"),
("RIODIN HE 50X380 MM (1042 GRS)", "kg"),
("RIODIN HE 50X380 MM (1042 GRS)", "kg"),
("RIODIN HE 60X570 MM (2300 GRS)", "kg"),
("RIOGEL TRONER 40x330 MM", "kg"),
("RIOGEL TRONER 50x500 MM", "kg"),
("RIOGEL TRONER 60x500 MM", "kg"),
("RIOPOL (POLVORA DE MINA Nº1)", "kg"),
("RIOXAM ST/ NAGOLITA ENSACADA", "kg")]
for db in databases:
connection = psycopg2.connect(database=db)
connection.set_isolation_level(0)
cr = connection.cursor()
for producto in productos:
if producto[1]=="kg":
uom_id_nuevo = 2
elif producto[1]=="m":
uom_id_nuevo = 7
cr.execute('UPDATE stock_move SET product_uom = %s WHERE (product_id = (SELECT id FROM product_product WHERE name_template = %s) and product_uom<>%s)',(uom_id_nuevo, producto[0], uom_id_nuevo))
connection.commit
connection.close()