opensource/Chat2DB
1
0
Fork 0
mirror of https://github.com/CodePhiliaX/Chat2DB.git synced 2025-08-01 08:52:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

support table edit

Browse Source
This commit is contained in:
SwallowGG
2023-09-28 17:29:33 +08:00
parent ce268dcd38
commit 2bd870b46f
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
chat2db-server/chat2db-server-web/chat2db-server-web-api/src/main/java/ai/chat2db/server/web/api/controller/rdb/RdbDmlController.java
View File

@ -61,13 +61,13 @@ public class RdbDmlController {
* @return
*/
@RequestMapping(value = "/execute_ddl", method = {RequestMethod.POST, RequestMethod.PUT})
public DataResult<Long> executeDDL(@RequestBody DmlRequest request) {
public DataResult<ExecuteResultVO> executeDDL(@RequestBody DmlRequest request) {
DlExecuteParam param = rdbWebConverter.request2param(request);
Connection connection = Chat2DBContext.getConnection();
if (connection != null) {
try {
boolean flag = true;
String message = "";
ExecuteResultVO executeResult = null;
connection.setAutoCommit(false);
ListResult<ExecuteResult> resultDTOListResult = dlTemplateService.execute(param);
List<ExecuteResultVO> resultVOS = rdbWebConverter.dto2vo(resultDTOListResult.getData());
@ -75,15 +75,18 @@ public class RdbDmlController {
for (ExecuteResultVO resultVO : resultVOS) {
if (!resultVO.getSuccess()) {
flag = false;
executeResult = resultVO;
break;
}
}
}
if (flag) {
connection.commit();
return DataResult.of(1L);
return DataResult.of(resultVOS.get(0));
}else {
connection.rollback();
return DataResult.error("sql error",message);
return DataResult.of(executeResult);
}
} catch (Exception e) {
throw new RuntimeException(e);