|
|
@@ -13,16 +13,16 @@ import com.server.dataSource.DataConnectorService;
|
|
|
import com.server.dataSource.ImplementSqlService;
|
|
|
import com.model.pojo.annotation.TargetDataSource;
|
|
|
import com.config.RoleInterceptor.Auth;
|
|
|
+import io.swagger.annotations.Api;
|
|
|
+import io.swagger.annotations.ApiOperation;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.web.bind.annotation.RequestBody;
|
|
|
-import org.springframework.web.bind.annotation.RequestHeader;
|
|
|
-import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
-import org.springframework.web.bind.annotation.RestController;
|
|
|
+import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
@RestController
|
|
|
@RequestMapping("/Connector")
|
|
|
+@Api(description = "数据源相关接口")
|
|
|
public class DataConnectorController {
|
|
|
@Autowired
|
|
|
DataConnectorService dataConnectorService;
|
|
|
@@ -33,9 +33,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
保存数据源配置
|
|
|
*/
|
|
|
+ @ApiOperation(value = "保存数据源配置", notes = "保存数据源配置", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
@Auth(user = "admin")
|
|
|
- @RequestMapping("/inputDataConnector")
|
|
|
+ @PostMapping("/inputDataConnector")
|
|
|
public RepEntity inputDataConnector(@RequestHeader String token, @RequestBody DataConnectorInfo body) {
|
|
|
System.out.println("-----------");
|
|
|
System.out.println(body);
|
|
|
@@ -45,8 +46,9 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
查看数据源列表
|
|
|
*/
|
|
|
+ @ApiOperation(value = "查看数据源列表", notes = "查看数据源列表", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/getListDataConnector")
|
|
|
+ @PostMapping("/getListDataConnector")
|
|
|
public RepEntity getListDataConnector(@RequestHeader String token, @RequestBody TestPage body){
|
|
|
return dataConnectorService.getListConnector(token, body);
|
|
|
}
|
|
|
@@ -54,9 +56,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
查看单个数据源配置
|
|
|
*/
|
|
|
+ @ApiOperation(value = "查看单个数据源配置", notes = "查看单个数据源配置", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
@Auth(user = "admin")
|
|
|
- @RequestMapping("/getDataConnector")
|
|
|
+ @PostMapping("/getDataConnector")
|
|
|
public RepEntity getDataConnector(@RequestHeader String token,@RequestBody int body){
|
|
|
return dataConnectorService.getConnector(body);
|
|
|
}
|
|
|
@@ -64,9 +67,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
更新数据源配置
|
|
|
*/
|
|
|
+ @ApiOperation(value = "更新数据源配置", notes = "更新数据源配置", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
@Auth(user = "admin")
|
|
|
- @RequestMapping("/updateData")
|
|
|
+ @PostMapping("/updateData")
|
|
|
public RepEntity updateData(@RequestHeader String token,@RequestBody DataConnectorInfo body){
|
|
|
return dataConnectorService.updateData(body);
|
|
|
}
|
|
|
@@ -74,8 +78,9 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
转交数据源
|
|
|
*/
|
|
|
+ @ApiOperation(value = "转交数据源", notes = "转交数据源", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/changeDbOrder")
|
|
|
+ @PostMapping("/changeDbOrder")
|
|
|
public RepEntity changeDbOrder(@RequestHeader String token,@RequestBody ChangeOrderInfo body){
|
|
|
return dataConnectorService.changeOrder(body, token);
|
|
|
}
|
|
|
@@ -83,9 +88,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
更新数据源配置的分组
|
|
|
*/
|
|
|
+ @ApiOperation(value = "更新数据源配置分组", notes = "更新数据源配置分组", response = RepEntity.class)
|
|
|
@Auth(user = "admin")
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/updateConnectConfigGroup")
|
|
|
+ @PostMapping("/updateConnectConfigGroup")
|
|
|
public RepEntity updateConConfigGroup(@RequestHeader String token,@RequestBody GroupUpdateId body){
|
|
|
return dataConnectorService.updateConfigGroup(body);
|
|
|
}
|
|
|
@@ -94,9 +100,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
删除配置
|
|
|
*/
|
|
|
+ @ApiOperation(value = "删除配置", notes = "删除配置", response = RepEntity.class)
|
|
|
@Auth(user = "admin")
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/delDataConnector")
|
|
|
+ @PostMapping("/delDataConnector")
|
|
|
public RepEntity delDataConnector(@RequestHeader String token,@RequestBody List<Integer> body){
|
|
|
return dataConnectorService.delDataConnector(body);
|
|
|
}
|
|
|
@@ -104,9 +111,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
执行数据源配置
|
|
|
*/
|
|
|
+ @ApiOperation(value = "执行数据源配置", notes = "执行数据源配置", response = RepEntity.class)
|
|
|
@TargetDataSource
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/implementSql")
|
|
|
+ @PostMapping("/implementSql")
|
|
|
@Auth(user = "admin")
|
|
|
public RepEntity implementSql(@RequestHeader String token,@RequestBody ToSql body){
|
|
|
return implementSqlService.implementSql(body);
|
|
|
@@ -115,8 +123,9 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
添加数据源分组
|
|
|
*/
|
|
|
+ @ApiOperation(value = "添加数据源分组", notes = "添加数据源分组", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/setConnectorGroup")
|
|
|
+ @PostMapping("/setConnectorGroup")
|
|
|
@Auth(user = "admin")
|
|
|
public RepEntity setConnectorGroup(@RequestHeader String token,@RequestBody GroupInfo body){
|
|
|
return dataConnectorService.setDataConnectorGroup(body);
|
|
|
@@ -125,9 +134,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
更新数据源分组
|
|
|
*/
|
|
|
+ @ApiOperation(value = "更新数据源分组", notes = "更新数据源分组", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
@Auth(user = "admin")
|
|
|
- @RequestMapping("/updataDataConnectorGroup")
|
|
|
+ @PostMapping("/updataDataConnectorGroup")
|
|
|
public RepEntity updataDataConnectorGroup(@RequestHeader String token,@RequestBody GroupInfo body){
|
|
|
return dataConnectorService.updataDataConnectorGroup(body);
|
|
|
}
|
|
|
@@ -135,9 +145,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
批量更新数据源分组
|
|
|
*/
|
|
|
+ @ApiOperation(value = "批量更新数据源分组", notes = "批量更新数据源分组", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
@Auth(user = "admin")
|
|
|
- @RequestMapping("/updataConnectorGroup")
|
|
|
+ @PostMapping("/updataConnectorGroup")
|
|
|
public RepEntity updataConnectorGroup(@RequestHeader String token,@RequestBody List<GroupInfo> body){
|
|
|
return dataConnectorService.updataConnectorGroups(body);
|
|
|
}
|
|
|
@@ -145,9 +156,10 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
删除数据源分组
|
|
|
*/
|
|
|
+ @ApiOperation(value = "删除数据源分组", notes = "删除数据源分组", response = RepEntity.class)
|
|
|
@Auth(user = "admin")
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/delDataConnectorGroup")
|
|
|
+ @PostMapping("/delDataConnectorGroup")
|
|
|
public RepEntity delDataConnectorGroup(@RequestHeader String token,@RequestBody List<Integer> body){
|
|
|
return dataConnectorService.delDataConnectorGroup(body);
|
|
|
}
|
|
|
@@ -155,8 +167,9 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
查询数据源分组
|
|
|
*/
|
|
|
+ @ApiOperation(value = "查询数据源分组", notes = "查询数据源分组", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/getConnectorGroup")
|
|
|
+ @PostMapping("/getConnectorGroup")
|
|
|
public RepEntity getConnectorGroup(@RequestHeader String token){
|
|
|
return dataConnectorService.getConnectorGroup();
|
|
|
}
|
|
|
@@ -164,8 +177,9 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
查询数据源数据
|
|
|
*/
|
|
|
+ @ApiOperation(value = "查询数据源数据", notes = "查询数据源数据", response = RepEntity.class)
|
|
|
@CheckToken
|
|
|
- @RequestMapping("/getConnectorData")
|
|
|
+ @PostMapping("/getConnectorData")
|
|
|
public RepEntity getConnectorData(@RequestHeader String token, @RequestBody BaseToDataInfo body){
|
|
|
return dataConnectorService.getConnectorData(token, body);
|
|
|
}
|