Skip to content

Commit

Permalink
feat: add set data to empty for platine batch (#51)
Browse files Browse the repository at this point in the history
* feat: add set data to empty for platine batch
  • Loading branch information
BettyB979 authored Feb 23, 2024
1 parent 6428952 commit 5b4533d
Show file tree
Hide file tree
Showing 4 changed files with 22 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>fr.insee.queen</groupId>
<artifactId>queen-batch</artifactId>
<version>4.2.1</version>
<version>4.2.2</version>
<packaging>jar</packaging>
<name>QueenBatch</name>
<description>Queen Batch</description>
Expand Down Expand Up @@ -164,7 +164,7 @@
</dependency>
</dependencies>

<build>
<build>
<pluginManagement>
<plugins>
<plugin>
Expand Down
6 changes: 6 additions & 0 deletions src/main/java/fr/insee/queen/batch/dao/DataDao.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,12 @@ public interface DataDao {
*/
int deleteDataBySurveyUnitIds(List<String> lstSu);

/**
* Set data to empty json for a list of SU
* @param lstSu
*/
int setDataToEmptyBySurveyUnitIds(List<String> lstSu);

/**
* Delete data by a campaign Id
* @param campaignId
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,15 @@ public int deleteDataBySurveyUnitIds(List<String> lstSu) {
return jdbcTemplate.update(qString, lstSu.toArray());
}

@Override
public int setDataToEmptyBySurveyUnitIds(List<String> lstSu) {
String values = lstSu.stream().map(id->"?").collect(Collectors.joining(","));
StringBuilder qStringBuilder = new StringBuilder("UPDATE data SET value='{}'::jsonb ")
.append("WHERE survey_unit_id in (%s)");
String qString = String.format(qStringBuilder.toString(), values);
return jdbcTemplate.update(qString, lstSu.toArray());
}

/**
* Delete data for a campaign
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,11 @@ public int deleteDataBySurveyUnitIds(List<String> lstSu) {
return nb.get();
}

@Override
public int setDataToEmptyBySurveyUnitIds(List<String> lstSu) {
return 0;
}

/**
* Delete the data for a Campaign id
*/
Expand Down

0 comments on commit 5b4533d

Please sign in to comment.