Skip to content
Snippets Groups Projects
Unverified Commit 3218971c authored by Martin Weise's avatar Martin Weise
Browse files

Fixed the query service

parent 2c9837d4
Branches
No related tags found
1 merge request!106Dev
...@@ -63,11 +63,11 @@ public class Table { ...@@ -63,11 +63,11 @@ public class Table {
@org.springframework.data.annotation.Transient @org.springframework.data.annotation.Transient
@ToString.Exclude @ToString.Exclude
@ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.DETACH) @ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.MERGE)
@JoinColumn(name = "tdbid", insertable = false, updatable = false) @JoinColumn(name = "tdbid", insertable = false, updatable = false)
private Database database; private Database database;
@OneToMany(fetch = FetchType.LAZY, cascade = CascadeType.DETACH, mappedBy = "table") @OneToMany(fetch = FetchType.LAZY, cascade = CascadeType.MERGE, mappedBy = "table")
@OrderBy("ordinalPosition") @OrderBy("ordinalPosition")
private List<TableColumn> columns; private List<TableColumn> columns;
......
...@@ -52,13 +52,13 @@ public class TableColumn implements Comparable<TableColumn> { ...@@ -52,13 +52,13 @@ public class TableColumn implements Comparable<TableColumn> {
private Long dfid; private Long dfid;
@ToString.Exclude @ToString.Exclude
@OneToOne(fetch = FetchType.LAZY, cascade = CascadeType.DETACH) @OneToOne(fetch = FetchType.LAZY, cascade = CascadeType.MERGE)
@JoinColumn(name = "dfid", referencedColumnName = "id", insertable = false, updatable = false) @JoinColumn(name = "dfid", referencedColumnName = "id", insertable = false, updatable = false)
private ContainerImageDate dateFormat; private ContainerImageDate dateFormat;
@org.springframework.data.annotation.Transient @org.springframework.data.annotation.Transient
@ToString.Exclude @ToString.Exclude
@ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.DETACH) @ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.MERGE)
@JoinColumns({ @JoinColumns({
@JoinColumn(name = "tid", referencedColumnName = "id", insertable = false, updatable = false), @JoinColumn(name = "tid", referencedColumnName = "id", insertable = false, updatable = false),
@JoinColumn(name = "cdbid", referencedColumnName = "tdbid", insertable = false, updatable = false) @JoinColumn(name = "cdbid", referencedColumnName = "tdbid", insertable = false, updatable = false)
...@@ -117,7 +117,7 @@ public class TableColumn implements Comparable<TableColumn> { ...@@ -117,7 +117,7 @@ public class TableColumn implements Comparable<TableColumn> {
@CreatedDate @CreatedDate
private Instant created; private Instant created;
@ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.DETACH) @ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.MERGE)
@JoinTable(name = "mdb_columns_concepts", @JoinTable(name = "mdb_columns_concepts",
joinColumns = { joinColumns = {
@JoinColumn(name = "cid", referencedColumnName = "id", insertable = false, updatable = false), @JoinColumn(name = "cid", referencedColumnName = "id", insertable = false, updatable = false),
......
...@@ -5,6 +5,7 @@ import at.tuwien.api.database.query.QueryResultDto; ...@@ -5,6 +5,7 @@ import at.tuwien.api.database.query.QueryResultDto;
import at.tuwien.api.database.table.TableCsvDto; import at.tuwien.api.database.table.TableCsvDto;
import at.tuwien.config.DockerConfig; import at.tuwien.config.DockerConfig;
import at.tuwien.config.ReadyConfig; import at.tuwien.config.ReadyConfig;
import at.tuwien.entities.database.table.Table;
import at.tuwien.exception.*; import at.tuwien.exception.*;
import at.tuwien.listener.impl.RabbitMqListenerImpl; import at.tuwien.listener.impl.RabbitMqListenerImpl;
import at.tuwien.repository.jpa.*; import at.tuwien.repository.jpa.*;
...@@ -74,6 +75,9 @@ public class QueryServiceIntegrationTest extends BaseUnitTest { ...@@ -74,6 +75,9 @@ public class QueryServiceIntegrationTest extends BaseUnitTest {
@Autowired @Autowired
private TableRepository tableRepository; private TableRepository tableRepository;
@Autowired
private TableColumnRepository tableColumnRepository;
@Autowired @Autowired
private ConceptRepository conceptRepository; private ConceptRepository conceptRepository;
...@@ -169,25 +173,31 @@ public class QueryServiceIntegrationTest extends BaseUnitTest { ...@@ -169,25 +173,31 @@ public class QueryServiceIntegrationTest extends BaseUnitTest {
databaseRepository.save(DATABASE_1); databaseRepository.save(DATABASE_1);
databaseRepository.save(DATABASE_2); databaseRepository.save(DATABASE_2);
databaseRepository.save(DATABASE_3); databaseRepository.save(DATABASE_3);
/* create tables */ /* create tables 1 */
TABLE_1.setDatabase(DATABASE_1); TABLE_1.setDatabase(DATABASE_1);
tableRepository.save(TABLE_1);
TABLE_1.setColumns(TABLE_1_COLUMNS); TABLE_1.setColumns(TABLE_1_COLUMNS);
TABLE_1_COLUMNS.forEach(column -> column.setTable(TABLE_1));
tableRepository.save(TABLE_1); tableRepository.save(TABLE_1);
TABLE_1_COLUMNS.forEach(column -> column.setTable(TABLE_1));
/* create tables 2 */
TABLE_2.setDatabase(DATABASE_1); TABLE_2.setDatabase(DATABASE_1);
tableRepository.save(TABLE_2);
TABLE_2.setColumns(TABLE_2_COLUMNS); TABLE_2.setColumns(TABLE_2_COLUMNS);
TABLE_2_COLUMNS.forEach(column -> column.setTable(TABLE_2));
tableRepository.save(TABLE_2); tableRepository.save(TABLE_2);
TABLE_2_COLUMNS.forEach(column -> column.setTable(TABLE_2));
/* create tables 3 */
TABLE_3.setDatabase(DATABASE_3); TABLE_3.setDatabase(DATABASE_3);
tableRepository.save(TABLE_3); tableRepository.save(TABLE_3);
TABLE_4.setDatabase(DATABASE_2); // TABLE_4.setDatabase(DATABASE_2);
TABLE_4.setColumns(TABLE_4_COLUMNS); // tableRepository.save(TABLE_4);
TABLE_4_COLUMNS.forEach(column -> column.setTable(TABLE_4)); // TABLE_4.setColumns(TABLE_4_COLUMNS);
tableRepository.save(TABLE_4); // TABLE_4_COLUMNS.forEach(column -> column.setTable(TABLE_4));
TABLE_5.setDatabase(DATABASE_2); // tableRepository.save(TABLE_4);
TABLE_5.setColumns(TABLE_5_COLUMNS); // TABLE_5.setDatabase(DATABASE_2);
TABLE_5_COLUMNS.forEach(column -> column.setTable(TABLE_5)); // tableRepository.save(TABLE_5);
tableRepository.save(TABLE_5); // TABLE_5.setColumns(TABLE_5_COLUMNS);
// TABLE_5_COLUMNS.forEach(column -> column.setTable(TABLE_5));
// tableRepository.save(TABLE_5);
} }
@Test @Test
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment