1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/*
* SonarQube
* Copyright (C) 2009-2025 SonarSource SA
* mailto:info AT sonarsource DOT com
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 3 of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program; if not, write to the Free Software Foundation,
* Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*/
package org.sonar.db.alm.setting;
import java.util.Collections;
import java.util.List;
import java.util.Locale;
import java.util.Optional;
import java.util.Set;
import org.sonar.api.utils.System2;
import org.sonar.core.util.UuidFactory;
import org.sonar.db.Dao;
import org.sonar.db.DbSession;
import org.sonar.db.Pagination;
import org.sonar.db.audit.AuditPersister;
import org.sonar.db.audit.model.DevOpsPlatformSettingNewValue;
import org.sonar.db.project.ProjectDto;
import static org.sonar.db.DatabaseUtils.executeLargeInputs;
public class ProjectAlmSettingDao implements Dao {
private final System2 system2;
private final UuidFactory uuidFactory;
private final AuditPersister auditPersister;
public ProjectAlmSettingDao(System2 system2, UuidFactory uuidFactory, AuditPersister auditPersister) {
this.system2 = system2;
this.uuidFactory = uuidFactory;
this.auditPersister = auditPersister;
}
public ProjectAlmSettingDto insertOrUpdate(DbSession dbSession, ProjectAlmSettingDto projectAlmSettingDto, String key, String projectName, String projectKey) {
String uuid = uuidFactory.create();
long now = system2.now();
ProjectAlmSettingMapper mapper = getMapper(dbSession);
boolean isUpdate = true;
if (mapper.update(projectAlmSettingDto, now) == 0) {
mapper.insert(projectAlmSettingDto, uuid, now);
projectAlmSettingDto.setUuid(uuid);
projectAlmSettingDto.setCreatedAt(now);
isUpdate = false;
}
projectAlmSettingDto.setUpdatedAt(now);
DevOpsPlatformSettingNewValue value = new DevOpsPlatformSettingNewValue(projectAlmSettingDto, key, projectName, projectKey);
if (isUpdate) {
auditPersister.updateDevOpsPlatformSetting(dbSession, value);
} else {
auditPersister.addDevOpsPlatformSetting(dbSession, value);
}
return projectAlmSettingDto;
}
public void deleteByProject(DbSession dbSession, ProjectDto project) {
int deletedRows = getMapper(dbSession).deleteByProjectUuid(project.getUuid());
if (deletedRows > 0) {
auditPersister.deleteDevOpsPlatformSetting(dbSession, new DevOpsPlatformSettingNewValue(project));
}
}
public void deleteByAlmSetting(DbSession dbSession, AlmSettingDto almSetting) {
getMapper(dbSession).deleteByAlmSettingUuid(almSetting.getUuid());
}
public int countByAlmSetting(DbSession dbSession, AlmSettingDto almSetting) {
return getMapper(dbSession).countByAlmSettingUuid(almSetting.getUuid());
}
public int countProjectAlmSettings(DbSession dbSession, ProjectAlmSettingQuery query) {
return getMapper(dbSession).countByQuery(query);
}
public List<ProjectAlmSettingDto> selectProjectAlmSettings(DbSession dbSession, ProjectAlmSettingQuery query, int page, int pageSize) {
return getMapper(dbSession).selectByQuery(query, Pagination.forPage(page).andSize(pageSize));
}
public Optional<ProjectAlmSettingDto> selectByUuid(DbSession dbSession, String uuid) {
return Optional.ofNullable(getMapper(dbSession).selectByUuid(uuid));
}
public Optional<ProjectAlmSettingDto> selectByProject(DbSession dbSession, ProjectDto project) {
return selectByProject(dbSession, project.getUuid());
}
public Optional<ProjectAlmSettingDto> selectByProject(DbSession dbSession, String projectUuid) {
return Optional.ofNullable(getMapper(dbSession).selectByProjectUuid(projectUuid));
}
private static ProjectAlmSettingMapper getMapper(DbSession dbSession) {
return dbSession.getMapper(ProjectAlmSettingMapper.class);
}
public List<ProjectAlmSettingDto> selectByAlmSettingAndSlugs(DbSession dbSession, AlmSettingDto almSettingDto, Set<String> almSlugs) {
return executeLargeInputs(almSlugs, slugs -> getMapper(dbSession).selectByAlmSettingAndSlugs(almSettingDto.getUuid(), slugs));
}
public List<ProjectAlmSettingDto> selectByAlmSettingAndRepos(DbSession dbSession, AlmSettingDto almSettingDto, Set<String> almRepos) {
return executeLargeInputs(almRepos, repos -> getMapper(dbSession).selectByAlmSettingAndRepos(almSettingDto.getUuid(), repos));
}
public List<ProjectAlmSettingDto> selectByAlm(DbSession dbSession, ALM alm) {
return getMapper(dbSession).selectByAlm(alm.getId().toLowerCase(Locale.ROOT));
}
public List<ProjectAlmSettingDto> selectByProjectUuidsAndAlm(DbSession dbSession, Set<String> projectUuids, ALM alm) {
if (projectUuids.isEmpty()) {
return Collections.emptyList();
}
return getMapper(dbSession).selectByProjectUuidsAndAlm(projectUuids, alm.getId().toLowerCase(Locale.ROOT));
}
public List<ProjectAlmKeyAndProject> selectAlmTypeAndUrlByProject(DbSession dbSession) {
return getMapper(dbSession).selectAlmTypeAndUrlByProject();
}
}
|
