[Git][ultreiaio/ird-observe][develop] 3 commits: move metadata model to service sql and clean all API - See ultreiaio/topia-extension#112 - Observe-commits

8 Mar 2022


      Tony CHEMIT pushed to branch develop at ultreiaio / ird-observe


Commits:
eb1c342b by Tony Chemit at 2022-03-08T06:13:12+01:00
move metadata model to service sql and clean all API - See ultreiaio/topia-extension#112

- - - - -
7d87fc65 by Tony Chemit at 2022-03-08T06:13:12+01:00
Add nice method TopiaSqlScript#content - See ultreiaio/topia-extension#113

- - - - -
a406736e by Tony Chemit at 2022-03-08T06:13:12+01:00
Improve service local logs (add type and id if found in method invocation)

- - - - -


19 changed files:

- client/core/src/main/java/fr/ird/observe/client/datasource/api/ObserveSwingDataSource.java
- client/datasource/actions/src/main/java/fr/ird/observe/client/datasource/actions/save/actions/Start.java
- client/datasource/editor/api/src/main/java/fr/ird/observe/client/datasource/editor/api/wizard/DataSourceHelper.java
- core/persistence/java/src/main/java/fr/ird/observe/entities/ObserveTopiaApplicationContext.java
- core/persistence/java/src/main/resources/META-INF/persistence/Observe/TopiaEntitySqlCopyPlanModel.json
- core/persistence/java/src/main/resources/META-INF/persistence/Observe/TopiaEntitySqlDeletePlanModel.json
- + core/persistence/java/src/main/resources/META-INF/persistence/Observe/TopiaEntitySqlReplicatePlanModel.json
- core/persistence/java/src/test/java/fr/ird/observe/spi/script/UpdateLastUpdateDateFieldScriptTest.java
- core/persistence/java/src/test/java/fr/ird/observe/spi/script/UpdateLastUpdateDateTableScriptTest.java
- core/persistence/test/src/main/java/fr/ird/observe/persistence/test/PersistenceTestSupportRead.java
- core/persistence/test/src/main/java/fr/ird/observe/persistence/test/PersistenceTestSupportWrite.java
- core/persistence/test/src/test/java/fr/ird/observe/persistence/test/DefinitionContentTest.java
- core/persistence/test/src/test/java/fr/ird/observe/persistence/test/PersistenceModelWriteTest.java
- core/persistence/test/src/test/java/fr/ird/observe/persistence/test/SqlServiceTest.java
- core/persistence/test/src/test/java/fr/ird/observe/persistence/test/ValidationContentTest.java
- core/services/local/src/main/java/fr/ird/observe/services/local/service/DataSourceServiceLocalSupport.java
- core/services/local/src/main/java/fr/ird/observe/services/local/service/ObserveServiceLocal.java
- core/services/local/src/main/java/fr/ird/observe/services/local/service/referential/SynchronizeServiceLocalSupport.java
- core/services/test/src/main/java/fr/ird/observe/services/service/DataSourceServiceFixtures.java


Changes:

=====================================
client/core/src/main/java/fr/ird/observe/client/datasource/api/ObserveSwingDataSource.java
=====================================
@@ -457,7 +457,7 @@ public class ObserveSwingDataSource extends AbstractJavaBean implements ObserveS
         log.info(String.format("Do backup of %s into: %s", this, dst));
         try {
             Files.deleteIfExists(dst);
-            CreateDatabaseRequest request = CreateDatabaseRequest.of(false, getClientConfig().getModelVersion()).addSchema().addStandaloneTables().addAllData();
+            CreateDatabaseRequest request = CreateDatabaseRequest.builder(false, getClientConfig().getModelVersion()).addSchema().addStandaloneTables().addAllData().build();
             TopiaSqlScript dataDump = getDataSourceService().produceCreateSqlScript(request);
             dataDump.copy(dst);
         } catch (Exception e) {


=====================================
client/datasource/actions/src/main/java/fr/ird/observe/client/datasource/actions/save/actions/Start.java
=====================================
@@ -86,7 +86,7 @@ public class Start extends SaveLocalUIActionSupport {
             File backupFile = stepModel.getBackupFile();
 
             DataSourceService dumpService = source.getDataSourceService();
-            CreateDatabaseRequest request = CreateDatabaseRequest.of(false, source.getVersion()).addSchema().addStandaloneTables().addAllData();
+            CreateDatabaseRequest request = CreateDatabaseRequest.builder(false, source.getVersion()).addSchema().addStandaloneTables().addAllData().build();
             TopiaSqlScript dump = dumpService.produceCreateSqlScript(request);
             dump.copy(backupFile.toPath());
         }


=====================================
client/datasource/editor/api/src/main/java/fr/ird/observe/client/datasource/editor/api/wizard/DataSourceHelper.java
=====================================
@@ -135,7 +135,7 @@ public class DataSourceHelper {
                 try (ObserveSwingDataSource source = model.getDataSourcesManager().newDataSource(configSrc)) {
                     source.open();
                     DataSourceService dumpService = source.getDataSourceService();
-                    CreateDatabaseRequest request = CreateDatabaseRequest.of(false, source.getVersion()).addSchema().addStandaloneTables();
+                    CreateDatabaseRequest request = CreateDatabaseRequest.builder(false, source.getVersion()).addSchema().addStandaloneTables().build();
                     importDatabase = dumpService.produceCreateSqlScript(request);
                 }
             }


=====================================
core/persistence/java/src/main/java/fr/ird/observe/entities/ObserveTopiaApplicationContext.java
=====================================
@@ -40,14 +40,15 @@ import org.nuiton.topia.persistence.TopiaConfigurationExtension;
 import org.nuiton.topia.persistence.TopiaEntity;
 import org.nuiton.topia.persistence.TopiaIdFactory;
 import org.nuiton.topia.persistence.TopiaPersistenceContextConstructorParameterSupport;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModel;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModelPaths;
 import org.nuiton.topia.persistence.script.TopiaSqlScript;
 import org.nuiton.topia.service.migration.TopiaMigrationService;
 import org.nuiton.topia.service.sql.blob.TopiaEntitySqlBlobModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModelPaths;
 import org.nuiton.topia.service.sql.model.TopiaEntitySqlModel;
 import org.nuiton.topia.service.sql.plan.copy.TopiaEntitySqlCopyPlanModel;
 import org.nuiton.topia.service.sql.plan.delete.TopiaEntitySqlDeletePlanModel;
+import org.nuiton.topia.service.sql.plan.replicate.TopiaEntitySqlReplicatePlanModel;
 import org.nuiton.topia.service.sql.request.CreateDatabaseRequest;
 import org.nuiton.topia.service.sql.usage.TopiaEntitySqlUsageModel;
 
@@ -120,6 +121,11 @@ public class ObserveTopiaApplicationContext extends AbstractObserveTopiaApplicat
         return ObserveTopiaEntitySqlModelResource.get().getCopyPlanModel();
     }
 
+    @Override
+    public TopiaEntitySqlReplicatePlanModel getReplicatePlanModel() {
+        return ObserveTopiaEntitySqlModelResource.get().getReplicatePlanModel();
+    }
+
     @Override
     public TopiaEntitySqlDeletePlanModel getDeletePlanModel() {
         return ObserveTopiaEntitySqlModelResource.get().getDeletePlanModel();
@@ -174,7 +180,7 @@ public class ObserveTopiaApplicationContext extends AbstractObserveTopiaApplicat
                     temporaryTopiaApplicationContext.getMigrationService().createSchemaIfNotExist();
                     temporaryTopiaApplicationContext.getMigrationService().runSchemaMigration();
                 }
-                CreateDatabaseRequest request = CreateDatabaseRequest.of(true, dataSourceConfiguration.getModelVersion()).addSchema().addStandaloneTables().addAllData();
+                CreateDatabaseRequest request = CreateDatabaseRequest.builder(true, dataSourceConfiguration.getModelVersion()).addSchema().addStandaloneTables().addAllData().build();
                 TopiaSqlScript dump = getSqlService().consume(request);
                 executeSqlStatements(dump);
                 migrationService.createSchemaIfNotExist();
@@ -204,8 +210,8 @@ public class ObserveTopiaApplicationContext extends AbstractObserveTopiaApplicat
                 log.info("Import referential.");
                 ObserveDataSourceConfiguration importDataSourceConfiguration = dataSourceCreateConfiguration.getImportReferentialDataSourceConfiguration();
                 Version dbVersion = Version.valueOf(getModelVersion());
