将阿里云RDS的功能抽到单独engine (#2087)

* 将阿里云RDS的功能迁移到engine

* 修复拼写错误

* 删除不再需要的文件sql/aliyun_rds.py

* 函数命名统一

* 删除冗余注释、移除无用传参

* 格式修复

---------

Co-authored-by: 小圈圈 <rtttte@qq.com>

sql/db_diagnostic.py

@@ -11,14 +11,8 @@
 from sql.engines import get_engine
 from common.utils.extend_json_encoder import ExtendJSONEncoder, ExtendJSONEncoderBytes
 from sql.utils.resource_group import user_instances
-from .models import AliyunRdsConfig, Instance
+from .models import Instance
 
-from .aliyun_rds import (
-    process_status as aliyun_process_status,
-    create_kill_session as aliyun_create_kill_session,
-    kill_session as aliyun_kill_session,
-    sapce_status as aliyun_sapce_status,
-)
 
 logger = logging.getLogger("default")
 
@@ -38,11 +32,7 @@ def process(request):
     query_engine = get_engine(instance=instance)
     query_result = None
     if instance.db_type == "mysql":
-        # 判断是RDS还是其他实例
-        if AliyunRdsConfig.objects.filter(instance=instance, is_enable=True).exists():
-            result = aliyun_process_status(request)
-        else:
-            query_result = query_engine.processlist(command_type)
+        query_result = query_engine.processlist(command_type)
 
     elif instance.db_type == "mongo":
         query_result = query_engine.current_op(command_type)
@@ -85,11 +75,7 @@ def create_kill_session(request):
     result = {"status": 0, "msg": "ok", "data": []}
     query_engine = get_engine(instance=instance)
     if instance.db_type == "mysql":
-        # 判断是RDS还是其他实例
-        if AliyunRdsConfig.objects.filter(instance=instance, is_enable=True).exists():
-            result = aliyun_create_kill_session(request)
-        else:
-            result["data"] = query_engine.get_kill_command(json.loads(thread_ids))
+        result["data"] = query_engine.get_kill_command(json.loads(thread_ids))
     elif instance.db_type == "mongo":
         kill_command = query_engine.get_kill_command(json.loads(thread_ids))
         result["data"] = kill_command
@@ -125,11 +111,7 @@ def kill_session(request):
     engine = get_engine(instance=instance)
     r = None
     if instance.db_type == "mysql":
-        # 判断是RDS还是其他实例
-        if AliyunRdsConfig.objects.filter(instance=instance, is_enable=True).exists():
-            result = aliyun_kill_session(request)
-        else:
-            r = engine.kill(json.loads(thread_ids))
+        r = engine.kill(json.loads(thread_ids))
     elif instance.db_type == "mongo":
         r = engine.kill_op(json.loads(thread_ids))
     elif instance.db_type == "oracle":
@@ -153,7 +135,7 @@ def kill_session(request):
 
 # 问题诊断--表空间信息
 @permission_required("sql.tablespace_view", raise_exception=True)
-def tablesapce(request):
+def tablespace(request):
     instance_name = request.POST.get("instance_name")
     offset = int(request.POST.get("offset", 0))
     limit = int(request.POST.get("limit", 14))
@@ -165,17 +147,9 @@ def tablesapce(request):
 
     query_engine = get_engine(instance=instance)
     if instance.db_type == "mysql":
-        # 判断是RDS还是其他实例
-        if AliyunRdsConfig.objects.filter(instance=instance, is_enable=True).exists():
-            result = aliyun_sapce_status(request)
-        else:
-            query_result = query_engine.tablesapce(offset, limit)
-            r = query_engine.tablesapce_num()
-            total = r.rows[0][0]
+        query_result = query_engine.tablespace(offset, limit)
     elif instance.db_type == "oracle":
         query_result = query_engine.tablespace(offset, limit)
-        r = query_engine.tablespace_count()
-        total = r.rows[0][0]
     else:
         result = {
             "status": 1,
@@ -187,6 +161,8 @@ def tablesapce(request):
     if query_result:
         if not query_result.error:
             table_space = query_result.to_dict()
+            r = query_engine.tablespace_count()
+            total = r[0][0]
             result = {"status": 0, "msg": "ok", "rows": table_space, "total": total}
         else:
             result = {"status": 1, "msg": query_result.error}

sql/engines/__init__.py

@@ -215,6 +215,12 @@ def set_variable(self, variable_name, variable_value):
 def get_engine(instance=None):  # pragma: no cover
     """获取数据库操作engine"""
     if instance.db_type == "mysql":
+        from sql.models import AliyunRdsConfig
+
+        if AliyunRdsConfig.objects.filter(instance=instance, is_enable=True).exists():
+            from .cloud.aliyun_rds import AliyunRDS
+
+            return AliyunRDS(instance=instance)
         from .mysql import MysqlEngine
 
         return MysqlEngine(instance=instance)