mirror of
https://github.com/Kingsrook/qqq.git
synced 2025-07-18 05:01:07 +00:00
CE-537 - Updating to support API Delete
This commit is contained in:
@ -32,6 +32,7 @@ import com.kingsrook.qqq.backend.core.model.metadata.QBackendMetaData;
|
|||||||
import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableBackendDetails;
|
import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableBackendDetails;
|
||||||
import com.kingsrook.qqq.backend.core.modules.backend.QBackendModuleInterface;
|
import com.kingsrook.qqq.backend.core.modules.backend.QBackendModuleInterface;
|
||||||
import com.kingsrook.qqq.backend.module.api.actions.APICountAction;
|
import com.kingsrook.qqq.backend.module.api.actions.APICountAction;
|
||||||
|
import com.kingsrook.qqq.backend.module.api.actions.APIDeleteAction;
|
||||||
import com.kingsrook.qqq.backend.module.api.actions.APIGetAction;
|
import com.kingsrook.qqq.backend.module.api.actions.APIGetAction;
|
||||||
import com.kingsrook.qqq.backend.module.api.actions.APIInsertAction;
|
import com.kingsrook.qqq.backend.module.api.actions.APIInsertAction;
|
||||||
import com.kingsrook.qqq.backend.module.api.actions.APIQueryAction;
|
import com.kingsrook.qqq.backend.module.api.actions.APIQueryAction;
|
||||||
@ -136,7 +137,7 @@ public class APIBackendModule implements QBackendModuleInterface
|
|||||||
@Override
|
@Override
|
||||||
public DeleteInterface getDeleteInterface()
|
public DeleteInterface getDeleteInterface()
|
||||||
{
|
{
|
||||||
return (null); //return (new RDBMSDeleteAction());
|
return (new APIDeleteAction());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -0,0 +1,59 @@
|
|||||||
|
/*
|
||||||
|
* QQQ - Low-code Application Framework for Engineers.
|
||||||
|
* Copyright (C) 2021-2022. Kingsrook, LLC
|
||||||
|
* 651 N Broad St Ste 205 # 6917 | Middletown DE 19709 | United States
|
||||||
|
* contact@kingsrook.com
|
||||||
|
* https://github.com/Kingsrook/
|
||||||
|
*
|
||||||
|
* This program is free software: you can redistribute it and/or modify
|
||||||
|
* it under the terms of the GNU Affero General Public License as
|
||||||
|
* published by the Free Software Foundation, either version 3 of the
|
||||||
|
* License, or (at your option) any later version.
|
||||||
|
*
|
||||||
|
* This program is distributed in the hope that it will be useful,
|
||||||
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
* GNU Affero General Public License for more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU Affero General Public License
|
||||||
|
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package com.kingsrook.qqq.backend.module.api.actions;
|
||||||
|
|
||||||
|
|
||||||
|
import com.kingsrook.qqq.backend.core.actions.interfaces.DeleteInterface;
|
||||||
|
import com.kingsrook.qqq.backend.core.exceptions.QException;
|
||||||
|
import com.kingsrook.qqq.backend.core.model.actions.tables.delete.DeleteInput;
|
||||||
|
import com.kingsrook.qqq.backend.core.model.actions.tables.delete.DeleteOutput;
|
||||||
|
import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableMetaData;
|
||||||
|
|
||||||
|
|
||||||
|
/*******************************************************************************
|
||||||
|
**
|
||||||
|
*******************************************************************************/
|
||||||
|
public class APIDeleteAction extends AbstractAPIAction implements DeleteInterface
|
||||||
|
{
|
||||||
|
/*******************************************************************************
|
||||||
|
**
|
||||||
|
*******************************************************************************/
|
||||||
|
public DeleteOutput execute(DeleteInput deleteInput) throws QException
|
||||||
|
{
|
||||||
|
QTableMetaData table = deleteInput.getTable();
|
||||||
|
preAction(deleteInput);
|
||||||
|
return (apiActionUtil.doDelete(table, deleteInput));
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
/*******************************************************************************
|
||||||
|
** Specify whether this particular module's update action can & should fetch
|
||||||
|
** records before updating them, e.g., for audits or "not-found-checks"
|
||||||
|
*******************************************************************************/
|
||||||
|
@Override
|
||||||
|
public boolean supportsPreFetchQuery()
|
||||||
|
{
|
||||||
|
return (false);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
@ -43,6 +43,8 @@ import com.kingsrook.qqq.backend.core.logging.QLogger;
|
|||||||
import com.kingsrook.qqq.backend.core.model.actions.AbstractTableActionInput;
|
import com.kingsrook.qqq.backend.core.model.actions.AbstractTableActionInput;
|
||||||
import com.kingsrook.qqq.backend.core.model.actions.tables.count.CountInput;
|
import com.kingsrook.qqq.backend.core.model.actions.tables.count.CountInput;
|
||||||
import com.kingsrook.qqq.backend.core.model.actions.tables.count.CountOutput;
|
import com.kingsrook.qqq.backend.core.model.actions.tables.count.CountOutput;
|
||||||
|
import com.kingsrook.qqq.backend.core.model.actions.tables.delete.DeleteInput;
|
||||||
|
import com.kingsrook.qqq.backend.core.model.actions.tables.delete.DeleteOutput;
|
||||||
import com.kingsrook.qqq.backend.core.model.actions.tables.get.GetInput;
|
import com.kingsrook.qqq.backend.core.model.actions.tables.get.GetInput;
|
||||||
import com.kingsrook.qqq.backend.core.model.actions.tables.get.GetOutput;
|
import com.kingsrook.qqq.backend.core.model.actions.tables.get.GetOutput;
|
||||||
import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertInput;
|
import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertInput;
|
||||||
@ -79,6 +81,7 @@ import org.apache.http.HttpEntityEnclosingRequest;
|
|||||||
import org.apache.http.HttpResponse;
|
import org.apache.http.HttpResponse;
|
||||||
import org.apache.http.HttpStatus;
|
import org.apache.http.HttpStatus;
|
||||||
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
||||||
|
import org.apache.http.client.methods.HttpDelete;
|
||||||
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
|
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
|
||||||
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.client.methods.HttpGet;
|
||||||
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.client.methods.HttpPost;
|
||||||
@ -384,6 +387,41 @@ public class BaseAPIActionUtil
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
/*******************************************************************************
|
||||||
|
**
|
||||||
|
*
|
||||||
|
*******************************************************************************/
|
||||||
|
public DeleteOutput doDelete(QTableMetaData table, DeleteInput deleteInput) throws QException
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
DeleteOutput deleteOutput = new DeleteOutput();
|
||||||
|
|
||||||
|
String urlSuffix = buildQueryStringForDelete(deleteInput.getQueryFilter(), deleteInput.getPrimaryKeys());
|
||||||
|
String url = buildTableUrl(table);
|
||||||
|
HttpDelete request = new HttpDelete(url + urlSuffix);
|
||||||
|
|
||||||
|
QHttpResponse response = makeRequest(table, request);
|
||||||
|
if(response.getStatusCode() == 204)
|
||||||
|
{
|
||||||
|
deleteOutput.setDeletedRecordCount(1);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
deleteOutput.setDeletedRecordCount(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
return (deleteOutput);
|
||||||
|
}
|
||||||
|
catch(Exception e)
|
||||||
|
{
|
||||||
|
LOG.error("Error in API Delete", e);
|
||||||
|
throw new QException("Error executing Delete: " + e.getMessage(), e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/*******************************************************************************
|
/*******************************************************************************
|
||||||
**
|
**
|
||||||
*******************************************************************************/
|
*******************************************************************************/
|
||||||
@ -601,6 +639,17 @@ public class BaseAPIActionUtil
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
/*******************************************************************************
|
||||||
|
** method to build up delete string based on a given QFilter object
|
||||||
|
**
|
||||||
|
*******************************************************************************/
|
||||||
|
protected String buildQueryStringForDelete(QQueryFilter filter, List<Serializable> primaryKeys) throws QException
|
||||||
|
{
|
||||||
|
return ("");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/*******************************************************************************
|
/*******************************************************************************
|
||||||
** Do a default query string for a single-record GET - e.g., a query for just 1 record.
|
** Do a default query string for a single-record GET - e.g., a query for just 1 record.
|
||||||
*******************************************************************************/
|
*******************************************************************************/
|
||||||
|
@ -69,7 +69,10 @@ public class QHttpResponse
|
|||||||
this.statusProtocolVersion = httpResponse.getStatusLine().getProtocolVersion().toString();
|
this.statusProtocolVersion = httpResponse.getStatusLine().getProtocolVersion().toString();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
this.content = EntityUtils.toString(httpResponse.getEntity());
|
if(httpResponse.getEntity() != null)
|
||||||
|
{
|
||||||
|
this.content = EntityUtils.toString(httpResponse.getEntity());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user