mirror of
https://github.com/VinylDNS/vinyldns
synced 2025-08-22 02:02:14 +00:00
fix records repetition (#1432)
Co-authored-by: Arpit Shah <arpit_shah@cable.comcast.com>
This commit is contained in:
parent
8747775fd3
commit
736b2b1538
@ -362,13 +362,16 @@ class MySqlRecordSetCacheRepository
|
|||||||
val recordsetDataJoin = sqls"RIGHT JOIN recordset ON recordset.id=recordset_data.recordset_id "
|
val recordsetDataJoin = sqls"RIGHT JOIN recordset ON recordset.id=recordset_data.recordset_id "
|
||||||
val recordsetDataJoinQuery = initialQuery.append(recordsetDataJoin)
|
val recordsetDataJoinQuery = initialQuery.append(recordsetDataJoin)
|
||||||
|
|
||||||
|
// Add GROUP BY clause to group by recordset_data.recordset_id and recordset_data.type
|
||||||
|
val groupByClause = sqls"GROUP BY recordset_data.recordset_id, recordset_data.type "
|
||||||
|
|
||||||
val appendOpts = if (opts.nonEmpty) {
|
val appendOpts = if (opts.nonEmpty) {
|
||||||
val setDelimiter = SQLSyntax.join(opts, sqls"AND")
|
val setDelimiter = SQLSyntax.join(opts, sqls"AND")
|
||||||
val addWhere = sqls"WHERE"
|
val addWhere = sqls"WHERE"
|
||||||
addWhere.append(setDelimiter)
|
addWhere.append(setDelimiter)
|
||||||
} else sqls""
|
} else sqls""
|
||||||
|
|
||||||
val appendQueries = recordsetDataJoinQuery.append(appendOpts)
|
val appendQueries = recordsetDataJoinQuery.append(appendOpts).append(groupByClause)
|
||||||
|
|
||||||
val finalQuery = appendQueries.append(finalQualifiers)
|
val finalQuery = appendQueries.append(finalQualifiers)
|
||||||
DB.readOnly { implicit s =>
|
DB.readOnly { implicit s =>
|
||||||
|
Loading…
x
Reference in New Issue
Block a user