@@ -109,7 +109,7 @@ func EmptyTable(dataSource *utils.DbAndSchema, tableName string) {
109
109
func GetLastCohortId () int {
110
110
dataSource := db .GetAtlasDB ()
111
111
var lastCohortDefinition models.CohortDefinition
112
- dataSource .Db .Last (& lastCohortDefinition )
112
+ dataSource .Db .Order ( "id DESC" ). First (& lastCohortDefinition )
113
113
return lastCohortDefinition .Id
114
114
}
115
115
@@ -124,21 +124,23 @@ func GetNextCohortId() int {
124
124
func GetLastConceptId (sourceId int ) int64 {
125
125
dataSource := GetOmopDataSourceForSourceId (sourceId )
126
126
var lastConcept models.Concept
127
- dataSource .Db .Last (& lastConcept )
127
+ dataSource .Db .Order ("concept_id DESC" ).First (& lastConcept )
128
+ log .Printf ("Last concept id found %d" ,
129
+ lastConcept .ConceptId )
128
130
return lastConcept .ConceptId
129
131
}
130
132
131
133
func GetLastObservationId (sourceId int ) int64 {
132
134
dataSource := GetOmopDataSourceForSourceId (sourceId )
133
135
var lastObservation models.Observation
134
- dataSource .Db .Last (& lastObservation )
136
+ dataSource .Db .Order ( "observation_id DESC" ). First (& lastObservation )
135
137
return lastObservation .ObservationId
136
138
}
137
139
138
140
func GetLastPersonId (sourceId int ) int64 {
139
141
dataSource := GetOmopDataSourceForSourceId (sourceId )
140
142
var lastPerson models.Person
141
- dataSource .Db .Last (& lastPerson )
143
+ dataSource .Db .Order ( "person_id DESC" ). First (& lastPerson )
142
144
return lastPerson .PersonId
143
145
}
144
146
0 commit comments