try mysqlclient

class/core/mw.py

@@ -1022,3 +1022,13 @@ def getMyORM():
     import orm
     o = orm.ORM()
     return o
+
+
+def getMyORMDb():
+    '''
+    获取MySQL资源的ORM pip install mysqlclient==2.0.3 | pip install mysql-python
+    '''
+    sys.path.append(os.getcwd() + "/class/plugin")
+    import ormDb
+    o = ormDb.ORM()
+    return o

class/plugin/ormDb.py

@@ -0,0 +1,109 @@
+# coding: utf-8
+
+import re
+import os
+import sys
+
+
+class ORM:
+    __DB_PASS = None
+    __DB_USER = 'root'
+    __DB_PORT = 3306
+    __DB_HOST = 'localhost'
+    __DB_CONN = None
+    __DB_CUR = None
+    __DB_ERR = None
+    __DB_CNF = '/etc/my.cnf'
+
+    __DB_SOCKET = '/www/server/mysql/mysql.sock'
+    __DB_CHARSET = 'utf8'
+
+    def __Conn(self):
+        '''连接MYSQL数据库'''
+        try:
+
+            try:
+                import MySQLdb
+            except Exception as ex:
+                self.__DB_ERR = ex
+                return False
+
+            # print(self.__DB_HOST)
+            # print(self.__DB_USER)
+            # print(self.__DB_PASS)
+            # print(self.__DB_PORT)
+            # print(self.__DB_CHARSET)
+            # print(self.__DB_SOCKET)
+            if os.path.exists(self.__DB_SOCKET):
+                try:
+                    self.__DB_CONN = MySQLdb.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1, unix_socket=self.__DB_SOCKET)
+                except Exception as e:
+                    print(e)
+                    self.__DB_HOST = '127.0.0.1'
+                    self.__DB_CONN = MySQLdb.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1, unix_socket=self.__DB_SOCKET)
+            else:
+                try:
+                    self.__DB_CONN = MySQLdb.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1)
+                except Exception as e:
+                    self.__DB_HOST = '127.0.0.1'
+                    self.__DB_CONN = MySQLdb.connect(host=self.__DB_HOST, user=self.__DB_USER, passwd=self.__DB_PASS,
+                                                     port=int(self.__DB_PORT), charset=self.__DB_CHARSET, connect_timeout=1)
+
+            self.__DB_CUR = self.__DB_CONN.cursor()
+
+            return True
+        except MySQLdb.Error as e:
+            self.__DB_ERR = e
+            return False
+
+    def setDbConf(self, conf):
+        self.__DB_CNF = conf
+
+    def setSocket(self, sock):
+        self.__DB_SOCKET = sock
+
+    def setCharset(self, charset):
+        self.__DB_CHARSET = charset
+
+    def setPort(self, port):
+        self.__DB_PORT = port
+
+    def setPwd(self, pwd):
+        self.__DB_PASS = pwd
+
+    def getPwd(self):
+        return self.__DB_PASS
+
+    def execute(self, sql):
+        # 执行SQL语句返回受影响行
+        if not self.__Conn():
+            return self.__DB_ERR
+        try:
+            result = self.__DB_CUR.execute(sql)
+            self.__DB_CONN.commit()
+            self.__Close()
+            return result
+        except Exception as ex:
+            return ex
+
+    def query(self, sql):
+        # 执行SQL语句返回数据集
+        if not self.__Conn():
+            return self.__DB_ERR
+        try:
+            self.__DB_CUR.execute(sql)
+            result = self.__DB_CUR.fetchall()
+            # 将元组转换成列表
+            data = map(list, result)
+            self.__Close()
+            return data
+        except Exception as ex:
+            return ex
+
+    # 关闭连接
+    def __Close(self):
+        self.__DB_CUR.close()
+        self.__DB_CONN.close()

plugins/mysql/index.py

@@ -134,7 +134,11 @@ def pSqliteDb(dbname='databases'):
 
 
 def pMysqlDb():
-    db = mw.getMyORM()
+    # mysql.connector
+    # db = mw.getMyORM()
+    # MySQLdb |
+    db = mw.getMyORMDb()
+
     db.setPort(getDbPort())
     db.setSocket(getSocketFile())
     # db.setCharset("utf8")