diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AccessTokenMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AccessTokenMapper.xml
index 15dceb70046d024761f86e047c15e825ed14c32d..cc1c5cec034168cdadc85962ad3bff180a882f8d 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AccessTokenMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AccessTokenMapper.xml
@@ -2,8 +2,8 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.AccessTokenMapper">
     <select id="selectAccessTokenPage" resultType="org.apache.dolphinscheduler.dao.entity.AccessToken">
-        select * from t_escheduler_access_token t
-        left join t_escheduler_user u on t.user_id = u.id
+        select * from t_ds_access_token t
+        left join t_ds_user u on t.user_id = u.id
         where 1 = 1
         <if test="userName != null and userName != ''">
             and u.user_name like concat ('%', #{userName}, '%')
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertGroupMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertGroupMapper.xml
index 347cef0022726d1b44706db6d18a909302101a69..77d3110cccff076cb521888cfd4b341a77a52fb7 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertGroupMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertGroupMapper.xml
@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.AlertGroupMapper">
     <select id="queryAlertGroupPage" resultType="org.apache.dolphinscheduler.dao.entity.AlertGroup">
-        select * from t_escheduler_alertgroup
+        select * from t_ds_alertgroup
         where 1 = 1
         <if test="groupName != null and groupName != ''">
             and group_name like concat('%', #{groupName}, '%')
@@ -10,21 +10,21 @@
         order by update_time desc
     </select>
     <select id="queryByGroupName" resultType="org.apache.dolphinscheduler.dao.entity.AlertGroup">
-        select * from t_escheduler_alertgroup
+        select * from t_ds_alertgroup
         where group_name=#{groupName}
     </select>
     <select id="queryByUserId" resultType="org.apache.dolphinscheduler.dao.entity.AlertGroup">
-        select * from t_escheduler_alertgroup t
-        left join t_escheduler_relation_user_alertgroup r on t.id=r.alertgroup_id
+        select * from t_ds_alertgroup t
+        left join t_ds_relation_user_alertgroup r on t.id=r.alertgroup_id
         where r.user_id=#{userId}
     </select>
     <select id="queryByAlertType" resultType="org.apache.dolphinscheduler.dao.entity.AlertGroup">
-        select * from t_escheduler_alertgroup
+        select * from t_ds_alertgroup
         where group_type=#{alertType}
     </select>
     <select id="queryAllGroupList" resultType="org.apache.dolphinscheduler.dao.entity.AlertGroup">
         select *
-        from t_escheduler_alertgroup
+        from t_ds_alertgroup
         order by update_time desc
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
index 4c38335992e68943f4c7dab36228a0744bfdbbbe..df80071c7df27524e106f16e62a82997d1d19c0a 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.AlertMapper">
     <select id="listAlertByStatus" resultType="org.apache.dolphinscheduler.dao.entity.Alert">
         select *
-        from t_escheduler_alert
+        from t_ds_alert
         where alert_status = #{alertStatus}
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/CommandMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/CommandMapper.xml
index b1455412e7c3d3cdcdefe993f91696cc0ebb454c..9abb6a95906197d6de752bcae9ce63df2097f17d 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/CommandMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/CommandMapper.xml
@@ -2,15 +2,15 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.CommandMapper">
     <select id="getOneToRun" resultType="org.apache.dolphinscheduler.dao.entity.Command">
-        select command.* from t_escheduler_command command
-        join t_escheduler_process_definition definition on command.process_definition_id = definition.id
+        select command.* from t_ds_command command
+        join t_ds_process_definition definition on command.process_definition_id = definition.id
         where definition.release_state = 1 AND definition.flag = 1
         order by update_time asc
         limit 1
     </select>
     <select id="countCommandState" resultType="org.apache.dolphinscheduler.dao.entity.CommandCount">
         select cmd.command_type as state, count(1) as count
-        from t_escheduler_command cmd, t_escheduler_process_definition process
+        from t_ds_command cmd, t_ds_process_definition process
         where cmd.process_definition_id = process.id
         <if test="projectIdArray != null and projectIdArray.length != 0">
             and process.project_id in 
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceMapper.xml
index 101313cdd72cdcbdb11850206e7e5d93a6b0c0d2..df8f4a5a2d13e9cf9c657fe762bbe65108625506 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceMapper.xml
@@ -3,15 +3,15 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.DataSourceMapper">
     <select id="queryDataSourceByType" resultType="org.apache.dolphinscheduler.dao.entity.DataSource">
         select *
-        from t_escheduler_datasource
+        from t_ds_datasource
         where type=#{type}
         <if test="userId != 0">
         and id in
           (select datasource_id
-          from t_escheduler_relation_datasource_user
+          from t_ds_relation_datasource_user
           where user_id=#{userId}
           union select id as datasource_id
-                from t_escheduler_datasource
+                from t_ds_datasource
                 where user_id=#{userId}
          )
         </if>
@@ -20,15 +20,15 @@
 
     <select id="selectPaging" resultType="org.apache.dolphinscheduler.dao.entity.DataSource">
         select *
-        from t_escheduler_datasource
+        from t_ds_datasource
         where 1 =1
         <if test="userId != 0">
          and id in
           (select datasource_id
-            from t_escheduler_relation_datasource_user
+            from t_ds_relation_datasource_user
             where user_id=#{userId}
             union select id as datasource_id
-            from t_escheduler_datasource
+            from t_ds_datasource
             where user_id=#{userId}
             )
         </if>
@@ -39,22 +39,22 @@
     </select>
     <select id="queryDataSourceByName" resultType="org.apache.dolphinscheduler.dao.entity.DataSource">
         select *
-        from t_escheduler_datasource
+        from t_ds_datasource
         where name=#{name}
     </select>
     <select id="queryAuthedDatasource" resultType="org.apache.dolphinscheduler.dao.entity.DataSource">
         select datasource.*
-        from t_escheduler_datasource datasource, t_escheduler_relation_datasource_user rel
+        from t_ds_datasource datasource, t_ds_relation_datasource_user rel
         where datasource.id = rel.datasource_id AND rel.user_id = #{userId}
     </select>
     <select id="queryDatasourceExceptUserId" resultType="org.apache.dolphinscheduler.dao.entity.DataSource">
         select *
-        from t_escheduler_datasource
+        from t_ds_datasource
         where user_id <![CDATA[ <> ]]> #{userId}
     </select>
     <select id="listAllDataSourceByType" resultType="org.apache.dolphinscheduler.dao.entity.DataSource">
         select *
-        from t_escheduler_datasource
+        from t_ds_datasource
         where type = #{type}
     </select>
 
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceUserMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceUserMapper.xml
index 0178b36acf50b3d3ed76e63d2a1a30d909c9bec3..fd48492929e62a111f5e09e96e6a832a0e02f5f7 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceUserMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/DataSourceUserMapper.xml
@@ -2,12 +2,12 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.DataSourceUserMapper">
     <delete id="deleteByUserId">
-        delete from t_escheduler_datasource_user
+        delete from t_ds_datasource_user
         where user_id = #{userId}
 
     </delete>
     <delete id="deleteByDatasourceId">
-        delete from t_escheduler_datasource_user
+        delete from t_ds_datasource_user
         where datasource_id = #{datasourceId}
     </delete>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml
index 278b7cbc08c4ec1d0b7f56d1084aea3d7af8650d..9fb103f82b204b0c2c67b908edc86c6741eabc70 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ErrorCommandMapper">
     <select id="countCommandState" resultType="org.apache.dolphinscheduler.dao.entity.CommandCount">
         select cmd.command_type as commandType, count(1) as count
-        from t_escheduler_error_command cmd, t_escheduler_process_definition process
+        from t_ds_error_command cmd, t_ds_process_definition process
         where cmd.process_definition_id = process.id
         <if test="projectIdArray != null and projectIdArray.length != 0">
             and process.project_id in
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml
index e16ae81ea1d65ad1416323ab8ba9f45511b7939a..ed53f815406e48d2a894ba498c3680b88dba3159 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml
@@ -3,18 +3,18 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ProcessDefinitionMapper">
     <select id="queryByDefineName" resultType="org.apache.dolphinscheduler.dao.entity.ProcessDefinition">
         select pd.*,u.user_name,p.name as project_name,t.tenant_code,t.tenant_name,q.queue,q.queue_name
-        from t_escheduler_process_definition pd
-        JOIN t_escheduler_user u ON pd.user_id = u.id
-        JOIN  t_escheduler_project p ON pd.project_id = p.id
-        JOIN  t_escheduler_tenant t ON t.id = u.tenant_id
-        JOIN t_escheduler_queue q ON t.queue_id = q.id
+        from t_ds_process_definition pd
+        JOIN t_ds_user u ON pd.user_id = u.id
+        JOIN  t_ds_project p ON pd.project_id = p.id
+        JOIN  t_ds_tenant t ON t.id = u.tenant_id
+        JOIN t_ds_queue q ON t.queue_id = q.id
         WHERE p.id = #{projectId}
         and pd.name = #{processDefinitionName}
     </select>
     <select id="queryDefineListPaging" resultType="org.apache.dolphinscheduler.dao.entity.ProcessDefinition">
         SELECT td.*,sc.schedule_release_state
-        FROM t_escheduler_process_definition td
-        left join (select process_definition_id,release_state as schedule_release_state from t_escheduler_schedules group by process_definition_id,release_state) sc on sc.process_definition_id = td.id
+        FROM t_ds_process_definition td
+        left join (select process_definition_id,release_state as schedule_release_state from t_ds_schedules group by process_definition_id,release_state) sc on sc.process_definition_id = td.id
         where td.project_id = #{projectId}
         <if test=" searchVal != null and searchVal != ''">
             and td.name like concat('%', #{searchVal}, '%')
@@ -26,13 +26,13 @@
     </select>
     <select id="queryAllDefinitionList" resultType="org.apache.dolphinscheduler.dao.entity.ProcessDefinition">
         select *
-        from t_escheduler_process_definition
+        from t_ds_process_definition
         where project_id = #{projectId}
         order by create_time desc
     </select>
     <select id="queryDefinitionListByIdList" resultType="org.apache.dolphinscheduler.dao.entity.ProcessDefinition">
         select *
-        from t_escheduler_process_definition
+        from t_ds_process_definition
         where id in
         <foreach collection="ids" index="index" item="i" open="(" separator="," close=")">
             #{i}
@@ -40,8 +40,8 @@
     </select>
     <select id="countDefinitionGroupByUser" resultType="org.apache.dolphinscheduler.dao.entity.DefinitionGroupByUser">
         SELECT td.user_id as user_id, tu.user_name as user_name, count(0) as count
-        FROM t_escheduler_process_definition td
-        JOIN t_escheduler_user tu on tu.id=td.user_id
+        FROM t_ds_process_definition td
+        JOIN t_ds_user tu on tu.id=td.user_id
         where 1 = 1
         <if test="projectIds != null and projectIds.length != 0">
             and td.project_id in
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapMapper.xml
index 7bffa899412440151c5442df36fd9c25c8ac43d1..c81e0689d7dd1e72f30adc406792022717dfa47d 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapMapper.xml
@@ -3,24 +3,24 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ProcessInstanceMapMapper">
     <delete id="deleteByParentProcessId">
         delete
-        from t_escheduler_relation_process_instance
+        from t_ds_relation_process_instance
         where parent_process_instance_id=#{parentProcessId}
 
     </delete>
     <select id="queryByParentId" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstanceMap">
         select *
-        from t_escheduler_relation_process_instance
+        from t_ds_relation_process_instance
         where parent_process_instance_id = #{parentProcessId}
         and parent_task_instance_id = #{parentTaskId}
     </select>
     <select id="queryBySubProcessId" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstanceMap">
         select *
-        from t_escheduler_relation_process_instance
+        from t_ds_relation_process_instance
         where process_instance_id = #{subProcessId}
     </select>
     <select id="querySubIdListByParentId" resultType="java.lang.Integer">
         select process_instance_id
-        from t_escheduler_process_instance_map
+        from t_ds_process_instance_map
         where parent_process_instance_id = #{parentInstanceId}
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.xml
index f956c148b7fc7f7b94b50f716059ab03adb16817..e925547dc7b8e5b8ca4ee13f3930f822b5bfbfbc 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.xml
@@ -3,12 +3,12 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ProcessInstanceMapper">
     <select id="queryDetailById" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select inst.*
-        from t_escheduler_process_instance inst
+        from t_ds_process_instance inst
         where inst.id = #{processId}
     </select>
     <select id="queryByHostAndStatus" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select *
-        from t_escheduler_process_instance
+        from t_ds_process_instance
         where 1=1
         <if test="host != null and host != ''">
             and host=#{host}
@@ -21,8 +21,8 @@
     </select>
     <select id="queryProcessInstanceListPaging" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select instance.*
-        from t_escheduler_process_instance instance
-        join t_escheduler_process_definition define ON instance.process_definition_id = define.id
+        from t_ds_process_instance instance
+        join t_ds_process_definition define ON instance.process_definition_id = define.id
         where 1=1
         and instance.is_sub_process=0
         and define.project_id = #{projectId}
@@ -47,7 +47,7 @@
         order by instance.start_time desc
     </select>
     <update id="setFailoverByHostAndStateArray">
-        update t_escheduler_process_instance
+        update t_ds_process_instance
         set host=null
         where host =#{host} and state in
         <foreach collection="states" index="index" item="i" open="(" close=")" separator=",">
@@ -55,15 +55,15 @@
         </foreach>
     </update>
     <update id="updateProcessInstanceByState">
-        update t_escheduler_process_instance
+        update t_ds_process_instance
         set state = #{destState}
         where state = #{originState}
     </update>
     <select id="countInstanceStateByUser" resultType="org.apache.dolphinscheduler.dao.entity.ExecuteStatusCount">
         select t.state, count(0) as count
-        from t_escheduler_process_instance t
-        join t_escheduler_process_definition d on d.id=t.process_definition_id
-        join t_escheduler_project p on p.id=d.project_id
+        from t_ds_process_instance t
+        join t_ds_process_definition d on d.id=t.process_definition_id
+        join t_ds_project p on p.id=d.project_id
         where 1 = 1
         and t.is_sub_process = 0
         <if test="startTime != null and endTime != null">
@@ -79,13 +79,13 @@
     </select>
     <select id="queryByProcessDefineId" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select *
-        from t_escheduler_process_instance
+        from t_ds_process_instance
         where process_definition_id=#{processDefinitionId}
         order by start_time desc limit #{size}
     </select>
     <select id="queryLastSchedulerProcess" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select *
-        from t_escheduler_process_instance
+        from t_ds_process_instance
         where process_definition_id=#{processDefinitionId}
         <if test="startTime!=null and endTime != null ">
             and schedule_time between #{startTime} and #{endTime}
@@ -94,7 +94,7 @@
     </select>
     <select id="queryLastRunningProcess" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select *
-        from t_escheduler_process_instance
+        from t_ds_process_instance
         where 1=1
         <if test="states !=null and states.length != 0">
             and state in
@@ -110,7 +110,7 @@
     </select>
     <select id="queryLastManualProcess" resultType="org.apache.dolphinscheduler.dao.entity.ProcessInstance">
         select *
-        from t_escheduler_process_instance
+        from t_ds_process_instance
         where process_definition_id=#{processDefinitionId}
         and schedule_time is null
         <if test="startTime!=null and endTime != null ">
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml
index e34576811d55d97dcd538a75c63f9154962e478d..e4d6f3d21040051673f8442bb7be550d24cc1a7e 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml
@@ -3,28 +3,28 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ProjectMapper">
     <select id="queryDetailById" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select p.*,u.user_name as user_name
-        from t_escheduler_project
-        join t_escheduler_user u on p.user_id = u.id
+        from t_ds_project
+        join t_ds_user u on p.user_id = u.id
         where p.id = #{projectId}
     </select>
     <select id="queryByName" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select p.* u.user_name as user_name
-        from t_escheduler_project
-        join t_escheduler_user u on p.user_id = u.id
+        from t_ds_project
+        join t_ds_user u on p.user_id = u.id
         where p.name = #{projectName}
         and p.flag = 1
     </select>
     <select id="queryProjectListPaging" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select p.*, u.user_name as user_name,
-        (SELECT COUNT(*) FROM t_escheduler_process_definition AS def WHERE def.project_id = p.id) AS def_count,
-        (SELECT COUNT(*) FROM t_escheduler_process_definition def, t_escheduler_process_instance inst WHERE def.id = inst.process_definition_id AND def.project_id = p.id AND inst.state=1 ) as inst_running_count,
-        from t_escheduler_project p
-        join t_escheduler_user u on u.id=p.user_id
+        (SELECT COUNT(*) FROM t_ds_process_definition AS def WHERE def.project_id = p.id) AS def_count,
+        (SELECT COUNT(*) FROM t_ds_process_definition def, t_ds_process_instance inst WHERE def.id = inst.process_definition_id AND def.project_id = p.id AND inst.state=1 ) as inst_running_count,
+        from t_ds_project p
+        join t_ds_user u on u.id=p.user_id
         where 1=1
         <if test="userId != 0">
             and p.id in
-            (select project_id from t_escheduler_relation_project_user  where user_id=#{userId}
-            union select id as project_id  from t_escheduler_project where user_id=#{userId})
+            (select project_id from t_ds_relation_project_user  where user_id=#{userId}
+            union select id as project_id  from t_ds_project where user_id=#{userId})
             )
         </if>
         <if test="searchName!=null and searchName != ''">
@@ -36,10 +36,10 @@
 
     <select id="queryAllProjectListPaging" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select p.*, u.user_name as user_name,
-        (SELECT COUNT(*) FROM t_escheduler_process_definition AS def WHERE def.project_id = p.id) AS def_count,
-        (SELECT COUNT(*) FROM t_escheduler_process_definition def, t_escheduler_process_instance inst WHERE def.id = inst.process_definition_id AND def.project_id = p.id AND inst.state=1 ) as inst_running_count,
-        from t_escheduler_project p
-        join t_escheduler_user u on u.id=p.user_id
+        (SELECT COUNT(*) FROM t_ds_process_definition AS def WHERE def.project_id = p.id) AS def_count,
+        (SELECT COUNT(*) FROM t_ds_process_definition def, t_ds_process_instance inst WHERE def.id = inst.process_definition_id AND def.project_id = p.id AND inst.state=1 ) as inst_running_count,
+        from t_ds_project p
+        join t_ds_user u on u.id=p.user_id
         where p.flag=1
         <if test="searchName!=null and searchName != ''">
             and p.name like concat('%', #{searchName}, '%')
@@ -48,17 +48,17 @@
     </select>
     <select id="queryAuthedProjectListByUserId" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select p.*
-        from t_escheduler_project p,t_escheduler_relation_project_user rel
+        from t_ds_project p,t_ds_relation_project_user rel
         where p.id = rel.project_id and p.flag=1 and rel.user_id= #{userId}
     </select>
     <select id="queryProjectExceptUserId" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select *
-        from t_escheduler_project
+        from t_ds_project
         where flag=1 and user_id <![CDATA[ <> ]]> #{userId}
     </select>
     <select id="queryProjectCreatedByUser" resultType="org.apache.dolphinscheduler.dao.entity.Project">
         select *
-        from t_escheduler_project
+        from t_ds_project
         where user_id = #{userId}
     </select>
 
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectUserMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectUserMapper.xml
index ad2b9b9343fa696a3df3040110529e63bf928862..06efa3a73dd377d28215d50ec870966248ea7330 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectUserMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProjectUserMapper.xml
@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ProjectUserMapper">
     <delete id="deleteProjectRelation">
-        delete from t_escheduler_relation_project_user
+        delete from t_ds_relation_project_user
         where 1=1
         and user_id = #{userId}
         <if test="projectId != 0 ">
@@ -11,7 +11,7 @@
     </delete>
     <select id="queryProjectRelation" resultType="org.apache.dolphinscheduler.dao.entity.ProjectUser">
       select *
-      from t_escheduler_relation_project_user
+      from t_ds_relation_project_user
       where project_id = #{projectId}
       and user_id = #{userId}
       limit 1
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/QueueMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/QueueMapper.xml
index 6eac1d3bc84c2afe5b994614679ddd7389a42a1b..28477a57103d5e97dcfc478a7e8a77e0f4c707bd 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/QueueMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/QueueMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.QueueMapper">
     <select id="queryQueuePaging" resultType="org.apache.dolphinscheduler.dao.entity.Queue">
         select *
-        from t_escheduler_queue
+        from t_ds_queue
         where  1= 1
         <if test="searchVal != null and searchVal != ''">
             and queue_name like concat('%', #{searchVal}, '%')
@@ -12,7 +12,7 @@
     </select>
     <select id="queryAllQueueList" resultType="org.apache.dolphinscheduler.dao.entity.Queue">
         select *
-        from t_escheduler_queue
+        from t_ds_queue
         where  1=1
         <if test="queue != null and queue != ''">
             and queue = #{queue}
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceMapper.xml
index acd8376be814f2026fe810dc5f6b292eac32f5fe..e794e21afdee2bcec8e35903f3994b800a20df19 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ResourceMapper">
     <select id="queryResourceList" resultType="org.apache.dolphinscheduler.dao.entity.Resource">
         select *
-        from t_escheduler_resources
+        from t_ds_resources
         where 1= 1
         <if test="alias != null and alias != ''">
             and alias = #{alias}
@@ -17,21 +17,21 @@
     </select>
     <select id="queryResourceListAuthored" resultType="org.apache.dolphinscheduler.dao.entity.Resource">
         select *
-        from t_escheduler_resources
+        from t_ds_resources
         where 1 = 1
         <if test="type != -1">
             and `type`=#{type}
         </if>
-        and id in (select resources_id from  t_escheduler_relation_resources_user where user_id=#{userId}
-                  union select id as resources_id  from t_escheduler_resources where user_id=#{userId})
+        and id in (select resources_id from  t_ds_relation_resources_user where user_id=#{userId}
+                  union select id as resources_id  from t_ds_resources where user_id=#{userId})
     </select>
     <select id="queryResourcePaging" resultType="org.apache.dolphinscheduler.dao.entity.Resource">
         select *
-        from t_escheduler_resources
+        from t_ds_resources
         where `type`=#{type}
         <if test="userId != 0">
-            and id in (select resources_id from  t_escheduler_relation_resources_user where user_id=#{userId}
-            union select id as resources_id  from t_escheduler_resources where user_id=#{userId})
+            and id in (select resources_id from  t_ds_relation_resources_user where user_id=#{userId}
+            union select id as resources_id  from t_ds_resources where user_id=#{userId})
         </if>
         <if test="searchVal != null and searchVal != ''">
             and  alias like concat('%', #{searchVal}, '%')
@@ -40,17 +40,17 @@
     </select>
     <select id="queryAuthorizedResourceList" resultType="org.apache.dolphinscheduler.dao.entity.Resource">
         select r.*
-        from  t_escheduler_resources r,t_escheduler_relation_resources_user rel
+        from  t_ds_resources r,t_ds_relation_resources_user rel
         where r.id = rel.resources_id AND rel.user_id = #{userId}
     </select>
     <select id="queryResourceExceptUserId" resultType="org.apache.dolphinscheduler.dao.entity.Resource">
         select *
-        from  t_escheduler_resources
+        from  t_ds_resources
         where user_id <![CDATA[ <> ]]> #{userId}
     </select>
     <select id="queryTenantCodeByResourceName" resultType="java.lang.String">
         select tenant_code
-        from t_escheduler_tenant t, t_escheduler_user u, t_escheduler_resources res
+        from t_ds_tenant t, t_ds_user u, t_ds_resources res
         where t.id = u.tenant_id and u.id = res.user_id and res.type=0
         and res.alias= #{resName}
     </select>
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceUserMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceUserMapper.xml
index deeadac8d3ee893d4159e165c63a88873bfb18e2..5d452d4e7856f99b656e2ed4aa13827a198bcbab 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceUserMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ResourceUserMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ResourceUserMapper">
     <delete id="deleteResourceUser">
         delete
-        from t_escheduler_relation_resources_user
+        from t_ds_relation_resources_user
         where 1 = 1
         <if test="userId != 0">
             and user_id = #{userId}
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ScheduleMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ScheduleMapper.xml
index 51edd4aad988f4d9f9e48329ea59cc0e54127358..093fb7d963787cbd5e2f8320d659e25993c03e0f 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ScheduleMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ScheduleMapper.xml
@@ -3,10 +3,10 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.ScheduleMapper">
     <select id="queryByProcessDefineIdPaging" resultType="org.apache.dolphinscheduler.dao.entity.Schedule">
         select p_f.name as process_definition_name, p.name as project_name,u.user_name,s.*
-        from t_escheduler_schedules s
-        join t_escheduler_process_definition p_f on s.process_definition_id = p_f.id
-        join t_escheduler_project as p on p_f.project_id = p.id
-        join t_escheduler_user as u on s.user_id = u.id
+        from t_ds_schedules s
+        join t_ds_process_definition p_f on s.process_definition_id = p_f.id
+        join t_ds_project as p on p_f.project_id = p.id
+        join t_ds_user as u on s.user_id = u.id
         where 1=1
         <if test="processDefinitionId!= 0">
             and s.process_definition_id = #{processDefinitionId}
@@ -15,15 +15,15 @@
     </select>
     <select id="querySchedulerListByProjectName" resultType="org.apache.dolphinscheduler.dao.entity.Schedule">
         select p_f.name as process_definition_name, p_f.description as definition_description, p.name as project_name,u.user_name,s.*
-        from t_escheduler_schedules s
-        join t_escheduler_process_definition p_f on s.process_definition_id = p_f.id
-        join t_escheduler_project as p on p_f.project_id = p.id
-        join t_escheduler_user as u on s.user_id = u.id
+        from t_ds_schedules s
+        join t_ds_process_definition p_f on s.process_definition_id = p_f.id
+        join t_ds_project as p on p_f.project_id = p.id
+        join t_ds_user as u on s.user_id = u.id
         where p.name = #{projectName}
     </select>
     <select id="selectAllByProcessDefineArray" resultType="org.apache.dolphinscheduler.dao.entity.Schedule">
         select *
-        from t_escheduler_schedules
+        from t_ds_schedules
         where  1= 1
         <if test="processDefineIds != null and processDefineIds.length != 0 ">
             and process_definition_id in
@@ -35,7 +35,7 @@
     </select>
     <select id="queryByProcessDefinitionId" resultType="org.apache.dolphinscheduler.dao.entity.Schedule">
         select *
-        from t_escheduler_schedules
+        from t_ds_schedules
         where process_definition_id =#{processDefinitionId}
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/SessionMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/SessionMapper.xml
index e8fd7f3eb376e0aecc3603b63e99134fd26a621f..7647809e892182da62ef30868071ea0cf7c49ed1 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/SessionMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/SessionMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.SessionMapper">
     <select id="queryByUserId" resultType="org.apache.dolphinscheduler.dao.entity.Session">
         select *
-        from t_escheduler_session
+        from t_ds_session
         where user_id = #{userId}
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
index d60153e1de5a432c5702d621122d41b25f405e4e..a5e857cb11e4f124e92ca4cfcc518b52940bc415 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
@@ -2,32 +2,32 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.TaskInstanceMapper">
     <update id="setFailoverByHostAndStateArray">
-        update t_escheduler_task_instance
+        update t_ds_task_instance
         set state = #{destStatus}
         where host = #{host} and state in (#{states})
     </update>
     <select id="queryById" resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
         select *, UNIX_TIMESTAMP(end_time)-UNIX_TIMESTAMP(start_time) as duration
-        from t_escheduler_task_instance
+        from t_ds_task_instance
         where id=#{taskInstanceId}
     </select>
     <select id="queryTaskByProcessIdAndState" resultType="java.lang.Integer">
         select *, UNIX_TIMESTAMP(end_time)-UNIX_TIMESTAMP(start_time) as duration
-        from t_escheduler_task_instance
+        from t_ds_task_instance
         WHERE  process_instance_id = #{processInstanceId}
         and state = #{state}
         and flag = 1
     </select>
     <select id="findValidTaskListByProcessId" resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
         select *, UNIX_TIMESTAMP(end_time)-UNIX_TIMESTAMP(start_time) as duration
-        from t_escheduler_task_instance
+        from t_ds_task_instance
         WHERE  process_instance_id = #{processInstanceId}
         and flag = #{flag}
         order by start_time desc
     </select>
     <select id="queryByHostAndStatus" resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
         select *
-        from t_escheduler_task_instance
+        from t_ds_task_instance
         where 1 = 1
         <if test="host != null and host != ''">
             and host = #{host}
@@ -36,9 +36,9 @@
     </select>
     <select id="countTaskInstanceStateByUser" resultType="org.apache.dolphinscheduler.dao.entity.ExecuteStatusCount">
         select  state, count(0) as count
-        from t_escheduler_task_instance t
-        left join t_escheduler_process_definition  d on d.id=t.process_definition_id
-        left join t_escheduler_project p on p.id=d.project_id
+        from t_ds_task_instance t
+        left join t_ds_process_definition  d on d.id=t.process_definition_id
+        left join t_ds_project p on p.id=d.project_id
         where 1=1
         <if test="projectIds != null and projectIds != ''">
             and d.project_id in (#{projectIds})
@@ -48,14 +48,14 @@
     </select>
     <select id="queryByInstanceIdAndName" resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
         select  *
-        from t_escheduler_task_instance
+        from t_ds_task_instance
         where process_instance_id = #{processInstanceId}
         and `name` = #{name}
         and `flag` = 1
     </select>
     <select id="countTask" resultType="java.lang.Integer">
         select count(1) as `count`
-        from t_escheduler_task_instance task,t_escheduler_process_definition process
+        from t_ds_task_instance task,t_ds_process_definition process
         where task.process_definition_id=process.id
         <if test="projectIds != null and projectIds != ''">
             and process.project_id in (#{projectIds})
@@ -69,8 +69,8 @@
     </select>
     <select id="queryTaskInstanceListPaging" resultType="org.apache.dolphinscheduler.dao.entity.TaskInstance">
         select instance.*,process.name as process_instance_name, UNIX_TIMESTAMP(instance.end_time)-UNIX_TIMESTAMP(instance.start_time) as duration
-        from t_escheduler_task_instance instance
-        join t_escheduler_process_definition define ON instance.process_definition_id = define.id
+        from t_ds_task_instance instance
+        join t_ds_process_definition define ON instance.process_definition_id = define.id
         join  process on process.id=instance.process_instance_id
         where define.project_id = #{projectId}
         <if test="startTime != null">
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TenantMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TenantMapper.xml
index 91fede5406d167c3d0cee6588d599fb5ca49de97..7217e4a7bcd20eb5d3903241f4098395b6fedeea 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TenantMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TenantMapper.xml
@@ -3,18 +3,18 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.TenantMapper">
     <select id="queryById" resultType="org.apache.dolphinscheduler.dao.entity.Tenant">
             SELECT t.*,q.queue_name,q.queue
-            FROM t_escheduler_tenant t,t_escheduler_queue q
+            FROM t_ds_tenant t,t_ds_queue q
             WHERE t.queue_id = q.id
             and t.id = #{tenantId}
     </select>
     <select id="queryByTenantCode" resultType="org.apache.dolphinscheduler.dao.entity.Tenant">
       select *
-      from t_escheduler_tenant
+      from t_ds_tenant
       where tenant_code = #{tenantCode}
     </select>
     <select id="queryTenantPaging" resultType="org.apache.dolphinscheduler.dao.entity.Tenant">
         SELECT t.*,q.queue_name
-        FROM t_escheduler_tenant t,t_escheduler_queue q
+        FROM t_ds_tenant t,t_ds_queue q
         WHERE t.queue_id = q.id
         <if test="searchVal != null and searchVal != ''">
             and  t.tenant_name like concat('%', #{searchVal}, '%')
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UDFUserMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UDFUserMapper.xml
index a47c3e4b67608bc4127ad958a702fc4ab09df979..caa2a910ed4a63b993cfb87d6ed830f2ba9cb741 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UDFUserMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UDFUserMapper.xml
@@ -2,11 +2,11 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.UDFUserMapper">
     <delete id="deleteByUserId">
-        delete from t_escheduler_relation_udfs_user
+        delete from t_ds_relation_udfs_user
         where `user_id` = #{userId}
     </delete>
     <delete id="deleteByUdfFuncId">
-        delete from t_escheduler_relation_udfs_user
+        delete from t_ds_relation_udfs_user
         where `udf_id` = #{udfFuncId}
     </delete>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UdfFuncMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UdfFuncMapper.xml
index e8bafc5c4d091a0e85ccbaebfb9b3cf7a02271af..db63fe98f0322b3635d2043a97522dacd391998f 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UdfFuncMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UdfFuncMapper.xml
@@ -3,7 +3,7 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.UdfFuncMapper">
     <select id="queryUdfByIdStr" resultType="org.apache.dolphinscheduler.dao.entity.UdfFunc">
         select *
-        from t_escheduler_udfs
+        from t_ds_udfs
         where 1 = 1
         <if test="ids != null and ids != ''">
             and id in
@@ -18,36 +18,36 @@
     </select>
     <select id="queryUdfFuncPaging" resultType="org.apache.dolphinscheduler.dao.entity.UdfFunc">
         select *
-        from t_escheduler_udfs
+        from t_ds_udfs
         where 1=1
         <if test="searchVal!= null and searchVal != ''">
             and `name` like concat('%', #{searchVal}, '%')
         </if>
         <if test="userId != 0">
             and id in (
-              select udf_id from t_escheduler_relation_udfs_user where user_id=#{userId}
-              union select id as udf_id  from t_escheduler_udfs where user_id=#{userId})
+              select udf_id from t_ds_relation_udfs_user where user_id=#{userId}
+              union select id as udf_id  from t_ds_udfs where user_id=#{userId})
         </if>
         order by create_time desc
     </select>
     <select id="getUdfFuncByType" resultType="org.apache.dolphinscheduler.dao.entity.UdfFunc">
         select *
-        from t_escheduler_udfs
+        from t_ds_udfs
         where `type` = #{type}
         <if test="userId != 0">
             and id in (
-            select udf_id from t_escheduler_relation_udfs_user where user_id=#{userId}
-            union select id as udf_id  from t_escheduler_udfs where user_id=#{userId})
+            select udf_id from t_ds_relation_udfs_user where user_id=#{userId}
+            union select id as udf_id  from t_ds_udfs where user_id=#{userId})
         </if>
     </select>
     <select id="queryUdfFuncExceptUserId" resultType="org.apache.dolphinscheduler.dao.entity.UdfFunc">
         select *
-        from t_escheduler_udfs
+        from t_ds_udfs
         where user_id <![CDATA[ <> ]]> #{userId}
     </select>
     <select id="queryAuthedUdfFunc" resultType="org.apache.dolphinscheduler.dao.entity.UdfFunc">
         SELECT u.*
-        from t_escheduler_udfs u,t_escheduler_relation_udfs_user rel
+        from t_ds_udfs u,t_ds_relation_udfs_user rel
         WHERE u.id = rel.udf_id
         AND rel.user_id = #{userId}
     </select>
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserAlertGroupMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserAlertGroupMapper.xml
index 51835894db4eb0401f555cb986b23a8a445201d9..b1ea9e264fc5f60754a7f46d54d7ae6586150c77 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserAlertGroupMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserAlertGroupMapper.xml
@@ -2,13 +2,13 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.UserAlertGroupMapper">
     <delete id="deleteByAlertgroupId">
-        delete from t_escheduler_relation_user_alertgroup
+        delete from t_ds_relation_user_alertgroup
         where `alertgroup_id` = #{alertgroupId}
     </delete>
     <select id="listUserByAlertgroupId" resultType="org.apache.dolphinscheduler.dao.entity.User">
            SELECT u.*
-           FROM t_escheduler_relation_user_alertgroup g_u
-           JOIN t_escheduler_user u on g_u.user_id = u.id
+           FROM t_ds_relation_user_alertgroup g_u
+           JOIN t_ds_user u on g_u.user_id = u.id
            WHERE g_u.alertgroup_id = #{alertgroupId}
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserMapper.xml
index 39dd9871bcd754a16967fab0045c321ecfe3b79d..55562ce6e85e1bb6a68c95019bb2a203c2e9050e 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/UserMapper.xml
@@ -3,15 +3,15 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.UserMapper">
 
     <select id="queryAllGeneralUser" resultType="org.apache.dolphinscheduler.dao.entity.User">
-        select * from t_escheduler_user
+        select * from t_ds_user
         where user_type=1;
     </select>
     <select id="queryByUserNameAccurately" resultType="org.apache.dolphinscheduler.dao.entity.User">
-        select * from t_escheduler_user
+        select * from t_ds_user
         where user_name=#{userName}
     </select>
     <select id="queryUserByNamePassword" resultType="org.apache.dolphinscheduler.dao.entity.User">
-        select * from t_escheduler_user
+        select * from t_ds_user
         where user_name=#{userName} and user_password = #{password}
     </select>
 
@@ -19,9 +19,9 @@
         select u.id,u.user_name,u.user_password,u.user_type,u.email,u.phone,u.tenant_id,u.create_time,
         u.update_time,t.tenant_name,
         case when u.queue  <![CDATA[ <> ]]> '' then u.queue else q.queue_name end as queue, q.queue_name
-        from t_escheduler_user u
-        left join t_escheduler_tenant t on u.tenant_id=t.id
-        left join t_escheduler_queue q on t.queue_id = q.id
+        from t_ds_user u
+        left join t_ds_tenant t on u.tenant_id=t.id
+        left join t_ds_queue q on t.queue_id = q.id
         where 1=1
         <if test="userName!=null and userName != ''" >
              and u.user_name like concat ('%', #{userName}, '%')
@@ -32,24 +32,24 @@
     <select id="queryDetailsById" resultType="org.apache.dolphinscheduler.dao.entity.User">
         select u.*, t.tenant_name,
         case when u.queue <![CDATA[ <> ]]>  '' then u.queue else q.queue_name end as queue_name
-        from t_escheduler_user u,t_escheduler_tenant t,t_escheduler_queue q
+        from t_ds_user u,t_ds_tenant t,t_ds_queue q
         WHERE u.tenant_id = t.id and t.queue_id = q.id and u.id = #{userId}
     </select>
 
     <select id="queryUserListByAlertGroupId" resultType="org.apache.dolphinscheduler.dao.entity.User">
       select u.*
-      from t_escheduler_user u, t_escheduler_relation_user_alertgroup rel
+      from t_ds_user u, t_ds_relation_user_alertgroup rel
       where u.id = rel.user_id AND u.user_type = 1 AND rel.alertgroup_id = #{alertgroupId}
     </select>
 
     <select id="queryTenantCodeByUserId" resultType="org.apache.dolphinscheduler.dao.entity.User">
         SELECT  u.*,t.tenant_code
-        FROM  t_escheduler_user u, t_escheduler_tenant t
+        FROM  t_ds_user u, t_ds_tenant t
         WHERE u.tenant_id = t.id AND u.id = #{userId}
     </select>
     <select id="queryUserByToken" resultType="org.apache.dolphinscheduler.dao.entity.User">
         select u.*
-        from t_escheduler_user u ,t_escheduler_access_token t
+        from t_ds_user u ,t_ds_access_token t
         where u.id = t.user_id and token=#{token} and t.expire_time > NOW()
     </select>
 </mapper>
\ No newline at end of file
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkerGroupMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkerGroupMapper.xml
index 0bc7b3a89142f4d63bad48afb596fb414aa1c169..1ff7c0742ee1764ae741fc9a6ba1c371d06fdb42 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkerGroupMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkerGroupMapper.xml
@@ -3,17 +3,17 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.WorkerGroupMapper">
     <select id="queryAllWorkerGroup" resultType="org.apache.dolphinscheduler.dao.entity.WorkerGroup">
         select *
-        from t_escheduler_worker_group
+        from t_ds_worker_group
         order by update_time desc
     </select>
     <select id="queryWorkerGroupByName" resultType="org.apache.dolphinscheduler.dao.entity.WorkerGroup">
         select *
-        from t_escheduler_worker_group
+        from t_ds_worker_group
         where `name` = #{name}
     </select>
     <select id="queryListPaging" resultType="org.apache.dolphinscheduler.dao.entity.WorkerGroup">
         select *
-        from t_escheduler_worker_group
+        from t_ds_worker_group
         where 1 = 1
         <if test="searchVal != null and searchVal != ''">
             and  name like concat('%', #{searchVal}, '%')