Add new file

mysql/PdbcTemplate.py

+import pymysql
+
+from mysql.log import Logger as Log
+
+
+class PdbcTemplate(object):
+    """python Database Connectivity，简称PDBC"""
+
+
+
+    def __init__(self, db, user, passwd, host, port=3306, charset='utf8'):
+        """初始化数据库"""
+        self.__db = db
+        self.__user = user
+        self.__passwd = passwd
+        self.__host = host
+        self.__port = port
+        self.__charset = charset
+        self.__connect = None
+        self.__cursor = None
+
+    def _connect_db(self):
+        """
+            PdbcTemplate._connect_db()
+        连接数据库
+        """
+        params = {
+            "db": self.__db,
+            "user": self.__user,
+            "passwd": self.__passwd,
+            "host": self.__host,
+            "port": self.__port,
+            "charset": self.__charset
+        }
+        self.__connect = pymysql.connect(**params)
+        self.__cursor = self.__connect.cursor()
+
+    def _close_db(self):
+        """
+            PdbcTemplate._close_db()
+        关闭数据库
+        """
+        self.__cursor.close()
+        self.__connect.close()
+
+
+    def executeBatch(self, sql, insert_data):
+        '''
+            PdbcTemplate.executeBatch(sql, insert_data)
+        批量添加数据到数据库
+        str -> sql 为字符串
+        [(,,,),(,,,)] -> insert_data为列表中嵌套tuple类型
+
+        '''
+        # 用户传入sql和tuple列表数据，批量添加进数据库
+        # 连接数据库
+        self._connect_db()
+
+        try:
+            self.__cursor.executemany(sql,insert_data)
+            self.__connect.commit()
+        except Exception as error:
+            print(error)
+            Log.error(error)
+        finally:
+            self._close_db()