-                CreateDatabaseRequest request = CreateDatabaseRequest.of(!dataSourceConfiguration.isLocal(), dbVersion)
-                        .addStandaloneTables();
+                CreateDatabaseRequest request = CreateDatabaseRequest.builder(!dataSourceConfiguration.isLocal(), dbVersion)
+                        .addStandaloneTables().build();
                 TopiaSqlScript referentialDump;
                 ObserveTopiaApplicationContext temporaryTopiaApplicationContext = null;
                 try {
@@ -225,10 +231,10 @@ public class ObserveTopiaApplicationContext extends AbstractObserveTopiaApplicat
             if (importData) {
                 ObserveDataSourceConfiguration importDataSourceConfiguration = dataSourceCreateConfiguration.getImportDataDataSourceConfiguration();
                 Version dbVersion = Version.valueOf(getModelVersion());
-                CreateDatabaseRequest request = CreateDatabaseRequest.of(!dataSourceConfiguration.isLocal(), dbVersion);
+                CreateDatabaseRequest.Builder requestBuilder = CreateDatabaseRequest.builder(!dataSourceConfiguration.isLocal(), dbVersion);
                 if (!referentialImported) {
                     log.info("Get referential.");
-                    request.addStandaloneTables();
+                    requestBuilder.addStandaloneTables();
                 }
 
                 // Récupération du dump qui contient les données
@@ -241,10 +247,11 @@ public class ObserveTopiaApplicationContext extends AbstractObserveTopiaApplicat
                 }
                 log.info(String.format("Get data: %s", importDataIds));
                 for (Map.Entry<String, Collection<String>> entry : idsByType.asMap().entrySet()) {
-                    request.dataIdsToAdd(entry.getKey(), Set.copyOf(entry.getValue()));
+                    requestBuilder.dataIdsToAdd(entry.getKey(), Set.copyOf(entry.getValue()));
                 }
                 TopiaSqlScript dataDump;
                 ObserveTopiaApplicationContext temporaryTopiaApplicationContext = null;
+                CreateDatabaseRequest request = requestBuilder.build();
                 try {
                     temporaryTopiaApplicationContext = ObserveTopiaApplicationContextFactory.createTopiaApplicationContext(importDataSourceConfiguration, false);
 //                    ObserveDataSourceConnection importDataSourceConnection = serviceContext().newService(importDataSourceConfiguration, AnonymousService.class).open(importDataSourceConfiguration);


=====================================
core/persistence/java/src/main/resources/META-INF/persistence/Observe/TopiaEntitySqlCopyPlanModel.json
=====================================
The diff for this file was not included because it is too large.

=====================================
core/persistence/java/src/main/resources/META-INF/persistence/Observe/TopiaEntitySqlDeletePlanModel.json
=====================================
@@ -1,5 +1,5 @@
 {
-  "typeDeletePlans": {
+  "plans": {
     "fr.ird.observe.entities.data.ll.common.GearUseFeatures": [
       "DELETE FROM ll_common.gearUseFeaturesMeasurement WHERE gearUseFeaturesMeasurement.gearUseFeatures %s;",
       "DELETE FROM ll_common.gearUseFeatures WHERE gearUseFeatures.topiaId %s;"


=====================================
core/persistence/java/src/main/resources/META-INF/persistence/Observe/TopiaEntitySqlReplicatePlanModel.json
=====================================
@@ -0,0 +1,1476 @@
+{
+  "plans": {
+    "fr.ird.observe.entities.data.ll.common.GearUseFeatures": [
+      {
+        "gav": "ll_common.gearUseFeatures",
+        "selectedSql": "SELECT %s FROM ll_common.gearUseFeatures WHERE gearUseFeatures.topiaId %s",
+        "insertSql": "INSERT INTO ll_common.gearUseFeatures(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,gear,homeid,lastupdatedate,number,topiacreatedate,topiaversion,trip,usedintrip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_common.gearUseFeaturesMeasurement",
+        "selectedSql": "SELECT %s FROM ll_common.gearUseFeaturesMeasurement gearUseFeaturesMeasurement WHERE gearUseFeaturesMeasurement.gearUseFeatures %s",
+        "insertSql": "INSERT INTO ll_common.gearUseFeaturesMeasurement(%s) VALUES (%%s);",
+        "parentColumnName": "gearUseFeatures",
+        "columnNames": "topiaid,gearcharacteristic,gearusefeatures,homeid,lastupdatedate,measurementvalue,topiacreatedate,topiaversion"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.common.GearUseFeaturesMeasurement": [
+      {
+        "gav": "ll_common.gearUseFeaturesMeasurement",
+        "selectedSql": "SELECT %s FROM ll_common.gearUseFeaturesMeasurement WHERE gearUseFeaturesMeasurement.topiaId %s",
+        "insertSql": "INSERT INTO ll_common.gearUseFeaturesMeasurement(%s) VALUES (%%s);",
+        "parentColumnName": "gearUseFeatures",
+        "columnNames": "topiaid,gearcharacteristic,gearusefeatures,homeid,lastupdatedate,measurementvalue,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.landing.Landing": [
+      {
+        "gav": "ll_landing.landing",
+        "selectedSql": "SELECT %s FROM ll_landing.landing WHERE landing.topiaId %s",
+        "insertSql": "INSERT INTO ll_landing.landing(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,brokeragecompany,comment,datasource,enddate,harbour,homeid,lastupdatedate,person,processingcompany,shippingcompany,startdate,topiacreatedate,topiaversion,trip,vessel",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_landing.landingPart",
+        "selectedSql": "SELECT %s FROM ll_landing.landingPart landingPart WHERE landingPart.landing %s",
+        "insertSql": "INSERT INTO ll_landing.landingPart(%s) VALUES (%%s);",
+        "parentColumnName": "landing",
+        "columnNames": "topiaid,categorymax,categorymin,conservation,count,dataquality,homeid,landing,lastupdatedate,onboardprocessing,species,topiacreatedate,topiaversion,weight,weightmeasuremethod"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.landing.LandingPart": [
+      {
+        "gav": "ll_landing.landingPart",
+        "selectedSql": "SELECT %s FROM ll_landing.landingPart WHERE landingPart.topiaId %s",
+        "insertSql": "INSERT INTO ll_landing.landingPart(%s) VALUES (%%s);",
+        "parentColumnName": "landing",
+        "columnNames": "topiaid,categorymax,categorymin,conservation,count,dataquality,homeid,landing,lastupdatedate,onboardprocessing,species,topiacreatedate,topiaversion,weight,weightmeasuremethod",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.Activity": [
+      {
+        "gav": "ll_logbook.set",
+        "selectedSql": "SELECT %s FROM ll_logbook.set set INNER JOIN ll_logbook.activity activity ON activity.set = set.topiaId WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.set(%s) VALUES (%%s);",
+        "columnNames": "topiaid,basketlinelength,basketspersectioncount,branchlinesperbasketcount,comment,haulingbreaks,haulingdirectionsameassetting,haulingendlatitude,haulingendlongitude,haulingendtimestamp,haulingstartlatitude,haulingstartlongitude,haulingstarttimestamp,homeid,lastupdatedate,lengthbetweenbranchlines,lightstickscolor,lightsticksperbasketcount,lightstickstype,lightsticksused,linetype,maxdepthtargeted,monitored,number,settingendlatitude,settingendlongitude,settingendtimestamp,settingshape,settingstartlatitude,settingstartlongitude,settingstarttimestamp,settingvesselspeed,shooterspeed,shooterused,snapweight,swivelweight,timebetweenhooks,topiacreatedate,topiaversion,totalbasketscount,totalhookscount,totallightstickscount,totallinelength,totalsectionscount,weightedsnap,weightedswivel"
+      },
+      {
+        "gav": "ll_logbook.sample",
+        "selectedSql": "SELECT %s FROM ll_logbook.sample sample INNER JOIN ll_logbook.activity activity ON activity.sample = sample.topiaId WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.sample(%s) VALUES (%%s);",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,latitude,longitude,timestamp,topiacreatedate,topiaversion,trip"
+      },
+      {
+        "gav": "ll_logbook.activity",
+        "selectedSql": "SELECT %s FROM ll_logbook.activity WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.activity(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,currentdirection,currentspeed,dataquality,endtimestamp,fpazone,homeid,lastupdatedate,latitude,longitude,relatedobservedactivity,sample,seasurfacetemperature,set,starttimestamp,topiacreatedate,topiaversion,trip,vesselactivity,wind,winddirection",
+        "columnsToReplace": "set,sample",
+        "columnsToDetach": "relatedObservedActivity~ll_observation.activity",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_logbook.baitsComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.baitsComposition baitsComposition INNER JOIN ll_logbook.activity activity ON activity.set = baitsComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.baitsComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,baitsettingstatus,baittype,homeid,individualsize,individualweight,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_logbook.branchlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.branchlinesComposition branchlinesComposition INNER JOIN ll_logbook.activity activity ON activity.set = branchlinesComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.branchlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,proportion,set,topiacreatedate,topiaversion,toptype,tracelinelength,tracelinetype"
+      },
+      {
+        "gav": "ll_logbook.catch",
+        "selectedSql": "SELECT %s FROM ll_logbook.catch catch INNER JOIN ll_logbook.activity activity ON activity.set = catch.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,beatdiameter,catchfate,catchhealthstatus,comment,count,countdepredated,depredated,depredatedproportion,discardhealthstatus,homeid,hookwhendiscarded,lastupdatedate,number,onboardprocessing,photoreferences,set,set_idx,species,tagnumber,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ll_logbook.floatlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.floatlinesComposition floatlinesComposition INNER JOIN ll_logbook.activity activity ON activity.set = floatlinesComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.floatlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,linetype,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_logbook.hooksComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.hooksComposition hooksComposition INNER JOIN ll_logbook.activity activity ON activity.set = hooksComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.hooksComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,hookoffset,hooksize,hooktype,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_logbook.samplePart",
+        "selectedSql": "SELECT %s FROM ll_logbook.samplePart samplePart INNER JOIN ll_logbook.activity activity ON activity.sample = samplePart.sample WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.samplePart(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,lastupdatedate,length,lengthmeasuremethod,sample,sample_idx,sex,sizemeasuretype,species,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype"
+      },
+      {
+        "gav": "ll_logbook.set_mitigationtype",
+        "selectedSql": "SELECT %s FROM ll_logbook.set_mitigationtype INNER JOIN ll_logbook.set set ON set_mitigationtype.set = set.topiaId INNER JOIN ll_logbook.activity activity ON activity.set = set.topiaId WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.set_mitigationtype(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "mitigationtype,set",
+        "columnsToReplace": "set"
+      },
+      {
+        "gav": "ll_logbook.catch_predator",
+        "selectedSql": "SELECT %s FROM ll_logbook.catch_predator INNER JOIN ll_logbook.catch catch ON catch_predator.catch = catch.topiaId INNER JOIN ll_logbook.activity activity ON activity.set = catch.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.catch_predator(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "catch,species",
+        "columnsToReplace": "catch"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.BaitsComposition": [
+      {
+        "gav": "ll_logbook.baitsComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.baitsComposition WHERE baitsComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.baitsComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,baitsettingstatus,baittype,homeid,individualsize,individualweight,lastupdatedate,proportion,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.BranchlinesComposition": [
+      {
+        "gav": "ll_logbook.branchlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.branchlinesComposition WHERE branchlinesComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.branchlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,proportion,set,topiacreatedate,topiaversion,toptype,tracelinelength,tracelinetype",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.Catch": [
+      {
+        "gav": "ll_logbook.catch",
+        "selectedSql": "SELECT %s FROM ll_logbook.catch WHERE catch.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,beatdiameter,catchfate,catchhealthstatus,comment,count,countdepredated,depredated,depredatedproportion,discardhealthstatus,homeid,hookwhendiscarded,lastupdatedate,number,onboardprocessing,photoreferences,set,set_idx,species,tagnumber,topiacreatedate,topiaversion,totalweight,weightmeasuremethod",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_logbook.catch_predator",
+        "selectedSql": "SELECT %s FROM ll_logbook.catch_predator WHERE catch_predator.catch %s",
+        "insertSql": "INSERT INTO ll_logbook.catch_predator(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "catch,species",
+        "columnsToReplace": "catch"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.FloatlinesComposition": [
+      {
+        "gav": "ll_logbook.floatlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.floatlinesComposition WHERE floatlinesComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.floatlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,linetype,proportion,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.HooksComposition": [
+      {
+        "gav": "ll_logbook.hooksComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.hooksComposition WHERE hooksComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.hooksComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,hookoffset,hooksize,hooktype,lastupdatedate,proportion,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.Sample": [
+      {
+        "gav": "ll_logbook.sample",
+        "selectedSql": "SELECT %s FROM ll_logbook.sample WHERE sample.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.sample(%s) VALUES (%%s);",
+        "updateReverseAssociationSql": "UPDATE ll_logbook.activity activity SET activity.sample = '%s' WHERE activity.topiaId = '%s'",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,latitude,longitude,timestamp,topiacreatedate,topiaversion,trip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_logbook.samplePart",
+        "selectedSql": "SELECT %s FROM ll_logbook.samplePart samplePart WHERE samplePart.sample %s",
+        "insertSql": "INSERT INTO ll_logbook.samplePart(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,lastupdatedate,length,lengthmeasuremethod,sample,sample_idx,sex,sizemeasuretype,species,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.SamplePart": [
+      {
+        "gav": "ll_logbook.samplePart",
+        "selectedSql": "SELECT %s FROM ll_logbook.samplePart WHERE samplePart.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.samplePart(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,lastupdatedate,length,lengthmeasuremethod,sample,sample_idx,sex,sizemeasuretype,species,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.logbook.Set": [
+      {
+        "gav": "ll_logbook.set",
+        "selectedSql": "SELECT %s FROM ll_logbook.set WHERE set.topiaId %s",
+        "insertSql": "INSERT INTO ll_logbook.set(%s) VALUES (%%s);",
+        "updateReverseAssociationSql": "UPDATE ll_logbook.activity activity SET activity.set = '%s' WHERE activity.topiaId = '%s'",
+        "columnNames": "topiaid,basketlinelength,basketspersectioncount,branchlinesperbasketcount,comment,haulingbreaks,haulingdirectionsameassetting,haulingendlatitude,haulingendlongitude,haulingendtimestamp,haulingstartlatitude,haulingstartlongitude,haulingstarttimestamp,homeid,lastupdatedate,lengthbetweenbranchlines,lightstickscolor,lightsticksperbasketcount,lightstickstype,lightsticksused,linetype,maxdepthtargeted,monitored,number,settingendlatitude,settingendlongitude,settingendtimestamp,settingshape,settingstartlatitude,settingstartlongitude,settingstarttimestamp,settingvesselspeed,shooterspeed,shooterused,snapweight,swivelweight,timebetweenhooks,topiacreatedate,topiaversion,totalbasketscount,totalhookscount,totallightstickscount,totallinelength,totalsectionscount,weightedsnap,weightedswivel",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_logbook.baitsComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.baitsComposition baitsComposition WHERE baitsComposition.set %s",
+        "insertSql": "INSERT INTO ll_logbook.baitsComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,baitsettingstatus,baittype,homeid,individualsize,individualweight,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_logbook.branchlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.branchlinesComposition branchlinesComposition WHERE branchlinesComposition.set %s",
+        "insertSql": "INSERT INTO ll_logbook.branchlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,proportion,set,topiacreatedate,topiaversion,toptype,tracelinelength,tracelinetype"
+      },
+      {
+        "gav": "ll_logbook.catch",
+        "selectedSql": "SELECT %s FROM ll_logbook.catch catch WHERE catch.set %s",
+        "insertSql": "INSERT INTO ll_logbook.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,beatdiameter,catchfate,catchhealthstatus,comment,count,countdepredated,depredated,depredatedproportion,discardhealthstatus,homeid,hookwhendiscarded,lastupdatedate,number,onboardprocessing,photoreferences,set,set_idx,species,tagnumber,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ll_logbook.floatlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.floatlinesComposition floatlinesComposition WHERE floatlinesComposition.set %s",
+        "insertSql": "INSERT INTO ll_logbook.floatlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,linetype,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_logbook.hooksComposition",
+        "selectedSql": "SELECT %s FROM ll_logbook.hooksComposition hooksComposition WHERE hooksComposition.set %s",
+        "insertSql": "INSERT INTO ll_logbook.hooksComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,hookoffset,hooksize,hooktype,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_logbook.set_mitigationtype",
+        "selectedSql": "SELECT %s FROM ll_logbook.set_mitigationtype WHERE set_mitigationtype.set %s",
+        "insertSql": "INSERT INTO ll_logbook.set_mitigationtype(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "mitigationtype,set",
+        "columnsToReplace": "set"
+      },
+      {
+        "gav": "ll_logbook.catch_predator",
+        "selectedSql": "SELECT %s FROM ll_logbook.catch_predator INNER JOIN ll_logbook.catch catch ON catch_predator.catch = catch.topiaId WHERE catch.set %s",
+        "insertSql": "INSERT INTO ll_logbook.catch_predator(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "catch,species",
+        "columnsToReplace": "catch"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Activity": [
+      {
+        "gav": "ll_observation.set",
+        "selectedSql": "SELECT %s FROM ll_observation.set set INNER JOIN ll_observation.activity activity ON activity.set = set.topiaId WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.set(%s) VALUES (%%s);",
+        "columnNames": "topiaid,basketspersectioncount,branchlinesperbasketcount,comment,haulingbreaks,haulingdirectionsameassetting,haulingendlatitude,haulingendlongitude,haulingendtimestamp,haulingstartlatitude,haulingstartlongitude,haulingstarttimestamp,homeid,lastupdatedate,lightstickscolor,lightsticksperbasketcount,lightstickstype,linetype,maxdepthtargeted,monitored,number,settingendlatitude,settingendlongitude,settingendtimestamp,settingshape,settingstartlatitude,settingstartlongitude,settingstarttimestamp,settingvesselspeed,shooterspeed,shooterused,snapweight,swivelweight,timebetweenhooks,topiacreatedate,topiaversion,totalbasketscount,totalhookscount,totalsectionscount,weightedsnap,weightedswivel"
+      },
+      {
+        "gav": "ll_observation.activity",
+        "selectedSql": "SELECT %s FROM ll_observation.activity WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.activity(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,dataquality,fpazone,homeid,lastupdatedate,latitude,longitude,seasurfacetemperature,set,timestamp,topiacreatedate,topiaversion,trip,vesselactivity",
+        "columnsToReplace": "set",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_observation.encounter",
+        "selectedSql": "SELECT %s FROM ll_observation.encounter encounter WHERE encounter.activity %s",
+        "insertSql": "INSERT INTO ll_observation.encounter(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,count,distance,encountertype,homeid,lastupdatedate,species,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.sensorUsed",
+        "selectedSql": "SELECT %s FROM ll_observation.sensorUsed sensorUsed WHERE sensorUsed.activity %s",
+        "insertSql": "INSERT INTO ll_observation.sensorUsed(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,data,datafilename,datalocation,homeid,lastupdatedate,sensorbrand,sensordataformat,sensorserialno,sensortype,topiacreatedate,topiaversion",
+        "useBlob": true
+      },
+      {
+        "gav": "ll_observation.baitsComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.baitsComposition baitsComposition INNER JOIN ll_observation.activity activity ON activity.set = baitsComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.baitsComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,baitsettingstatus,baittype,homeid,individualsize,individualweight,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.branchlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.branchlinesComposition branchlinesComposition INNER JOIN ll_observation.activity activity ON activity.set = branchlinesComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.branchlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,proportion,set,topiacreatedate,topiaversion,toptype,tracelinelength,tracelinetype"
+      },
+      {
+        "gav": "ll_observation.floatlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.floatlinesComposition floatlinesComposition INNER JOIN ll_observation.activity activity ON activity.set = floatlinesComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.floatlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,linetype,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.hooksComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.hooksComposition hooksComposition INNER JOIN ll_observation.activity activity ON activity.set = hooksComposition.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.hooksComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,hookoffset,hooksize,hooktype,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.section",
+        "selectedSql": "SELECT %s FROM ll_observation.section section INNER JOIN ll_observation.activity activity ON activity.set = section.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.section(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,haulingidentifier,homeid,lastupdatedate,set,settingidentifier,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.basket",
+        "selectedSql": "SELECT %s FROM ll_observation.basket basket INNER JOIN ll_observation.section section ON section.topiaId = basket.section  INNER JOIN ll_observation.activity activity ON activity.set = section.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.basket(%s) VALUES (%%s);",
+        "parentColumnName": "section",
+        "columnNames": "topiaid,floatline1length,floatline2length,haulingidentifier,homeid,lastupdatedate,section,settingidentifier,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.branchline",
+        "selectedSql": "SELECT %s FROM ll_observation.branchline branchline INNER JOIN ll_observation.basket basket ON basket.topiaId = branchline.basket  INNER JOIN ll_observation.section section ON section.topiaId = basket.section  INNER JOIN ll_observation.activity activity ON activity.set = section.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.branchline(%s) VALUES (%%s);",
+        "parentColumnName": "basket",
+        "columnNames": "topiaid,baithaulingstatus,baitsettingstatus,baittype,basket,branchlinelength,comment,depthrecorder,haulingidentifier,homeid,hooklost,hookoffset,hooksize,hooktype,lastupdatedate,settingidentifier,snapweight,swivelweight,timer,timertimeonboard,timesincecontact,topiacreatedate,topiaversion,toptype,tracecutoff,tracelinelength,tracelinetype,weightedsnap,weightedswivel"
+      },
+      {
+        "gav": "ll_observation.tdr",
+        "selectedSql": "SELECT %s FROM ll_observation.tdr tdr INNER JOIN ll_observation.activity activity ON activity.set = tdr.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.tdr(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,basket,branchline,data,datafilename,datalocation,deploymentend,deploymentstart,fishingend,fishingenddepth,fishingstart,fishingstartdepth,floatline1length,floatline2length,homeid,itemhorizontalposition,itemverticalposition,lastupdatedate,maxfishingdepth,meandeploymentdepth,meanfishingdepth,mediandeploymentdepth,medianfishingdepth,minfishingdepth,section,sensorbrand,serialno,set,topiacreatedate,topiaversion",
+        "columnsToReplace": "section,basket,branchline",
+        "useBlob": true
+      },
+      {
+        "gav": "ll_observation.catch",
+        "selectedSql": "SELECT %s FROM ll_observation.catch catch INNER JOIN ll_observation.activity activity ON activity.set = catch.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,basket,beatdiameter,branchline,catchfate,catchhealthstatus,comment,count,depredated,discardhealthstatus,gonadeweight,homeid,hookposition,hookwhendiscarded,lastupdatedate,maturitystatus,number,photoreferences,section,set,set_idx,sex,species,stomachfullness,tagnumber,topiacreatedate,topiaversion,totalweight,weightmeasuremethod",
+        "columnsToReplace": "section,basket,branchline"
+      },
+      {
+        "gav": "ll_observation.sizeMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.sizeMeasure sizeMeasure INNER JOIN ll_observation.catch catch ON catch.topiaId = sizeMeasure.catch  INNER JOIN ll_observation.activity activity ON activity.set = catch.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.sizeMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,size,sizemeasuretype,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.weightMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.weightMeasure weightMeasure INNER JOIN ll_observation.catch catch ON catch.topiaId = weightMeasure.catch  INNER JOIN ll_observation.activity activity ON activity.set = catch.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.weightMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,topiacreatedate,topiaversion,weight,weightmeasuretype"
+      },
+      {
+        "gav": "ll_observation.set_mitigationtype",
+        "selectedSql": "SELECT %s FROM ll_observation.set_mitigationtype INNER JOIN ll_observation.set set ON set_mitigationtype.set = set.topiaId INNER JOIN ll_observation.activity activity ON activity.set = set.topiaId WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.set_mitigationtype(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "mitigationtype,set",
+        "columnsToReplace": "set"
+      },
+      {
+        "gav": "ll_observation.tdr_species",
+        "selectedSql": "SELECT %s FROM ll_observation.tdr_species INNER JOIN ll_observation.tdr tdr ON tdr_species.tdr = tdr.topiaId INNER JOIN ll_observation.activity activity ON activity.set = tdr.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.tdr_species(%s) VALUES (%%s);",
+        "parentColumnName": "tdr",
+        "columnNames": "species,tdr",
+        "columnsToReplace": "tdr"
+      },
+      {
+        "gav": "ll_observation.catch_predator",
+        "selectedSql": "SELECT %s FROM ll_observation.catch_predator INNER JOIN ll_observation.catch catch ON catch_predator.catch = catch.topiaId INNER JOIN ll_observation.activity activity ON activity.set = catch.set WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.catch_predator(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "catch,species",
+        "columnsToReplace": "catch"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.BaitsComposition": [
+      {
+        "gav": "ll_observation.baitsComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.baitsComposition WHERE baitsComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.baitsComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,baitsettingstatus,baittype,homeid,individualsize,individualweight,lastupdatedate,proportion,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Basket": [
+      {
+        "gav": "ll_observation.basket",
+        "selectedSql": "SELECT %s FROM ll_observation.basket WHERE basket.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.basket(%s) VALUES (%%s);",
+        "parentColumnName": "section",
+        "columnNames": "topiaid,floatline1length,floatline2length,haulingidentifier,homeid,lastupdatedate,section,settingidentifier,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_observation.branchline",
+        "selectedSql": "SELECT %s FROM ll_observation.branchline branchline WHERE branchline.basket %s",
+        "insertSql": "INSERT INTO ll_observation.branchline(%s) VALUES (%%s);",
+        "parentColumnName": "basket",
+        "columnNames": "topiaid,baithaulingstatus,baitsettingstatus,baittype,basket,branchlinelength,comment,depthrecorder,haulingidentifier,homeid,hooklost,hookoffset,hooksize,hooktype,lastupdatedate,settingidentifier,snapweight,swivelweight,timer,timertimeonboard,timesincecontact,topiacreatedate,topiaversion,toptype,tracecutoff,tracelinelength,tracelinetype,weightedsnap,weightedswivel"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Branchline": [
+      {
+        "gav": "ll_observation.branchline",
+        "selectedSql": "SELECT %s FROM ll_observation.branchline WHERE branchline.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.branchline(%s) VALUES (%%s);",
+        "parentColumnName": "basket",
+        "columnNames": "topiaid,baithaulingstatus,baitsettingstatus,baittype,basket,branchlinelength,comment,depthrecorder,haulingidentifier,homeid,hooklost,hookoffset,hooksize,hooktype,lastupdatedate,settingidentifier,snapweight,swivelweight,timer,timertimeonboard,timesincecontact,topiacreatedate,topiaversion,toptype,tracecutoff,tracelinelength,tracelinetype,weightedsnap,weightedswivel",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.BranchlinesComposition": [
+      {
+        "gav": "ll_observation.branchlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.branchlinesComposition WHERE branchlinesComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.branchlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,proportion,set,topiacreatedate,topiaversion,toptype,tracelinelength,tracelinetype",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Catch": [
+      {
+        "gav": "ll_observation.catch",
+        "selectedSql": "SELECT %s FROM ll_observation.catch WHERE catch.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,basket,beatdiameter,branchline,catchfate,catchhealthstatus,comment,count,depredated,discardhealthstatus,gonadeweight,homeid,hookposition,hookwhendiscarded,lastupdatedate,maturitystatus,number,photoreferences,section,set,set_idx,sex,species,stomachfullness,tagnumber,topiacreatedate,topiaversion,totalweight,weightmeasuremethod",
+        "columnsToDetach": "section~ll_observation.section,basket~ll_observation.basket,branchline~ll_observation.branchline",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_observation.sizeMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.sizeMeasure sizeMeasure WHERE sizeMeasure.catch %s",
+        "insertSql": "INSERT INTO ll_observation.sizeMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,size,sizemeasuretype,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.weightMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.weightMeasure weightMeasure WHERE weightMeasure.catch %s",
+        "insertSql": "INSERT INTO ll_observation.weightMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,topiacreatedate,topiaversion,weight,weightmeasuretype"
+      },
+      {
+        "gav": "ll_observation.catch_predator",
+        "selectedSql": "SELECT %s FROM ll_observation.catch_predator WHERE catch_predator.catch %s",
+        "insertSql": "INSERT INTO ll_observation.catch_predator(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "catch,species",
+        "columnsToReplace": "catch"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Encounter": [
+      {
+        "gav": "ll_observation.encounter",
+        "selectedSql": "SELECT %s FROM ll_observation.encounter WHERE encounter.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.encounter(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,count,distance,encountertype,homeid,lastupdatedate,species,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.FloatlinesComposition": [
+      {
+        "gav": "ll_observation.floatlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.floatlinesComposition WHERE floatlinesComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.floatlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,linetype,proportion,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.HooksComposition": [
+      {
+        "gav": "ll_observation.hooksComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.hooksComposition WHERE hooksComposition.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.hooksComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,hookoffset,hooksize,hooktype,lastupdatedate,proportion,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Section": [
+      {
+        "gav": "ll_observation.section",
+        "selectedSql": "SELECT %s FROM ll_observation.section WHERE section.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.section(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,haulingidentifier,homeid,lastupdatedate,set,settingidentifier,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_observation.basket",
+        "selectedSql": "SELECT %s FROM ll_observation.basket basket WHERE basket.section %s",
+        "insertSql": "INSERT INTO ll_observation.basket(%s) VALUES (%%s);",
+        "parentColumnName": "section",
+        "columnNames": "topiaid,floatline1length,floatline2length,haulingidentifier,homeid,lastupdatedate,section,settingidentifier,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.branchline",
+        "selectedSql": "SELECT %s FROM ll_observation.branchline branchline INNER JOIN ll_observation.basket basket ON basket.topiaId = branchline.basket WHERE basket.section %s",
+        "insertSql": "INSERT INTO ll_observation.branchline(%s) VALUES (%%s);",
+        "parentColumnName": "basket",
+        "columnNames": "topiaid,baithaulingstatus,baitsettingstatus,baittype,basket,branchlinelength,comment,depthrecorder,haulingidentifier,homeid,hooklost,hookoffset,hooksize,hooktype,lastupdatedate,settingidentifier,snapweight,swivelweight,timer,timertimeonboard,timesincecontact,topiacreatedate,topiaversion,toptype,tracecutoff,tracelinelength,tracelinetype,weightedsnap,weightedswivel"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.SensorUsed": [
+      {
+        "gav": "ll_observation.sensorUsed",
+        "selectedSql": "SELECT %s FROM ll_observation.sensorUsed WHERE sensorUsed.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.sensorUsed(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,data,datafilename,datalocation,homeid,lastupdatedate,sensorbrand,sensordataformat,sensorserialno,sensortype,topiacreatedate,topiaversion",
+        "useBlob": true,
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Set": [
+      {
+        "gav": "ll_observation.set",
+        "selectedSql": "SELECT %s FROM ll_observation.set WHERE set.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.set(%s) VALUES (%%s);",
+        "updateReverseAssociationSql": "UPDATE ll_observation.activity activity SET activity.set = '%s' WHERE activity.topiaId = '%s'",
+        "columnNames": "topiaid,basketspersectioncount,branchlinesperbasketcount,comment,haulingbreaks,haulingdirectionsameassetting,haulingendlatitude,haulingendlongitude,haulingendtimestamp,haulingstartlatitude,haulingstartlongitude,haulingstarttimestamp,homeid,lastupdatedate,lightstickscolor,lightsticksperbasketcount,lightstickstype,linetype,maxdepthtargeted,monitored,number,settingendlatitude,settingendlongitude,settingendtimestamp,settingshape,settingstartlatitude,settingstartlongitude,settingstarttimestamp,settingvesselspeed,shooterspeed,shooterused,snapweight,swivelweight,timebetweenhooks,topiacreatedate,topiaversion,totalbasketscount,totalhookscount,totalsectionscount,weightedsnap,weightedswivel",
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_observation.baitsComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.baitsComposition baitsComposition WHERE baitsComposition.set %s",
+        "insertSql": "INSERT INTO ll_observation.baitsComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,baitsettingstatus,baittype,homeid,individualsize,individualweight,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.branchlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.branchlinesComposition branchlinesComposition WHERE branchlinesComposition.set %s",
+        "insertSql": "INSERT INTO ll_observation.branchlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,proportion,set,topiacreatedate,topiaversion,toptype,tracelinelength,tracelinetype"
+      },
+      {
+        "gav": "ll_observation.floatlinesComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.floatlinesComposition floatlinesComposition WHERE floatlinesComposition.set %s",
+        "insertSql": "INSERT INTO ll_observation.floatlinesComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,length,linetype,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.hooksComposition",
+        "selectedSql": "SELECT %s FROM ll_observation.hooksComposition hooksComposition WHERE hooksComposition.set %s",
+        "insertSql": "INSERT INTO ll_observation.hooksComposition(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,hookoffset,hooksize,hooktype,lastupdatedate,proportion,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.section",
+        "selectedSql": "SELECT %s FROM ll_observation.section section WHERE section.set %s",
+        "insertSql": "INSERT INTO ll_observation.section(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,haulingidentifier,homeid,lastupdatedate,set,settingidentifier,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.basket",
+        "selectedSql": "SELECT %s FROM ll_observation.basket basket INNER JOIN ll_observation.section section ON section.topiaId = basket.section WHERE section.set %s",
+        "insertSql": "INSERT INTO ll_observation.basket(%s) VALUES (%%s);",
+        "parentColumnName": "section",
+        "columnNames": "topiaid,floatline1length,floatline2length,haulingidentifier,homeid,lastupdatedate,section,settingidentifier,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.branchline",
+        "selectedSql": "SELECT %s FROM ll_observation.branchline branchline INNER JOIN ll_observation.basket basket ON basket.topiaId = branchline.basket  INNER JOIN ll_observation.section section ON section.topiaId = basket.section WHERE section.set %s",
+        "insertSql": "INSERT INTO ll_observation.branchline(%s) VALUES (%%s);",
+        "parentColumnName": "basket",
+        "columnNames": "topiaid,baithaulingstatus,baitsettingstatus,baittype,basket,branchlinelength,comment,depthrecorder,haulingidentifier,homeid,hooklost,hookoffset,hooksize,hooktype,lastupdatedate,settingidentifier,snapweight,swivelweight,timer,timertimeonboard,timesincecontact,topiacreatedate,topiaversion,toptype,tracecutoff,tracelinelength,tracelinetype,weightedsnap,weightedswivel"
+      },
+      {
+        "gav": "ll_observation.tdr",
+        "selectedSql": "SELECT %s FROM ll_observation.tdr tdr WHERE tdr.set %s",
+        "insertSql": "INSERT INTO ll_observation.tdr(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,basket,branchline,data,datafilename,datalocation,deploymentend,deploymentstart,fishingend,fishingenddepth,fishingstart,fishingstartdepth,floatline1length,floatline2length,homeid,itemhorizontalposition,itemverticalposition,lastupdatedate,maxfishingdepth,meandeploymentdepth,meanfishingdepth,mediandeploymentdepth,medianfishingdepth,minfishingdepth,section,sensorbrand,serialno,set,topiacreatedate,topiaversion",
+        "columnsToReplace": "section,basket,branchline",
+        "useBlob": true
+      },
+      {
+        "gav": "ll_observation.catch",
+        "selectedSql": "SELECT %s FROM ll_observation.catch catch WHERE catch.set %s",
+        "insertSql": "INSERT INTO ll_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,basket,beatdiameter,branchline,catchfate,catchhealthstatus,comment,count,depredated,discardhealthstatus,gonadeweight,homeid,hookposition,hookwhendiscarded,lastupdatedate,maturitystatus,number,photoreferences,section,set,set_idx,sex,species,stomachfullness,tagnumber,topiacreatedate,topiaversion,totalweight,weightmeasuremethod",
+        "columnsToReplace": "section,basket,branchline"
+      },
+      {
+        "gav": "ll_observation.sizeMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.sizeMeasure sizeMeasure INNER JOIN ll_observation.catch catch ON catch.topiaId = sizeMeasure.catch WHERE catch.set %s",
+        "insertSql": "INSERT INTO ll_observation.sizeMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,size,sizemeasuretype,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ll_observation.weightMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.weightMeasure weightMeasure INNER JOIN ll_observation.catch catch ON catch.topiaId = weightMeasure.catch WHERE catch.set %s",
+        "insertSql": "INSERT INTO ll_observation.weightMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,topiacreatedate,topiaversion,weight,weightmeasuretype"
+      },
+      {
+        "gav": "ll_observation.set_mitigationtype",
+        "selectedSql": "SELECT %s FROM ll_observation.set_mitigationtype WHERE set_mitigationtype.set %s",
+        "insertSql": "INSERT INTO ll_observation.set_mitigationtype(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "mitigationtype,set",
+        "columnsToReplace": "set"
+      },
+      {
+        "gav": "ll_observation.tdr_species",
+        "selectedSql": "SELECT %s FROM ll_observation.tdr_species INNER JOIN ll_observation.tdr tdr ON tdr_species.tdr = tdr.topiaId WHERE tdr.set %s",
+        "insertSql": "INSERT INTO ll_observation.tdr_species(%s) VALUES (%%s);",
+        "parentColumnName": "tdr",
+        "columnNames": "species,tdr",
+        "columnsToReplace": "tdr"
+      },
+      {
+        "gav": "ll_observation.catch_predator",
+        "selectedSql": "SELECT %s FROM ll_observation.catch_predator INNER JOIN ll_observation.catch catch ON catch_predator.catch = catch.topiaId WHERE catch.set %s",
+        "insertSql": "INSERT INTO ll_observation.catch_predator(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "catch,species",
+        "columnsToReplace": "catch"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.SizeMeasure": [
+      {
+        "gav": "ll_observation.sizeMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.sizeMeasure WHERE sizeMeasure.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.sizeMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,size,sizemeasuretype,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.Tdr": [
+      {
+        "gav": "ll_observation.tdr",
+        "selectedSql": "SELECT %s FROM ll_observation.tdr WHERE tdr.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.tdr(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,basket,branchline,data,datafilename,datalocation,deploymentend,deploymentstart,fishingend,fishingenddepth,fishingstart,fishingstartdepth,floatline1length,floatline2length,homeid,itemhorizontalposition,itemverticalposition,lastupdatedate,maxfishingdepth,meandeploymentdepth,meanfishingdepth,mediandeploymentdepth,medianfishingdepth,minfishingdepth,section,sensorbrand,serialno,set,topiacreatedate,topiaversion",
+        "columnsToDetach": "section~ll_observation.section,basket~ll_observation.basket,branchline~ll_observation.branchline",
+        "useBlob": true,
+        "entryPoint": true
+      },
+      {
+        "gav": "ll_observation.tdr_species",
+        "selectedSql": "SELECT %s FROM ll_observation.tdr_species WHERE tdr_species.tdr %s",
+        "insertSql": "INSERT INTO ll_observation.tdr_species(%s) VALUES (%%s);",
+        "parentColumnName": "tdr",
+        "columnNames": "species,tdr",
+        "columnsToReplace": "tdr"
+      }
+    ],
+    "fr.ird.observe.entities.data.ll.observation.WeightMeasure": [
+      {
+        "gav": "ll_observation.weightMeasure",
+        "selectedSql": "SELECT %s FROM ll_observation.weightMeasure WHERE weightMeasure.topiaId %s",
+        "insertSql": "INSERT INTO ll_observation.weightMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "catch",
+        "columnNames": "topiaid,catch,homeid,lastupdatedate,topiacreatedate,topiaversion,weight,weightmeasuretype",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.common.GearUseFeatures": [
+      {
+        "gav": "ps_common.gearUseFeatures",
+        "selectedSql": "SELECT %s FROM ps_common.gearUseFeatures WHERE gearUseFeatures.topiaId %s",
+        "insertSql": "INSERT INTO ps_common.gearUseFeatures(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,gear,homeid,lastupdatedate,number,topiacreatedate,topiaversion,trip,usedintrip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_common.gearUseFeaturesMeasurement",
+        "selectedSql": "SELECT %s FROM ps_common.gearUseFeaturesMeasurement gearUseFeaturesMeasurement WHERE gearUseFeaturesMeasurement.gearUseFeatures %s",
+        "insertSql": "INSERT INTO ps_common.gearUseFeaturesMeasurement(%s) VALUES (%%s);",
+        "parentColumnName": "gearUseFeatures",
+        "columnNames": "topiaid,gearcharacteristic,gearusefeatures,homeid,lastupdatedate,measurementvalue,topiacreatedate,topiaversion"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.common.GearUseFeaturesMeasurement": [
+      {
+        "gav": "ps_common.gearUseFeaturesMeasurement",
+        "selectedSql": "SELECT %s FROM ps_common.gearUseFeaturesMeasurement WHERE gearUseFeaturesMeasurement.topiaId %s",
+        "insertSql": "INSERT INTO ps_common.gearUseFeaturesMeasurement(%s) VALUES (%%s);",
+        "parentColumnName": "gearUseFeatures",
+        "columnNames": "topiaid,gearcharacteristic,gearusefeatures,homeid,lastupdatedate,measurementvalue,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.landing.Landing": [
+      {
+        "gav": "ps_landing.landing",
+        "selectedSql": "SELECT %s FROM ps_landing.landing WHERE landing.topiaId %s",
+        "insertSql": "INSERT INTO ps_landing.landing(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,date,destination,fate,fatevessel,homeid,lastupdatedate,species,topiacreatedate,topiaversion,trip,trip_idx,weight,weightcategory",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.localmarket.Batch": [
+      {
+        "gav": "ps_localmarket.batch",
+        "selectedSql": "SELECT %s FROM ps_localmarket.batch WHERE batch.topiaId %s",
+        "insertSql": "INSERT INTO ps_localmarket.batch(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,count,date,homeid,lastupdatedate,origin,packaging,species,survey,topiacreatedate,topiaversion,trip,weight,weightcomputedsource",
+        "columnsToDetach": "survey~ps_localmarket.survey",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.localmarket.Sample": [
+      {
+        "gav": "ps_localmarket.sample",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sample WHERE sample.topiaId %s",
+        "insertSql": "INSERT INTO ps_localmarket.sample(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,date,homeid,lastupdatedate,number,sampletype,topiacreatedate,topiaversion,trip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_localmarket.sampleSpecies",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sampleSpecies sampleSpecies WHERE sampleSpecies.sample %s",
+        "insertSql": "INSERT INTO ps_localmarket.sampleSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,measuredcount,sample,sizemeasuretype,species,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_localmarket.sampleSpeciesMeasure",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sampleSpeciesMeasure sampleSpeciesMeasure INNER JOIN ps_localmarket.sampleSpecies sampleSpecies ON sampleSpecies.topiaId = sampleSpeciesMeasure.sampleSpecies WHERE sampleSpecies.sample %s",
+        "insertSql": "INSERT INTO ps_localmarket.sampleSpeciesMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sampleSpecies",
+        "columnNames": "topiaid,count,homeid,lastupdatedate,samplespecies,sizeclass,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_localmarket.sample_well",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sample_well WHERE sample_well.sample %s",
+        "insertSql": "INSERT INTO ps_localmarket.sample_well(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "sample,well",
+        "columnsToReplace": "sample"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.localmarket.SampleSpecies": [
+      {
+        "gav": "ps_localmarket.sampleSpecies",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sampleSpecies WHERE sampleSpecies.topiaId %s",
+        "insertSql": "INSERT INTO ps_localmarket.sampleSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,measuredcount,sample,sizemeasuretype,species,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_localmarket.sampleSpeciesMeasure",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sampleSpeciesMeasure sampleSpeciesMeasure WHERE sampleSpeciesMeasure.sampleSpecies %s",
+        "insertSql": "INSERT INTO ps_localmarket.sampleSpeciesMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sampleSpecies",
+        "columnNames": "topiaid,count,homeid,lastupdatedate,samplespecies,sizeclass,topiacreatedate,topiaversion"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.localmarket.SampleSpeciesMeasure": [
+      {
+        "gav": "ps_localmarket.sampleSpeciesMeasure",
+        "selectedSql": "SELECT %s FROM ps_localmarket.sampleSpeciesMeasure WHERE sampleSpeciesMeasure.topiaId %s",
+        "insertSql": "INSERT INTO ps_localmarket.sampleSpeciesMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sampleSpecies",
+        "columnNames": "topiaid,count,homeid,lastupdatedate,samplespecies,sizeclass,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.localmarket.Survey": [
+      {
+        "gav": "ps_localmarket.survey",
+        "selectedSql": "SELECT %s FROM ps_localmarket.survey WHERE survey.topiaId %s",
+        "insertSql": "INSERT INTO ps_localmarket.survey(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,date,homeid,lastupdatedate,number,topiacreatedate,topiaversion,trip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_localmarket.surveyPart",
+        "selectedSql": "SELECT %s FROM ps_localmarket.surveyPart surveyPart WHERE surveyPart.survey %s",
+        "insertSql": "INSERT INTO ps_localmarket.surveyPart(%s) VALUES (%%s);",
+        "parentColumnName": "survey",
+        "columnNames": "topiaid,homeid,lastupdatedate,proportion,species,survey,topiacreatedate,topiaversion"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.localmarket.SurveyPart": [
+      {
+        "gav": "ps_localmarket.surveyPart",
+        "selectedSql": "SELECT %s FROM ps_localmarket.surveyPart WHERE surveyPart.topiaId %s",
+        "insertSql": "INSERT INTO ps_localmarket.surveyPart(%s) VALUES (%%s);",
+        "parentColumnName": "survey",
+        "columnNames": "topiaid,homeid,lastupdatedate,proportion,species,survey,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.Activity": [
+      {
+        "gav": "ps_logbook.activity",
+        "selectedSql": "SELECT %s FROM ps_logbook.activity WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.activity(%s) VALUES (%%s);",
+        "parentColumnName": "route",
+        "columnNames": "topiaid,comment,currentdirection,currentspeed,dataquality,fpazone,homeid,informationsource,lastupdatedate,latitude,latitudeoriginal,longitude,longitudeoriginal,number,originaldatamodified,positioncorrected,reasonfornofishing,reasonfornullset,relatedobservedactivity,route,schooltype,seasurfacetemperature,setcount,setsuccessstatus,time,topiacreatedate,topiaversion,totalweight,vesselactivity,vmsdivergent,wind,winddirection",
+        "columnsToDetach": "relatedObservedActivity~ps_observation.activity",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_logbook.catch",
+        "selectedSql": "SELECT %s FROM ps_logbook.catch catch WHERE catch.activity %s",
+        "insertSql": "INSERT INTO ps_logbook.catch(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,activity_idx,comment,count,homeid,lastupdatedate,species,speciesfate,topiacreatedate,topiaversion,weight,weightcategory,weightmeasuremethod,well"
+      },
+      {
+        "gav": "ps_logbook.floatingObject",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObject floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObject(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,comment,computedwhenarrivingbiodegradable,computedwhenarrivingnonentangling,computedwhenarrivingsimplifiedobjecttype,computedwhenleavingbiodegradable,computedwhenleavingnonentangling,computedwhenleavingsimplifiedobjecttype,homeid,lastupdatedate,objectoperation,supportvesselname,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_logbook.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObjectPart floatingObjectPart INNER JOIN ps_logbook.floatingObject floatingObject ON floatingObject.topiaId = floatingObjectPart.floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving"
+      },
+      {
+        "gav": "ps_logbook.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_logbook.transmittingBuoy transmittingBuoy INNER JOIN ps_logbook.floatingObject floatingObject ON floatingObject.topiaId = transmittingBuoy.floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_logbook.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel"
+      },
+      {
+        "gav": "ps_logbook.activity_observedsystem",
+        "selectedSql": "SELECT %s FROM ps_logbook.activity_observedsystem WHERE activity_observedsystem.activity %s",
+        "insertSql": "INSERT INTO ps_logbook.activity_observedsystem(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "activity,observedsystem",
+        "columnsToReplace": "activity"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.Catch": [
+      {
+        "gav": "ps_logbook.catch",
+        "selectedSql": "SELECT %s FROM ps_logbook.catch WHERE catch.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.catch(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,activity_idx,comment,count,homeid,lastupdatedate,species,speciesfate,topiacreatedate,topiaversion,weight,weightcategory,weightmeasuremethod,well",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.FloatingObject": [
+      {
+        "gav": "ps_logbook.floatingObject",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObject WHERE floatingObject.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObject(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,comment,computedwhenarrivingbiodegradable,computedwhenarrivingnonentangling,computedwhenarrivingsimplifiedobjecttype,computedwhenleavingbiodegradable,computedwhenleavingnonentangling,computedwhenleavingsimplifiedobjecttype,homeid,lastupdatedate,objectoperation,supportvesselname,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_logbook.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObjectPart floatingObjectPart WHERE floatingObjectPart.floatingObject %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving"
+      },
+      {
+        "gav": "ps_logbook.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_logbook.transmittingBuoy transmittingBuoy WHERE transmittingBuoy.floatingObject %s",
+        "insertSql": "INSERT INTO ps_logbook.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.FloatingObjectPart": [
+      {
+        "gav": "ps_logbook.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObjectPart WHERE floatingObjectPart.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.Route": [
+      {
+        "gav": "ps_logbook.route",
+        "selectedSql": "SELECT %s FROM ps_logbook.route WHERE route.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.route(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,date,fishingtime,homeid,lastupdatedate,timeatsea,topiacreatedate,topiaversion,trip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_logbook.activity",
+        "selectedSql": "SELECT %s FROM ps_logbook.activity activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_logbook.activity(%s) VALUES (%%s);",
+        "parentColumnName": "route",
+        "columnNames": "topiaid,comment,currentdirection,currentspeed,dataquality,fpazone,homeid,informationsource,lastupdatedate,latitude,latitudeoriginal,longitude,longitudeoriginal,number,originaldatamodified,positioncorrected,reasonfornofishing,reasonfornullset,relatedobservedactivity,route,schooltype,seasurfacetemperature,setcount,setsuccessstatus,time,topiacreatedate,topiaversion,totalweight,vesselactivity,vmsdivergent,wind,winddirection",
+        "columnsToDetach": "relatedObservedActivity~ps_observation.activity"
+      },
+      {
+        "gav": "ps_logbook.catch",
+        "selectedSql": "SELECT %s FROM ps_logbook.catch catch INNER JOIN ps_logbook.activity activity ON activity.topiaId = catch.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_logbook.catch(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,activity_idx,comment,count,homeid,lastupdatedate,species,speciesfate,topiacreatedate,topiaversion,weight,weightcategory,weightmeasuremethod,well"
+      },
+      {
+        "gav": "ps_logbook.floatingObject",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObject floatingObject INNER JOIN ps_logbook.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObject(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,comment,computedwhenarrivingbiodegradable,computedwhenarrivingnonentangling,computedwhenarrivingsimplifiedobjecttype,computedwhenleavingbiodegradable,computedwhenleavingnonentangling,computedwhenleavingsimplifiedobjecttype,homeid,lastupdatedate,objectoperation,supportvesselname,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_logbook.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_logbook.floatingObjectPart floatingObjectPart INNER JOIN ps_logbook.floatingObject floatingObject ON floatingObject.topiaId = floatingObjectPart.floatingObject  INNER JOIN ps_logbook.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_logbook.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving"
+      },
+      {
+        "gav": "ps_logbook.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_logbook.transmittingBuoy transmittingBuoy INNER JOIN ps_logbook.floatingObject floatingObject ON floatingObject.topiaId = transmittingBuoy.floatingObject  INNER JOIN ps_logbook.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_logbook.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel"
+      },
+      {
+        "gav": "ps_logbook.activity_observedsystem",
+        "selectedSql": "SELECT %s FROM ps_logbook.activity_observedsystem INNER JOIN ps_logbook.activity activity ON activity_observedsystem.activity = activity.topiaId WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_logbook.activity_observedsystem(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "activity,observedsystem",
+        "columnsToReplace": "activity"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.Sample": [
+      {
+        "gav": "ps_logbook.sample",
+        "selectedSql": "SELECT %s FROM ps_logbook.sample WHERE sample.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.sample(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,bigsweight,comment,homeid,lastupdatedate,number,samplequality,sampletype,smallsweight,supersample,topiacreatedate,topiaversion,totalweight,trip,well",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_logbook.sampleActivity",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleActivity sampleActivity WHERE sampleActivity.sample %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleActivity(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,activity,homeid,lastupdatedate,sample,topiacreatedate,topiaversion,weightedweight",
+        "columnsToDetach": "activity~ps_logbook.activity"
+      },
+      {
+        "gav": "ps_logbook.sampleSpecies",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleSpecies sampleSpecies WHERE sampleSpecies.sample %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,comment,endtime,homeid,lastupdatedate,measuredcount,sample,sample_idx,sizemeasuretype,species,starttime,subsamplenumber,topiacreatedate,topiaversion,totalcount"
+      },
+      {
+        "gav": "ps_logbook.sampleSpeciesMeasure",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleSpeciesMeasure sampleSpeciesMeasure INNER JOIN ps_logbook.sampleSpecies sampleSpecies ON sampleSpecies.topiaId = sampleSpeciesMeasure.sampleSpecies WHERE sampleSpecies.sample %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleSpeciesMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sampleSpecies",
+        "columnNames": "topiaid,count,homeid,lastupdatedate,samplespecies,sizeclass,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_logbook.sample_person",
+        "selectedSql": "SELECT %s FROM ps_logbook.sample_person WHERE sample_person.sample %s",
+        "insertSql": "INSERT INTO ps_logbook.sample_person(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "person,sample",
+        "columnsToReplace": "sample"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.SampleActivity": [
+      {
+        "gav": "ps_logbook.sampleActivity",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleActivity WHERE sampleActivity.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleActivity(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,activity,homeid,lastupdatedate,sample,topiacreatedate,topiaversion,weightedweight",
+        "columnsToDetach": "activity~ps_logbook.activity",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.SampleSpecies": [
+      {
+        "gav": "ps_logbook.sampleSpecies",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleSpecies WHERE sampleSpecies.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,comment,endtime,homeid,lastupdatedate,measuredcount,sample,sample_idx,sizemeasuretype,species,starttime,subsamplenumber,topiacreatedate,topiaversion,totalcount",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_logbook.sampleSpeciesMeasure",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleSpeciesMeasure sampleSpeciesMeasure WHERE sampleSpeciesMeasure.sampleSpecies %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleSpeciesMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sampleSpecies",
+        "columnNames": "topiaid,count,homeid,lastupdatedate,samplespecies,sizeclass,topiacreatedate,topiaversion"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.SampleSpeciesMeasure": [
+      {
+        "gav": "ps_logbook.sampleSpeciesMeasure",
+        "selectedSql": "SELECT %s FROM ps_logbook.sampleSpeciesMeasure WHERE sampleSpeciesMeasure.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.sampleSpeciesMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sampleSpecies",
+        "columnNames": "topiaid,count,homeid,lastupdatedate,samplespecies,sizeclass,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.TransmittingBuoy": [
+      {
+        "gav": "ps_logbook.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_logbook.transmittingBuoy WHERE transmittingBuoy.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.logbook.WellPlan": [
+      {
+        "gav": "ps_logbook.wellPlan",
+        "selectedSql": "SELECT %s FROM ps_logbook.wellPlan WHERE wellPlan.topiaId %s",
+        "insertSql": "INSERT INTO ps_logbook.wellPlan(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,activity,homeid,lastupdatedate,species,topiacreatedate,topiaversion,trip,trip_idx,weight,weightcategory,well,wellsamplingconformity,wellsamplingstatus",
+        "columnsToDetach": "activity~ps_logbook.activity",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.Activity": [
+      {
+        "gav": "ps_observation.set",
+        "selectedSql": "SELECT %s FROM ps_observation.set set INNER JOIN ps_observation.activity activity ON activity.set = set.topiaId WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.set(%s) VALUES (%%s);",
+        "columnNames": "topiaid,comment,currentdirection,currentmeasuredepth,currentspeed,endtimestamp,haulingendtimestamp,haulingstarttimestamp,homeid,lastupdatedate,maxgeardepth,reasonfornullset,schoolmeandepth,schoolthickness,schooltopdepth,schooltype,starttime,supportvesselname,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.activity",
+        "selectedSql": "SELECT %s FROM ps_observation.activity WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.activity(%s) VALUES (%%s);",
+        "parentColumnName": "route",
+        "columnNames": "topiaid,comment,currentfpazone,dataquality,detectionmode,ersid,homeid,lastupdatedate,latitude,longitude,nextfpazone,observedsystemdistance,previousfpazone,reasonfornofishing,route,seasurfacetemperature,set,surroundingactivity,time,topiacreatedate,topiaversion,vesselactivity,vesselspeed,wind",
+        "columnsToReplace": "set",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_observation.catch",
+        "selectedSql": "SELECT %s FROM ps_observation.catch catch INNER JOIN ps_observation.activity activity ON activity.set = catch.set  INNER JOIN ps_observation.route route ON route.topiaId = activity.route WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,catchweight,catchweightcomputedsource,comment,homeid,informationsource,lastupdatedate,lengthmeasuremethod,meanlength,meanlengthcomputedsource,meanweight,meanweightcomputedsource,reasonfordiscard,set,set_idx,species,speciesfate,topiacreatedate,topiaversion,totalcount,totalcountcomputedsource,weightmeasuremethod,well"
+      },
+      {
+        "gav": "ps_observation.floatingObject",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObject floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObject(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,comment,computedwhenarrivingbiodegradable,computedwhenarrivingnonentangling,computedwhenarrivingsimplifiedobjecttype,computedwhenleavingbiodegradable,computedwhenleavingnonentangling,computedwhenleavingsimplifiedobjecttype,homeid,lastupdatedate,objectoperation,supportvesselname,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObjectPart floatingObjectPart INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = floatingObjectPart.floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving"
+      },
+      {
+        "gav": "ps_observation.nonTargetCatchRelease",
+        "selectedSql": "SELECT %s FROM ps_observation.nonTargetCatchRelease nonTargetCatchRelease INNER JOIN ps_observation.activity activity ON activity.set = nonTargetCatchRelease.set  INNER JOIN ps_observation.route route ON route.topiaId = activity.route WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.nonTargetCatchRelease(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,comment,conformity,count,homeid,lastupdatedate,length,lengthmeasuremethod,releasingtime,set,set_idx,sex,species,speciesgroupreleasemode,status,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.objectObservedSpecies",
+        "selectedSql": "SELECT %s FROM ps_observation.objectObservedSpecies objectObservedSpecies INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = objectObservedSpecies.floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_observation.objectObservedSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,count,floatingobject,homeid,lastupdatedate,species,speciesstatus,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.objectSchoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.objectSchoolEstimate objectSchoolEstimate INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = objectSchoolEstimate.floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_observation.objectSchoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ps_observation.schoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.schoolEstimate schoolEstimate INNER JOIN ps_observation.activity activity ON activity.set = schoolEstimate.set  INNER JOIN ps_observation.route route ON route.topiaId = activity.route WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.schoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,meanweight,set,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ps_observation.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_observation.transmittingBuoy transmittingBuoy INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = transmittingBuoy.floatingObject WHERE floatingObject.activity %s",
+        "insertSql": "INSERT INTO ps_observation.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel"
+      },
+      {
+        "gav": "ps_observation.sample",
+        "selectedSql": "SELECT %s FROM ps_observation.sample sample INNER JOIN ps_observation.activity activity ON activity.set = sample.set  INNER JOIN ps_observation.route route ON route.topiaId = activity.route WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.sample(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.sampleMeasure",
+        "selectedSql": "SELECT %s FROM ps_observation.sampleMeasure sampleMeasure INNER JOIN ps_observation.sample sample ON sample.topiaId = sampleMeasure.sample  INNER JOIN ps_observation.activity activity ON activity.set = sample.set  INNER JOIN ps_observation.route route ON route.topiaId = activity.route WHERE activity.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.sampleMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,islengthcomputed,isweightcomputed,lastupdatedate,length,lengthmeasuremethod,picturesreferences,sample,sample_idx,sex,sizemeasuretype,species,speciesfate,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype"
+      },
+      {
+        "gav": "ps_observation.activity_observedsystem",
+        "selectedSql": "SELECT %s FROM ps_observation.activity_observedsystem WHERE activity_observedsystem.activity %s",
+        "insertSql": "INSERT INTO ps_observation.activity_observedsystem(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "activity,observedsystem",
+        "columnsToReplace": "activity"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.Catch": [
+      {
+        "gav": "ps_observation.catch",
+        "selectedSql": "SELECT %s FROM ps_observation.catch WHERE catch.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,catchweight,catchweightcomputedsource,comment,homeid,informationsource,lastupdatedate,lengthmeasuremethod,meanlength,meanlengthcomputedsource,meanweight,meanweightcomputedsource,reasonfordiscard,set,set_idx,species,speciesfate,topiacreatedate,topiaversion,totalcount,totalcountcomputedsource,weightmeasuremethod,well",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.FloatingObject": [
+      {
+        "gav": "ps_observation.floatingObject",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObject WHERE floatingObject.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObject(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,comment,computedwhenarrivingbiodegradable,computedwhenarrivingnonentangling,computedwhenarrivingsimplifiedobjecttype,computedwhenleavingbiodegradable,computedwhenleavingnonentangling,computedwhenleavingsimplifiedobjecttype,homeid,lastupdatedate,objectoperation,supportvesselname,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_observation.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObjectPart floatingObjectPart WHERE floatingObjectPart.floatingObject %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving"
+      },
+      {
+        "gav": "ps_observation.objectObservedSpecies",
+        "selectedSql": "SELECT %s FROM ps_observation.objectObservedSpecies objectObservedSpecies WHERE objectObservedSpecies.floatingObject %s",
+        "insertSql": "INSERT INTO ps_observation.objectObservedSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,count,floatingobject,homeid,lastupdatedate,species,speciesstatus,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.objectSchoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.objectSchoolEstimate objectSchoolEstimate WHERE objectSchoolEstimate.floatingObject %s",
+        "insertSql": "INSERT INTO ps_observation.objectSchoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ps_observation.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_observation.transmittingBuoy transmittingBuoy WHERE transmittingBuoy.floatingObject %s",
+        "insertSql": "INSERT INTO ps_observation.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.FloatingObjectPart": [
+      {
+        "gav": "ps_observation.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObjectPart WHERE floatingObjectPart.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.NonTargetCatchRelease": [
+      {
+        "gav": "ps_observation.nonTargetCatchRelease",
+        "selectedSql": "SELECT %s FROM ps_observation.nonTargetCatchRelease WHERE nonTargetCatchRelease.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.nonTargetCatchRelease(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,comment,conformity,count,homeid,lastupdatedate,length,lengthmeasuremethod,releasingtime,set,set_idx,sex,species,speciesgroupreleasemode,status,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.ObjectObservedSpecies": [
+      {
+        "gav": "ps_observation.objectObservedSpecies",
+        "selectedSql": "SELECT %s FROM ps_observation.objectObservedSpecies WHERE objectObservedSpecies.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.objectObservedSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,count,floatingobject,homeid,lastupdatedate,species,speciesstatus,topiacreatedate,topiaversion",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.ObjectSchoolEstimate": [
+      {
+        "gav": "ps_observation.objectSchoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.objectSchoolEstimate WHERE objectSchoolEstimate.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.objectSchoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.Route": [
+      {
+        "gav": "ps_observation.route",
+        "selectedSql": "SELECT %s FROM ps_observation.route WHERE route.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.route(%s) VALUES (%%s);",
+        "parentColumnName": "trip",
+        "columnNames": "topiaid,comment,date,endlogvalue,homeid,lastupdatedate,startlogvalue,topiacreatedate,topiaversion,trip",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_observation.set",
+        "selectedSql": "SELECT %s FROM ps_observation.set set INNER JOIN ps_observation.activity activity ON activity.set = set.topiaId WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.set(%s) VALUES (%%s);",
+        "columnNames": "topiaid,comment,currentdirection,currentmeasuredepth,currentspeed,endtimestamp,haulingendtimestamp,haulingstarttimestamp,homeid,lastupdatedate,maxgeardepth,reasonfornullset,schoolmeandepth,schoolthickness,schooltopdepth,schooltype,starttime,supportvesselname,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.activity",
+        "selectedSql": "SELECT %s FROM ps_observation.activity activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.activity(%s) VALUES (%%s);",
+        "parentColumnName": "route",
+        "columnNames": "topiaid,comment,currentfpazone,dataquality,detectionmode,ersid,homeid,lastupdatedate,latitude,longitude,nextfpazone,observedsystemdistance,previousfpazone,reasonfornofishing,route,seasurfacetemperature,set,surroundingactivity,time,topiacreatedate,topiaversion,vesselactivity,vesselspeed,wind",
+        "columnsToReplace": "set"
+      },
+      {
+        "gav": "ps_observation.catch",
+        "selectedSql": "SELECT %s FROM ps_observation.catch catch INNER JOIN ps_observation.activity activity ON activity.set = catch.set WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,catchweight,catchweightcomputedsource,comment,homeid,informationsource,lastupdatedate,lengthmeasuremethod,meanlength,meanlengthcomputedsource,meanweight,meanweightcomputedsource,reasonfordiscard,set,set_idx,species,speciesfate,topiacreatedate,topiaversion,totalcount,totalcountcomputedsource,weightmeasuremethod,well"
+      },
+      {
+        "gav": "ps_observation.floatingObject",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObject floatingObject INNER JOIN ps_observation.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObject(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "topiaid,activity,comment,computedwhenarrivingbiodegradable,computedwhenarrivingnonentangling,computedwhenarrivingsimplifiedobjecttype,computedwhenleavingbiodegradable,computedwhenleavingnonentangling,computedwhenleavingsimplifiedobjecttype,homeid,lastupdatedate,objectoperation,supportvesselname,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.floatingObjectPart",
+        "selectedSql": "SELECT %s FROM ps_observation.floatingObjectPart floatingObjectPart INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = floatingObjectPart.floatingObject  INNER JOIN ps_observation.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.floatingObjectPart(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,objectmaterial,topiacreatedate,topiaversion,whenarriving,whenleaving"
+      },
+      {
+        "gav": "ps_observation.nonTargetCatchRelease",
+        "selectedSql": "SELECT %s FROM ps_observation.nonTargetCatchRelease nonTargetCatchRelease INNER JOIN ps_observation.activity activity ON activity.set = nonTargetCatchRelease.set WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.nonTargetCatchRelease(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,comment,conformity,count,homeid,lastupdatedate,length,lengthmeasuremethod,releasingtime,set,set_idx,sex,species,speciesgroupreleasemode,status,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.objectObservedSpecies",
+        "selectedSql": "SELECT %s FROM ps_observation.objectObservedSpecies objectObservedSpecies INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = objectObservedSpecies.floatingObject  INNER JOIN ps_observation.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.objectObservedSpecies(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,count,floatingobject,homeid,lastupdatedate,species,speciesstatus,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.objectSchoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.objectSchoolEstimate objectSchoolEstimate INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = objectSchoolEstimate.floatingObject  INNER JOIN ps_observation.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.objectSchoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,floatingobject,homeid,lastupdatedate,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ps_observation.schoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.schoolEstimate schoolEstimate INNER JOIN ps_observation.activity activity ON activity.set = schoolEstimate.set WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.schoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,meanweight,set,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ps_observation.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_observation.transmittingBuoy transmittingBuoy INNER JOIN ps_observation.floatingObject floatingObject ON floatingObject.topiaId = transmittingBuoy.floatingObject  INNER JOIN ps_observation.activity activity ON activity.topiaId = floatingObject.activity WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel"
+      },
+      {
+        "gav": "ps_observation.sample",
+        "selectedSql": "SELECT %s FROM ps_observation.sample sample INNER JOIN ps_observation.activity activity ON activity.set = sample.set WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.sample(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.sampleMeasure",
+        "selectedSql": "SELECT %s FROM ps_observation.sampleMeasure sampleMeasure INNER JOIN ps_observation.sample sample ON sample.topiaId = sampleMeasure.sample  INNER JOIN ps_observation.activity activity ON activity.set = sample.set WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.sampleMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,islengthcomputed,isweightcomputed,lastupdatedate,length,lengthmeasuremethod,picturesreferences,sample,sample_idx,sex,sizemeasuretype,species,speciesfate,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype"
+      },
+      {
+        "gav": "ps_observation.activity_observedsystem",
+        "selectedSql": "SELECT %s FROM ps_observation.activity_observedsystem INNER JOIN ps_observation.activity activity ON activity_observedsystem.activity = activity.topiaId WHERE activity.route %s",
+        "insertSql": "INSERT INTO ps_observation.activity_observedsystem(%s) VALUES (%%s);",
+        "parentColumnName": "activity",
+        "columnNames": "activity,observedsystem",
+        "columnsToReplace": "activity"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.Sample": [
+      {
+        "gav": "ps_observation.sample",
+        "selectedSql": "SELECT %s FROM ps_observation.sample WHERE sample.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.sample(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,set,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_observation.sampleMeasure",
+        "selectedSql": "SELECT %s FROM ps_observation.sampleMeasure sampleMeasure WHERE sampleMeasure.sample %s",
+        "insertSql": "INSERT INTO ps_observation.sampleMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,islengthcomputed,isweightcomputed,lastupdatedate,length,lengthmeasuremethod,picturesreferences,sample,sample_idx,sex,sizemeasuretype,species,speciesfate,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.SampleMeasure": [
+      {
+        "gav": "ps_observation.sampleMeasure",
+        "selectedSql": "SELECT %s FROM ps_observation.sampleMeasure WHERE sampleMeasure.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.sampleMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,islengthcomputed,isweightcomputed,lastupdatedate,length,lengthmeasuremethod,picturesreferences,sample,sample_idx,sex,sizemeasuretype,species,speciesfate,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.SchoolEstimate": [
+      {
+        "gav": "ps_observation.schoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.schoolEstimate WHERE schoolEstimate.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.schoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,meanweight,set,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod",
+        "entryPoint": true
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.Set": [
+      {
+        "gav": "ps_observation.set",
+        "selectedSql": "SELECT %s FROM ps_observation.set WHERE set.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.set(%s) VALUES (%%s);",
+        "updateReverseAssociationSql": "UPDATE ps_observation.activity activity SET activity.set = '%s' WHERE activity.topiaId = '%s'",
+        "columnNames": "topiaid,comment,currentdirection,currentmeasuredepth,currentspeed,endtimestamp,haulingendtimestamp,haulingstarttimestamp,homeid,lastupdatedate,maxgeardepth,reasonfornullset,schoolmeandepth,schoolthickness,schooltopdepth,schooltype,starttime,supportvesselname,topiacreatedate,topiaversion",
+        "entryPoint": true
+      },
+      {
+        "gav": "ps_observation.catch",
+        "selectedSql": "SELECT %s FROM ps_observation.catch catch WHERE catch.set %s",
+        "insertSql": "INSERT INTO ps_observation.catch(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,catchweight,catchweightcomputedsource,comment,homeid,informationsource,lastupdatedate,lengthmeasuremethod,meanlength,meanlengthcomputedsource,meanweight,meanweightcomputedsource,reasonfordiscard,set,set_idx,species,speciesfate,topiacreatedate,topiaversion,totalcount,totalcountcomputedsource,weightmeasuremethod,well"
+      },
+      {
+        "gav": "ps_observation.nonTargetCatchRelease",
+        "selectedSql": "SELECT %s FROM ps_observation.nonTargetCatchRelease nonTargetCatchRelease WHERE nonTargetCatchRelease.set %s",
+        "insertSql": "INSERT INTO ps_observation.nonTargetCatchRelease(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,acquisitionmode,comment,conformity,count,homeid,lastupdatedate,length,lengthmeasuremethod,releasingtime,set,set_idx,sex,species,speciesgroupreleasemode,status,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.schoolEstimate",
+        "selectedSql": "SELECT %s FROM ps_observation.schoolEstimate schoolEstimate WHERE schoolEstimate.set %s",
+        "insertSql": "INSERT INTO ps_observation.schoolEstimate(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,homeid,lastupdatedate,meanweight,set,species,topiacreatedate,topiaversion,totalweight,weightmeasuremethod"
+      },
+      {
+        "gav": "ps_observation.sample",
+        "selectedSql": "SELECT %s FROM ps_observation.sample sample WHERE sample.set %s",
+        "insertSql": "INSERT INTO ps_observation.sample(%s) VALUES (%%s);",
+        "parentColumnName": "set",
+        "columnNames": "topiaid,comment,homeid,lastupdatedate,set,topiacreatedate,topiaversion"
+      },
+      {
+        "gav": "ps_observation.sampleMeasure",
+        "selectedSql": "SELECT %s FROM ps_observation.sampleMeasure sampleMeasure INNER JOIN ps_observation.sample sample ON sample.topiaId = sampleMeasure.sample WHERE sample.set %s",
+        "insertSql": "INSERT INTO ps_observation.sampleMeasure(%s) VALUES (%%s);",
+        "parentColumnName": "sample",
+        "columnNames": "topiaid,acquisitionmode,count,homeid,islengthcomputed,isweightcomputed,lastupdatedate,length,lengthmeasuremethod,picturesreferences,sample,sample_idx,sex,sizemeasuretype,species,speciesfate,tagnumber,topiacreatedate,topiaversion,weight,weightmeasuremethod,weightmeasuretype"
+      }
+    ],
+    "fr.ird.observe.entities.data.ps.observation.TransmittingBuoy": [
+      {
+        "gav": "ps_observation.transmittingBuoy",
+        "selectedSql": "SELECT %s FROM ps_observation.transmittingBuoy WHERE transmittingBuoy.topiaId %s",
+        "insertSql": "INSERT INTO ps_observation.transmittingBuoy(%s) VALUES (%%s);",
+        "parentColumnName": "floatingObject",
+        "columnNames": "topiaid,code,comment,country,floatingobject,homeid,lastupdatedate,latitude,longitude,topiacreatedate,topiaversion,transmittingbuoyoperation,transmittingbuoyownership,transmittingbuoytype,vessel",
+        "entryPoint": true
+      }
+    ]
+  }
+}
\ No newline at end of file


=====================================
core/persistence/java/src/test/java/fr/ird/observe/spi/script/UpdateLastUpdateDateFieldScriptTest.java
=====================================
@@ -23,12 +23,10 @@ package fr.ird.observe.spi.script;
  */
 
 import fr.ird.observe.entities.ObserveTopiaEntitySqlModelResource;
-import fr.ird.observe.spi.script.ToolkitEntitySqlScriptModel;
-import fr.ird.observe.spi.script.UpdateLastUpdateDateFieldScript;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModel;
 
 import java.util.Date;
 import java.util.List;


=====================================
core/persistence/java/src/test/java/fr/ird/observe/spi/script/UpdateLastUpdateDateTableScriptTest.java
=====================================
@@ -23,12 +23,10 @@ package fr.ird.observe.spi.script;
  */
 
 import fr.ird.observe.entities.ObserveTopiaEntitySqlModelResource;
-import fr.ird.observe.spi.script.ToolkitEntitySqlScriptModel;
-import fr.ird.observe.spi.script.UpdateLastUpdateDateTableScript;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModel;
 
 import java.util.Date;
 import java.util.List;


=====================================
core/persistence/test/src/main/java/fr/ird/observe/persistence/test/PersistenceTestSupportRead.java
=====================================
@@ -33,8 +33,8 @@ import fr.ird.observe.test.spi.DatabaseVersionConfiguration;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.junit.ClassRule;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataEntity;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataEntity;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModel;
 import org.nuiton.topia.service.sql.model.TopiaEntitySqlModel;
 
 import java.util.List;


=====================================
core/persistence/test/src/main/java/fr/ird/observe/persistence/test/PersistenceTestSupportWrite.java
=====================================
@@ -39,7 +39,7 @@ import org.junit.After;
 import org.junit.Assert;
 import org.junit.ClassRule;
 import org.junit.Rule;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataEntity;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataEntity;
 import org.nuiton.topia.service.sql.model.TopiaEntitySqlDescriptors;
 import org.nuiton.topia.service.sql.model.TopiaEntitySqlModel;
 import org.nuiton.topia.service.sql.plan.copy.TopiaEntitySqlCopyPlan;


=====================================
core/persistence/test/src/test/java/fr/ird/observe/persistence/test/DefinitionContentTest.java
=====================================
@@ -29,7 +29,7 @@ import fr.ird.observe.spi.context.DtoEntityContext;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModel;
 
 /**
  * Created on 22/11/2021.


=====================================
core/persistence/test/src/test/java/fr/ird/observe/persistence/test/PersistenceModelWriteTest.java
=====================================
@@ -111,7 +111,7 @@ public class PersistenceModelWriteTest extends PersistenceTestSupportWrite {
             TopiaEntitySqlCopyPlan copyPlan = copyPlan(classifier, applicationContext);
             createRequest(classifier);
             if (!classifier.equals(CLASSIFIER_REFERENTIAL)) {
-                request.addReplicateTableRequest(applicationContext.getSqlService().getCopyPlanModel().getStandalonePlan(), null);
+                request.addCopyTableRequest(applicationContext.getSqlService().getCopyPlanModel().getStandalonePlan(), null);
                 selectArgument = TopiaEntitySqlSelectArgument.of(tripId);
             }
             importScriptAndAssertCount(applicationContext, copyPlan, selectArgument, expectedCount);
@@ -136,7 +136,7 @@ public class PersistenceModelWriteTest extends PersistenceTestSupportWrite {
     }
 
     void importScriptAndAssertCount(ObserveTopiaApplicationContext applicationContext, TopiaEntitySqlCopyPlan copyPlan, TopiaEntitySqlSelectArgument selectArgument, Map<String, Long> expectedResults) throws Exception {
-        request.addReplicateTableRequest(copyPlan, selectArgument);
+        request.addCopyTableRequest(copyPlan, selectArgument);
         TopiaSqlScript script = applicationContext.getSqlService().consume(request);
         log.info(String.format("Generated script: %s", scriptFile));
         File targetDatabaseDirectory = new File(localTestMethodResource.getTestDirectory(), "import-" + scriptFile.getName());


=====================================
core/persistence/test/src/test/java/fr/ird/observe/persistence/test/SqlServiceTest.java
=====================================
@@ -41,9 +41,7 @@ import org.junit.runners.Parameterized;
 import org.nuiton.topia.persistence.script.TopiaSqlScript;
 import org.nuiton.topia.service.sql.request.DeleteRequest;
 
-import java.io.ByteArrayOutputStream;
 import java.io.IOException;
-import java.nio.charset.StandardCharsets;
 import java.util.Comparator;
 import java.util.stream.Collectors;
 
@@ -82,11 +80,7 @@ public class SqlServiceTest extends PersistenceTestSupportWrite {
         DeleteRequest request = DeleteRequest.of(false, entityType.getName(), id);
         TopiaSqlScript script = applicationContext.getSqlService().consume(request);
         if (!ObservePersistenceFixtures.WITH_ASSERT) {
-            String content;
-            try (ByteArrayOutputStream target = new ByteArrayOutputStream()) {
-                script.copy(target);
-                content = target.toString(StandardCharsets.UTF_8);
-            }
+            String content = script.content();
             System.out.println(content);
         }
         applicationContext.executeSqlStatements(script);


=====================================
core/persistence/test/src/test/java/fr/ird/observe/persistence/test/ValidationContentTest.java
=====================================
@@ -29,7 +29,7 @@ import fr.ird.observe.spi.context.DtoEntityContext;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
-import org.nuiton.topia.persistence.metadata.TopiaMetadataModel;
+import org.nuiton.topia.service.sql.metadata.TopiaMetadataModel;
 
 /**
  * Created on 22/11/2021.


=====================================
core/services/local/src/main/java/fr/ird/observe/services/local/service/DataSourceServiceLocalSupport.java
=====================================
@@ -38,6 +38,7 @@ import org.nuiton.topia.persistence.script.TopiaSqlScript;
 import org.nuiton.topia.service.sql.request.CopyEntryPointRequest;
 import org.nuiton.topia.service.sql.request.CreateDatabaseRequest;
 import org.nuiton.topia.service.sql.request.DeleteRequest;
+import org.nuiton.topia.service.sql.request.ReplicateRequest;
 
 import java.io.File;
 import java.util.Date;
@@ -108,6 +109,11 @@ public class DataSourceServiceLocalSupport extends ObserveServiceLocal implement
         return getTopiaApplicationContext().getSqlService().consume(request);
     }
 
+    @Override
+    public TopiaSqlScript produceMoveSqlScript(ReplicateRequest request) {
+        return getTopiaApplicationContext().getSqlService().consume(request);
+    }
+
     @Override
     public TopiaSqlScript produceCreateSqlScript(CreateDatabaseRequest request) {
         if (request.isAddStandaloneTables()) {


=====================================
core/services/local/src/main/java/fr/ird/observe/services/local/service/ObserveServiceLocal.java
=====================================
@@ -370,6 +370,7 @@ public abstract class ObserveServiceLocal implements ObserveService, ServiceCont
     }
 
     protected final void log(long t0, String prefix, String methodName) {
+        //TODO Maybe for production, we should remove this ? Need to see memory impact
         TIME_LOG.log(t0, String.format("%s %s.%s", prefix, getClass().getName(), methodName));
     }
 


=====================================
core/services/local/src/main/java/fr/ird/observe/services/local/service/referential/SynchronizeServiceLocalSupport.java
=====================================
@@ -33,7 +33,6 @@ import fr.ird.observe.spi.context.ReferentialDtoEntityContext;
 import fr.ird.observe.spi.module.ObserveBusinessProject;
 import fr.ird.observe.spi.referential.synchro.OneSideSqlRequest;
 import fr.ird.observe.spi.referential.synchro.OneSideSqlResult;
-import io.ultreia.java4all.util.TimeLog;
 import org.nuiton.topia.persistence.script.TopiaSqlScript;
 
 import java.util.LinkedHashSet;
@@ -70,20 +69,15 @@ public class SynchronizeServiceLocalSupport extends ObserveServiceLocal implemen
 
     @Override
     public OneSideSqlResult produceSqlResult(OneSideSqlRequest request) {
-        long startTime = TimeLog.getTime();
-        OneSideSqlResult result = getTopiaApplicationContext()
+        return getTopiaApplicationContext()
                 .newOneSideSqlResultBuilder(this, now())
                 .build(request);
-        TIME_LOG.log(startTime, "produceSqlResult");
-        return result;
     }
 
     @Override
     public void applySql(TopiaSqlScript script, String lastUpdateDateKey) {
-        long startTime = TimeLog.getTime();
         getTopiaPersistenceContext().executeSqlScript(script);
         updateLastUpdateDates(lastUpdateDateKey);
-        TIME_LOG.log(startTime, "applySql");
     }
 
     protected void updateLastUpdateDates(String lastUpdateDateKey) {


=====================================
core/services/test/src/main/java/fr/ird/observe/services/service/DataSourceServiceFixtures.java
=====================================
@@ -26,17 +26,22 @@ package fr.ird.observe.services.service;
 import fr.ird.observe.dto.referential.ps.common.ProgramDto;
 import fr.ird.observe.services.ObserveServicesProvider;
 import io.ultreia.java4all.util.Version;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import org.junit.Assert;
 import org.nuiton.topia.persistence.script.TopiaSqlScript;
 import org.nuiton.topia.service.sql.request.CopyEntryPointRequest;
 import org.nuiton.topia.service.sql.request.CreateDatabaseRequest;
 import org.nuiton.topia.service.sql.request.DeleteRequest;
+import org.nuiton.topia.service.sql.request.ReplicateRequest;
 
 import java.util.Collections;
 import java.util.Set;
 
 public class DataSourceServiceFixtures extends GeneratedDataSourceServiceFixtures {
 
+    private static final Logger log = LogManager.getLogger(DataSourceServiceFixtures.class);
+
     @Override
     public void isIdValid(ObserveServicesProvider servicesProvider, DataSourceService service) {
         boolean actual = service.isIdValid(ProgramDto.class, getProperty("isIdValid.id"));
@@ -77,12 +82,11 @@ public class DataSourceServiceFixtures extends GeneratedDataSourceServiceFixture
         Assert.assertTrue(actual.isEmpty());
     }
 
-
     @Override
     public void produceCreateSqlScript(ObserveServicesProvider servicesProvider, DataSourceService service) {
         Version dbVersion = Version.VZERO;
-        CreateDatabaseRequest h2Request = CreateDatabaseRequest.of(false, dbVersion);
-        CreateDatabaseRequest pgRequest = CreateDatabaseRequest.of(true, dbVersion);
+        CreateDatabaseRequest.Builder h2Request = CreateDatabaseRequest.builder(false, dbVersion);
+        CreateDatabaseRequest.Builder pgRequest = CreateDatabaseRequest.builder(true, dbVersion);
 
         produceCreateSqlScript(service, h2Request);
         produceCreateSqlScript(service, pgRequest);
@@ -95,6 +99,13 @@ public class DataSourceServiceFixtures extends GeneratedDataSourceServiceFixture
         produceAddSqlScript(service, true, dbVersion);
     }
 
+    @Override
+    public void produceMoveSqlScript(ObserveServicesProvider servicesProvider, DataSourceService service) {
+        Version dbVersion = Version.VZERO;
+        produceMoveSqlScript(service, false, dbVersion);
+        produceMoveSqlScript(service, true, dbVersion);
+    }
+
     @Override
     public void produceDeleteSqlScript(ObserveServicesProvider servicesProvider, DataSourceService service) {
         String id = getProperty("produceDeleteSqlScript.id");
@@ -102,7 +113,7 @@ public class DataSourceServiceFixtures extends GeneratedDataSourceServiceFixture
         Assert.assertNotNull(actual);
     }
 
-    protected void produceCreateSqlScript(DataSourceService service, CreateDatabaseRequest request) {
+    protected void produceCreateSqlScript(DataSourceService service, CreateDatabaseRequest.Builder request) {
         testRequest(service, request);
         testRequest(service, request = request.addSchema());
         testRequest(service, request = request.addStandaloneTables());
@@ -118,14 +129,35 @@ public class DataSourceServiceFixtures extends GeneratedDataSourceServiceFixture
         testRequest(service, CopyEntryPointRequest.of(pg, dbVersion, "fr.ird.observe.entities.data.ll.common.Trip", Collections.singleton(getLlCommonTripId())));
     }
 
+    protected void produceMoveSqlScript(DataSourceService service, boolean pg, Version dbVersion) {
+        String psObsRouteId = getVariable(getVariableName(fr.ird.observe.dto.data.ps.observation.RouteDto.class));
+        String psObsActivityId = getVariable(getVariableName(fr.ird.observe.dto.data.ps.observation.ActivityDto.class));
+        String psLogbookRouteId = getVariable(getVariableName(fr.ird.observe.dto.data.ps.logbook.RouteDto.class));
+        String psLogbookActivityId = getVariable(getVariableName(fr.ird.observe.dto.data.ps.logbook.ActivityDto.class));
+        String llObsActivityId = getVariable(getVariableName(fr.ird.observe.dto.data.ll.observation.ActivityDto.class));
+        String llLogbookActivityId = getVariable(getVariableName(fr.ird.observe.dto.data.ll.logbook.ActivityDto.class));
+        testRequest(service, ReplicateRequest.of(pg, dbVersion, getPsCommonTripId(), "fr.ird.observe.entities.data.ps.observation.Route", Set.of(psObsRouteId)));
+        testRequest(service, ReplicateRequest.of(pg, dbVersion, psObsRouteId, "fr.ird.observe.entities.data.ps.observation.Activity", Set.of(psObsActivityId)));
+        testRequest(service, ReplicateRequest.of(pg, dbVersion, getPsCommonTripId(), "fr.ird.observe.entities.data.ps.logbook.Route", Set.of(psLogbookRouteId)));
+        testRequest(service, ReplicateRequest.of(pg, dbVersion, psLogbookRouteId, "fr.ird.observe.entities.data.ps.logbook.Activity", Set.of(psLogbookActivityId)));
+        testRequest(service, ReplicateRequest.of(pg, dbVersion, getLlCommonTripId(), "fr.ird.observe.entities.data.ll.observation.Activity", Set.of(llObsActivityId)));
+        testRequest(service, ReplicateRequest.of(pg, dbVersion, getLlCommonTripId(), "fr.ird.observe.entities.data.ll.logbook.Activity", Set.of(llLogbookActivityId)));
+    }
+
     protected void testRequest(DataSourceService service, CopyEntryPointRequest request) {
         TopiaSqlScript actual = service.produceAddSqlScript(request);
         Assert.assertNotNull(actual);
     }
 
-    protected void testRequest(DataSourceService service, CreateDatabaseRequest request) {
-        TopiaSqlScript actual = service.produceCreateSqlScript(request);
+    protected void testRequest(DataSourceService service, CreateDatabaseRequest.Builder request) {
+        TopiaSqlScript actual = service.produceCreateSqlScript(request.build());
+        Assert.assertNotNull(actual);
+    }
+
+    protected void testRequest(DataSourceService service, ReplicateRequest request) {
+        TopiaSqlScript actual = service.produceMoveSqlScript(request);
         Assert.assertNotNull(actual);
+        log.warn(String.format("Move script for: %s\n:%s", request, actual.content()));
     }
 
 }



View it on GitLab: https://gitlab.com/ultreiaio/ird-observe/-/compare/df53fa17927f568fea595513b...

-- 
View it on GitLab: https://gitlab.com/ultreiaio/ird-observe/-/compare/df53fa17927f568fea595513b...
You're receiving this email because of your account on gitlab.com.

    

[Git][ultreiaio/ird-observe][develop] 3 commits: move metadata model to service sql and clean all API - See ultreiaio/topia-extension#112

Tony CHEMIT (＠tchemit)

tags

participants (1)