mysql数据库支持设置charset

mysql数据库支持设置charset，解决老旧(测试5.0.15版本)mysql的charset不支持utf8mb4，只支持utf8的问题。

Author: coloraven

feapder/db/mysqldb.py

@@ -41,7 +41,8 @@ def wapper(*args, **kwargs):
 
 class MysqlDB:
     def __init__(
-        self, ip=None, port=None, db=None, user_name=None, user_pass=None, set_session=None, **kwargs
+            self, ip=None, port=None, db=None, user_name=None, user_pass=None, charset="utf8mb4", set_session=None,
+            **kwargs
     ):
         # 可能会改setting中的值，所以此处不能直接赋值为默认值，需要后加载赋值
         if not ip:
@@ -68,7 +69,7 @@ def __init__(
                 user=user_name,
                 passwd=user_pass,
                 db=db,
-                charset="utf8mb4",
+                charset=charset,
                 setsession=set_session,
                 cursorclass=cursors.SSCursor,
                 **kwargs
@@ -85,7 +86,7 @@ def __init__(
             user_pass: {}
             exception: {}
             """.format(
-                    ip, port, db, user_name, user_pass, e
+                    ip, port, db, user_name, user_pass, charset, e
                 )
             )
         else:
@@ -119,7 +120,9 @@ def from_url(cls, url, **kwargs):
             "user_pass": url_parsed.password.strip(),
             "db": url_parsed.path.strip("/").strip(),
         }
-
+        # 解析 query 字符串参数，比如 ?charset=utf8
+        query_params = dict(parse.parse_qsl(url_parsed.query))
+        connect_params.update(query_params)
         connect_params.update(kwargs)
 
         return cls(**connect_params)
@@ -200,7 +203,7 @@ def convert(col):
                 if isinstance(col, (datetime.date, datetime.time)):
                     return str(col)
                 elif isinstance(col, str) and (
-                    col.startswith("{") or col.startswith("[")
+                        col.startswith("{") or col.startswith("[")
                 ):
                     try:
                         # col = self.unescape_string(col)