diff --git a/sql/engines/oracle.py b/sql/engines/oracle.py
index 3e179ac4b3..4c18c2832d 100644
--- a/sql/engines/oracle.py
+++ b/sql/engines/oracle.py
@@ -14,7 +14,7 @@
 from . import EngineBase
 import cx_Oracle
 from .models import ResultSet, ReviewSet, ReviewResult
-from sql.utils.data_masking import brute_mask
+from sql.utils.data_masking import simple_column_mask
 
 logger = logging.getLogger('default')
 
@@ -361,12 +361,11 @@ def query(self, db_name=None, sql='', limit_num=0, close_conn=True, **kwargs):
                 self.close()
         return result_set
 
-    def query_masking(self, schema_name=None, sql='', resultset=None):
-        """传入 sql语句, db名, 结果集,
-        返回一个脱敏后的结果集"""
-        # 仅对select语句脱敏
-        if re.match(r"^select|^with", sql, re.I):
-            filtered_result = brute_mask(self.instance, resultset)
+
+    def query_masking(self, db_name=None, sql='', resultset=None):
+        """简单字段脱敏规则, 仅对select有效"""
+        if re.match(r"^select", sql, re.I):
+            filtered_result = simple_column_mask(self.instance, resultset)
             filtered_result.is_masked = True
         else:
             filtered_result = resultset
@@ -637,9 +636,9 @@ def execute_workflow(self, workflow, close_conn=True):
                 rowcount = cursor.rowcount
                 stagestatus = "Execute Successfully"
                 if sqlitem.stmt_type == "PLSQL" and sqlitem.object_name and sqlitem.object_name != 'ANONYMOUS' and sqlitem.object_name != '':
-                    query_obj_sql = f"""SELECT OBJECT_NAME, STATUS, TO_CHAR(LAST_DDL_TIME, 'YYYY-MM-DD HH24:MI:SS') FROM ALL_OBJECTS 
-                                         WHERE OWNER = '{sqlitem.object_owner}' 
-                                         AND OBJECT_NAME = '{sqlitem.object_name}' 
+                    query_obj_sql = f"""SELECT OBJECT_NAME, STATUS, TO_CHAR(LAST_DDL_TIME, 'YYYY-MM-DD HH24:MI:SS') FROM ALL_OBJECTS
+                                         WHERE OWNER = '{sqlitem.object_owner}'
+                                         AND OBJECT_NAME = '{sqlitem.object_name}'
                                         """
                     cursor.execute(query_obj_sql)
                     row = cursor.fetchone()
@@ -738,7 +737,7 @@ def backup(self, workflow, cursor, begin_time, end_time):
                                         endtime=>to_date('{end_time}','yyyy/mm/dd hh24:mi:ss'),
                                         options=>dbms_logmnr.dict_from_online_catalog + dbms_logmnr.continuous_mine);
                                     end;'''
-            undo_sql = f'''select sql_redo,sql_undo from v$logmnr_contents 
+            undo_sql = f'''select sql_redo,sql_undo from v$logmnr_contents
                                   where  SEG_OWNER not in ('SYS','SYSTEM')
                                          and session# = (select sid from v$mystat where rownum = 1)
                                          and serial# = (select serial# from v$session s where s.sid = (select sid from v$mystat where rownum = 1 )) order by scn desc'''
@@ -822,7 +821,7 @@ def sqltuningadvisor(self, db_name=None, sql='', close_conn=True, **kwargs):
                                   my_sqltext := '{sql}';
                                   my_task_name := DBMS_SQLTUNE.CREATE_TUNING_TASK(
                                   sql_text    => my_sqltext,
-                                  user_name   => '{db_name}', 
+                                  user_name   => '{db_name}',
                                   scope       => 'COMPREHENSIVE',
                                   time_limit  => 30,
                                   task_name   => '{task_name}',
@@ -848,8 +847,8 @@ def sqltuningadvisor(self, db_name=None, sql='', close_conn=True, **kwargs):
         finally:
             # 结束分析任务
             if task_begin == 1:
-                end_sql = f'''DECLARE 
-                             begin 
+                end_sql = f'''DECLARE
+                             begin
                              dbms_sqltune.drop_tuning_task('{task_name}');
                              end;'''
                 cursor.execute(end_sql)
diff --git a/sql/engines/redis.py b/sql/engines/redis.py
index 157c610166..64707ba814 100644
--- a/sql/engines/redis.py
+++ b/sql/engines/redis.py
@@ -85,6 +85,10 @@ def query(self, db_name=None, sql='', limit_num=0, close_conn=True, **kwargs):
                 else:
                     result_set.rows = tuple([row] for row in rows)
                     result_set.affected_rows = len(rows)
+            elif isinstance(rows, dict):
+                result_set.column_list = ["field", "value"]
+                result_set.rows = tuple([[k, v] for k, v in rows.items()])
+                result_set.affected_rows = len(result_set.rows)
             else:
                 result_set.rows = tuple([[rows]])
                 result_set.affected_rows = 1 if rows else 0
diff --git a/sql/engines/tests.py b/sql/engines/tests.py
index 28b8b95f9a..c73dcb72b0 100644
--- a/sql/engines/tests.py
+++ b/sql/engines/tests.py
@@ -1427,7 +1427,7 @@ def test_filter_sql_with_limit(self):
     def test_query_masking(self):
         query_result = ResultSet()
         new_engine = OracleEngine(instance=self.ins)
-        masking_result = new_engine.query_masking(schema_name='', sql='select 1', resultset=query_result)
+        masking_result = new_engine.query_masking(sql='select 1 from dual', resultset=query_result)
         self.assertEqual(masking_result, query_result)
 
     def test_execute_check_select_sql(self):