refactor: 添加主键重复时的异常处理

Author: neekyjiang

MANIFEST

@@ -14,6 +14,7 @@ bin/mtls-log
 bin/mtls-monitor
 bin/mtls-multi-session
 bin/mtls-perf-bench
+bin/mtls-ps-mem
 bin/mtls-random-passwd
 bin/mtls-rows-diff
 bin/mtls-sql-distribution
@@ -38,3 +39,5 @@ mtls/values.py
 mtls/variable.py
 mtls/kits/__init__.py
 mtls/kits/fileformat.py
+mtls/ps/__init__.py
+mtls/ps/mem.py

bin/mtls-auto-fill

@@ -14,6 +14,7 @@ from mysql import connector
 from datetime import datetime
 from collections import namedtuple
 from mtls.values import InsertSQL,TableMeta
+from mysql.connector.errors import IntegrityError
 from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor
 
 
@@ -62,8 +63,12 @@ def insert(host="127.0.0.1",port=3306,user="apuser",password="mtls@0352",databas
 
         for i in range(rows):
             sql,args,*_ = ist[i]
-            cursor.execute(sql,args)
-            cnx.commit()
+            try:
+                cursor.execute(sql,args)
+                cnx.commit()
+            except IntegrityError as err:
+                # 主键重复时不用管
+                pass
 
     except Exception as err:
         logging.exception(str(err))

setup.py

@@ -7,14 +7,15 @@
                 'bin/mtls-http', 'bin/mtls-log', 'bin/mtls-monitor', 'bin/mtls-backup',
                 'bin/mtls-perf-bench', 'bin/mtls-kill-all-conections', 'bin/mtls-sql-distribution',
                 'bin/mtls-file-stat', 'bin/mtls-expired-tables', 'bin/mtls-random-passwd',
-                'bin/mtls-rows-diff', 'bin/mtls-fake-mysqld','bin/mtls-auto-fill','bin/mtls-multi-session']
+                'bin/mtls-rows-diff', 'bin/mtls-fake-mysqld','bin/mtls-auto-fill','bin/mtls-multi-session',
+                'bin/mtls-ps-mem']
 
 scripts = olds_scripts + news_scripts
 
 setup(name='mysqltools-python',
-      version='2.22.03.01',
+      version='2.22.07.00',
       scripts=scripts,
-      packages=['mtls', 'mtls.kits'],
+      packages=['mtls', 'mtls.kits','mtls.ps'],
       maintainer='Neeky',
       maintainer_email='[email protected]',
       url='https://github.com/Neeky/mysqltools-python',