Package eu.dnetlib.organizations.utils

Class DatabaseUtils

java.lang.Object

eu.dnetlib.organizations.utils.DatabaseUtils

@Component
public class DatabaseUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DatabaseUtils.VocabularyTable

Constructor Summary

Constructors

Constructor	Description
DatabaseUtils()

Method Summary

Modifier and Type	Method	Description
String	addPersistentOrgs(String id)
List<BrowseEntry>	browseCountries()
List<BrowseEntry>	browseCountriesForUser(String email)
List<BrowseEntry>	browseTypes()
List<BrowseEntry>	browseTypesForUser(String email)
void	clearCache()
Map<String,Map<String,Long>>	countValidOrgsByTypesAndCountry()
void	deletePersistentOrgs(String id)
void	deleteUser(String email)
Optional<User>	findUser(String email)
void	fixConflictDifferents(List<String> differentsIds, String user)
String	fixConflictSimilars(List<String> similarIds, String user)
void	importDedupEvents()
String	insertOrUpdateOrganization(OrganizationView orgView, String user, boolean isSimpleUser)
List<String>	invalidCountriesInSuggestions()
List<OrganizationConflict>	listConflictsForId(String id)
List<VocabularyTerm>	listCountriesForUser(String name)
Iterable<PersistentOrganizationView>	listPersistentOrgs()
List<VocabularyTerm>	listValuesOfVocabularyTable(DatabaseUtils.VocabularyTable table)
void	newUser(String email, String fullname, String organization, String referencePerson, String requestMessage, List<String> countries)
List<String>	obtainLogEntries(int year, int month, String country)
List<String>	obtainLogEntries(String id)
void	saveDuplicates(List<OpenaireDuplicate> simrels, String user)
void	saveRelations(String orgId, List<Relationship> rels, String user)
void	updateFulltextIndex()
void	updateUser(UserView userView)
void	updateUserDetails(String email, String fullname, String organization)
void	verifyConsistency()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DatabaseUtils

public DatabaseUtils()

Method Details

insertOrUpdateOrganization

public String insertOrUpdateOrganization(OrganizationView orgView,
 String user,
 boolean isSimpleUser)

saveDuplicates

public void saveDuplicates(List<OpenaireDuplicate> simrels,
 String user)

verifyConsistency

@Scheduled(fixedRate=300000L)
public void verifyConsistency()

listValuesOfVocabularyTable

@Cacheable("vocs")
public List<VocabularyTerm> listValuesOfVocabularyTable(DatabaseUtils.VocabularyTable table)

listCountriesForUser

@Cacheable("countries_for_user")
public List<VocabularyTerm> listCountriesForUser(String name)

clearCache

@CacheEvict(value={"vocs","countries_for_user"},
            allEntries=true)
public void clearCache()

updateUser

public void updateUser(@RequestBody
 UserView userView)

deleteUser

public void deleteUser(String email)

newUser

public void newUser(String email,
 String fullname,
 String organization,
 String referencePerson,
 String requestMessage,
 List<String> countries)

saveRelations

public void saveRelations(String orgId,
 List<Relationship> rels,
 String user)

browseCountries

public List<BrowseEntry> browseCountries()

browseCountriesForUser

public List<BrowseEntry> browseCountriesForUser(String email)

browseTypes

public List<BrowseEntry> browseTypes()

browseTypesForUser

public List<BrowseEntry> browseTypesForUser(String email)

countValidOrgsByTypesAndCountry

public Map<String,Map<String,Long>> countValidOrgsByTypesAndCountry()

listConflictsForId

public List<OrganizationConflict> listConflictsForId(String id)

importDedupEvents

public void importDedupEvents()
                       throws Exception

Throws:

Exception

updateFulltextIndex

public void updateFulltextIndex()

fixConflictSimilars

public String fixConflictSimilars(List<String> similarIds,
 String user)

fixConflictDifferents

public void fixConflictDifferents(List<String> differentsIds,
 String user)

findUser

public Optional<User> findUser(String email)

updateUserDetails

public void updateUserDetails(String email,
 String fullname,
 String organization)

invalidCountriesInSuggestions

public List<String> invalidCountriesInSuggestions()

listPersistentOrgs

public Iterable<PersistentOrganizationView> listPersistentOrgs()

addPersistentOrgs

public String addPersistentOrgs(String id)

deletePersistentOrgs

public void deletePersistentOrgs(String id)

obtainLogEntries

public List<String> obtainLogEntries(String id)

obtainLogEntries

public List<String> obtainLogEntries(int year,
 int month,
 String country)