diff --git a/pom.xml b/pom.xml
index ddefd22..74ff4fa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -40,7 +40,11 @@
             <artifactId>postgresql</artifactId>
             <version>${postgresql.version}</version>
         </dependency>
-
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.27</version>
+        </dependency>
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>
diff --git a/src/main/java/sdk_996/mapper/SqlExecuteMapper.java b/src/main/java/sdk_996/mapper/SqlExecuteMapper.java
index f2f5798..89428fb 100644
--- a/src/main/java/sdk_996/mapper/SqlExecuteMapper.java
+++ b/src/main/java/sdk_996/mapper/SqlExecuteMapper.java
@@ -1,5 +1,6 @@
 package sdk_996.mapper;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Select;
@@ -9,9 +10,13 @@ import java.util.Map;
 
 @Mapper
 public interface SqlExecuteMapper extends BaseMapper<Object> {
-
+    @DS("master_1")
     @Select("${value}")
-    List<Map<String, Object>> sqlQuery(String value);
+    List<Map<String, Object>> sql_pgsql_Query(String value);
+
+    @DS("master_2")
+    @Select("${value}")
+    List<Map<String, Object>> sql_mysql_Query(String value);
 
 
 }
diff --git a/src/main/java/sdk_996/service/SqlExecuteService.java b/src/main/java/sdk_996/service/SqlExecuteService.java
index b7bb280..7c51bf1 100644
--- a/src/main/java/sdk_996/service/SqlExecuteService.java
+++ b/src/main/java/sdk_996/service/SqlExecuteService.java
@@ -25,7 +25,7 @@ public class SqlExecuteService {
     @Autowired
     private SqlExecuteMapper sqlExecuteMapper;
 
-    public JSONObject performCustomQuery(String sqlstr) {
+    public JSONObject  performCustomQuery(String sqlstr) {
         // 返回的json对象
         JSONObject returnJsonObject = new JSONObject();
         JSONObject sqlJsonObject;
@@ -70,7 +70,7 @@ public class SqlExecuteService {
 
             long startTime = System.currentTimeMillis();
             // 执行 SQL 查询
-            List<Map<String, Object>> resultList = sqlExecuteMapper.sqlQuery(sqlStr);
+            List<Map<String, Object>> resultList = sqlExecuteMapper.sql_mysql_Query(sqlStr);
             long endTime = System.currentTimeMillis();
             logger.info("sql执行时长:{}ms  执行sql:{}", (endTime - startTime), sqlStr);
 
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 75856c0..0ea7043 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -16,6 +16,17 @@ spring:
             connection-timeout: 30000
             idle-timeout: 600000
             max-lifetime: 1800000
+        master_2:
+          url: jdbc:mysql://yin520.cn:3306/996
+          username: root
+          password: yin520.cn
+          driver-class-name: com.mysql.jdbc.Driver
+          hikari:
+            minimum-idle: 10
+            maximum-pool-size: 100
+            connection-timeout: 30000
+            idle-timeout: 600000
+            max-lifetime: 1800000
 
 #logging:
 #  level: