feat:增加可以根据PROJECT_ID获取数据库分片信息的接口 TencentBlueKing#6186

yjieliang · Mar 2, 2022 · 2a95c20 · 2a95c20
1 parent 1c3bda6
commit 2a95c20
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/.../core/project/biz-project/src/main/kotlin/com/tencent/devops/project/dao/DataSourceDao.kt b/.../core/project/biz-project/src/main/kotlin/com/tencent/devops/project/dao/DataSourceDao.kt
@@ -125,9 +125,16 @@ class DataSourceDao {
         }
     }
 
-    fun getDataBasePiecewiseById(dslContext: DSLContext, projectId: String, moduleCode: String, clusterName: String): TDataSourceRecord? {
+    fun getDataBasePiecewiseById(dslContext: DSLContext,
+                                 projectId: String,
+                                 moduleCode: String,
+                                 clusterName: String
+    ): TDataSourceRecord? {
         val tr = TShardingRoutingRule.T_SHARDING_ROUTING_RULE
-        val routingRule = dslContext.select(tr.ROUTING_RULE).from(tr).where(tr.ROUTING_NAME.eq(projectId)).fetchOne()
+        val routingRule = dslContext.select(tr.ROUTING_RULE)
+            .from(tr)
+            .where(tr.ROUTING_NAME.eq(projectId))
+            .fetchOne()
             if (routingRule != null && routingRule[0] != null) {
                 with(TDataSource.T_DATA_SOURCE) {
                     return dslContext.selectFrom(this)