test/datacap
1
0
Fork 0
mirror of https://gitee.com/devlive-community/datacap.git synced 2024-12-02 20:17:45 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

[Core] [Source] Adapter metadata convert

Browse Source
This commit is contained in:
qianmoQ 2024-06-10 00:21:14 +08:00
parent 51c26a340c
commit 4dfbbd9c3c
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/datacap-service/src/main/java/io/edurt/datacap/service/service/impl/DataSetServiceImpl.java
View File

@ -728,7 +728,8 @@ public class DataSetServiceImpl
SqlColumn.builder().column("active").operator(SqlOperator.EQ).value("1").build()))
.condition(" AND ")
.build());
configure.setFormat("");
configure.setFormat("None");
configure.setInjector(injector);
plugin.connect(configure);
Response outputResponse = plugin.execute(builder.getSql());
if (outputResponse.getIsSuccessful()) {

16
core/datacap-service/src/main/java/io/edurt/datacap/service/service/impl/TableServiceImpl.java
View File

@ -329,7 +329,7 @@ public class TableServiceImpl
List<SqlColumn> columns = Lists.newArrayList();
int totalRows = Integer.parseInt(table.getRows());
Configure countConfigure = source.toConfigure();
countConfigure.setFormat("");
countConfigure.setFormat("None");
countConfigure.setInjector(injector);
plugin.connect(countConfigure);
SqlBody countBody = SqlBody.builder()
@ -430,7 +430,7 @@ public class TableServiceImpl
{
try {
Configure updateConfigure = source.toConfigure();
updateConfigure.setFormat("");
updateConfigure.setFormat("None");
updateConfigure.setInjector(injector);
plugin.connect(updateConfigure);
List<String> allSql = Lists.newArrayList();
@ -488,7 +488,7 @@ public class TableServiceImpl
{
try {
Configure updateConfigure = source.toConfigure();
updateConfigure.setFormat("");
updateConfigure.setFormat("None");
updateConfigure.setInjector(injector);
plugin.connect(updateConfigure);
List<String> allSql = Lists.newArrayList();
@ -526,7 +526,7 @@ public class TableServiceImpl
{
try {
Configure updateConfigure = source.toConfigure();
updateConfigure.setFormat("");
updateConfigure.setFormat("None");
updateConfigure.setInjector(injector);
plugin.connect(updateConfigure);
List<String> allSql = Lists.newArrayList();
@ -560,7 +560,7 @@ public class TableServiceImpl
{
try {
Configure alterConfigure = source.toConfigure();
alterConfigure.setFormat("");
alterConfigure.setFormat("None");
alterConfigure.setInjector(injector);
plugin.connect(alterConfigure);
SqlBody body = SqlBody.builder()
@ -589,7 +589,7 @@ public class TableServiceImpl
{
try {
Configure alterConfigure = source.toConfigure();
alterConfigure.setFormat("");
alterConfigure.setFormat("None");
alterConfigure.setInjector(injector);
plugin.connect(alterConfigure);
SqlBody body = SqlBody.builder()
@ -617,7 +617,7 @@ public class TableServiceImpl
{
try {
Configure alterConfigure = source.toConfigure();
alterConfigure.setFormat("");
alterConfigure.setFormat("None");
alterConfigure.setInjector(injector);
plugin.connect(alterConfigure);
SqlBody body = SqlBody.builder()
@ -645,7 +645,7 @@ public class TableServiceImpl
{
try {
Configure alterConfigure = source.toConfigure();
alterConfigure.setFormat("");
alterConfigure.setFormat("None");
alterConfigure.setInjector(injector);
plugin.connect(alterConfigure);
SqlBody body = SqlBody.builder()