瀏覽代碼

Add truncate statement

gabriel 6 年之前
父節點
當前提交
b2bd0886c0
共有 1 個文件被更改,包括 24 次插入10 次删除
  1. 24 10
      UpdServicePortCmd.py

+ 24 - 10
UpdServicePortCmd.py

@@ -9,19 +9,19 @@ def get_value(line, key, onu=False):
     :return: Returns value
     """
     data_compare = line.lower().split()
-        
+
     try:
         index = data_compare.index(key)
     except ValueError:
-        index = -1  
-        
+        index = -1
+
     if index >= 0 and onu:
         return data_compare[index + 2].strip()
     elif index >= 0:
         return data_compare[index + 1].strip()
     else:
         return ""
-            
+
 
 parser = argparse.ArgumentParser(description='Arguments')
 
@@ -56,11 +56,25 @@ for lines in bbs_config:
                     if "ont add %(link)s %(ont)s " % locals() in line.text:
                         sn_auth = get_value(line.text, 'sn-auth')
                         sql.append(""" ((SELECT o.id FROM olt AS o JOIN onu ON o.id=onu.olt_id \
-WHERE onu.pon_serial_number=%(sn_auth)s),(SELECT id FROM onu \
-WHERE pon_serial_number=%(sn_auth)s),\
-%(number)s,%(gemport)s,%(vlan)s,\'%(type)s\')\n"""  % locals())
+                        WHERE onu.pon_serial_number=%(sn_auth)s),(SELECT id FROM onu \
+                        WHERE pon_serial_number=%(sn_auth)s),\
+                        %(number)s,%(gemport)s,%(vlan)s)\n""" % locals())
+
+if len(sql) > 0:
+    print("""TRUNCATE service_port; INSERT INTO service_port (`olt_id`, `onu_id`, `number`, `gemport`, `vlan`) 
+    VALUES """ + ','.join(sql) + ";")
+else:
+    print "NO SE PUDO PROCESAR EL ARCHIVO"
+
+
+
+
+
+
+
+
+
+
+
 
-sql = """REPLACE INTO service_port (`olt_id`, `onu_id`, `number`, `gemport`, `vlan`, `type`) 
-VALUES """ + ','.join(sql) + ";"
 
-print sql